Swoole webSocket消息服务系统代码设计详解

docker pull easyswoole/easyswoole3
docker run -ti -p 9501:9501 -p 80:80 
--name easyswoole easyswoole/easyswoole3 

├── EasySwooleEvent.php
├── bootstrap.php
├── composer.JSON
├── composer.lock
├── dev.php
├── easyswoole
├── produce.php
└── vendor

public static function loadConf()
{
    $ConfPath = EASYSWOOLE_ROOT . '/App/Conf/';
    $Conf  = Config::getInstance();
    $files = File::scanDirectory($ConfPath);
    if (!is_array($files['files'])) {
        return;
    }
    foreach ($files['files'] as $file) {
        $data = require_once $file;
        $Conf->setConf(strtolower(basename($file, '.php')), (array)$data);
    }
}

<?php
use EasySwoole\ORM\Db\Config as DBConfig;
use EasySwoole\ORM\Db\Connection;
use EasySwoole\ORM\DbManager;
return [
    //mysql数据库配置
    'mysql-msg' => [
        'host' => '59.110.162.133',
        'port' => '3306',
        'database' => 'swoole_msg', //cpwxw2_db_v2
        'username' => 'work',
        'passWord' => 'cp2018csq123456',
        'timeout' => 300,
        'charset' => 'utf8mb4'
    ],
    //Mysql连接池配置
    'conn_pool' => [
        'timeOut' => '3.0',    //设置获取连接池对象超时时间
        'checkOut' => 30 * 1000,  //设置检测连接存活执行回收和创建的周期
        'maxidleTime' => 15,       //连接池对象最大闲置时间(秒)
        'maxObjectNumber' => 100,       //设置最大连接池存在连接对象数量
        'minObjectNumber' => 5,        //设置最小连接池存在连接对象数量
        'autoPing' => 5,        //设置自动ping客户端链接的间隔
    ],
];

use \EasySwoole\Redis\Config\RedisConfig;
use \EasySwoole\RedisPool\RedisPool;
$redisConf = GlobalConfig::getInstance()->getConf('redis');
RedisPool::getInstance()->reGISter(new RedisConfig($redisConf),'redis');

use  \EasySwoole\EasySwoole\Logger;
Logger::getInstance(new \App\Log\LogHandel());

use Swoole\Coroutine\Scheduler;
use EasySwoole\EasySwoole\Crontab\Crontab;
//用户通知队列
Crontab::getInstance()->addTask(\App\Crontab\PushUserNoticeMsg::class);

$hotReloadOptions = new \EasySwoole\HotReload\HotReloadOptions;
$hotReload = new \EasySwoole\HotReload\HotReload($hotReloadOptions);
$hotReloadOptions->setMonitorFolder([EASYSWOOLE_ROOT . '/App']);
$server = ServerManager::getInstance()->getSwooleServer();
$hotReload->attachToServer($server);

php easyswoole server start -mode=websocket -d
php easyswoole server stop 

use EasySwoole\EasySwoole\Task\TaskManager;
TaskManager::getInstance()->async(function () use ($tableName,$data) {
    // todo code ...
});

DbManager::getInstance()->invoke(function (ClientInterface $client)
use ($where, $tableName, $count) {
    $pushMsgModel = PushMsgModel::invoke($client);
    $pushMsGobj = $pushMsgModel->tableName($tableName)
        ->field(['push_id'])
        ->get($where);
}, self::MYSQL_CONN_NAME);

## invoke方式
public function setAuthorFd(int $uid, int $fd)
{
    RedisPool::invoke(function (Redis $redis) use ($fd, $uid) {
        $sRet = $redis->zAdd(self::PUSH_MSG_AUTHOR_NOTICE_SYSTEM, $uid, $fd);
    }, self::REDIS_CONN_NAME);
}
## defer方式
$redis = \EasySwoole\RedisPool\RedisPool::defer('redis');
$data = $redis->lRange(self::PUSH_MSG_COMMENT_DELAY_LISTS, 0, 1000);

//$fd，指的是系统里的文件描述符fd
use EasySwoole\EasySwoole\ServerManager;
$server = ServerManager::getInstance()->getSwooleServer();
$server->push($fd,json_encode($messageData));
//获取当前链接的详细信息
$info = $server->getClientInfo($fd);
//获取全部websocket中的链接fd
//全员在线消息通知
$server = ServerManager::getInstance()->getSwooleServer();
$start_fd = 0;
while(true)
{
    $conn_list = $server->getClientList( $start_fd, $this->limit );
    if ($conn_list===false || count($conn_list) === 0 || empty($conn_list))
    {
        break;
    }
    $start_fd = end($conn_list);
    foreach ($conn_list as $fd){
        $info = $server->getClientInfo($fd);
        if ($info && $info['websocket_status'] === WEBSOCKET_STATUS_FRAME) {
            $server->push($fd, json_encode($this->pushMsg));
        }
    }
}