（1）业务复杂度介绍

500W * 1000条/秒=50亿条/秒

使用Go做WebSocket开发无非就是三种情况：

golang.org/x/netgorilla/websocketgolang.org/net

根据估算结果，弹幕推送量很大的时候，Linux内核将会出现瓶颈，因为Linux内核发送TCP包的时候极限包发送频率是100W。因此可以将同一秒内的弹幕消息合并为1条推送，减少网络小数据包的发送，从而降低推送频率。

弹幕系统需要维护在线的用户长连接来实现定向推送到在线的用户，通常是使用Hash字典结构，通常推送消息就是遍历在线用的Hash字典。在弹幕推送期间用户在不断的上下线，为了维护上线用户，那么就得不断的修改Hash字典，不断地进行锁操作，用户量过大导致锁瓶颈。因此可以将整个Hash结构拆分为多个Hash结构，分别对多个Hash结构加不同的锁，并且使用读写锁替代互斥锁。

通常服务器与客户端交互使用JSON结构，那么需要不断的编码解码JSON数据，这将会导致CPU瓶颈。将消息先进行合并，然后进行编码，最后轮询Hash结构进行推送。

以上是单体架构存在的问题，为了支持更多的用户负载，通常弹幕系统采用分布式架构，进行弹性扩容缩容。

（2）推送还是拉取？

如果是客户端拉取服务器端数据，那么将会存在以下几个问题：

  • 直播在线人数多就意味着消息数据更新频率高，拉取消息意味着弹幕无法满足时效性
  • 如果很多客户端同时拉取，那么服务器端的压力无异于DDOS
  • 一个弹幕系统应该是通用的，因此对于直播间弹幕较少的场景，意味着消息数据拉取请求都是无效的

因此我们考虑推送模式：当数据发生更新的时候服务器端主动推送到客户端，这样可以有效减少客户端的请求次数。如果需要实现消息推送，那么就意味着服务器端维护大量的长连接。

（3）为什么使用WebSocket？

实现弹幕消息的实时更新一定是使用Socket的方式，那么为啥要使用WebSocket呢？现在大部分直播应用的开发都是跨平台的，然而跨平台的开发框架本质就是Web开发，那么一定离不开WebSocket，而且一部分用户会选择在Web端看视频，比如Bilibili，现如今也有一些桌面应用是用Electron等跨平台框架开发的，比如Lark飞书等，因此实现消息推送的最佳方案就是使用WebSocket。

使用WebSocket可以轻松的维持服务器端长连接，其次WebSocket是架构在HTTP协议之上的，并且也可以使用HTTPS方式，因此WebSocket是可靠传输，并且不需要开发者关注底层细节。

为啥要使用Go搞WebSocket呢？首先说到WebSocket你可能会想到Node.js，但是Node.js是单线程模型，如果实现高并发，不得不创建多个Node.js进程，但是这又不容易服务端遍历整个连接集合；如果使用Java就会显得比较笨重，Java项目的部署，编写Dockerfile都不如Go的目标二进制更加简洁，并且Go协程很容易实现高并发，上一章说到Go语言目前也有成熟的WebSocket轮子。

（4）服务端基本Demo

首先搭建好一个框架：

然后完善messageHandler函数：

现在基本上实现了WebSocket功能，但是websocket的原生API不是线程安全的（Close方法是线程安全的，并且是可重入的），并且其他模块无法复用业务逻辑，因此进行封装：

  • 封装Connection对象描述一个WebSocket连接
  • 为Connection对象提供线程安全的关闭、接收、发送API

至此，你已经学会了如何使用Go构建WebSocket服务。