菜单开关

周梦康 发表于 2017-10-01 1191 次浏览

免费领取阿里云优惠券 我的直播 - 《PHP 进阶之路》

直播是云栖社区的主要模块之一,弹幕服务是在直播频道上线之后,为了更多的互动,提出的。

我主要做了下面的一些迭代:

  • 使用 netty 构建弹幕应用
  • 授权服务与弹幕服务的分离
  • 专题页本地缓存
  • 使用 nginx lua 为 web 应用加速
  • 实时监控在线人数

使用 netty 构建弹幕应用

抽离出来的小demo https://github.com/zhoumengkang/netty-websocket

├── WebSocketServer.java                启动服务器端口监听
├── WebSocketServerInitializer.java     初始化服务
├── WebSocketServerHandler.java         接管WebSocket数据连接
├── dto
│   └── Response.java                   返回给客户端数据对象
├── entity
│   └── Client.java                     每个连接到WebSocket服务的客户端对象
└── service
    ├── MessageService.java             完成发送消息
    └── RequestService.java             WebSocket初始化连接握手时的数据处理

客户端授权与弹幕服务的分离

客户端请求 web 服务器 api 获取弹幕服务请求的完整地址

https://yq.aliyun.com/yqapi/webinar/barrage/url?id={id}

然后返回类似于

wss://barrage.aliyun.com/websocket/?rid={id}&code=xxxxx

然后客户端使用返回的websocket地址发起请求即可。
因为在获取code的过程中,需要读取集团 cookie,和账号中心交互验证用户身份合法性。获取用户的基本信息

{
  uid: xxx,
  name: xxx,
  level: xxx,
  isAdmin: xxx
}

然后和时间戳对称加密运算得到最终的code,这样弹幕服务器只需要验证解密code验证数据的合法性,就可以使用客户端传递过来的用户信息了,免去了弹幕服务身份认证,获取用户信息等操作的网络I/O。

专题页本地缓存

很多直播页面都是静态的专题页面,我们原来的做法是在tms里面运营编辑好了,我们再抓取过来缓存在redis里面,然后最后通过后端框架呈现。这样还是有一次web服务器到远程的集中式的redis缓存的网络I/O。

做了以下的修改,在nginx配置单文件来操作

rewrite ^/promotion/(.*)$  /promotion.php last;

promotion.php 需要做两个个工作

  • 判断客户端是移动端还是PC端,然后读取不一样的数据
  • 本地缓存文件不存在则从远程redis里读取,然后缓存到本地

同时后台在抓取页面到redis时的同时,我会推送缓存到各个web服务器的指定目录

#!/bin/bash
# 更新同步 html 静态缓存到各个服务器

servers=(xxx.xxx.xxx.200 xxx.xxx.xxx.201 xxx.xxx.xxx.202 xxx.xxx.xxx.203)
for server in ${servers[@]};do
    cd /path/to/cache/output/
    rsync -aR promotion/pc/$1.html username@$server:/path/to/cache/output/
    rsync -aR promotion/mobile/$1.html username@$server:/path/to/cache/output/
done

还需要验证文件发布是否成功,对比最终的md5

使用 nginx lua 为 web 应用加速

有了上面的缓存文件的推送之后,我想缓存的读取直接在nginx 里进行。需求也就是:
pc、mobile 一个地址有两套页面,需要在后端根据浏览器的 user_agent 来显示不同的页面。

具体参考:https://mengkang.net/998.html

我在我们自己私人的web服务器上做了性能测试的对比,性能提升了近1倍,稳定性也挺高了很多。

实时监控在线人数

我们自己使用Grafana+telegraf+InfluxDb搭建了一个简单的监控系统,然后我编写了一个脚本来每秒监控统计端口ip

压测

websocket 压测

脚本 https://github.com/zhoumengkang/netty-websocket/blob/master/benchmark.py

并测试为N个客户端,每个客户端发送10条消息,服务器配置2核4G内存,广播给所有的客户端,我们测试1000个并发的时候,负载在后期陡升。
实际情况下,不可能那么多人同时说话广播,而是说话的人少,接受广播的人多。

实际线上之后,在不限制刷帖频率大家狂轰滥炸的情况下,1500多人在线,半小时,负载一直都处于0.5以下。

web 服务的压测

ab -n 8000 -c 800 http://mengkang.net/promotion/1
Complete requests:      8000
Failed requests:        0
Requests per second:    7046.66 [#/sec] (mean)
Time per request:       113.529 [ms] (mean

ab -n 10000 -c 1000 http://mengkang.net/promotion/1
Complete requests:      10000
Failed requests:        0
Requests per second:    5670.38 [#/sec] (mean)
Time per request:       176.355 [ms] (mean)

嗨,老铁,欢迎来到我的博客!

如果觉得我的内容还不错的话,可以关注下我在 segmentfault.com 上的直播。我主要从事 PHP 和 Java 方面的开发,《深入 PHP 内核》作者之一。

直播中我将毫无保留的分享我这六年的全部工作经验和踩坑的故事,以及会穿插着一些面试中的 考点难点加分点

评论列表