GatewayWorker与ThinkPHP等框架结合的介绍

使用GatewayWorker时开发者最关心的是如何与现有mvc框架(ThinkPHP Yii laravel等)整合，以下是官方推荐的整合方式。

见示意图：

现有mvc框架项目与GatewayWorker独立部署互不干扰

所有的业务逻辑都由网站页面post/get到mvc框架中完成

GatewayWorker不接受客户端发来的数据，即GatewayWorker不处理任何业务逻辑，GatewayWorker仅仅当做一个单向的推送通道

仅当mvc框架需要向浏览器主动推送数据时才在mvc框架中调用Gateway的API(GatewayClient)完成推送

1、网站页面建立与GatewayWorker的websocket连接

2、GatewayWorker发现有页面发起连接时，将对应连接的client_id发给网站页面

3、网站页面收到client_id后触发一个ajax请求(假设是bind.php)将client_id发到mvc后端

4、mvc后端bind.php收到client_id后利用GatewayClient调用Gateway::bindUid($client_id, $uid)将client_id与当前uid(用户id或者客户端唯一标识)绑定。如果有群组、群发功能，也可以利用Gateway::joinGroup($client_id, $group_id)将client_id加入到对应分组

5、页面发起的所有请求都直接post/get到mvc框架统一处理，包括发送消息

6、mvc框架处理业务过程中需要向某个uid或者某个群组发送数据时，直接调用GatewayClient的接口Gateway::sendToUid Gateway::sendToGroup 等发送即可

GatewayWorker中Events.php代码（只有个onConnect回调设置）

 ?phpuse /GatewayWorker/Lib/Gateway;html' target='_blank'>class Events{ // 当有客户端连接时，将client_id返回，让mvc框架判断当前uid并执行绑定 public static function onConnect($client_id) Gateway::sendToClient($client_id, json_encode(array( type = init , client_id = $client_id ))); } // GatewayWorker建议不做任何业务逻辑，onMessage留空即可 public static function onMessage($client_id, $message)}

/** * 与GatewayWorker建立websocket连接，域名和端口改为你实际的域名端口， * 其中端口为Gateway端口，即start_gateway.php指定的端口。 * start_gateway.php 中需要指定websocket协议，像这样 * $gateway = new Gateway(websocket://0.0.0.0:7272);ws = new WebSocket( ws://your_domain.com:7272 // 服务端主动推送消息时会触发这里的onmessagews.onmessage = function(e){ // json数据转换成js对象 var data = eval( ( +e.data+ ) var type = data.type || switch(type){ // Events.php中返回的init类型的消息，将client_id发给后台进行uid绑定 case init : // 利用jquery发起ajax请求，将client_id发给后端进行uid绑定 $.post( ./bind.php , {client_id: data.client_id}, function(data){}, json break; // 当mvc框架调用GatewayClient发消息时直接alert出来 default : alert(e.data);};

bind.php (利用GatewayClient绑定)

 ?php//加载GatewayClient。关于GatewayClient参见本页面底部介绍require_once /your/path/GatewayClient/Gateway.php // GatewayClient 3.0.0版本开始要使用命名空间use GatewayClient/Gateway;// 设置GatewayWorker服务的Register服务ip和端口，请根据实际情况改成实际值(ip不能是0.0.0.0)Gateway::$registerAddress = 127.0.0.1:1236 // 假设用户已经登录，用户uid和群组id在session中$uid = $_SESSION[ uid $group_id = $_SESSION[ group // client_id与uid绑定Gateway::bindUid($client_id, $uid);// 加入某个群组（可调用多次加入多个群组）Gateway::joinGroup($client_id, $group_id);

send_message.php (利用GatewayClient发送)

 ?php//加载GatewayClient。关于GatewayClient参见本页面底部介绍require_once /your/path/GatewayClient/Gateway.php // GatewayClient 3.0.0版本开始要使用命名空间use GatewayClient/Gateway;// 设置GatewayWorker服务的Register服务ip和端口，请根据实际情况改成实际值(ip不能是0.0.0.0)Gateway::$registerAddress = 127.0.0.1:1236 // 向任意uid的网站页面发送数据Gateway::sendToUid($uid, $message);// 向任意群组的网站页面发送数据Gateway::sendToGroup($group, $message);

以上仅是mvc框架与GatewayWorker官方推荐的结合方式，并不是强制使用此方式，开发者可以自由变化选择结合方式以适应自己的业务需求。

当然也可以采用客户端与GatewayWorker直接双向通讯的方式完成业务通讯。

以上就是本文的全部内容，希望对大家的学习有所帮助，更多相关内容请关注PHP ！

相关推荐：

Yii1.1框架关于日志配置的使用

用laravel dingo api插件库创建api的方法

郑重声明：本文版权归原作者所有，转载文章仅为传播更多信息之目的，如作者信息标记有误，请第一时间联系我们修改或删除，多谢。