工业物联网数据桥接教程：OPC UA 桥接到 MQTT

属性（Attribute）用于描述节点，不同的节点类有不同的属性（属性集合）。节点类的定义中包括属性的定义，因此地址空间中不包括属性。

引用（Reference）表示节点之间的关系。引用被定义为引用类型节点的实例，存在于地址空间中。

节点模型的通用属性如下：

在 OPC UA 中，最重要的节点类别是对象，变量和方法。

对象节点，对象节点用于构成地址空间，不包含数据，使用变量为对象公开数值，对象节点可用于分组管理对象，变量或方法（变量和方法总属于一个对象）。

变量节点，变量节点代表一个值，值的数据类型取决于变量，客户端可以对值进行读写和订阅。

方法节点，方法节点代表服务器中一个有客户端调用并返回结果的方法，输入参数和输出结果以变量的形式作为方法节点的组成部分，客户端指定输入参数，调用后获得输出结果。

为什么将 OPC UA 桥接到 MQTT？

MQTT（Message Queuing Telemetry Transport）是一种为物联网设备和应用程序设计的消息协议，采用发布与订阅模型，具有轻量、高效、可靠，支持实时通讯等优点。 MQTT 非常适合资源受限的环境，特别是需要高效使用电力和带宽的场景。

业界在 MQTT 3.1.1 的基础上建立了名为 SparkplugB 的工业物联网数据规范，在保证灵活和效率的前提下，提供了基础的数据统一建模能力。得益于 MQTT 协议的优秀设计，SparkPlugB 提供了良好的网络状态感知能力，并且能够为设备和系统提供强大的互操作性。

OPC UA 和 MQTT 在功能上有一定程度的重叠，但它们的使用场景却截然不同：

OPC UA 是一种用于工业场景的通信协议，可使来自不同制造商的不同设备和系统使用标准化语言进行无缝通信。

MQTT 是一种物联网协议，专为基于互联网的传感器数据传输而设计，既能满足低带宽和不可靠的网络条件，又能有效处理连续的实时数据。它的订阅/发布机制为使用提供了极大的灵活性。

在工业场景中，MQTT 擅长在分布式系统中发送信息，而 OPC UA 则侧重于提供互操作性。通过将两者结合，可以使用 OPC UA 对业务数据进行抽象和聚合，而 MQTT 则可以利用其强大的连接能力，以分布式方式实现无缝数据交换。

OPC UA over MQTT

OPC 基金会在最新的 OPC UA 规范中提出的 Pub-Sub 模型允许使用 MQTT Broker 将数据变更推送给订阅者。

Pub-Sub 的安全性比客户端/服务器中的安全性要复杂一些，而且规范没有那么细致。在 MQTT 网络中，安全性基于 SSL/TLS，MQTT Broker 除了可以为传输启用 SSL/TLS，还可以定义应用程序级身份验证，原则上，对于每个可以加入网络的订阅端和发布端，这些安全模式要么全有，要么全无。新的 OPC UA 标准化仍在进行中，丰富的 OPC UA 信息模型如何以最佳方式映射到 MQTT 目前尚不明确。

通过 Neuron 将 OPC UA 桥接到 MQTT

Neuron 是一款现代的工业物联网连接服务器，可以连接多种使用标准协议或者设备专有协议的工业设备，实现了工业物联网平台与海量设备的互联。作为一款轻量级的工业协议网关软件，Neuron 可以运行在各种有限资源的物联网边缘硬件设备上，其主要目标是应对以统一方式访问以数据为中心的自动化设备的挑战，从而为智能制造提供必要的支持。

EMQX 是一款大规模可扩展的云原生分布式物联网 MQTT 消息服务器。作为全球最具扩展性的 MQTT 消息服务器，EMQX 可为海量物联网设备提供高效可靠的连接，实现消息和事件流的高性能实时移动和处理，帮助用户快速构建关键业务的物联网平台与应用。

Neuron 的南向 OPC UA 驱动程序可采集和汇总 OPC UA 数据源，将其转换为 MQTT 协议，并传输到 EMQX MQTT Broker。然后，后者将其分发到各种分布式应用程序。

在本文中，我们将利用 Neuron 和 EMQX 提供从 OPC UA 到 MQTT 的桥接解决方案。我们将演示使用 Neuron 从 Prosys OPC UA Simulator 收集数据，将收集到的数据上传到本地构建的 EMQX MQTT Broker（mqtt://192.168.10.174:1883），最后使用 MQTTX 订阅主题查看数据的变化。

安装 OPC UA 模拟器

安装包可从 Prosys OPC 网站 下载。安装完成后，运行 Prosys OPC UA Simulation。确保 Neuron 与模拟器运行在同一局域网内。

点击 Objects->Objects::FolderType->Simulation::FolderType 查看数据，并选择 Counter::BaseDataVariableType.

启动 EMQX

执行以下命令安装并运行 EMQX 容器。有关如何安装 EMQX 容器的更多信息，请访问 安装指南 。

docker pull emqx/emqx:5.1.0
docker run -d --name emqx -p 1883:1883 -p 8081:8081 -p 8083:8083 -p 8084:8084 -p 8883:8883 -p 18083
设置 Neuron
Neuron 提供多种安装方法，您可以在安装指南中详细查看。本示例使用容器化部署，以便尽快开始体验 Neuron。执行以下命令安装并运行 Neuron 容器。
$ docker pull emqx/neuron:latest
$ docker run -d --name neuron -p 7000:7000 --privileged=true --restart=always emqx/neuron:latest
打开网络浏览器，输入运行 Neuron 的网关地址和端口号，进入管理控制台页面。默认端口号为7000。通过浏览器访问 http://localhost:7000（可以用实际 IP 地址代替 localhost）。
步骤 1：登录
页面打开后，进入登录界面，使用初始用户名和密码（初始用户名：admin，初始密码：0000）登录。
步骤 2：添加南向设备
在配置菜单中选择南向设备，进入到南向设备界面，点击添加设备新增设备。
名称：填写设备名称，例如 opcua-195-prosys。
插件：下拉框选择 OPC UA 插件。
步骤 3：设置南向设备参数
添加南向设备后自动进入设备配置界面，填写参数并提交。
端点 URL：填写 OPC UA Simulation Server 的连接地址，如：opc.tcp://192.168.10.174:53530/OPCUA/SimulationServer。
用户名：默认不用填写。
密码：默认不用填写。
证书：默认不用上传。
密钥：默认不用上传。
确保 Prosys OPC UA Simulation Server 已经切换到 Expert Mode （Option->Switch to Expert Mode），点击 Certificates 将左侧列表中的 NeuronClient@localhost 设置为 Trusted。
步骤 4：在设备卡片中创建组
点击设备节点卡片任意空白处，进入组列表管理界面，点击 创建 ，弹出 创建组 的对话框。填写参数并提交：
组名称：填写组名称，例如 group-1。
间隔：默认1000。
步骤 5：在组中添加数据点位
进入点列表管理界面，点击创建，填写点参数并提交：
名称：填写点位名称，例如，Counter。
属性：下拉选择点位属性，例如，Read，Write。
类型：下拉选择数据类型，例如，INT32。
地址：填写驱动地址，例如，3!1001。3代表 OPC UA 模拟器中数据点的 Namespace，1001代表数据点的 Node ID。
描述、乘系数、精度不填。
步骤 6：数据监控中查看采集数据
选择监控→数据监控，进入数据监控界面，查看已创建点位读取到的数值，如下图所示。
南向设备：下拉框选择想要查看的南向设备，例如，选择已创建的 opcua-195-prosys。
组名称：下拉框选择想要查看所选南向设备下的组，例如，选择已创建的 group-1。
选择完成，页面将会展示读取到的组中所有点位的值。
使用 MQTTX 查看数据
可进入 MQTT X 官网下载 MQTT X 并安装。安装好后启动 MQTTX 后添加连接，Host 设置为 mqtt://192.168.10.174，Port 设置为 1883，订阅主题 /neuron/MQTT/group-1，就可以接收到 OPC UA 端传输过来的数据了。
OPC UA 协议实现了设备之间的通信和数据交换，而 MQTT 则提供了一种高效、灵活和安全的消息传递机制。通过利用这两种协议的优势，该集成可将设备数据无缝传输到云端，从而促进高效、安全的远程监控。从设备和流程中获取实时信息的能力使企业能够优化运营、提高生产率并确保最高质量水平。采用这种创新方法不仅能提高工业系统的整体效率，还能为更智能的数据驱动型决策铺平道路，推动各行业走向更加互联和繁荣的未来。