gateway-worker 在 thinkphp6中 怎么自定义协议

给你的composer.json 里的autoload.files 选项里加上你的协议类的加载路径。类似这种

"autoload": {
    "psr-4": {
      "" : "./"
    },
    "files": [
      "你的协议类路径"
    ]
  }

然后执行 composer dumpautoload

如果实在不会就手动require文件吧。

1. 使用composer require workerman/gateway-worker 安装Linux版本的gateway

2. 创建一个自定义协议类

   <?php
   namespace app\gateway\protocols;
   use Workerman\Connection\ConnectionInterface;
   class Custom {
   public static function input($buffer, ConnectionInterface $connection) {}
   public static function decode($buffer, ConnectionInterface $connection) {}
   public static function encode($data) {}
   }

3. 再创建启动服务的文件Run.php

   <?php
   namespace app\gateway\controller;
   use think\Controller;
   use Workerman\Worker;
   use GatewayWorker\Register;
   use GatewayWorker\BusinessWorker;
   use GatewayWorker\Gateway;
   class Run {
   public function __construct()
   {
       // 初始化register
       new Register('text://0.0.0.0:1236');
   
       //初始化 bussinessWorker 进程
       $worker = new BusinessWorker();
       $worker->name = 'RoomBusinessWorker';
       $worker->count = 4;
       $worker->registerAddress = '127.0.0.1:1236';
   
       // 设置处理业务的类,此处制定Events的命名空间
       $worker->eventHandler = '\app\gateway\controller\Events';
       // 初始化 gateway 进程
       $gateway = new Gateway("websocket://0.0.0.0:7272");
       $gateway->name = 'RoomGateway';
        $gateway->protocol = Custom::class;    //应用层协议,这里用上面的那个文件
       $gateway->count = 4;
       $gateway->lanIp = '127.0.0.1';
       $gateway->startPort = 2900;
       $gateway->registerAddress = '127.0.0.1:1236';
   
       // 运行所有Worker;
       Worker::runAll();
   }
   }

4. 发送消息处理Events.php

   <?php
   namespace app\gateway\controller;
   use GatewayWorker\Lib\Gateway;
   use think\Controller;
   class Events extends Controller
   {
   /**
    * 有消息时
    * @param integer $client_id 连接的客户端
    * @param mixed $message
    * @return void
    */
   public static function onMessage($client_id, $message){}
   /**
    * 当客户端断开连接时
    * @param integer $client_id 客户端id
    */
   public static function onClose($client_id) {}
   
   /**
    * 当用户连接时触发的方法
    * @param integer $client_id 连接的客户端
    * @return void
    */
   public static function onConnect($client_id) { }
   
   /**
    * 当用户断开连接时触发的方法
    * @param integer $client_id 断开连接的客户端
    * @return void
    */
   //    public static function onClose($client_id)
   //    {
   //        Gateway::sendToAll("client[$client_id] logout\n");
   //    }
   
   /**
    * 当进程启动时
    * @param integer $businessWorker 进程实例
    */
   public static function onWorkerStart($businessWorker) {
       echo "WorkerStart\n";
   }
   
   /**
    * 当进程关闭时
    * @param integer $businessWorker 进程实例
    */
   public static function onWorkerStop($businessWorker) {
       echo "WorkerStop\n";
   }
   }

5. 最后再根目录创建gateway.php启动方便启动

   <?php
   // [ 应用入口文件 ]
   // 定义应用目录
   define('APP_PATH', __DIR__ . '/application/');
   define('BIND_MODULE','gateway/Run');
   // 加载框架引导文件
   require __DIR__ . '/thinkphp/start.php';

6. 根目录cmd执行：php gateway.php start启动服务
   代码对齐有点乱 , 将就着看吧