給你的composer.json 里的autoload.files 選項(xiàng)里加上你的協(xié)議類(lèi)的加載路徑。類(lèi)似這種

"autoload": {
    "psr-4": {
      "" : "./"
    },
    "files": [
      "你的協(xié)議類(lèi)路徑"
    ]
  }

然后執(zhí)行 composer dumpautoload

如果實(shí)在不會(huì)就手動(dòng)require文件吧。

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

2. 創(chuàng)建一個(gè)自定義協(xié)議類(lèi)

   <?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. 再創(chuàng)建啟動(dòng)服務(wù)的文件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 進(jìn)程
       $worker = new BusinessWorker();
       $worker->name = 'RoomBusinessWorker';
       $worker->count = 4;
       $worker->registerAddress = '127.0.0.1:1236';
   
       // 設(shè)置處理業(yè)務(wù)的類(lèi),此處制定Events的命名空間
       $worker->eventHandler = '\app\gateway\controller\Events';
       // 初始化 gateway 進(jìn)程
       $gateway = new Gateway("websocket://0.0.0.0:7272");
       $gateway->name = 'RoomGateway';
        $gateway->protocol = Custom::class;    //應(yīng)用層協(xié)議,這里用上面的那個(gè)文件
       $gateway->count = 4;
       $gateway->lanIp = '127.0.0.1';
       $gateway->startPort = 2900;
       $gateway->registerAddress = '127.0.0.1:1236';
   
       // 運(yùn)行所有Worker;
       Worker::runAll();
   }
   }

4. 發(fā)送消息處理Events.php

   <?php
   namespace app\gateway\controller;
   use GatewayWorker\Lib\Gateway;
   use think\Controller;
   class Events extends Controller
   {
   /**
    * 有消息時(shí)
    * @param integer $client_id 連接的客戶(hù)端
    * @param mixed $message
    * @return void
    */
   public static function onMessage($client_id, $message){}
   /**
    * 當(dāng)客戶(hù)端斷開(kāi)連接時(shí)
    * @param integer $client_id 客戶(hù)端id
    */
   public static function onClose($client_id) {}
   
   /**
    * 當(dāng)用戶(hù)連接時(shí)觸發(fā)的方法
    * @param integer $client_id 連接的客戶(hù)端
    * @return void
    */
   public static function onConnect($client_id) { }
   
   /**
    * 當(dāng)用戶(hù)斷開(kāi)連接時(shí)觸發(fā)的方法
    * @param integer $client_id 斷開(kāi)連接的客戶(hù)端
    * @return void
    */
   //    public static function onClose($client_id)
   //    {
   //        Gateway::sendToAll("client[$client_id] logout\n");
   //    }
   
   /**
    * 當(dāng)進(jìn)程啟動(dòng)時(shí)
    * @param integer $businessWorker 進(jìn)程實(shí)例
    */
   public static function onWorkerStart($businessWorker) {
       echo "WorkerStart\n";
   }
   
   /**
    * 當(dāng)進(jìn)程關(guān)閉時(shí)
    * @param integer $businessWorker 進(jìn)程實(shí)例
    */
   public static function onWorkerStop($businessWorker) {
       echo "WorkerStop\n";
   }
   }

5. 最后再根目錄創(chuàng)建gateway.php啟動(dòng)方便啟動(dòng)

   <?php
   // [ 應(yīng)用入口文件 ]
   // 定義應(yīng)用目錄
   define('APP_PATH', __DIR__ . '/application/');
   define('BIND_MODULE','gateway/Run');
   // 加載框架引導(dǎo)文件
   require __DIR__ . '/thinkphp/start.php';

6. 根目錄cmd執(zhí)行：php gateway.php start啟動(dòng)服務(wù)
   代碼對(duì)齊有點(diǎn)亂 , 將就著看吧