简介面向需要在Java应用中接入OPC服务器的开发者这份资源提供了一套基于Utgard的完整实现方案。OPC是工业自动化领域的数据交换标准而Utgard库则解决了Java与底层COM组件通信的难题。包内包含可直接借鉴的Java源码、依赖JAR包、XML与YAML等工程配置以及编译后的class文件配合说明文档可帮助理解从建立连接、读写数据点到断开连接的完整调用流程。资源共113个文件压缩包21.14MB目录结构清晰便于按模块检索。已有1702人学习下载适用于正在做数据采集、工业监控或希望将OPC数据接入VR展示等项目的开发人员。通过这套资源可以快速搭建基于Utgard的OPC客户端掌握事件监听、数据同步、异常处理等关键点减少自行摸索COM交互底层细节的成本。1. 为什么Java项目调OPC还要选Utgard一条DCOM老路在Java应用里要调OPC服务器如果目标还是老式的OPC DA接口那么能用的现成库一只手数得过来Utgard是其中最容易落地的一个。它把DCOM那套COM调用封装成Java对象让你在不用JNI、不用写C的前提下直接连Windows上的Kepware、Matrikon这类OPC DA服务器。这篇笔记适合正在做数据采集的Java后端也适合要给老车间OPC点位接平台的自动化工程师。你看完能知道什么时候选Utgard、连接怎么配、读写怎么封装还有把连接参数和权限坑一次性解决。2. 先分清OPC DA、OPC UA和Utgard的边界选型比写代码更重要很多项目翻车不是代码问题而是协议选错了。老服务器只有OPC DA接口你非要用OPC UA客户端连那怎么调都对不上。动手写Utgard之前我习惯先花十分钟确认三件事目标服务器是DA还是UA、注册表里能不能拿到CLSID、Java机器到Windows服务器的DCOM端口通不通。2.1 OPC DA是DCOM时代的老接口Utgard用j-interop跨过COMOPC DAData Access是OPC基金会早期的经典接口底层基于Windows的COM/DCOM所以天然跟Windows绑定。你在网上搜“C#连接西门子OPC”大多数方案是直接引用西门子的COM组件或者在IEC 61850那套协议上做大文章但Java这边没有官方COM封装连DCOM都要绕一圈。Utgard就是OpenSCADA项目里负责OPC DA通信的Java客户端库它底层用j-interop在Java层面实现了DCOM协议所以Java进程可以像本地COM客户端一样访问远程OPC服务器。不要把它当成OPC UA客户端。Utgard只认DA的IO、Group、Item这套模型适合连Matrikon Simulation、KEPServerEX、SIMATIC NET这一类老服务器。如果对方已经支持OPC UA我更推荐用Milo这类纯UA客户端一是跨平台更稳二是安全模型比DA完善得多。Utgard的优势恰恰在“老”字上很多产线上停产的服务器只有DA端口对Java开放。2.2 什么场景该用Utgard什么场景该换OPC UA场景推荐方案理由只暴露OPC DA 2.0/3.0的Windows服务器Utgard唯一能较快走通的Java路线服务器支持OPC UA且能开证书Eclipse Milo/UA客户端跨平台、防火墙策略简单已有WinCC且配置了WinCC OPC UAOPC UA不要用Utgard去硬怼UA端口临时连通测试、读几个仿真标签Utgard 单文件Demo启动快依赖少这个表也是我自己的经验。曾有台设备只有Kepware的DA接口OPC UA地址返回Connection refused最后用Utgard五分钟就连上了反过来如果服务器已经开了UA端口再用Utgard去翻DCOM反而是给自己找麻烦。2.3 测试环境准备OPC模拟服务器和DCOM配置我一般先在Windows机器上装Matrikon OPC Simulation它带一组可读写、会自己变化的标签适合练手。装完后先把ProgID对应的CLSID查出来后续Java端连接要用reg query HKLM\SOFTWARE\Classes\Matrikon.OPC.Simulation.1\CLSID命令会输出类似{D92139A1-...}的字符串把它记下来。如果你的OPC服务器是西门子SIMATIC NET可以在注册表里搜OPC.SimaticNET。然后做DCOM配置运行dcomcnfg依次展开“组件服务 - 计算机 - 我的电脑 - DCOM配置”找到对应OPC服务器打开属性。重点看三项安全里的“启动和激活权限”“访问权限”要加上Java端运行所用的Windows用户标识里选“当前交互式用户”或指定一个专用服务账号如果Java不在同一台机器防火墙必须放行TCP 135和DCOM动态端口区间。做完这些再进下一步写代码能少踩一半坑。3. 用Maven把Utgard拉进工程核心依赖、连接参数和第一个标签读取环境到位后剩下的事就是把依赖引进来。这里不需要额外的原生DLL只要jar包j-interop会随Utgard一起带进来。3.1 核心依赖我用的Maven坐标是Utgard 1.5.0dependency groupIdorg.openscada.utgard/groupId artifactIdorg.openscada.utgard.core/artifactId version1.5.0/version /dependency这个包会把org.openscada.opc.lib.da下面的连接、服务器、组、项全部引进来同时传递引入j-interop的DCOM传输层。如果你的工程里已经有老版本j-interop注意排除冲突否则DCOM调用可能报版本错误。提示Utgard本身不是活跃更新项目依赖它的日志框架可能跟Spring Boot的日志实现冲突。我一般会在引入后启动一个空Main类先确认ConnectionInformation和Connection类能正常加载再做复杂业务。3.2 ConnectionInformation里的主机、域、用户和ProgId连接参数集中在ConnectionInformation里。贴一段最常用的配置import org.openscada.opc.lib.common.ConnectionInformation; import org.openscada.opc.lib.da.Connection; ConnectionInformation ci new ConnectionInformation(); ci.setHost(192.168.1.23); ci.setDomain(WORKGROUP); ci.setUser(opcuser); ci.setPassword(your-password); ci.setProgId(Matrikon.OPC.Simulation.1); Connection connection new Connection(ci); connection.connect();这段代码里最容易配错的三个参数是domain、user、password。如果Java运行的Windows账号就是OPC服务器的本机管理员domain可以填机器名如果是工作组环境填WORKGROUP如果是从域服务器读要填真实域名。setProgId会在Java端自动去目标机器查注册表但如果你的程序要同时连多台服务器我建议直接用上一节查出来的CLSID填setClsid少一次注册表网络依赖。3.3 第一次读取监听回调 submit 轮询连接成功后OPC DA的读取方式不是像HTTP那样发一次请求拿一次响应而是往Group里挂Item再通过回调接收变化值。看一个最小示例import org.openscada.opc.lib.da.*; Group group server.addGroup(javaUtgardGroup); Item item group.addItem(Random.Int); item.addListener(new DataListener() { Override public void changeReceived(Item item, Value value) { System.out.println(item.getId() value.getValue() , quality value.getQuality() , time value.getTimestamp()); } }); group.submit(1000);server是connection.getServer()返回的Server对象。addGroup创建OPC组addItem挂载具体标签最后一个参数是要订阅的项。group.submit(1000)表示以1000ms为周期向OPC服务器发起变化查询服务器只要发现值或质量戳变化就会回调changeReceived。有一点必须说清楚如果标签长时间不变回调不会频繁触发。比如一个状态值连续十分钟不变线程池可能一直不执行回调。所以你后续做“读最新值”时不要依赖回调频率去判断服务器活着需要用看门狗标签或者主动SyncRead。4. 批量读写与缓存最新值从单点Demo到采集模块单点读取跑通之后接着要面对的是批处理一次读几十上百个标签还要能写。Utgard提供的SyncAccess正好干这个事。4.1 SyncAccess同步读一批点位import org.openscada.opc.lib.da.*; Group group server.addGroup(batchGroup); Item item1 group.addItem(Random.Int); Item item2 group.addItem(Random.Real4); SyncAccess access new SyncAccess(group, 1000); ListItem items Arrays.asList(item1, item2); Value[] values access.read(items); for (int i 0; i items.size(); i) { System.out.println(items.get(i).getId() values[i].getValue()); }SyncAccess的第二个参数是读取等待时间单位毫秒。如果OPC服务器响应慢把它从1000调到3000如果点位过多建议拆成每50个一组请求避免DCOM单次调用压力过大。它的返回值在不同小版本里可能是Value[]或MapItem, Value编译后以IDE提示为准整体思路一致。4.2 写OPC点注意服务器和标签的写权限写点和读点逻辑类似但要注意两个问题标签是否允许写、Simulation服务器里不是每个点都能写。下面用Bucket.Int做写测试这个点通常是允许外部写入的Item writeTarget group.addItem(Bucket.Int); SyncAccess access new SyncAccess(group, 1000); Value targetValue new Value(42); access.write( Collections.singletonList(writeTarget), Collections.singletonList(targetValue) );write的第一个集合是Item列表第二个集合是Value列表顺序必须对应。写完立刻调read不一定能看到新值因为有些OPC服务器会按PLC扫描周期刷新内部缓存比较稳妥的做法是写完后延迟500ms再读一次校验。4.3 生产环境里的监听回调缓存写读取接口时我更推荐用回调缓存的方式把每个标签的最新值放进ConcurrentHashMap业务层只从这个Map取值避免每次请求都同步走DCOM。MapString, Value cache new ConcurrentHashMap(); DataListener listener new DataListener() { Override public void changeReceived(Item item, Value value) { cache.put(item.getId(), value); } }; Group group server.addGroup(cacheGroup); group.addItem(Random.Int, listener); group.addItem(Random.Real4, listener); group.submit(500);这样写的好处是OPC服务器自己会维护变化推送Java端不需要为每个接口调用都卡在DCOM上。缺点也很明显值一旦长期不变缓存里的时间戳还是旧的所以用这个方案时一定要配合质量戳value.getQuality()和最后更新的时间戳判断数据新鲜度。5. Utgard调用OPC服务器的避坑记录权限、CLSID、防火墙、重连下面这些坑每一个我都实际踩过按“现象 - 原因 - 解决”列出来。5.1 报错0x80070005/ 拒绝访问现象connection.connect()抛出JIException: 0x80070005中文意思是“拒绝访问”。原因DCOM权限没有给Java运行账号。常见情况是OPC服务器在DCOM配置里只允许本机交互用户访问而你Java程序是作为服务或远程用户启动的。解决在DCOM配置里找到目标OPC服务器打开属性 - 安全把Java启动账号加入“启动和激活权限”“访问权限”。如果你不确定账号先选“允许所有人”测试通后再收窄权限。5.2 报错0x80040154/ CLASS_E_CLASSNOTREGISTERED现象Java端报类未注册但OPC服务器明明开了。原因注册表里的CLSID和实际OPC服务器不匹配。比如你填了UA服务器的CLSID去连DA服务器或者OPC服务器是32位而你查询的注册表视图在64位路径下。解决用reg query查准确CLSID优先用setProgId代替setClsid。如果是经典DCOM的老问题还要检查opcproxy.dll是否注册通常使用管理员运行regsvr32 opcproxy.dll就能解决。5.3 跨网段或非域环境连不上西门子SIMATIC NET现象连常规的Matrikon没问题换成西门子SIMATIC NET就报RPC超时或0x800706BA。原因SIMATIC NET的OPC DA服务器会校验调用者对PC Station的访问关系单纯放开DCOM访问权限不够目标站点还需要把Java运行机加入“SIMATIC NET OPC DA”组。解决在Windows服务器上打开“用户和组”新建一个组加入Java端使用的域账号或本地账号然后在SIMATIC NET控制台里把该账号设为允许访问OPC Server。这一步和C#连接西门子OPC遇到的问题几乎一样只是C#可能因为本机COM直接用小号口令绕过Java走远程DCOM更容易暴露。5.4group.submit之后JVM无法退出现象主线程执行完disconnect()但控制台不退出进程一直挂着。原因Group.submit内部启动线程池或定时任务disconnect()只关闭COM连接不会自动中断所有轮询线程。解决程序退出前一定要调用group.stop()然后connection.disconnect()。如果还是退不掉把创建Connection时自动跑的带名字线程找出来手动shutdownNow()。我一般在finally块里统一处理。5.5 标签名对但一直读不到值现象同样的标签在OPC客户端工具里能看到值Java端回调却一次都不触发。原因标签名大小写或路径少了一级。Matrikon、Kepware这些服务器的节点名是大小写敏感的Random.int和Random.Int是两个标签。解决用OPC客户端工具浏览标签复制完整FQN。不要手敲。如果手头没有客户端工具可以先在OPC服务器配置界面里找到标签列表再选中项导出CSV。6. 更稳的生产用法把Utgard封装成可监控的采集服务到了生产环境不能每次断线都靠人工重启。我习惯把Utgard包在一个类里维护连接状态、缓存最新值、定时健康检查并在连接失效时自动重连。6.1 一个最小的UtgardClient封装先看核心结构连接和监听使用前面的常规APIpublic class UtgardClient { private final ConnectionInformation ci; private final ListString tags; private final MapString, Value cache new ConcurrentHashMap(); private final AtomicLong lastUpdate new AtomicLong(); private volatile Connection connection; private volatile Group group; public UtgardClient(ConnectionInformation ci, ListString tags) { this.ci ci; this.tags tags; } public void start() throws Exception { connect(); ScheduledExecutorService scheduler Executors.newScheduledThreadPool(1); scheduler.scheduleAtFixedRate(this::healthCheck, 5, 5, TimeUnit.SECONDS); } private void connect() throws Exception { connection new Connection(ci); connection.connect(); Server server connection.getServer(); group server.addGroup(prodGroup); for (String tag : tags) { group.addItem(tag, (item, value) - { cache.put(tag, value); lastUpdate.set(System.currentTimeMillis()); }); } group.submit(500); } private void healthCheck() { long gap System.currentTimeMillis() - lastUpdate.get(); if (gap 10000) { try { reconnect(); } catch (Exception e) { // 记录日志下一轮再试 } } } private synchronized void reconnect() throws Exception { if (group ! null) { group.stop(); } if (connection ! null) { connection.disconnect(); } connect(); } public MapString, Value getCache() { return cache; } }这里没有依赖Utgard内部状态只用了回调更新lastUpdate。生产上我会给healthCheck加日志和重连次数上限超过三次就发告警。这样做的好处是即使OPC服务器不变化某个标签只要至少有一个标签保持周期波动健康检查就不会误判。6.2 验证连接时先做一次主动读健康检查补完重连还不够至少每五分钟要主动读一次看门狗点避免缓存一直不动。推荐在OPC服务器里专门建一个1秒变化的模拟量点比如“Heartbeat”然后在healthCheck里每周期间接调用一次SyncAccess读它。如果连续三次读失败才允许触发reconnect()。6.3 质量戳处理是最后一道保险OPC DA的良值质量码一般是0xC0也就是192。在写入业务库前我会先看value.getQuality()不满足就丢弃这条数据而不是直接拿getValue()入库。老服务器的DCOM连接确实玄学断线、权限、防火墙问题都可能让回调收到一个质量为坏但值还保留旧数据的对象。从那以后我每次在Java工程里接Utgard都会强制走一遍“注册表CLSID核对 - DCOM权限验证 - 看门狗点隔离 - 质量戳过滤”这个流程省掉了大半半夜告警。希望帮到你。本文还有配套的精品资源点击获取