关于easyswoole实现websocket聊天室的步骤解析

- op 命令
- args 额外参数
- msg 消息内容
- msgType 消息类型(默认为1)
- flagId 消息标识符(前端随机生成一个标识符,后台处理完该消息之后,会返回相同的标识符给与前端确认)

- op 命令(响应类型)
- args 额外参数
- msg 消息内容(成功时为OK)
- msgType 消息类型(默认为1)
- flagId 将返回和前端一致的标识符,告知前端该次请求 成功/失败

## 发送消息
私聊消息:
`{"op":1001,"args":{"userId":12},"msg":"test","flagId":10086}`
将回复:
`{"op":1000,"args":\[\],"msg":"ok","flagId":10086}`
目标用户将收到:
`{"op":1101,"args":{"fromUserId":"12","msgId":16},"msg":"test"}`

## ping
发送:直接给客户端发送 "ping"即可
返回:
`{"op":1000,"args":null,"msg":"PONG"}`

### 消息接收状态
`{"op":4002,"args":{"msgId":42},"msg":"","flagId":111}`
服务器将响应:
`{"op":1000,"args":\[\],"msg":"ok","msgType":1,"flagId":111}`

当ws连接成功时,可通过该命令获取所有的未读好友消息:
`{"op":4001,"args":{"userId":null,"size":5},"msg":"","flagId":111}`
其中\`userId\` 为限制单独一个好友的未读消息,可不传
其中\`size\`为每次响应条数,默认为5,可不传
服务器将响应:
`{"op":4101,"args":{"total":0,"list":\[\]},"msg":"ok","msgType":1,"flagId":111}

<?php
namespace App\\Utility;
use EasySwoole\\Component\\Singleton;
use Swoole\\Table;
class FdManager
{
    use Singleton;
    private $fdUserId;//fd=>userId
    private $userIdFd;//userId=>fd
    function __construct(int $size = 1024*256)
    {
        $this->fdUserId = new Table($size);
        $this->fdUserId->column('userId',Table::TYPE_STRING,25);
        $this->fdUserId->create();
        $this->userIdFd = new Table($size);
        $this->userIdFd->column('fd',Table::TYPE_INT,10);
        $this->userIdFd->create();
    }
    function bind(int $fd,int $userId)
    {
        $this->fdUserId->set($fd,\['userId'=>$userId\]);
        $this->userIdFd->set($userId,\['fd'=>$fd\]);
    }
    function delete(int $fd)
    {
        $userId = $this->fdUserId($fd);
        if($userId){
            $this->userIdFd->del($userId);
        }
        $this->fdUserId->del($fd);
    }
    function fdUserId(int $fd):?string
    {
        $ret = $this->fdUserId->get($fd);
        if($ret){
            return $ret\['userId'\];
        }else{
            return null;
        }
    }
    function userIdFd(int $userId):?int
    {
        $ret = $this->userIdFd->get($userId);
        if($ret){
            return $ret\['fd'\];
        }else{
            return null;
        }
    }
}

namespace App\\Task;
use App\\HttpController\\Api\\User\\Message\\GroupMessage;
use App\\HttpController\\Api\\User\\Message\\SystemMessage;
use App\\Model\\Group\\GroupUserModel;
use App\\Model\\Message\\GroupMessageModel;
use App\\Model\\Message\\SystemMessageModel;
use App\\Model\\Message\\UserMessageModel;
use App\\Utility\\FdManager;
use App\\WebSocket\\Command;
use EasySwoole\\EasySwoole\\ServerManager;
use EasySwoole\\Task\\AbstractInterface\\TaskInterface;
//消息异步推送
class WebSocketPush implements TaskInterface
{
    protected $messageModel;
    function __construct($messageModel)
    {
        $this->messageModel = $messageModel;
    }
    function run(int $taskId, int $workerIndex)
    {
        $message = $this->messageModel;
        $result = false;
        //好友消息
        if ($message instanceof UserMessageModel) {
            $result = $this->friendMsg($message);
        }
        //群组消息
        if ($message instanceof GroupMessageModel) {
            $result = $this->groupMsg($message);
        }
        //系统消息
        if ($message instanceof SystemMessageModel) {
            $result = $this->systemMsg($message);
        }
        return $result;
    }
}

{
  "op": -1003,
  "args": \[\],
  "msg": "登陆状态失效",
  "msgType": 1,
  "flagId": null
}

{
  "op": -1002,
  "args": \[\],
  "msg": "你的账号在其他设备登陆,你已被强制下线",
  "msgType": 1,
  "flagId": null
}
``````bash
   static function onOpen(Server $server, \\Swoole\\Http\\Request $request)
    {
        $session = $request->get\['userSession'\] ?? null;
        $user = new UserModel();
        if (!empty($session)) {
            $user->userSession = $session;
            $info = $user->getOneBySession();
            if (empty($info)) {
                self::pushSessionError($request->fd);
                ServerManager::getInstance()->getSwooleServer()->close($request->fd);
                return true;
            }
            //如果已经有设备登陆,则强制退出
            self::userClose($info->userId);
            FdManager::getInstance()->bind($request->fd, $info->userId);
            //推送消息
//                self::pushMessage($request->fd,$info->userId);
        } else {
            self::pushSessionError($request->fd);
            ServerManager::getInstance()->getSwooleServer()->close($request->fd);
        }
    }