您看一下，我把結(jié)構(gòu)以及代碼都發(fā)出來(lái)了！

<?php
namespace app\index\controller;

/**

• 用于檢測(cè)業(yè)務(wù)代碼死循環(huán)或者長(zhǎng)時(shí)間阻塞等問(wèn)題
• 如果發(fā)現(xiàn)業(yè)務(wù)卡死，可以將下面declare打開（去掉//注釋），并執(zhí)行php start.php reload
• 然后觀察一段時(shí)間workerman.log看是否有process_timeout異常
  */
  //declare(ticks=1);

/**

• 聊天主邏輯
• 主要是處理 onMessage onClose
  */
  use \GatewayWorker\Lib\Gateway;

class Events
{
/**

• 有消息時(shí)
• @param int $client_id

• @param mixed $message
  */
  public static function onMessage($client_id, $message)
  {
  // debug
  echo "client:{$_SERVER['REMOTE_ADDR']}:{$_SERVER['REMOTE_PORT']} gateway:{$_SERVER['GATEWAY_ADDR']}:{$_SERVER['GATEWAY_PORT']} client_id:$client_id session:".json_encode($_SESSION)." onMessage:".$message."\n";

  // 客戶端傳遞的是json數(shù)據(jù)
  $message_data = json_decode($message, true);
  if(!$message_data)
  {
      return ;
  }
  
  // 根據(jù)類型執(zhí)行不同的業(yè)務(wù)
  switch($message_data['type'])
  {
      // 客戶端回應(yīng)服務(wù)端的心跳
      case 'pong':
          return;
      // 客戶端登錄 message格式: {type:login, name:xx, room_id:1} ，添加到客戶端，廣播給所有客戶端xx進(jìn)入聊天室
      case 'login':
          // 判斷是否有房間號(hào)
          if(!isset($message_data['room_id']))
          {
              throw new \Exception("\$message_data['room_id'] not set. client_ip:{$_SERVER['REMOTE_ADDR']} \$message:$message");
          }
  
          // 把房間號(hào)昵稱放到session中
          $room_id = $message_data['room_id'];
          $client_name = htmlspecialchars($message_data['client_name']);
          $_SESSION['room_id'] = $room_id;
          $_SESSION['client_name'] = $client_name;
  
          // 獲取房間內(nèi)所有用戶列表 
          $clients_list = Gateway::getClientSessionsByGroup($room_id);
          foreach($clients_list as $tmp_client_id=>$item)
          {
              $clients_list[$tmp_client_id] = $item['client_name'];
          }
          $clients_list[$client_id] = $client_name;
  
          // 轉(zhuǎn)播給當(dāng)前房間的所有客戶端，xx進(jìn)入聊天室 message {type:login, client_id:xx, name:xx} 
          $new_message = array('type'=>$message_data['type'], 'client_id'=>$client_id, 'client_name'=>htmlspecialchars($client_name), 'time'=>date('Y-m-d H:i:s'));
          Gateway::sendToGroup($room_id, json_encode($new_message));
          Gateway::joinGroup($client_id, $room_id);
  
          // 給當(dāng)前用戶發(fā)送用戶列表 
          $new_message['client_list'] = $clients_list;
          Gateway::sendToCurrentClient(json_encode($new_message));
          return;
  
      // 客戶端發(fā)言 message: {type:say, to_client_id:xx, content:xx}
      case 'say':
          // 非法請(qǐng)求
          if(!isset($_SESSION['room_id']))
          {
              throw new \Exception("\$_SESSION['room_id'] not set. client_ip:{$_SERVER['REMOTE_ADDR']}");
          }
          $room_id = $_SESSION['room_id'];
          $client_name = $_SESSION['client_name'];
  
          // 私聊
          if($message_data['to_client_id'] != 'all')
          {
              $new_message = array(
                  'type'=>'say',
                  'from_client_id'=>$client_id, 
                  'from_client_name' =>$client_name,
                  'to_client_id'=>$message_data['to_client_id'],
                  'content'=>"<b>對(duì)你說(shuō): </b>".nl2br(htmlspecialchars($message_data['content'])),
                  'time'=>date('Y-m-d H:i:s'),
              );
              Gateway::sendToClient($message_data['to_client_id'], json_encode($new_message));
              $new_message['content'] = "<b>你對(duì)".htmlspecialchars($message_data['to_client_name'])."說(shuō): </b>".nl2br(htmlspecialchars($message_data['content']));
              return Gateway::sendToCurrentClient(json_encode($new_message));
          }
  
          $new_message = array(
              'type'=>'say', 
              'from_client_id'=>$client_id,
              'from_client_name' =>$client_name,
              'to_client_id'=>'all',
              'content'=>nl2br(htmlspecialchars($message_data['content'])),
              'time'=>date('Y-m-d H:i:s'),
          );
          return Gateway::sendToGroup($room_id ,json_encode($new_message));
  }

  }

  /**

• 當(dāng)客戶端斷開連接時(shí)

• @param integer $client_id 客戶端id
  */
  public static function onClose($client_id)
  {
  // debug
  echo "client:{$_SERVER['REMOTE_ADDR']}:{$_SERVER['REMOTE_PORT']} gateway:{$_SERVER['GATEWAY_ADDR']}:{$_SERVER['GATEWAY_PORT']} client_id:$client_id onClose:''\n";

  // 從房間的客戶端列表中刪除
  if(isset($_SESSION['room_id']))
  {
  $room_id = $_SESSION['room_id'];
  $new_message = array('type'=>'logout', 'from_client_id'=>$client_id, 'from_client_name'=>$_SESSION['client_name'], 'time'=>date('Y-m-d H:i:s'));
  Gateway::sendToGroup($room_id, json_encode($new_message));
  }
  }

}

我找到位置了，您幫我看一下