在物联网采集管控系统中，前后端隔离的情况下，前端通过表单（比如按钮，开关，表格等）输入数据到数据库（比如mysql，通过webapi服务端输入），然后采集控制端到数据库里去扫表取数据，将数据下发给物联网络中的终端设备（比如风扇控制板），从而来控制风扇的开跟关。
采集控制端需要到数据库中去扫表。这个扫表操作会带来几个问题：
扫表会有锁表风险，当该dbcontext被占用的时候，其他线程不能实时使用此dbcontext。
在物联网系统中，数据会非常多，比如有10000台设备，每台设备有100个采集控制点，则控制点最多可能会达到100w数据，这样去扫表，不仅占用dbcontext上下文的时间会很长，而且实时性会很差。
增加了采集服务端编程的复杂性。
用户体验效果较差：客户点了开关控制风扇打开，然后底端设备需要很长时间才能真正打开。
使用消息订阅发布方法。rabbitmq比较重，故这里选用redis的订阅发布功能，而且很多情况下redis已经被作为缓存在引用，详见如下。
前端将实时控制值以restful api形式通过ip地址端口号+路由（比如：192.168.2.106:5000/controlconfig）将此值传递给服务端。
这里通过nuget获得csrediscore,来操作redis的订阅发布功能。采集控制端订阅消息。服务端发布消息。这样操作达到了如下目的：2.1不用经过数据库消息的实时传递；2.2 实时性好；2.3 编程也简单；2.4 实时效果好。
csredis 是 redis.io 官方推荐库，支持 redis-trib集群、哨兵、私有分区与连接池管理技术，简易 redishelper 静态类。
https://www.nuget.org/packages/csrediscore/
通过nuget获得csrediscore库
详细说明参考注释。
我要评论using csredis;
namespace ibms.infrastruct.redis
{
public interface iredismq
{ //连接redis
csredisclient connectcsredis();
//订阅频道
void subscribecsredis(string channelname);
//把message异步发布redis的频道
void publishasynccsredis(string channel, string message);
//释放redis
void disposecsredis();
//订阅接受下来的msg的方法
void rcv(string msg, string channel);
}
}
详细说明见注释
using system;
using csredis;
using ibms.infrastruct.appsetting;
namespace ibms.infrastruct.redis
{
public class redismq : iredismq
{
//读取连接redis字符串
private readonly string connectredis = appsettings.app(new string[] { "appsettings", "rediscaching", "connectionstring" });//按照层级的顺序，依次写出来
//定义一个redis客户端对象
csredisclient _redismq;
//连接redis
public csredisclient connectcsredis()
{
return _redismq = new csredisclient(connectredis);
}
//释放redis
public void disposecsredis()
{
_redismq.dispose();
}
//异步发布消息到redis的某个频道
public void publishasynccsredis(string channelname, string message)
{
_redismq.publishasync(channelname, message);
}
//如果自己需要用消息值，需要想方法返回数据
//订阅消息的处理方法
public void rcv(string channel, string msg)
{
console.writeline($"{datetime.now.tolongdatestring()}|rcv:{channel},msg:{msg}");
}
//订阅消息
public void subscribecsredis(string channelname)
{
_redismq.subscribe((channelname, msg => rcv(msg.channel, msg.body)));
}
}
}
// put: api/controlconfig/5
[httpput]
public async task update([frombody] controlconfig controlconfig)
{
_redismq.connectcsredis();
_redismq.subscribecsredis("web");
_redismq.publishasynccsredis("web", $"add at{datetime.now}");
_redismq.publishasynccsredis("web", $"{serializehelper.serialize(controlconfig)}");
console.readkey();
_redismq.disposecsredis();
}
在startup.cs中的configureservices方法进行依赖注入，如下。
services.addscoped<iredismq, redismq>();
在redisdesktopmanager的命令行窗口中输入psubscribe web，进行订阅web频道，如下
在前端控制了风扇打开操作之后如5.1，在redisdesktopmanager观察web频道输出信息
风扇实时打开。
如对本文有疑问， 点击进行留言回复！！
网友评论