以前聊过Golang长连接-基于WebSocket,这次我们聊SSE(Server-Sent Events)。
简介
SSE(Server-Sent Events)和WebSocket都是实现实时通信的技术。以下是它们的区别和相同点:
相同点:
- 都是基于HTTP协议实现的实时通信技术。
- 都可以实现服务器向客户端发送实时更新的数据。
区别:
- SSE是单向通信,只能服务器向客户端发送数据;而WebSocket是双向通信,服务器和客户端都可以发送数据。
- SSE使用HTTP协议,而WebSocket使用ws协议(或wss协议,当使用SSL加密时)。
- SSE在某些场景下更适用于低延迟的数据传输,如股票行情等;而WebSocket更适用于需要双向实时交互的应用,如在线聊天、游戏等。
- SSE支持自动重连,如果连接中断,浏览器会自动尝试重新连接;而WebSocket需要手动实现重连逻辑。
- SSE的浏览器兼容性较差,不支持IE和较低版本的浏览器;而WebSocket的浏览器兼容性较好。
- SSE使用文本格式传输数据,而WebSocket支持文本和二进制数据传输。
实战
请求
请求体里需要设置为text/event-stream,可以使用封装好的EventSource
1 | var stream = new EventSource("/sse/subscribe?user=%s&topics=%s"); |
可以监听事件、和错误信息,并做出响应的处理
服务
服务端对建立的链接定时发送消息即可,如果想关闭,返回false。
1 | c.Stream(func(w io.Writer) bool { |
效果
最终效果如下图所示,home接口显示html,并发起subscribe请求。subscribe设置定时器,1s返回一条数据,到达最终值后返回false。为了防止重连,在html里判断onerror,直接关闭stream链接。
总结
上面的代码位于:https://github.com/shidawuhen/asap/tree/master/controller/sse
SSE的实现比Websocket要方便的多,大家可以基于自己的需要去选择。
- 实现一个完整的服务仅需要少量的代码;
- 可以在现有的服务中使用,不需要启动一个新的服务;
- 可以用任何一种服务端语言中使用;
- 基于 HTTP / HTTPS 协议,可以直接运行于现有的代理服务器和认证技术。