swoole 弹幕系统

一、服务器分布

1、LVS负载均衡

2、多台danmu server

3、Redis(集群)用于存储数据和夸服务器订阅通知

4、Cli server用于读取缓存数据并存到mysql,以及清空缓存

二、弹幕服务端

1、danmu-server使用swoole_websocket_server,中间是子进程,最下面是redis服务器

2、web-server是网页http请求,可以产生的动态推送,并将消息存到redis

3、receive-worker-n是worker进程

3.1、接收用户发出的消息,并存到redis

3.2、在共享内存(data cache进程)标示该房间有新消息

4、data-cache-process是process进程,用于做共享内存,存放roomId、fdId对应关系,房间是否有新消息标示等等

5、monitor-process是process进程

5.1、分析本机共享内存看哪个房间有新消息(对应3.2)

5.2、分析redis看哪个房间有新消息(对应2)

5.3、对有新消息的roomId进行publish

6、send-process-n是process进程

6.1、启动时swoole_redis去subscribe

6.2、onMessage之后读取消息,并遍历发送给房间内的fd

三、data process进程数据交互

1、worker:sendMessage与onPipeMessage

2、process:write与read(写最大8k,读最大64k,自己用pack打包)

四、特殊说明

1、swoole table需要设置行数,且只支持一维,所以自己用process做共享内存

2、onHandshake的时候,还处理了分房间、记录用户信息、刷新新用户列表、进入房间消息等

3、monitor-process除了上面说到的监控新消息,还包含监控直播间回收、监控禁言、监控在线人数等

4、部分功能点通过cli脚本处理,包括redis资源入库及回收等

五、代码段(暂不提供)

1、server.php

2、coroutine.php

3、data_cache.php

4、packet.php

5、pool.php

时间: 2024-11-10 11:36:23

swoole 弹幕系统的相关文章

高并发实时弹幕系统 并发数一定是可以进行控制的 每个需要异步处理开启的 Goroutine(Go 协程)都必须预先创建好固定的个数,如果不提前进行控制,那么 Goroutine 就随时存在爆发的可能。

小结: 1.内存优化1.一个消息一定只有一块内存使用 Job 聚合消息,Comet 指针引用. 2.一个用户的内存尽量放到栈上内存创建在对应的用户 Goroutine(Go 程)中. 3.内存由自己控制主要是针对 Comet 模块所做的优化,可以查看模块中各个分配内存的地方,使用内存池. 2.模块优化1.消息分发一定是并行的并且互不干扰要保证到每一个 Comet 的通讯通道必须是相互独立的,保证消息分发必须是完全并列的,并且彼此之间互不干扰. 2.并发数一定是可以进行控制的每个需要异步处理开启的

bilibili高并发实时弹幕系统的实战之路

高并发实时弹幕是一种互动的体验.对于互动来说,考虑最多的地方就是:高稳定性.高可用性以及低延迟这三个方面. 高稳定性,为了保证互动的实时性,所以要求连接状态稳定: 高可用性,相当于提供一种备用方案,比如,互动时如果一台机器挂了,此时必须保证可以和另外一台机器连接,这样就从侧面解决了,用户连接不中断的问题: 低延迟,弹幕的延迟周期控制在1秒以内,响应是比较快的,所以可以满足互动的需求. B站直播弹幕服务架构(下面简称GOIM)的出现就是为了解决这一系列的需求.下面将对此进行详细的介绍. B站直播弹

使用swoole和websocket结合来制造弹幕

在知乎上无意中看到了一篇有关这个的话题https://zhuanlan.zhihu.com/p/23992890,刚好没事也好久没弄swoole了就自己按照知乎上的那篇文站实操了一下 那个试验中有几个点需要注意一下: 1.首先得安装php的swoole扩展 pecl install swoole  用php -m检查扩展是否安好 2.jquery包和弹幕所需要的包最好用他那个dist中的文件,不然的话有可能页面js会报错 3. liunx发行版安装php5.3+并且编译swoole扩展,在php

Android弹幕实现:基于B站弹幕开源系统(1)

?? Android弹幕实现:基于B站弹幕开源系统(1) 如今的视频播放,流行在视频上飘弹幕.这里面做的相对比较成熟.稳定.使用量较多的弹幕系统,当推B站的弹幕系统,B站的弹幕系统已经作为开源项目在github上,其项目地址:https://github.com/Bilibili/DanmakuFlameMaster 以B站开源的弹幕项目为基础,现给出一个简单的例子,实现发送简单的文本弹幕.第一步,首先要在Android的build.gradle文件中引入B站的项目: repositories

react视频弹幕播放

不要陷入轮子的围城中 说的确实没错.. 那我为什么还要研究这个弹幕系统呢 因为我没有发现业界有特别高端的弹幕播放器 基于html5的 也可能是我见的少 如果你发现优秀的弹幕播放器 务必告知! 研究这个之前我度娘了一下相关的html5弹幕播放器 还是有相关插件的 但是都太low 太low 太low... 那些每帧运动几个像素和无视弹幕重叠问题的弹幕播放器都不用考虑! 我理想的弹幕系统要尽可能的解决重叠问题 而且每条弹幕的运动轨迹不光只是从右往左的线性运动 还可以是各种参数方程 如下效果 上面就有2

揭秘国外社交平台的灰色利益链

近年来,随着互联网技术的快速发展,物联网这一领域也跟着水涨船高,各项具有应用意义的项目也在不断拓展,比如智能家居,视频监控系统等,身处千里之外,却能知悉家中的一举一动,这也体现了"万物互联"的概念.其中,作为物联网的终端节点,随着大众将目光逐步转移到物联网时,这些设备因自身的安全性问题也遭受到来自恶意攻击者的觊觎. 国际商业时报报道,不久前,黑客对互联网服务提供商Dyn的攻击,让包括Netflix.Facebook.Twitter及<卫报>在内的众多网站陷入瘫痪.网络安全公

网上搜集第三方(二)

這是我收集了一些第三方的 Library,大部份都還沒用過Orz,只是這樣整理以後要用到的時候會比較好找到. UI UI Design alertView Menu(選單) Side ViewController UICollectionView Segment Control Others 動畫 影像特效 模糊.毛玻璃效果(Blur) 畫面轉換 各種統計圖表 Line Bar Pie Others Pull To ReFresh Notification Auto Layout Data St

云端基于Docker的微服务与持续交付实践

云端基于Docker的微服务与持续交付实践笔记,是基于易立老师在阿里巴巴首届在线技术峰会上<云端基于Docker的微服务与持续交付实践>总结而出的. 本次主要讲了什么? Docker Swarm Docker Swarm mode 微服务支持(Docker集群架构体系) Docker的发展趋势和前沿成果 在Docker技术方面还是很佩服大牛的,所以赶紧写下笔记,追随大神的脚步. 阿里云资深专家易立,技术就不说了,他比其他直播间硬生生多讲了半个多点,于情于理还是万分感谢本次分享的(可惜devOp

2016文章汇总

Java系列: JVM系列:jvm基本结构 JVM系列:java中JVM的原理 JVM系列:解决JVM最大内存设置问题 JVM系列:JVM参数设置.分析 HashMap , HashTable , ConcurrentHashMap 源码比较 从使用到原理学习Java线程池 谈谈HashMap线程不安全的体现 Java NIO浅析 解密ThreadLocal JAVA虚拟机体系结构 Java常量池理解与总结 一道面试题比较synchronized和读写锁 synchronized的实现原理和应用