通讯网关软件022——利用CommGate X2MQTT实现MQTT访问MSSQL服务器

本文主要是介绍通讯网关软件022——利用CommGate X2MQTT实现MQTT访问MSSQL服务器,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

本文介绍利用CommGate X2MQTT实现MQTT访问MS SQL数据库。CommGate X2MQTT是宁波科安网信开发的网关软件,软件可以登录到网信智汇(http://wangxinzhihui.com)下载。

【案例】如下图所示,实现上位机通过MQTT来获取MS SQL数据库的数据。

【解决方案】设置网关机,与MS SQL采用以太网通讯,与MQTT Broker Server采用以太网通讯,安装CommGate X2MQTT软件。

  1. MS SQL数据表结构要求:

  • 至少要求具备name、value二个字段。
  • name:标签名称,字符类型
  • value:数值,可以是字符类型或浮点类型
  • state:不是必须的,整型类型,1表示好值 0表示坏值
  • time:不是必须,可以是datetime或bigint
  • 以上字段名称如不是name、value、state、time,需要在以下配置文件进行字段名称的配置

2. MS SQL通讯调试:在网关机上运行MS SQL调试工具,与MS SQL服务器通讯调试。通讯正常后,记下通讯参数。

3. MQTT通讯调试:在网关机上运行MQTT调试工具,与MQTT Broker Server通讯调试。通讯正常后,记下通讯参数。

4. 配置X2MQTT 出口端参数:在X2MQTT安装目录Ini下编辑X2MQTT.ini,修改出口端参数。

[OUT]
;通讯类型MQTT,不做修改
Type = MQTT;MQTT Broker服务器IP
ServerIP =;MQTT Broker服务器端口
Port = 1883;用户ID,可以随意设置
ClientID =;认证用户
UserName =;认证密码
Password = ;消息话题
Topic = Values;QOS   0: 最多一次传递,数据可能丢失  1:最少一次传递,数据可能重复 2:恰好一次传递,数据不会重复
QOS = 1;保持激活的间隔时间,单位s,最小值为10s
KeepAliveInterval = 20;默认为1。如果设置为1,代表客户端请求删除与代理关联的会话状态。如果设置为0,代表在断开连接后保留会话状态,以便下一次连接时恢复。
CleanSession = 1;默认为1。如果设置为1,需要发送完一条消息才能发送下一条。如果设置为0,飞行中的消息最多可达10条
Reliable = 1;连接超时时间,单位s
ConnectTimeout= 10;尝试重连的时间,单位s
RetryInterval = 10;发送超时时间,单位s
SendTimeout= 10;1次发送标签数,取值10-1000
SendTagsOnce = 1000[IN]
;输入端配置文件名,不含后缀
INI = MssqlType =

5. 配置X2MQTT 入口端参数:在X2MQTT安装目录Ini下编辑Mssql.ini,按照刚才记下的通讯参数修改入口端参数。

[IN];输入源类型:MS SQL Server,不做修改
Type=MS_SQL;SQL Server IP
ServerIP=127.0.0.1;SQL Server用户
UserName=sa;用户密码
Pwd=123456;数据库名称
DB=test;Port 0表示采用默认端口
port = 0;连接串,定义连接串,以连接串信息为准,以上用户密码等信息配置忽略
ConnectStr=Provider=SQLOLEDB.1;Persist Security Info=False;User ID=sa;Password=123456;Initial Catalog=test;Data Source=127.0.0.1;读取数据的SQL语句,如果不设置的话,将由以下字段名自动构造
;表中至少包含name,value字段
;state字段不是必须的,没有state字段时,必须构造1个虚拟state字段,如select name, value, 1 as state from snapshot
;State值 = 1 好值  =0 坏值ReadSQL=select name, value, state, time from snapshot;定义Name字段名,默认为name
NameField = name;定义Value字段名,默认为value
ValueField = value;定义State字段名,默认为state
StateField = state;定义Time字段名,可以不定义,默认为空,表示没有Time字段
TimeField = time

6. 标签配置:在X2MQTT安装目录下编辑X2MQTT.xls,配置标签。

7. 运行X2MQTT.exe,启动网关。

8. 用MQTT Subscrible连接MQTT Broker服务器,确认数据是否正确。

9. 详细配置说明见《X2MQTT V4使用手册》。

更多通信资源请登录网信智汇(http://wangxinzhihui.com)。

这篇关于通讯网关软件022——利用CommGate X2MQTT实现MQTT访问MSSQL服务器的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/196027

相关文章

AJAX请求上传下载进度监控实现方式

《AJAX请求上传下载进度监控实现方式》在日常Web开发中,AJAX(AsynchronousJavaScriptandXML)被广泛用于异步请求数据,而无需刷新整个页面,:本文主要介绍AJAX请... 目录1. 前言2. 基于XMLHttpRequest的进度监控2.1 基础版文件上传监控2.2 增强版多

Redis分片集群的实现

《Redis分片集群的实现》Redis分片集群是一种将Redis数据库分散到多个节点上的方式,以提供更高的性能和可伸缩性,本文主要介绍了Redis分片集群的实现,具有一定的参考价值,感兴趣的可以了解一... 目录1. Redis Cluster的核心概念哈希槽(Hash Slots)主从复制与故障转移2.

springboot+dubbo实现时间轮算法

《springboot+dubbo实现时间轮算法》时间轮是一种高效利用线程资源进行批量化调度的算法,本文主要介绍了springboot+dubbo实现时间轮算法,文中通过示例代码介绍的非常详细,对大家... 目录前言一、参数说明二、具体实现1、HashedwheelTimer2、createWheel3、n

基于Python打造一个可视化FTP服务器

《基于Python打造一个可视化FTP服务器》在日常办公和团队协作中,文件共享是一个不可或缺的需求,所以本文将使用Python+Tkinter+pyftpdlib开发一款可视化FTP服务器,有需要的小... 目录1. 概述2. 功能介绍3. 如何使用4. 代码解析5. 运行效果6.相关源码7. 总结与展望1

使用Python实现一键隐藏屏幕并锁定输入

《使用Python实现一键隐藏屏幕并锁定输入》本文主要介绍了使用Python编写一个一键隐藏屏幕并锁定输入的黑科技程序,能够在指定热键触发后立即遮挡屏幕,并禁止一切键盘鼠标输入,这样就再也不用担心自己... 目录1. 概述2. 功能亮点3.代码实现4.使用方法5. 展示效果6. 代码优化与拓展7. 总结1.

Mybatis 传参与排序模糊查询功能实现

《Mybatis传参与排序模糊查询功能实现》:本文主要介绍Mybatis传参与排序模糊查询功能实现,本文通过实例代码给大家介绍的非常详细,感兴趣的朋友跟随小编一起看看吧... 目录一、#{ }和${ }传参的区别二、排序三、like查询四、数据库连接池五、mysql 开发企业规范一、#{ }和${ }传参的

使用Python开发一个简单的本地图片服务器

《使用Python开发一个简单的本地图片服务器》本文介绍了如何结合wxPython构建的图形用户界面GUI和Python内建的Web服务器功能,在本地网络中搭建一个私人的,即开即用的网页相册,文中的示... 目录项目目标核心技术栈代码深度解析完整代码工作流程主要功能与优势潜在改进与思考运行结果总结你是否曾经

Docker镜像修改hosts及dockerfile修改hosts文件的实现方式

《Docker镜像修改hosts及dockerfile修改hosts文件的实现方式》:本文主要介绍Docker镜像修改hosts及dockerfile修改hosts文件的实现方式,具有很好的参考价... 目录docker镜像修改hosts及dockerfile修改hosts文件准备 dockerfile 文

基于SpringBoot+Mybatis实现Mysql分表

《基于SpringBoot+Mybatis实现Mysql分表》这篇文章主要为大家详细介绍了基于SpringBoot+Mybatis实现Mysql分表的相关知识,文中的示例代码讲解详细,感兴趣的小伙伴可... 目录基本思路定义注解创建ThreadLocal创建拦截器业务处理基本思路1.根据创建时间字段按年进

SpringBoot3实现Gzip压缩优化的技术指南

《SpringBoot3实现Gzip压缩优化的技术指南》随着Web应用的用户量和数据量增加,网络带宽和页面加载速度逐渐成为瓶颈,为了减少数据传输量,提高用户体验,我们可以使用Gzip压缩HTTP响应,... 目录1、简述2、配置2.1 添加依赖2.2 配置 Gzip 压缩3、服务端应用4、前端应用4.1 N