ThinkPHP5.1框架与Workerman之GatewayWorker框架结合案例

文档地址：http://www.workerman.net/gatewaydoc/

一、测试官方DEMO（Windows 版本）

1、下载demo（在下方评论中自取）

2、解压到任意位置，我这里为：

D:/phpStudy/PHPTutorial/WWW/GatewayWorker

3、进入GatewayWorker目录

4、双击start_for_win.bat启动。（如果出现错误请参考这里设置phphtml' target='_blank'>环境变量），效果如下

5、命令行窗口运行 telnet 127.0.0.1 8282，输入任意字符即可聊天（非本机测试请将127.0.0.1替换成实际ip）。

PS：以上表示TCP连接测试成功

二、修改测试websocket

1、需要修改 start_gateway.php 指定websocket协议，像这样

$gateway = new Gateway(websocket://0.0.0.0:7272);

2、重新启动 start_for_win.bat

3、测试js

小结：只需要改动一个文件（ start_gateway.php）的协议和端口即可，别的不需用改动。

三、与ThinkPHP5.1框架结合

（一）服务端主动推送消息到客户端

原则：

1、TP5.1框架项目与GatewayWorker独立部署互不干扰

2、所有的业务逻辑都由网站（websocket连接的）页面以post/get请求到TP5.1框架的控制器中完成

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

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

具体实现步骤

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

ws = new WebSocket( ws://127.0.0.1:7272 

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

Event.php 内容

public static function onConnect($client_id) $resData = [ type = init , client_id = $client_id, msg = connect is success // 初始化房间信息 Gateway::sendToClient($client_id, json_encode($resData));}

index.html 内容

 !DOCTYPE html  html  head  meta charset= UTF-8  title GatewayWorker的websocket连接 /title  /head  body  h1 GatewayWorker的websocket连接 /h1  script src= https://cdn.bootcss.com/jquery/3.3.1/jquery.min.js /script  script type= text/javascript  ws = new WebSocket( ws://127.0.0.1:7272  // 服务端主动推送消息时会触发这里的onmessage ws.onmessage = function(e){ // json数据转换成js对象 var data = JSON.parse(e.data); console.log(data); var type = data.type ||  switch(type){ // Events.php中返回的init类型的消息，将client_id发给后台进行uid绑定 case init : // 利用jquery发起ajax请求，将client_id发给后端进行uid绑定 $.post( {:url( index/chat_room/bind )} , {client_id: data.client_id}, function(data) console.log(data); json  break; case say : console.log( TP5 msg +e.data); break; // 当mvc框架调用GatewayClient发消息时直接alert出来 default : alert(e.data); /script  /body  /html 

3、网站页面收到client_id后触发一个ajax请求(index/chat_room/bind)将client_id发到TP5.0后端，bind方法

/* * 用户登录后初始化以及绑定client_idpublic function bind() // 设置GatewayWorker服务的Register服务ip和端口，请根据实际情况改成实际值 Gateway::$registerAddress = 127.0.0.1:1238  $uid = $this- userId; $group_id = $this- groupId; $client_id = request()- param( client_id  // client_id与uid绑定 Gateway::bindUid($client_id, $uid); // 加入某个群组（可调用多次加入多个群组） Gateway::joinGroup($client_id, $group_id);}

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

连接成功后返回值

PS：以上返回值为 GatewayWorker服务 连接成功后返回的json数据

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

通过sendMessage发送消息（服务端主动推送消息到客户端）

// mvc后端发消息 利用GatewayClient发送 Events.phppublic function sendMessage() // stream_socket_client(): unable to connect to tcp://127.0.0.1:1236 $uid = $this- userId; $group = $this- groupId; $message = json_encode([ type = say , msg = Hello ThinkPHP5  // 设置GatewayWorker服务的Register服务ip和端口，请根据实际情况改成实际值 Gateway::$registerAddress = 127.0.0.1:1238  // 向任意uid的网站页面发送数据 Gateway::sendToUid($uid, $message); // 向任意群组的网站页面发送数据，如果开启，则会向页面发送两条一样的消息 //Gateway::sendToGroup($group, $message);}

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

通过浏览器访问sendMessage操作，测试结果

PS：以上的消息是TP5.0 通过 GatewayClient/Gateway 发送写消息，和GatewayWorker服务没有直接关系

以上为 服务端主动推送消息到客户端

注意区分：

1、服务端主动推送消息到客户端

2、客户端推送消息到客户端

（二）客户端推送消息到客户端

修改客户端到客户端的消息发送和接受，下面修改 GatewayWorker 的 Events.php（开发者只需要关注这个文件）

public static function onConnect($client_id) $resData = [ type = init , client_id = $client_id, msg = connect is success // 初始化房间信息 Gateway::sendToClient($client_id, json_encode($resData)); * 当客户端发来消息时触发 * @param int $client_id 连接id * @param mixed $message 具体消息public static function onMessage($client_id, $message) // 服务端console输出 //echo msg : $message /r/n  // 解析数据 $resData = json_decode($message, true); $type = $resData[ type  $roomId = $resData[ roomId  $userId = $resData[ userId // 未登录，则传递一个随机 $userName = $resData[ userName // 未登录，则传递一个随机 $content = isset($resData[ content ]) ? $resData[ content ] : default content  //将时间全部置为服务器时间 $serverTime = date( Y-m-d H:i:s , time()); switch ($type) { case join : // 用户进入直播间 //将客户端加入到某一直播间 Gateway::joinGroup($client_id, $roomId); $resData = [ type = join , roomId = $roomId, userName = $userName, msg = enters the Room , // 发送给客户端的消息，而不是聊天发送的内容 joinTime = $serverTime // 加入时间  // 广播给直播间内所有人，谁？什么时候？加入了那个房间？ Gateway::sendToGroup($roomId, json_encode($resData)); break; case say : // 用户发表评论 $resData = [ type = say , roomId = $roomId, userName = $userName, content = $content, commentTime = $serverTime // 发表评论时间 // 广播给直播间内所有人 Gateway::sendToGroup($roomId, json_encode($resData)); break; case pong : break; // 接收心跳 default: //Gateway::sendToAll($client_id,$json_encode($resData)); break;}

index.html 聊天室页面

 !DOCTYPE html  html  head  meta charset= UTF-8  title GatewayWorker的websocket连接 /title  /head  body  h1 GatewayWorker的websocket连接 /h1  div  websocket send content： input type= text >
重启开启服务
测试结果
扩展：
可以把消息存储的Redis中，通过Redis统计直播间的PV
$redis = new /Redis;$redis- connect( 127.0.0.1 ,6379);$key = PV:ROOM: .$roomId;$field = ROOM_TOTAL_PV // 进入房间的人数增长，自增 ，增加PV统计$redis- hIncrBy($key,$field,1);
相关推荐：《PHP教程》
以上就是ThinkPHP5.1框架与Workerman之GatewayWorker框架结合案例的详细内容，PHP教程        
郑重声明：本文版权归原作者所有，转载文章仅为传播更多信息之目的，如作者信息标记有误，请第一时间联系我们修改或删除，多谢。