在非WorkerMan项目中推送消息

需求

有时候需要在非GatewayWorker环境中向客户端推送数据。例如在一个普通的Web项目中通过GatewayWorker推送数据(前提是已经部署了GatewayWorker,客户端已经连接GatewayWorker)。目前有三种比较方便方法推送数据。

方法一、使用GatewayClient客户端推送,接口与GatewayWorker中的接口一致

客户端源码:

https://github.com/walkor/GatewayClient

GatewayWorker1.0请使用1.0版本的GatewayClient

GatewayWorker2.0.1-2.0.4请使用2.0.4版本的GatewayClient

GatewayWorker2.0.5-2.0.6版本请使用2.0.6版本的GatewayClient

GatewayWorker2.0.7及以上版本请使用 2.0.7版本的GatewayClient

查看GatewayWorker版本方法请点击点击这里

注意:

如果GatewayClient和GatewayWorker不是在同一台服务器上,则需要先将start_gateway.php中的lanIp改成当前服务器的内网ip(如果不在一个内网可改成公网ip)。

反之如果GatewayClient和GatewayWorker在同一台服务器上运行,则不用做任何更改,直接按照示例使用GatewayClient即可。

注意:通过GatewayClient发送的数据不会经过Event.php,而是直接经由Gateway进程转发给客户端。

注意:GatewayClient无法接收客户端发来的数据.

客户端使用示例

require_once '/your/path/GatewayClient/Gateway.php';

/**
 *====这个步骤是必须的====
 *这里填写Register服务的ip(通常是运行GatewayWorker的服务器ip)和端口
 *注意Register服务端口在start_register.php中可以找到(chat默认是1236)
 *这里假设GatewayClient和Register服务都在一台服务器上,ip填写127.0.0.1
 **/
Gateway::$registerAddress = '127.0.0.1:1236';


// 以下是调用示例,接口与GatewayWorker环境的接口一致
// 注意除了不支持sendToCurrentClient和closeCurrentClient方法
// 其它方法都支持
Gateway::sendToAll('{"type":"broadcast","content":"hello all"}');

Gateway::sendToClient($client_id,'{"type":"say","content":"hello"}');

Gateway::isOnline($client_id);

Gateway::bindUid($client_id, $uid);

Gateway::sendToUid($client_id, $uid);

Gateway::getSession($client_id);
...

方法二、用一个特殊的账号当做管理客户端,通过这个账号推送数据

此方法通俗易懂,可以通过现有客户端直接操作,具体代码根据自己的业务实现

方法三、开启一个内部Gateway端口,用于推送数据

方法二虽然简单,但是局限于只能通过客户端界面操作,定时推送等需求不好直接操作客户端,而通过PHP模拟客户端可能会受到复杂协议的限制不好操作,这时我们可以开启一个内部文本协议的Gateway端口,通过PHP代码使用文本协议连接WorkerMan作为客户端向其它客户端推送数据。

示例(workerman-chat为例)

服务端:新建文件Applications/Chat/start_text_gateway.php,用于增加一个文本协议Gateway端口,内容如下

<?php
use \Workerman\Worker;
use \GatewayWorker\Gateway;
use \Workerman\Autoloader;
require_once __DIR__ . '/../../Workerman/Autoloader.php';
Autoloader::setRootPath(__DIR__);

// #### 内部推送端口(假设当前服务器内网ip为192.168.100.100) ####
$internal_gateway = new Gateway("Text://192.168.100.100:7273");
$internal_gateway->name='internalGateway';
$internal_gateway->startPort = 2800;
// 端口为start_register.php中监听的端口,聊天室默认是1236
$internal_gateway->registerAddress = '127.0.0.1:1236';
// #### 内部推送端口设置完毕 ####

if(!defined('GLOBAL_START'))
{
    Worker::runAll();
}

客户端:在其它项目中就可以直接用PHP socket 使用文本协议调用,代码类似如下:

// 建立连接,@see http://php.net/manual/zh/function.stream-socket-client.php
$client = stream_socket_client('tcp://192.168.100.100:7273');
if(!$client)exit("can not connect");
// 模拟超级用户,以文本协议发送数据,注意Text文本协议末尾有换行符(发送的数据中最好有能识别超级用户的字段),这样在Event.php中的onMessage方法中便能收到这个数据,然后做相应的处理即可
fwrite($client, '{"type":"send","content":"hello all", "user":"admin", "pass":"******"}'."\n");

results matching ""

    No results matching ""