尧图网站建设 
简介这份资源是面向工业自动化开发者与工控软件工程师的 OPCUA 通信实例源码聚焦 PLC 与 PC 机之间的数据交换场景帮助读者理解并落地 OPC 统一架构下的客户端与服务器交互机制。压缩包共 285 个文件约 926KB以 C 语言源码111 个 .c与头文件47 个 .h为核心实现辅以 21 个 Python 脚本、12 个 CMake 构建文件及若干配置、说明与测试文档整体结构清晰便于按模块阅读与二次开发。内容围绕身份验证与授权、信息模型、服务集、网络通信及二进制编解码等关键技术点展开涵盖服务器端节点建模与监听、客户端连接浏览读写订阅、安全证书配置及示例应用等模块。已有 265 人学习下载适合希望掌握 OPCUA 通信原理、提升自动化系统集成与扩展能力的开发者参考实践。1. OPCUA 通信用于 PLC 与 PC 机通信实例源码从握手到订阅的完整落地车间里一台西门子 S7-1200 跑着产线逻辑上位机 PC 需要每 200ms 抓一次温度、压力、节拍还要在参数越限时立刻收到推送。传统做法是走 Modbus TCP 轮询点位一多就卡语义还得自己对齐。这套 OPCUA 通信用于 PLC 与 PC 机通信的实例源码解决的正是这个场景它把服务器端、客户端、配置文件和示例应用打包在一起让你直接看到 PLC 侧信息模型怎么建、PC 侧怎么连、怎么读、怎么写、怎么订阅。适合做工业自动化的开发者、上位机工程师以及正在把 OPCUA 塞进现有产线通信链路的从业者。源码不是玩具它把身份验证、数据模型、服务集、网络通信、编码解码这几块都落到了可运行的文件里下面按「是什么 → 怎么用 → 坑在哪」拆开讲。2. 源码结构与 OPCUA 通信链路拆解服务器、客户端、配置各管什么拿到压缩包先别急着跑把目录翻一遍理解每个文件在通信链路里的位置后面调参和排错才不会抓瞎。这套源码的骨架大致分四块服务器端代码、客户端端代码、配置文件、示例应用。它们不是孤立的服务器端负责在 PLC 侧把数据组织成节点树并监听连接客户端端负责在 PC 侧发起会话、浏览节点、读写和订阅配置文件承载安全策略与证书信息示例应用则把客户端调用串成一个能看结果的小程序。2.1 服务器端信息模型与节点是怎么建起来的OPCUA 服务器不是简单开个端口等连接它要先有一套信息模型。信息模型就是一棵节点树每个节点有 NodeId、BrowseName、数据类型、访问权限。PLC 里的一个温度变量在服务器端会被映射成一个变量节点挂在某个对象节点下面。源码里服务器端的核心动作通常是这几步初始化服务器、加载证书、注册地址空间、添加变量节点、启动监听。# 服务器端初始化与节点注册示意按源码实际类名替换 from opcua import Server server Server() server.set_endpoint(opc.tcp://0.0.0.0:4840/freeopcua/server/) # 监听所有网卡端口 4840 server.set_server_name(PLC_OPCUA_Server) # 加载安全策略与证书源码里通常放在配置文件读取 server.load_certificate(cert/server_cert.pem) server.load_private_key(cert/server_key.pem) idx server.register_namespace(http://plc.example.com) # 自定义命名空间 objects server.get_objects_node() plc_obj objects.add_object(idx, PLC_Line1) # 建一个产线对象节点 temp_node plc_obj.add_variable(idx, Temperature, 25.0) # 温度变量节点 temp_node.set_writable() # 允许客户端写入 server.start()这段代码的逻辑说明set_endpoint决定客户端连哪个地址0.0.0.0表示监听本机所有网卡端口 4840 是 OPCUA 常见默认端口但源码里如果改了端口客户端必须同步改。register_namespace注册自定义命名空间避免和标准节点冲突。add_object和add_variable是建信息模型的关键节点层级决定了客户端浏览时的路径。set_writable不加客户端写入会直接被拒。参数上命名空间索引idx后面客户端要用到写死或动态获取都行但两边必须一致。2.2 客户端端连接、浏览、读写、订阅四件事客户端在 PC 机上跑任务就四件连上服务器、浏览节点找到目标、读写变量、订阅变化。源码里客户端部分一般会把这四步拆成独立函数方便你替换成自己的业务逻辑。# 客户端连接与订阅示意 from opcua import Client client Client(opc.tcp://192.168.1.10:4840/freeopcua/server/) client.set_user(operator) # 用户名源码配置文件里定义 client.set_password(opcua123) # 密码 client.connect() root client.get_root_node() plc_obj root.get_child([0:Objects, 2:PLC_Line1]) # 按命名空间索引找节点 temp_node plc_obj.get_child([2:Temperature]) print(当前温度:, temp_node.get_value()) # 读 temp_node.set_value(30.5) # 写 # 订阅值变化时回调 class SubHandler: def datachange_notification(self, node, val, data): print(温度变化:, val) handler SubHandler() sub client.create_subscription(200, handler) # 200ms 发布间隔 sub.subscribe_data_change(temp_node)逻辑说明Client的地址必须和服务器set_endpoint完全一致IP、端口、路径三者错一个就连不上。get_child里的0:Objects是标准节点2:PLC_Line1里的2就是服务器注册的命名空间索引这个数字两边对不上是新手最常见的翻车点。create_subscription的第一个参数是发布间隔单位毫秒设太小网络压力大设太大实时性差200ms 是产线监控里比较稳的值。订阅回调datachange_notification是服务器主动推不是客户端轮询这是 OPCUA 相比 Modbus 轮询的核心优势。2.3 配置文件安全策略与证书别用默认配置文件通常管三件事服务器端点地址、安全策略、证书路径。安全策略常见有 None、Basic128Rsa15、Basic256Sha256 几档源码为了让你先跑通可能默认给的是 None但实际产线不能这么干。证书这块服务器和客户端要互相交换证书客户端信任服务器证书服务器信任客户端证书任何一边没导入信任列表握手阶段就会断。配置文件里还会写用户名密码或匿名访问开关匿名访问调试方便上线前必须关掉。提示先把配置文件里的端点地址、端口、命名空间索引、安全策略四项抄下来后面客户端和服务器对不上时第一个查的就是这四项。3. 从零跑通 PLC 与 PC 机通信环境、连接、读写、订阅四步实操上一章把结构拆开了这一章直接动手。目标很明确让 PC 机上的客户端连上 PLC 侧的服务器读到值、写进去、收到订阅推送。整个过程分四步每步都有容易卡住的地方我按实际调试顺序写。3.1 环境准备与依赖安装先确认 Python 版本源码一般跑在 3.7 以上。依赖主要是 OPCUA 库常见的是opcua或asyncua源码用哪个就装哪个。虚拟环境建议开避免和系统里其他工业库冲突。python -m venv venv source venv/bin/activate # Windows 用 venv\Scripts\activate pip install opcua # 按源码 requirements.txt 为准 pip install cryptography # 证书相关安全策略非 None 时必需逻辑说明cryptography在安全策略为 None 时可能不报错但一旦切到 Basic256Sha256没有它直接起不来。参数上如果源码带了requirements.txt优先按文件装版本号别乱升工业库版本差异经常导致 API 不兼容。3.2 启动服务器并确认监听服务器端代码跑起来后别急着开客户端先在 PLC 侧或本机确认端口在听。# Linux 下确认 4840 端口监听 netstat -tlnp | grep 4840 # Windows 下 netstat -ano | findstr 4840逻辑说明如果端口没出现说明服务器没起来或崩了先看服务器端日志。常见原因是证书路径写错、端口被占、命名空间注册失败。参数上0.0.0.0:4840表示所有网卡如果只想本机调试可以改127.0.0.1但 PC 机远程连就必须是0.0.0.0或实际网卡 IP。3.3 客户端连接与节点浏览连接成功后第一件事不是读写是浏览节点树确认你要的变量到底挂在哪。# 浏览节点打印层级 def browse(node, depth0): for child in node.get_children(): print( * depth child.get_browse_name().to_string()) browse(child, depth 1) browse(client.get_root_node())逻辑说明get_browse_name返回的是 BrowseName带命名空间前缀和 NodeId 不是一回事。浏览的目的是拿到目标节点的准确路径路径错了get_child就抛异常。参数上浏览深度别太深产线服务器节点多的时候全量浏览很慢可以先定位到 Objects 再往下。3.4 读写与订阅的完整调用浏览确认路径后读写和订阅按第 2 章的客户端代码走。这里补一个实际业务里常用的点批量读。# 批量读多个节点减少往返 nodes [temp_node, pressure_node, cycle_node] values [n.get_value() for n in nodes] print(dict(zip([temp, pressure, cycle], values)))逻辑说明OPCUA 单次读一个节点会有网络往返开销点位多的时候批量读能明显降延迟。参数上订阅间隔和批量读频率要配合订阅负责变化推送批量读负责周期快照两者别设成同一频率互相打架。注意读写测试先用一个可写变量别拿产线正在用的关键变量练手写错值可能触发联锁。4. 避坑与排查OPCUA 连接失败、订阅无推送、证书报错的常见问题这一章是血泪经验集中区。OPCUA 的报错信息经常很笼统光看异常栈定位不到根因下面五条是我在实际项目里反复遇到的。4.1 连接直接被拒端点地址或端口不一致现象客户端connect()抛连接异常服务器日志没有连接记录。原因客户端地址和服务器set_endpoint不一致IP、端口、路径任意一项不同都会连不上。解决把两边地址逐字符对比路径里的freeopcua/server/这种后缀最容易漏。端口被防火墙拦也会这样先在服务器本机用客户端连一次排除网络因素。4.2 握手阶段断开证书未互信现象TCP 能连上但会话建立到一半断日志提示证书验证失败。原因服务器证书没导入客户端信任列表或客户端证书没导入服务器信任列表。解决找到双方证书目录把对方证书加入 trusted 列表重启服务。安全策略从 None 切到加密时这一步必做没有后悔药。4.3 订阅建了但收不到推送现象create_subscription没报错但回调一直不触发。原因订阅的节点值没变化或发布间隔设得比变化频率还大或节点本身不可订阅。解决先手动改一次节点值确认订阅链路通再把发布间隔调小测试。参数上发布间隔要小于你关心的最小变化周期。4.4 写入被拒节点不可写或权限不足现象set_value抛权限异常。原因服务器端节点没调set_writable或当前用户角色没有写权限。解决服务器端确认节点可写配置文件里确认用户角色。匿名访问默认通常只读。4.5 命名空间索引对不上现象get_child找不到节点报 BadNodeIdUnknown。原因客户端用的命名空间索引和服务器注册的不一致服务器重启后索引可能变。解决客户端动态获取命名空间索引别写死数字。常见做法是用get_namespace_index按 URI 查。5. 进阶技巧用订阅批量读把 PLC 与 PC 机通信延迟压到 100ms 内跑通之后真正决定这套源码能不能上产线的是延迟和稳定性。我一般会做三件事订阅负责变化、批量读负责快照、心跳负责探活。订阅间隔设 100ms批量读 500ms 一次两者错开避免同一时刻网络拥塞。心跳用一个只读节点客户端每 2s 读一次读不到就重连。# 心跳探活与自动重连 import time def keep_alive(client, heartbeat_node): while True: try: heartbeat_node.get_value() time.sleep(2) except Exception: print(连接断开尝试重连) client.connect() time.sleep(1)逻辑说明get_value成功说明会话还在失败就重连。参数上心跳间隔别太短2s 足够太短反而增加服务器负担。重连后订阅要重新建因为会话变了旧订阅失效这点源码里如果没处理要自己补。参数建议值说明订阅发布间隔100200ms越小实时性越好网络压力越大批量读周期500ms和订阅错开避免拥塞心跳间隔2s探活失败触发重连安全策略Basic256Sha256上线必用调试可临时 None从那以后我每次把 OPCUA 往产线推之前都强制走一遍「订阅批量读心跳」三件套少一件都不敢上线。希望帮到你。本文还有配套的精品资源点击获取 OPCUA通信实战：PLC与PC机通信源码解析与避坑指南
简介这份资源是面向工业自动化开发者与工控软件工程师的 OPCUA 通信实例源码聚焦 PLC 与 PC 机之间的数据交换场景帮助读者理解并落地 OPC 统一架构下的客户端与服务器交互机制。压缩包共 285 个文件约 926KB以 C 语言源码111 个 .c与头文件47 个 .h为核心实现辅以 21 个 Python 脚本、12 个 CMake 构建文件及若干配置、说明与测试文档整体结构清晰便于按模块阅读与二次开发。内容围绕身份验证与授权、信息模型、服务集、网络通信及二进制编解码等关键技术点展开涵盖服务器端节点建模与监听、客户端连接浏览读写订阅、安全证书配置及示例应用等模块。已有 265 人学习下载适合希望掌握 OPCUA 通信原理、提升自动化系统集成与扩展能力的开发者参考实践。1. OPCUA 通信用于 PLC 与 PC 机通信实例源码从握手到订阅的完整落地车间里一台西门子 S7-1200 跑着产线逻辑上位机 PC 需要每 200ms 抓一次温度、压力、节拍还要在参数越限时立刻收到推送。传统做法是走 Modbus TCP 轮询点位一多就卡语义还得自己对齐。这套 OPCUA 通信用于 PLC 与 PC 机通信的实例源码解决的正是这个场景它把服务器端、客户端、配置文件和示例应用打包在一起让你直接看到 PLC 侧信息模型怎么建、PC 侧怎么连、怎么读、怎么写、怎么订阅。适合做工业自动化的开发者、上位机工程师以及正在把 OPCUA 塞进现有产线通信链路的从业者。源码不是玩具它把身份验证、数据模型、服务集、网络通信、编码解码这几块都落到了可运行的文件里下面按「是什么 → 怎么用 → 坑在哪」拆开讲。2. 源码结构与 OPCUA 通信链路拆解服务器、客户端、配置各管什么拿到压缩包先别急着跑把目录翻一遍理解每个文件在通信链路里的位置后面调参和排错才不会抓瞎。这套源码的骨架大致分四块服务器端代码、客户端端代码、配置文件、示例应用。它们不是孤立的服务器端负责在 PLC 侧把数据组织成节点树并监听连接客户端端负责在 PC 侧发起会话、浏览节点、读写和订阅配置文件承载安全策略与证书信息示例应用则把客户端调用串成一个能看结果的小程序。2.1 服务器端信息模型与节点是怎么建起来的OPCUA 服务器不是简单开个端口等连接它要先有一套信息模型。信息模型就是一棵节点树每个节点有 NodeId、BrowseName、数据类型、访问权限。PLC 里的一个温度变量在服务器端会被映射成一个变量节点挂在某个对象节点下面。源码里服务器端的核心动作通常是这几步初始化服务器、加载证书、注册地址空间、添加变量节点、启动监听。# 服务器端初始化与节点注册示意按源码实际类名替换 from opcua import Server server Server() server.set_endpoint(opc.tcp://0.0.0.0:4840/freeopcua/server/) # 监听所有网卡端口 4840 server.set_server_name(PLC_OPCUA_Server) # 加载安全策略与证书源码里通常放在配置文件读取 server.load_certificate(cert/server_cert.pem) server.load_private_key(cert/server_key.pem) idx server.register_namespace(http://plc.example.com) # 自定义命名空间 objects server.get_objects_node() plc_obj objects.add_object(idx, PLC_Line1) # 建一个产线对象节点 temp_node plc_obj.add_variable(idx, Temperature, 25.0) # 温度变量节点 temp_node.set_writable() # 允许客户端写入 server.start()这段代码的逻辑说明set_endpoint决定客户端连哪个地址0.0.0.0表示监听本机所有网卡端口 4840 是 OPCUA 常见默认端口但源码里如果改了端口客户端必须同步改。register_namespace注册自定义命名空间避免和标准节点冲突。add_object和add_variable是建信息模型的关键节点层级决定了客户端浏览时的路径。set_writable不加客户端写入会直接被拒。参数上命名空间索引idx后面客户端要用到写死或动态获取都行但两边必须一致。2.2 客户端端连接、浏览、读写、订阅四件事客户端在 PC 机上跑任务就四件连上服务器、浏览节点找到目标、读写变量、订阅变化。源码里客户端部分一般会把这四步拆成独立函数方便你替换成自己的业务逻辑。# 客户端连接与订阅示意 from opcua import Client client Client(opc.tcp://192.168.1.10:4840/freeopcua/server/) client.set_user(operator) # 用户名源码配置文件里定义 client.set_password(opcua123) # 密码 client.connect() root client.get_root_node() plc_obj root.get_child([0:Objects, 2:PLC_Line1]) # 按命名空间索引找节点 temp_node plc_obj.get_child([2:Temperature]) print(当前温度:, temp_node.get_value()) # 读 temp_node.set_value(30.5) # 写 # 订阅值变化时回调 class SubHandler: def datachange_notification(self, node, val, data): print(温度变化:, val) handler SubHandler() sub client.create_subscription(200, handler) # 200ms 发布间隔 sub.subscribe_data_change(temp_node)逻辑说明Client的地址必须和服务器set_endpoint完全一致IP、端口、路径三者错一个就连不上。get_child里的0:Objects是标准节点2:PLC_Line1里的2就是服务器注册的命名空间索引这个数字两边对不上是新手最常见的翻车点。create_subscription的第一个参数是发布间隔单位毫秒设太小网络压力大设太大实时性差200ms 是产线监控里比较稳的值。订阅回调datachange_notification是服务器主动推不是客户端轮询这是 OPCUA 相比 Modbus 轮询的核心优势。2.3 配置文件安全策略与证书别用默认配置文件通常管三件事服务器端点地址、安全策略、证书路径。安全策略常见有 None、Basic128Rsa15、Basic256Sha256 几档源码为了让你先跑通可能默认给的是 None但实际产线不能这么干。证书这块服务器和客户端要互相交换证书客户端信任服务器证书服务器信任客户端证书任何一边没导入信任列表握手阶段就会断。配置文件里还会写用户名密码或匿名访问开关匿名访问调试方便上线前必须关掉。提示先把配置文件里的端点地址、端口、命名空间索引、安全策略四项抄下来后面客户端和服务器对不上时第一个查的就是这四项。3. 从零跑通 PLC 与 PC 机通信环境、连接、读写、订阅四步实操上一章把结构拆开了这一章直接动手。目标很明确让 PC 机上的客户端连上 PLC 侧的服务器读到值、写进去、收到订阅推送。整个过程分四步每步都有容易卡住的地方我按实际调试顺序写。3.1 环境准备与依赖安装先确认 Python 版本源码一般跑在 3.7 以上。依赖主要是 OPCUA 库常见的是opcua或asyncua源码用哪个就装哪个。虚拟环境建议开避免和系统里其他工业库冲突。python -m venv venv source venv/bin/activate # Windows 用 venv\Scripts\activate pip install opcua # 按源码 requirements.txt 为准 pip install cryptography # 证书相关安全策略非 None 时必需逻辑说明cryptography在安全策略为 None 时可能不报错但一旦切到 Basic256Sha256没有它直接起不来。参数上如果源码带了requirements.txt优先按文件装版本号别乱升工业库版本差异经常导致 API 不兼容。3.2 启动服务器并确认监听服务器端代码跑起来后别急着开客户端先在 PLC 侧或本机确认端口在听。# Linux 下确认 4840 端口监听 netstat -tlnp | grep 4840 # Windows 下 netstat -ano | findstr 4840逻辑说明如果端口没出现说明服务器没起来或崩了先看服务器端日志。常见原因是证书路径写错、端口被占、命名空间注册失败。参数上0.0.0.0:4840表示所有网卡如果只想本机调试可以改127.0.0.1但 PC 机远程连就必须是0.0.0.0或实际网卡 IP。3.3 客户端连接与节点浏览连接成功后第一件事不是读写是浏览节点树确认你要的变量到底挂在哪。# 浏览节点打印层级 def browse(node, depth0): for child in node.get_children(): print( * depth child.get_browse_name().to_string()) browse(child, depth 1) browse(client.get_root_node())逻辑说明get_browse_name返回的是 BrowseName带命名空间前缀和 NodeId 不是一回事。浏览的目的是拿到目标节点的准确路径路径错了get_child就抛异常。参数上浏览深度别太深产线服务器节点多的时候全量浏览很慢可以先定位到 Objects 再往下。3.4 读写与订阅的完整调用浏览确认路径后读写和订阅按第 2 章的客户端代码走。这里补一个实际业务里常用的点批量读。# 批量读多个节点减少往返 nodes [temp_node, pressure_node, cycle_node] values [n.get_value() for n in nodes] print(dict(zip([temp, pressure, cycle], values)))逻辑说明OPCUA 单次读一个节点会有网络往返开销点位多的时候批量读能明显降延迟。参数上订阅间隔和批量读频率要配合订阅负责变化推送批量读负责周期快照两者别设成同一频率互相打架。注意读写测试先用一个可写变量别拿产线正在用的关键变量练手写错值可能触发联锁。4. 避坑与排查OPCUA 连接失败、订阅无推送、证书报错的常见问题这一章是血泪经验集中区。OPCUA 的报错信息经常很笼统光看异常栈定位不到根因下面五条是我在实际项目里反复遇到的。4.1 连接直接被拒端点地址或端口不一致现象客户端connect()抛连接异常服务器日志没有连接记录。原因客户端地址和服务器set_endpoint不一致IP、端口、路径任意一项不同都会连不上。解决把两边地址逐字符对比路径里的freeopcua/server/这种后缀最容易漏。端口被防火墙拦也会这样先在服务器本机用客户端连一次排除网络因素。4.2 握手阶段断开证书未互信现象TCP 能连上但会话建立到一半断日志提示证书验证失败。原因服务器证书没导入客户端信任列表或客户端证书没导入服务器信任列表。解决找到双方证书目录把对方证书加入 trusted 列表重启服务。安全策略从 None 切到加密时这一步必做没有后悔药。4.3 订阅建了但收不到推送现象create_subscription没报错但回调一直不触发。原因订阅的节点值没变化或发布间隔设得比变化频率还大或节点本身不可订阅。解决先手动改一次节点值确认订阅链路通再把发布间隔调小测试。参数上发布间隔要小于你关心的最小变化周期。4.4 写入被拒节点不可写或权限不足现象set_value抛权限异常。原因服务器端节点没调set_writable或当前用户角色没有写权限。解决服务器端确认节点可写配置文件里确认用户角色。匿名访问默认通常只读。4.5 命名空间索引对不上现象get_child找不到节点报 BadNodeIdUnknown。原因客户端用的命名空间索引和服务器注册的不一致服务器重启后索引可能变。解决客户端动态获取命名空间索引别写死数字。常见做法是用get_namespace_index按 URI 查。5. 进阶技巧用订阅批量读把 PLC 与 PC 机通信延迟压到 100ms 内跑通之后真正决定这套源码能不能上产线的是延迟和稳定性。我一般会做三件事订阅负责变化、批量读负责快照、心跳负责探活。订阅间隔设 100ms批量读 500ms 一次两者错开避免同一时刻网络拥塞。心跳用一个只读节点客户端每 2s 读一次读不到就重连。# 心跳探活与自动重连 import time def keep_alive(client, heartbeat_node): while True: try: heartbeat_node.get_value() time.sleep(2) except Exception: print(连接断开尝试重连) client.connect() time.sleep(1)逻辑说明get_value成功说明会话还在失败就重连。参数上心跳间隔别太短2s 足够太短反而增加服务器负担。重连后订阅要重新建因为会话变了旧订阅失效这点源码里如果没处理要自己补。参数建议值说明订阅发布间隔100200ms越小实时性越好网络压力越大批量读周期500ms和订阅错开避免拥塞心跳间隔2s探活失败触发重连安全策略Basic256Sha256上线必用调试可临时 None从那以后我每次把 OPCUA 往产线推之前都强制走一遍「订阅批量读心跳」三件套少一件都不敢上线。希望帮到你。本文还有配套的精品资源点击获取