Swoole入门到实战（三）：图文直播和聊天室模块、系统监控和性能优化模块、负载均衡 - 完结篇

Scott 发布于2019-07-16 16:21 / 3159人阅读

摘要：缺点客户端可能会再用一层代理负载均衡示例完参考教程韩天峰力荐入门到实战打造高性能赛事直播平台

上一篇：Swoole入门到实战（二）：进程，内存和协程、Swoole完美支持ThinkPHP5、分发Task异步任务机制实现 一、直播、聊天 1.1 图文直播（Redis）

    在线用户处理：
    方案（一）：https://wiki.swoole.com/wiki/...（推荐）
    方案（二）redis方案，无序集合Set
    方案（三）swoole-table

    /**
     * 监听ws连接事件
     * @param $ws
     * @param $request
     */
    public function onOpen($ws, $request) {
        // fd redis [1]
        appcommonlib
edisPredis::getInstance()->sAdd(config("redis.live_game_key"), $request->fd);
        var_dump($request->fd);
    }

    /**
     * 监听ws消息事件
     * @param $ws
     * @param $frame
     */
    public function onMessage($ws, $frame) {
        echo "ser-push-message:{$frame->data}
";
        $ws->push($frame->fd, "server-push:".date("Y-m-d H:i:s"));
    }

    /**
     * close
     * @param $ws
     * @param $fd
     */
    public function onClose($ws, $fd) {
        // fd del
        appcommonlib
edisPredis::getInstance()->sRem(config("redis.live_game_key"), $fd);
        echo "clientid:{$fd}
";
    }

// 获取连接的用户
// 赛况的基本信息入库   2、数据组织好 push到直播页面
 $taskData = [
            "method" => "pushLive",
            "data" => $data
        ];
        $_POST["http_server"]->task($taskData);

    /**
     * 通过task机制发送赛况实时数据给客户端
     * @param $data
     * @param $serv swoole server对象
     */
    public function pushLive($data, $serv) {
        $clients = Predis::getInstance()->sMembers(config("redis.live_game_key"));

        foreach($clients as $fd) {
            $serv->push($fd, json_encode($data));
        }
    }

    /**
     * 基础类库优化，优化两个参数的方法（重要）
     * 1.集合的添加和删除
     * @param $name
     * @param $arguments
     * @return array
     */
    public function __call($name, $arguments) {
        //echo $name.PHP_EOL;
        //print_r($arguments);
        if(count($arguments) != 2) {
            return "";
        }
        $this->redis->$name($arguments[0], $arguments[1]);
    }

Tips：关闭服务后，清除Redis中所有客户端的id

1.2 聊天(connections)

$this->ws = new swoole_websocket_server(self::HOST, self::PORT);
$this->ws->listen(self::HOST, self::CHART_PORT, SWOOLE_SOCK_TCP);

//推荐使用connections这种方式，redis方式也可以
foreach($_POST["http_server"]->ports[1]->connections as $fd) {
    $_POST["http_server"]->push($fd, json_encode($data));
}

二、系统监控和性能优化模块 2.1 系统监控

/**
 * 监控服务 ws http 9911
 */

class Server {
    const PORT = 9911;
    public function port() {
        $shell  =  "netstat -anp 2>/dev/null | grep ". self::PORT . " | grep LISTEN | wc -l";

        $result = shell_exec($shell);
        if($result != 1) {
            // 发送报警服务 邮件 短信
            /// todo
            echo date("Ymd H:i:s")."error".PHP_EOL;
        } else {
            echo date("Ymd H:i:s")."succss".PHP_EOL;
        }
    }
}

// 每2秒执行一次
swoole_timer_tick(2000, function($timer_id) {
    (new Server())->port();
    echo "time-start".PHP_EOL;
});

以‘守护进程’方式在后台执行：

nohup /usr/local/php/bin/php /home/wwwroot/swoole/thinkphp/extend/swoole/monitor/server.php > /home/wwwlog/monitor.log &

检测：

ps aux | grep monitor/server.php

tail -f /home/wwwlog/monitor.log

2.2 平滑重启

/**
 * 设置进程名，为后续平滑重启进程
 * @param $server
 */
public function onStart($server) {
    swoole_set_process_name("live_master");
}

reload.sh

echo "loading..."
pid=`pidof live_master`
echo $pid
kill -USR1 $pid
echo "loading success"
# linux 信号控制：USR1 平滑重载所有worker进程并重新载入配置和二进制模块

2.3 nginx 转发到 swoole_server

if (!-e $request_filename ) {
    proxy_pass http://127.0.0.1:9911;
}

三、负载均衡

负载均衡：nginx必须是单台，其实nginx特别耗费cpu，需要测试nginx的转发量

 代理 - 代为办理（如代理理财、代理收货等等）

3.1 代理分类

1、正向代理：

2、反向代理：

3.2 后端服务器在负载均衡调度中的状态

模拟down和backup可通过关闭端口：iptables -I INPUT -p tcp --dport 8003 -j DROP
清理规则：iptables -F

3.3 轮询策略

ip_hash：解决了不同请求打到不同服务器问题，从而保证了session和cookie的一致性。

缺点:客户端可能会再用一层代理**

url_hash:

3.4 负载均衡示例

完！

参考教程：韩天峰力荐 Swoole入门到实战打造高性能赛事直播平台

idc机房托管超融合服务器模块化机房和等保数据中心微模块和传统机房 4g通信模块和云服务器一体化机房和模块化机房

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/34739.html

Swoole入门到实战（三）：图文直播和聊天室模块、系统监控和性能优化模块、负载均衡 - 完结篇

摘要：缺点客户端可能会再用一层代理负载均衡示例完参考教程韩天峰力荐入门到实战打造高性能赛事直播平台上一篇：Swoole入门到实战（二）：进程，内存和协程、Swoole完美支持ThinkPHP5、分发Task异步任务机制实现一、直播、聊天 1.1 图文直播（Redis）在线用户处理：方案（一）：https://wiki.swoole.com/wiki/...（推荐） ...

binaryTree 2019-07-16 16:33 评论0 收藏0
当S8遇上边缘计算：谈阿里云ENS对直播业务场景的支撑

摘要：阿里云推出的边缘节点服务这个云产品，就是针对前面提到的目标场景，来应对客户自建边缘设施遇到的痛点和挑战的。针对赛事直播业务场景的优化阿里云团队针对常规活动赛事电竞直播这一业务场景，也做了很多技术优化。近日，英雄联盟S8全球总决赛落下帷幕，中国战队IG零封FNC夺得冠军。这场比赛引起了国内网友的超高关注度，也给直播平台带来了不小的技术挑战。虎牙直播平台结合阿里云边缘节点技术方案，保障了...

lily_wang 2019-06-21 16:51 评论0 收藏0
node技术栈 - 收藏集 - 掘金

摘要：异步最佳实践避免回调地狱前端掘金本文涵盖了处理异步操作的一些工具和技术和异步函数。 Nodejs 连接各种数据库集合例子 - 后端 - 掘金Cassandra Module: cassandra-driver Installation ... 编写 Node.js Rest API 的 10 个最佳实践 - 前端 - 掘金全文共 6953 字，读完需 8 分钟，速读需 2 分钟。翻译自...

王伟廷 2019-06-26 17:15 评论0 收藏0
一篇写给新手入门PHP的文章

摘要：如果在学习过程中有什么问题可以关注我公众号琉忆编程库给我留言。有兴趣可以深入学习最后附上学习的知识结构图谱，可以按着下面的这个知识结构图进行学习不一定完整，更多资料，面试题，都可以关注公众号琉忆编程库获取。你好，是我——琉忆。PHP程序员面试系列图书作者。作为一名PHP开发者过来人，也是经历了菜鸟到老手的过程，在此给那些想学PHP的同学指条路，即使你是转行学PHP一样可以学会PHP...

Ilikewhite 2019-07-01 11:04 评论0 收藏0
一篇写给新手入门PHP的文章

摘要：如果在学习过程中有什么问题可以关注我公众号琉忆编程库给我留言。有兴趣可以深入学习最后附上学习的知识结构图谱，可以按着下面的这个知识结构图进行学习不一定完整，更多资料，面试题，都可以关注公众号琉忆编程库获取。你好，是我——琉忆。PHP程序员面试系列图书作者。作为一名PHP开发者过来人，也是经历了菜鸟到老手的过程，在此给那些想学PHP的同学指条路，即使你是转行学PHP一样可以学会PHP...

Richard_Gao 2019-08-01 10:15 评论0 收藏0