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

本文主要是介绍Swoole入门到实战(三):图文直播和聊天室模块、系统监控和性能优化模块、负载均衡 - 完结篇,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

一、直播、聊天

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]\app\common\lib\redis\Predis::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}\n";$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\app\common\lib\redis\Predis::getInstance()->sRem(config('redis.live_game_key'), $fd);echo "clientid:{$fd}\n";}
// 获取连接的用户
// 赛况的基本信息入库   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) {// 发送报警服务 邮件 短信/// todoecho 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 &

    检测:

  1. ps aux | grep monitor/server.php
  2. 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 代理分类

    clipboard.png

1、正向代理:

    clipboard.png

2、反向代理:

    clipboard.png

    clipboard.png

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

    clipboard.png

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

3.3 轮询策略

    clipboard.png

ip_hash:解决了不同请求打到不同服务器问题,从而保证了 sessioncookie的一致性。

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

    url_hash:

    clipboard.png

3.4 负载均衡示例

clipboard.png

完!

这篇关于Swoole入门到实战(三):图文直播和聊天室模块、系统监控和性能优化模块、负载均衡 - 完结篇的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/993660

相关文章

Python的time模块一些常用功能(各种与时间相关的函数)

《Python的time模块一些常用功能(各种与时间相关的函数)》Python的time模块提供了各种与时间相关的函数,包括获取当前时间、处理时间间隔、执行时间测量等,:本文主要介绍Python的... 目录1. 获取当前时间2. 时间格式化3. 延时执行4. 时间戳运算5. 计算代码执行时间6. 转换为指

Python正则表达式语法及re模块中的常用函数详解

《Python正则表达式语法及re模块中的常用函数详解》这篇文章主要给大家介绍了关于Python正则表达式语法及re模块中常用函数的相关资料,正则表达式是一种强大的字符串处理工具,可以用于匹配、切分、... 目录概念、作用和步骤语法re模块中的常用函数总结 概念、作用和步骤概念: 本身也是一个字符串,其中

Python中的getopt模块用法小结

《Python中的getopt模块用法小结》getopt.getopt()函数是Python中用于解析命令行参数的标准库函数,该函数可以从命令行中提取选项和参数,并对它们进行处理,本文详细介绍了Pyt... 目录getopt模块介绍getopt.getopt函数的介绍getopt模块的常用用法getopt模

MySQL索引的优化之LIKE模糊查询功能实现

《MySQL索引的优化之LIKE模糊查询功能实现》:本文主要介绍MySQL索引的优化之LIKE模糊查询功能实现,本文通过示例代码给大家介绍的非常详细,感兴趣的朋友一起看看吧... 目录一、前缀匹配优化二、后缀匹配优化三、中间匹配优化四、覆盖索引优化五、减少查询范围六、避免通配符开头七、使用外部搜索引擎八、分

Python列表去重的4种核心方法与实战指南详解

《Python列表去重的4种核心方法与实战指南详解》在Python开发中,处理列表数据时经常需要去除重复元素,本文将详细介绍4种最实用的列表去重方法,有需要的小伙伴可以根据自己的需要进行选择... 目录方法1:集合(set)去重法(最快速)方法2:顺序遍历法(保持顺序)方法3:副本删除法(原地修改)方法4:

在Spring Boot中浅尝内存泄漏的实战记录

《在SpringBoot中浅尝内存泄漏的实战记录》本文给大家分享在SpringBoot中浅尝内存泄漏的实战记录,结合实例代码给大家介绍的非常详细,感兴趣的朋友一起看看吧... 目录使用静态集合持有对象引用,阻止GC回收关键点:可执行代码:验证:1,运行程序(启动时添加JVM参数限制堆大小):2,访问 htt

python logging模块详解及其日志定时清理方式

《pythonlogging模块详解及其日志定时清理方式》:本文主要介绍pythonlogging模块详解及其日志定时清理方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录python logging模块及日志定时清理1.创建logger对象2.logging.basicCo

Qt spdlog日志模块的使用详解

《Qtspdlog日志模块的使用详解》在Qt应用程序开发中,良好的日志系统至关重要,本文将介绍如何使用spdlog1.5.0创建满足以下要求的日志系统,感兴趣的朋友一起看看吧... 目录版本摘要例子logmanager.cpp文件main.cpp文件版本spdlog版本:1.5.0采用1.5.0版本主要

python连接本地SQL server详细图文教程

《python连接本地SQLserver详细图文教程》在数据分析领域,经常需要从数据库中获取数据进行分析和处理,下面:本文主要介绍python连接本地SQLserver的相关资料,文中通过代码... 目录一.设置本地账号1.新建用户2.开启双重验证3,开启TCP/IP本地服务二js.python连接实例1.

Python通过模块化开发优化代码的技巧分享

《Python通过模块化开发优化代码的技巧分享》模块化开发就是把代码拆成一个个“零件”,该封装封装,该拆分拆分,下面小编就来和大家简单聊聊python如何用模块化开发进行代码优化吧... 目录什么是模块化开发如何拆分代码改进版:拆分成模块让模块更强大:使用 __init__.py你一定会遇到的问题模www.