asp.net core系列 70 即时通迅-WebSocket+Redis发布订阅
一.概述
在asp.net core 中可以用websocket 或asp.net core signalr来开发即时通迅。在项目中由于开发前后端分离,对于signalr前端技术人员不想依赖juqery和signalr.js包,后端确定使用websocket 来实现。对于asp.net core有自带的app.usewebsockets()中间件,但是使用iis做为web代理服务器时,需要在windows系统添加程序iis配置websocket才能使用websocket通讯。于是项目引用了一个开源包fleck。
fleck是对c#websocket的实现,程序内部使用了system.net.sockets类来实现websocket,不依赖于任何目标框架。 fleck使用介绍 :https://github.com/statianzo/fleck
下面是msdn文档原话:
对于大多数应用程序,我们建议使用 signalr,而不是原始 websocket。 signalr 可为 websocket 不可用的环境提供传输回退。 它还可提供简单的远程过程调用应用模型。 并且在大多数情况下,与使用原始 websocket 相比,signalr 没有显著的性能缺点。
websocket客户端支持:
浏览器 |
支持情况 |
chrome |
chrome version 4+支持 |
firefox |
firefox version 5+支持 |
ie |
ie version 10+支持 |
safari |
ios 5+支持 |
android brower |
android 4.5+支持 |
二.项目中即时通迅实现架构
在我业务项目中实现的流程是:第三方接口发送数据过来,使用redis进行发布消息, 在web端进行消息订阅, 把订阅的消息通过websocket发送到前端站点,前端界面进行局部数据刷新展示,已解决前端即时消息的展示。
三. 项目实现
3.1相关包
(1) 发布订阅redis包:install-package stackexchange.redis -version 2.0.601
(2) websocket引用 fleck 包。install-package fleck -version 1.1.0
3.2 fleck案例
关于fleck的websocket的参考如下:https://github.com/statianzo/fleck/tree/master/src/samples/consoleapp
3.3 项目中演示效果
(1) 使用web来做websocket宿主,websocket地址为:ws://127.0.0.1:8181,如下所示websocket服务已启动
(2) 启动前端界面,下图可以看到websocket已连接
前端页面连接websocket服务关键代码: window.ws = new wsimpl('ws://127.0.0.1:8181',"footballgoalscore"); 具体参考fleck的websocket示例。
(3) 控制台程序使用redis模拟发布信息, web端redis订阅消息,再通过websocket服务推送消息到前端页面,通过下图可以看到消息已即时传到
public void footballscore(iwebsocketconnection websocke) { //redis先订阅消息 _subscriber.subscribe("queue2", (msg) => { //websocket服务推送消息 websocke.send(msg); _llogger.debug("消息已发送!"); });
下面是模拟第三方接口消息达到后,使用redis来发布消息,发布后web端redis自动订阅。
static void main(string[] args) { isubscriber subscriber = new gfredissubscriber(); //足球比分 subscriber.publish("queue2", "1:0"); //即时欧指 subscriber.publish("queue1", "1.69|3.30|3.78"); console.readline(); }
参考文献:
上一篇: 榴莲能冷冻吗,榴莲怎样才好吃?
下一篇: 头条造手机——一场破局苦旅