• 通讯网关软件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,修改出口端参数。

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

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

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

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

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

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

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

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

  • 相关阅读:
    3.5 动态定位shellcode
    【面试题-007】说一下JVM原理
    linux读取U盘操作
    Windows卸载ninja流程
    Linux 系统安装 Redis7 —— 超详细操作演示!
    WSW-PEG-IR825 肝靶向多肽WSW-聚乙二醇-近红外荧光染料IR825
    科技成果验收测试需注意哪些方面?
    《计算机视觉中的多视图几何》笔记(9)
    ATA-8035射频功率放大器在通信领域的主要应用
    一个非常明显的现象,正在发生——元宇宙正在被越来越多的人所推崇
  • 原文地址:https://blog.csdn.net/zhouwl72/article/details/133787539