thinkphp5集成GatewayWorker全过程

在前几天的博客中波波根据thinkPHP5的官方文档对thinkPHP集成workman做了稍微细致的分享。今天波波就将workman的另一版本GatewayWorker的集成方法分享一下。

thinkphp5集成GatewayWorker

我们知道如果要做实时通信目前PHP语言主要集中在socket和swool两种开发方式上，如果再深究的话，那么两种方式又是可以称为一种。GatewayWorker是workman的另一版本，其优势在于物联网应用开发方面。废话不多讲。集成Gateway的操作步骤如下：

1、准备好一个tp5的项目。

2、SSH登录服务器，切换到项目根目录执行命令：

  1. composer require workerman/gateway-worker

3、在项目运行目录中创建启用文件gateway.php，示例如下：

  1. #!/usr/bin/env php
  2. <?php
  3. /**
  4.  * Created by bobo.
  5.  * DateTime: 2018/10/10 22:32
  6.  * Function:CLI模式下运行
  7.  */
  9. define('APP_PATH', __DIR__ . '/application/');
  10. define('RUNTIME_PATH', __DIR__ . '/runtime/');
  11. define('BIND_MODULE','pigeon/start');
  12. // 加载框架引导文件
  13. require __DIR__ . '/thinkphp/start.php';

4、在/application/pigeon目录下创建Gateway启动的控制器文件Start.php(注意大小写)。

  1. <?php
  2. /**
  3.  * Created by BoBo.
  4.  * Date: 2018/11/15 14:37
  5.  * Function:
  6.  */
  7. namespace app\pigeon\controller;
  9. use \Workerman\Worker;
  10. use \GatewayWorker\Register;
  11. use \Workerman\WebServer;
  12. use \GatewayWorker\Gateway;
  13. use \GatewayWorker\BusinessWorker;
  14. use \Workerman\Autoloader;
  16. class Start extends Worker{
  18.     public function __construct(){
  19.         //初始化register
  20.         new Register('text://0.0.0.0:1238');
  22.         //初始化 bussinessWorker 进程
  23.         $worker = new BusinessWorker();
  24.         $worker->name = 'mygate';
  25.         $worker->count = 4;
  26.         $worker->registerAddress = '127.0.0.1:1238';
  27.         //设置处理业务的类,此处制定Events的命名空间
  28.         $worker->eventHandler = '\app\pigeon\controller\Events';
  29.         // 初始化 gateway 进程
  30.         $gateway = new Gateway("websocket://0.0.0.0:8383");
  31.         $gateway->name = 'pigeon';
  32.         $gateway->count = 4;
  33.         $gateway->lanIp = '127.0.0.1';
  34.         $gateway->startPort = 2900;
  35.         $gateway->pingInterval = 10;
  36.         $gateway->pingData = '{"type":"ping"}';
  37.         $gateway->registerAddress = '127.0.0.1:1238';
  39.         //运行所有Worker;
  40.         Worker::runAll();
  41.     }
  44. }

5、在/application/pigeon目录下创建Gateway的事件处理控制器文件Events.php(注意大小写)。

  1. <?php
  2. /**
  3.  * Created by BoBo.
  4.  * Date: 2018/11/15 14:56
  5.  * Function:事件处理类
  6.  */
  7. namespace app\pigeon\controller;
  9. use GatewayWorker\Lib\Gateway;
  11. class Events {
  13.     /**
  14.      * 当客户端发来消息时触发
  15.      * @param int $client_id 连接id
  16.      * @param mixed $data 具体消息
  17.      */
  18.     public static function onMessage($client_id, $data){
  19.         $message = json_decode($data, true);
  20.         Gateway::sendToCurrentClient(json_encode($data));
  21.     }
  23.     /**
  24.      * 当客户端连接时触发
  25.      * 如果业务不需此回调可以删除onConnect
  26.      *
  27.      * @param int $client_id 连接id
  28.      */
  29.     public static function onConnect($client_id)
  30.     {
  31.         Gateway::sendToClient($client_id,json_encode(['status'=>"success",'msg'=>"连接成功"]));
  32.     }
  33.     /**
  34.      * 当连接断开时触发的回调函数
  35.      * @param $connection
  36.      */
  37.     public static function onClose($client_id){
  38.         Gateway::sendToClient($client_id,json_encode(['status'=>"error",'msg'=>"断开连接"]));
  39.     }
  40.     /**
  41.      * 当客户端的连接上发生错误时触发
  42.      * @param $connection
  43.      * @param $code
  44.      * @param $msg
  45.      */
  46.     public static function onError($client_id, $code, $msg){
  47.         echo "error $code $msg\n";
  48.     }
  49.     /**
  50.      * 每个进程启动
  51.      * @param $worker
  52.      */
  53.     public static function onWorkerStart($worker){
  55.     }
  57. }

6、启动GatewayWorker。（终端中输入如下指令）

  1. php gateway.php start

看到如下画面就表示集成成功了。

thinkphp5集成GatewayWorker全过程

今天的分享就到这里，有空的话再分享双协议下的端口转发，敬请关注。

你想把广告放到这里吗？

发表评论

您必须 登录 才能发表留言！