PMQ - 推送项目上线一年后的总结和复盘

概述

项目使用Swoole+Redis，更新迭代了4版，从最初的消息提醒、到后来的客服系统，它终于慢慢的长大了，具备了可持续推送的能力和动力，我要总结一下其中的酸甜苦辣。

PHP的运行模式的生命周期来讲一种有2种，一种是fpm的，这种模式下，主要编写Web服务,一种是Cli模式的，Swoole是php7版本之后的神作，可以说它开启了php也可以提供更多的网络服务的可能。

学习了源码后，发现php7真的是划时代的一个产品，重构了数组（从物理Hash链路调整成逻辑链结构）、字符串（二进制安全）、新增了Ast（抽象语法树）还有很多，主要提升了性能，说的有点多，回到项目本身。

项目我愿意把它定义成PMQ，主要的功能就是推送+拉取，尽量的精简以免后期维护上的麻烦，选取EasySwoole这个框架，因为当时慕课网上有视频教程，而且文档丰富，加入群有问题可以及时反馈给开发作者。

使用WebSocket服务来推送消息，WebSocket是一个建立在Http协议上的全双工通信协议，掌握以后发现还是挺简单，在这之前做了大量的学习和积累，对我的成长帮助非常大，做一个东西往往要深挖背后的原理，掌握好原理在去指导实践事半功倍，其实我当时也是瑟瑟发抖,没有心情考虑那么多，第一个想法就是实现功能。

失败和解决问题

第一次主要的功能是心跳、登陆、拉取未读消息数、评论和通知，消息确认几个功能。

第一次上线就，直接失败了，并发量太大，只上线了半个小时，Mysql没有扛住直接就挂了，服务紧急叫停，查找原因，当时正在年前，正好春节因为疫情也没有回家，就查找原因，进行下一次尝试。

1.添加缓存，更改缓存失效算法

从垮掉的Mysql开始修复，首先判断是这个原因，在登陆验证用户身份时请求主站的地方，做了一层缓存，主站过期的策略是7300s，为了防止同一时刻回收缓存引起雪崩，过期策略采用固定时长+随机过期的方法。

public function getUserId(string $token) :int
{$uid = \EasySwoole\RedisPool\RedisPool::invoke(function (\EasySwoole\Redis\Redis $redis) use ($token) {$uid = $redis->get($token);if (!isset($uid) || empty($uid)) {//远程验证token$uid = OAuth::getUserInfo($token);if (isset($uid) && !empty($uid) && intval($uid) > 0) {//存入缓存时间，过期时间小于 7300s$expireTime = 3650 + rand(1, 3000);$redis->setEx($token, $expireTime, $uid);}}return $uid;}, self::REDIS_CONN_NAME);return intval($uid);
}

2.函数内实现功能

当时对Swoole的新特性不太清楚，好像也报了几个跨协程调用的错误，为了保证服务的稳定和可靠，都把改成自己函数处理，当时有点惊弓之鸟。

还把所有的Redis链接池的defer模式改成了invoke模式，invoke模式的特点就是使用完成后立刻回收资源，defer模式是等执行完成后统一回收，区别是这点。

后来V1不那么完美，但是成功上线了。

计数

V2的功能只是在基础通信的基础上添加了计数功能，这版本平平无奇，只是加了个计数器的功能，很平静。

设计方案使用字符串为每个使用的人单独做key，在接收到主站的http请求时，未读数+1，读取消息数后清零。

在使用Crontab里的计划任务执行队列里的消息 1000/分，因为主站的消息没有事实请求我的服务，所以只能采用折中的方案，有一定的延迟。

public function commentsCounter(int $toUid, int $commentUid)
{if ($toUid == $commentUid || empty($toUid) || empty($commentUid)) return false;\EasySwoole\RedisPool\RedisPool::invoke(function (\EasySwoole\Redis\Redis $redis) use ($toUid, $commentUid) {//收到评论数 +1$redis->incr(Category::_getUnReadFromCommentsKeyName($toUid));//更新消息未读数$redis->lPush(self::PUSH_UNREAD_NUMBER_All, $toUid);$redis->lPush(self::PUSH_UNREAD_NUMBER_All, $commentUid);}, self::REDIS_CONN_NAME);
}

客服IM

客服功能是一个绝对优化和升华的精品项目，进行了大刀阔斧的改革，重构、设计方案、优化方案都得到了质的飞跃。

1.链接到WebSocket服务，进行用户验证（第一版功能）

2.进行链接客服管理员【建立 - 通信 - 结束】，建立一次通信的生命周期过程和流程。

客服的user_id，使用的是虚拟ID，66666666做为起始值（理论上当公司用户发展到6千万或者客服发展到3千人的时候，会出现问题）。

3.分配方法：上次聊天的客服管理员优先分配，第一次咨询的用户随机分配。

4.支持离线消息/消息确认/聊天记录/发送图片等等功能

5.离线消息按用户和管理员关系进行，1对1分配。

6.重构和优化，重构了第一版中函数的代码冗余，优化了初始化的路由层。

下面是代码细细说部分：

1.关于服务的优化

Swoole的高效在于预加载和常驻内存的特点，所以Swoole服务的热启动只支持Controller部分，所以对路由层做了一个大的整改，提高可用性。

把所有对路由的参数交给ForwardRoute类，去处理和控制参数，是路由变的灵活，可自动重启。

/*** 解析器避免高耦合，从解析器开始分发请求，使控制器分离*/
public function decode($raw, $client): ?Caller
{$caller = new Caller();$this->data = json_decode($raw, true);$toolRoute = new ForwardRoute($this->data);$controllerRoute = $toolRoute->_getRouter();$this->action = $toolRoute->_getAction();$this->body = $toolRoute->_formatBody();$caller->setControllerClass($controllerRoute);$caller->setAction($this->action);$caller->setArgs($this->body);return $caller;
}

2.停止服务时，添加onShutdown方法,完善清理fd旧关系数据

$register->set(EventRegister::onShutdown,function (\swoole_server $server ) use ($websocketEvent) {$websocketEvent->onShutdown($server);
});

3.分离Server层

新建Server层的原因有两个，减少代码冗余，将函数分离出来还有一个好处，函数在执行完以后，回收内存，尽可能的减少内存开销。

├── ChangPeiServer
│   └── UserServer.php
├── MysqlServer
│   └── PushMsg.php
├── RedisServer
│   ├── CountServer.php
│   ├── FdServer.php
│   └── QueueServer.php
├── Server.php
└── WebSocketServer└── PushServer.php

4.消费消息的双队列（这是第一版内容）

消费队列设计了快慢两个队列进行消费，快速队列6分支为一组，设置超时时间，如果用户超过1天不上线，放入延迟队列，延迟队列最多保持15天，15天后系统进行回收。

在使用Nosql缓存时，一定要注意的是内存的回收，设置超时时间。

$redis = \EasySwoole\RedisPool\RedisPool::defer('redis');
$server = ServerManager::getInstance()->getSwooleServer();
//每分钟消费limit条
$data = $redis->lRange(self::PUSH_MSG_COMMENT_LISTS, 0, $this->limit );
if (!empty($data) && is_array($data)){$pushLists = [];$lRemList = [];foreach ($data as $json){$msgPushInfo = json_decode($json,true);if(isset($msgPushInfo['to_uid']) && !empty($msgPushInfo['to_uid'])){$delayList = [];//用户超过1天不上线，放入延迟队列$diff_unix_times = time() - $msgPushInfo['create_time'];if( $diff_unix_times > $this->timeOut  ){$delayList[] = $json;}  else {$lRemList[$msgPushInfo['to_uid']][] = $json;$pushLists[$msgPushInfo['to_uid']]['uid'] = $msgPushInfo['to_uid'];$pushLists[$msgPushInfo['to_uid']]['noce_ack'] = $msgPushInfo['noce_ack'];}}else{//对错误数据及时清理$redis->lRem(self::PUSH_MSG_COMMENT_LISTS, 1, $json);}}

还有问题?

万万没想到，竟然还有问题，链接数变化正常，但是内存好像没有得到很好的释放，而且进程里也出现了很多野进程?

野进程多可能存在的原因是这样的，你没有守护启动，然后主进程挂了，后面的进程找不到父进程，变成了僵尸进程或者是孤儿进程。

内存也不对劲，大概率是我执行脚本里出了问题，去掉了修改配置的语句，在Base类里加入了unset，及时释放掉内存。

ini_set('memory_limit', '1024M');
set_time_limit(0);

第二天查看了日志，错误大小只有9.1K了，有明显改善，放心了。

未来

php的未来多半是扩展开发，集成Swoole的服务功能，集成Swoole想对来说还比较简单，扩展开发就有难度了，所有的方向都是殊途同归的，就是让性能达到最优，但我觉得性能不能单纯的寄托给语言，也要和Redis、Nginx、Linux参数配合使用，把思路融入在项目生产中，会创造更大的价值吧。