通讯网关软件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

相关文章

解读静态资源访问static-locations和static-path-pattern

《解读静态资源访问static-locations和static-path-pattern》本文主要介绍了SpringBoot中静态资源的配置和访问方式,包括静态资源的默认前缀、默认地址、目录结构、访... 目录静态资源访问static-locations和static-path-pattern静态资源配置

VScode连接远程Linux服务器环境配置图文教程

《VScode连接远程Linux服务器环境配置图文教程》:本文主要介绍如何安装和配置VSCode,包括安装步骤、环境配置(如汉化包、远程SSH连接)、语言包安装(如C/C++插件)等,文中给出了详... 目录一、安装vscode二、环境配置1.中文汉化包2.安装remote-ssh,用于远程连接2.1安装2

Java中使用Java Mail实现邮件服务功能示例

《Java中使用JavaMail实现邮件服务功能示例》:本文主要介绍Java中使用JavaMail实现邮件服务功能的相关资料,文章还提供了一个发送邮件的示例代码,包括创建参数类、邮件类和执行结... 目录前言一、历史背景二编程、pom依赖三、API说明(一)Session (会话)(二)Message编程客

Java中List转Map的几种具体实现方式和特点

《Java中List转Map的几种具体实现方式和特点》:本文主要介绍几种常用的List转Map的方式,包括使用for循环遍历、Java8StreamAPI、ApacheCommonsCollect... 目录前言1、使用for循环遍历:2、Java8 Stream API:3、Apache Commons

C#提取PDF表单数据的实现流程

《C#提取PDF表单数据的实现流程》PDF表单是一种常见的数据收集工具,广泛应用于调查问卷、业务合同等场景,凭借出色的跨平台兼容性和标准化特点,PDF表单在各行各业中得到了广泛应用,本文将探讨如何使用... 目录引言使用工具C# 提取多个PDF表单域的数据C# 提取特定PDF表单域的数据引言PDF表单是一

使用Python实现高效的端口扫描器

《使用Python实现高效的端口扫描器》在网络安全领域,端口扫描是一项基本而重要的技能,通过端口扫描,可以发现目标主机上开放的服务和端口,这对于安全评估、渗透测试等有着不可忽视的作用,本文将介绍如何使... 目录1. 端口扫描的基本原理2. 使用python实现端口扫描2.1 安装必要的库2.2 编写端口扫

PyCharm接入DeepSeek实现AI编程的操作流程

《PyCharm接入DeepSeek实现AI编程的操作流程》DeepSeek是一家专注于人工智能技术研发的公司,致力于开发高性能、低成本的AI模型,接下来,我们把DeepSeek接入到PyCharm中... 目录引言效果演示创建API key在PyCharm中下载Continue插件配置Continue引言

MySQL分表自动化创建的实现方案

《MySQL分表自动化创建的实现方案》在数据库应用场景中,随着数据量的不断增长,单表存储数据可能会面临性能瓶颈,例如查询、插入、更新等操作的效率会逐渐降低,分表是一种有效的优化策略,它将数据分散存储在... 目录一、项目目的二、实现过程(一)mysql 事件调度器结合存储过程方式1. 开启事件调度器2. 创

使用Python实现操作mongodb详解

《使用Python实现操作mongodb详解》这篇文章主要为大家详细介绍了使用Python实现操作mongodb的相关知识,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录一、示例二、常用指令三、遇到的问题一、示例from pymongo import MongoClientf

SQL Server使用SELECT INTO实现表备份的代码示例

《SQLServer使用SELECTINTO实现表备份的代码示例》在数据库管理过程中,有时我们需要对表进行备份,以防数据丢失或修改错误,在SQLServer中,可以使用SELECTINT... 在数据库管理过程中,有时我们需要对表进行备份,以防数据丢失或修改错误。在 SQL Server 中,可以使用 SE