接上一篇:node版本https://www.jianshu.com/p/395c40fac26f
此篇幅为java版本原生Servlet版本,spring boot版本类似,在对应注解函数中填写代码即可。
广播推送的例子。为什么要用这个呢,因为业务问题websocket再https下必须有证书的。so,大家懂得。
直接上代码
1.新建一个消息对象。也就是按text/event-stream标准定义一个能字符串。
枚举是定义了一些类型,无关紧要。
image.png
2.新建客户端对象,因一个客户端保存一个HttpServletResponse。这样后台可以主动推送消息。其他属性无所谓,但是response必须可访问,不然服务端消息无法送达指定客户端
image.png
3.static 消息工具
客户端全局变量
image.png
服务端消息通道
image.png
4.SSE的Servlet
image.png
为什么要while true,sse长连接模式,如果请求结束,则这个链接断开,sse会重新再链接,这样的话跟ajax的轮询一样了。java监听ServletRequest close 使用的是ServletRequestListener监听所有的,非当前request
5.在ServletContextListener初始化的时候后台模拟发送消息。发数据就是往Queue塞数据就行了。任何地方都可以调用。
image.png
6.关闭,手动触发模式,这个简单就是提供一个接口,ajax掉一下就行。
image.png
ps:尝试发送二进制数据来着,好像不太好弄,因为content-type:text/event-stream;charset=UTF-8 只能传字符串。想着把文件转为base64 再发送的,图片还好。但是大文件,分割再组合,呵呵。我不想写代码了。
1.png 2.png
网友评论