如何通过LayuiAdmin&LayIM&Thinkphp&Gateway实现小程序多客服接入系统的例子

先看下效果图吧。

3、在tp的application目录下创建一个模块chat，创建Run的控制器，这里除了Events的命名空间，其他基本不需要改动，改动端口有点坑，建议就用gateway默认的
class Run
{
    public function __construct()
    {
        //注册register
        new Register(&＃39;text://0.0.0.0:1236&＃39;);
        //初始化 bussinessWorker 进程
        $worker = new BusinessWorker();
        $worker->name = &＃39;WebIMBusinessWorker&＃39;;
        $worker->count = 4;
        $worker->registerAddress = &＃39;127.0.0.1:1236&＃39;;
        //设置处理业务的类,此处制定Events的命名空间
        $worker->eventHandler = &＃39;\app\chat\controller\Events&＃39;;
        // 初始化 gateway 进程
        $gateway = new Gateway("websocket://0.0.0.0:8282");
        $gateway->name = &＃39;WebIMGateway&＃39;;
        $gateway->count = 4;
        $gateway->lanIp = &＃39;127.0.0.1&＃39;;
        $gateway->startPort = 2900;
        $gateway->registerAddress = &＃39;127.0.0.1:1236&＃39;;
        $gateway->pingInterval = 55;
        $gateway->pingNotRespOnseLimit= 1;
        $gateway->pingData = &＃39;{"emit":"ping"}&＃39;;//此处为心跳包数据
        //运行所有Worker;
        if(!defined(&＃39;GLOBAL_START&＃39;))
        {
            Worker::runAll();
        }
    }
}
4、创建Event.php的控制器类，Event.php是主要的逻辑处理类，这里我只简单说下我的onmessage方法：    
public static function onMessage($client_id, $data){
        $message = json_decode($data, true);
        $message_type = $message[&＃39;emit&＃39;];
        
        switch($message_type) {
            case &＃39;init&＃39;:
                // uid
                //根据token获取uid
                $tokenCache =   new TokenCache();
                $user   =   $tokenCache->where(&＃39;token&＃39;,&＃39;eq&＃39;,$message[&＃39;token&＃39;])->order(&＃39;id DESC&＃39;)->find();
                if(!$user->uid||$user->date+$user->lifetimewhere(&＃39;openid&＃39;,&＃39;eq&＃39;,$user->uid)->where(&＃39;type&＃39;,&＃39;eq&＃39;,0)->find();
                if(!$msgUser->id){
                    self::onClose($client_id);
                }
                //*客服上线，设置数据库状态字段为在线状态
                $msgUser->status    =   1;
                $msgUser->save();
                $uid    =   $msgUser->id;
                // 设置session，这个$_SESSION我是为了下面的onclose方法里设置客服离线状态
                $_SESSION = [
                    &＃39;id&＃39;       => $uid,
                ];
                // 将当前$client_id与uid绑定
                Gateway::bindUid($client_id, $uid);
                $msgService = new MsgService();
                $msgService->checkLeavedMessage($uid);
                return;
                break;
            case &＃39;ping&＃39;:
                $pingData=[
                    &＃39;emit&＃39;=>&＃39;pong&＃39;,
                    &＃39;data&＃39;=>$client_id
                ];
                Gateway::sendToClient($client_id, json_encode($pingData));
                return;
            default:
                echo "unknown message $data" . PHP_EOL;
        }
    }
这里因为我用的是jwt验证，所以多绕了一层，先通过token找到layuiadmin的uid，再通过uid找到客服ID，把客服ID和client_id绑定，这样在后端php里就可以直接使用gateway::sendToUid来推送消息了。
5、tp后端，在需要推送消息的地方使用GatewayClient来主动推送消息。
这是接收消息的整个流程：微信开放接口请求消息推送接口url→php拿到数据，存库，通过GatewayClient主动推送到指定客服→前端拿到数据通过layim渲染到视图
其实这个Event.php我只做了两件事，一个是心跳检测，另一个就是登陆后将客服的ID和client_id绑定。
发送消息我用的是ajax的http方式发送，没有使用websocket。
未能实现的功能：
消息状态的处理，未读/已读
layim隐身/在线
目前只有文字消息，没有图片和卡片消息