如何实现支持数亿用户的长连消息系统

1、room实例地址，通过room service下发给长连接 Center Service比较重的工作如全网广播，需要把所有的任务分解成一系列的子任务，分发给所有center，然后在所有的子任务里，分别获取在线和离线的所有用户，再批量推到Room Service。

创新互联是专业的绛县网站建设公司，绛县接单;提供成都做网站、成都网站建设,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行绛县网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!

2、现在流行的消息推送实现方式，主要为长链接方式实现。

3、利用kafka技术可以在廉价PC Server上搭建起大规模的消息系统。Kafka具有消息持久化、高吞吐、分布式、实时、低耦合、多客户端支持、数据可靠等诸多特点，适合在线和离线的消息处理。

4、基于TCP长连接则能够更好地支持大批量用户，问题是客户端和服务器的实现比较复杂。也有一些改进，比如下行使用MQTT进行服务器通知/消息的下发，上行使用HTTP短连接进行指令和消息的上传。

WebSocket+SLB(负载均衡)会话保持解决重连问题

只要SLB能够正常识别WS握手协议里Request的cookie和正常识别服务器返回的Response并且往里面插入cookie，就可以利用会话保持解决重连问题。

负载均衡所解决的问题主要包括两点：第一点，SLB能够消除系统的单点故障，这是因为SLB的后面是由多台云服务器组成的服务器池，那么当其中某一台服务器出现故障的时候并不会影响整个系统的可服务性。

首先它不能降低内部连接数量以及转发次数，所以无法降低资源消耗；而负载均衡应该做到内部一个子节点仅用一个连接，做到批量发送数据减少内部数据发送次数。

go语言中的tcpconn是阻塞还是非阻塞的

阻塞socket和非阻塞socket的区别： 读操作 对于阻塞的socket，当socket的接收缓冲区中没有数据时，read调用会一直阻塞住，直到有数据到来才返回。当socket缓冲区中的数据量小于期望读取的数据量时，返回实际读取的字节数。

如果 net.Conn Close() 了，不论 Read() 阻塞还是 Write() 阻塞都会立即收到 err 返回。一般来说，Write() 是不可能主动知道连接断开的，除非是 SetDeadline() 猜测对方断掉了，指定时间内没有写成功就认为是断开。

socket当前还没发现这样的api，确实有io timeout，但是不是这个场景，如果recv_buf中有数据了，哪怕是一个字节，read调用就返回。当前还没发现，不知道其他的有没有库提供这功能。

本质上，是作为文件处理的，发送是“write，print”，接受是“read”。连接相当于打开文件。

网页题目：go语言基于tcp协议 go语言通信
网页链接：http://chengdu.cdxwcx.cn/article/dedoope.html