告别UAExpert用SpringBootMilo构建自动化OPC UA测试框架在工业自动化领域OPC UA已成为设备互联的事实标准协议。传统测试中工程师们习惯使用UAExpert等图形化客户端进行手动验证但当面对持续集成环境或需要批量验证数百个节点的场景时这种人工操作方式显得效率低下且容易出错。本文将展示如何基于SpringBoot和Eclipse Milo框架打造一个可集成到自动化测试流水线中的智能OPC UA客户端工具。1. 为什么需要替代UAExpertUAExpert作为OPC基金会官方提供的免费客户端确实为协议调试和基础测试提供了便利。但在实际工程实践中我们发现它存在三个明显短板无法集成到CI/CD流程图形界面操作难以自动化执行缺乏定制化能力无法针对特定业务逻辑添加验证规则性能监控不足难以统计长时间运行的连接稳定性指标我们的解决方案采用SpringBootMilo组合具备以下优势特性UAExpertSpringBootMilo方案自动化能力❌ 手动操作✅ 全自动执行测试用例管理❌ 无法保存✅ Junit集成多服务器并行测试❌ 单实例✅ 线程池支持自定义验证逻辑❌ 固定功能✅ 自由扩展2. 环境搭建与基础配置2.1 组件选型与依赖配置首先创建SpringBoot项目并添加关键依赖dependencies !-- Milo OPC UA客户端核心库 -- dependency groupIdorg.eclipse.milo/groupId artifactIdsdk-client/artifactId version0.6.6/version /dependency !-- 用于JSON序列化 -- dependency groupIdcom.fasterxml.jackson.core/groupId artifactIdjackson-databind/artifactId /dependency /dependencies2.2 模拟服务器准备推荐使用Prosys OPC UA Simulation Server作为测试目标它内置了多种数据类型模拟下载并安装Prosys Simulation Server启动后记下endpoint地址默认opc.tcp://localhost:53530/OPCUA/SimulationServer确认以下测试节点可用Counter (ns3;i1001) - 自增计数器Random (ns3;i1002) - 随机数生成器SineWave (ns3;i1003) - 正弦波形数据提示在Expert模式下可以查看完整的节点树和修改服务器配置3. 核心客户端封装设计3.1 连接管理模块创建带重试机制的连接工厂类public class OpcUaConnector { private static final int MAX_RETRY 3; private static final Duration RETRY_INTERVAL Duration.ofSeconds(5); public OpcUaClient connect(String endpointUrl) { int attempt 0; while (attempt MAX_RETRY) { try { return OpcUaClient.create(endpointUrl, clientBuilder - clientBuilder .setIdentityProvider(new AnonymousProvider()) .setRequestTimeout(UInteger.valueOf(5000))) .get(); } catch (Exception e) { attempt; if (attempt MAX_RETRY) { throw new RuntimeException(Connection failed after MAX_RETRY attempts, e); } Thread.sleep(RETRY_INTERVAL.toMillis()); } } throw new IllegalStateException(Unreachable code); } }3.2 数据操作服务层封装支持多种节点标识类型的读取服务Service public class OpcUaDataService { // 支持String类型节点ID public DataValue readNode(OpcUaClient client, int nsIndex, String identifier) { NodeId nodeId new NodeId(nsIndex, identifier); return readNodeInternal(client, nodeId); } // 支持Integer类型节点ID public DataValue readNode(OpcUaClient client, int nsIndex, int identifier) { NodeId nodeId new NodeId(nsIndex, identifier); return readNodeInternal(client, nodeId); } // 支持完整NodeId字符串 public DataValue readNode(OpcUaClient client, String nodeIdStr) { NodeId nodeId NodeId.parse(nodeIdStr); return readNodeInternal(client, nodeId); } private DataValue readNodeInternal(OpcUaClient client, NodeId nodeId) { try { return client.readValue(0, TimestampsToReturn.Both, nodeId).get(); } catch (InterruptedException | ExecutionException e) { throw new OpcUaOperationException(Read operation failed, e); } } }4. 实现自动化测试流水线4.1 基础测试用例示例创建JUnit测试类验证基础功能SpringBootTest public class OpcUaBasicTests { Autowired private OpcUaConnector connector; Autowired private OpcUaDataService dataService; private OpcUaClient client; BeforeEach void setup() { client connector.connect(opc.tcp://localhost:53530/OPCUA/SimulationServer); } Test void shouldReadCounterNode() { DataValue value dataService.readNode(client, 3, 1001); assertNotNull(value.getValue().getValue()); System.out.println(Counter value: value.getValue().getValue()); } AfterEach void tearDown() throws Exception { client.disconnect().get(); } }4.2 高级订阅测试实现创建带回调处理的订阅管理器public class SubscriptionManager { private final OpcUaClient client; private final MapInteger, UaSubscription subscriptions new ConcurrentHashMap(); public SubscriptionManager(OpcUaClient client) { this.client client; } public void subscribe(int subId, NodeId nodeId, ConsumerDataValue callback) { try { UaSubscription subscription client .getSubscriptionManager() .createSubscription(1000.0).get(); subscription.addMonitoredItem( new ReadValueId(nodeId, AttributeId.Value.uid(), null, null), MonitoringMode.Reporting, new MonitoringParameters( UInteger.valueOf(subId), 1000.0, null, UInteger.valueOf(10), true), (item, value) - callback.accept(value)); subscriptions.put(subId, subscription); } catch (InterruptedException | ExecutionException e) { throw new OpcUaOperationException(Subscription failed, e); } } public void unsubscribe(int subId) { UaSubscription subscription subscriptions.remove(subId); if (subscription ! null) { subscription.delete().exceptionally(ex - { System.err.println(Failed to delete subscription: ex.getMessage()); return null; }); } } }5. 生产级功能增强5.1 性能监控与统计添加Micrometer指标收集Configuration public class MetricsConfig { Bean public OpcUaClientMetrics opcUaClientMetrics(MeterRegistry registry) { return new OpcUaClientMetrics(registry); } } public class OpcUaClientMetrics { private final Counter readOperations; private final Counter failedReads; private final Timer readTimer; public OpcUaClientMetrics(MeterRegistry registry) { this.readOperations registry.counter(opcua.read.operations); this.failedReads registry.counter(opcua.read.failures); this.readTimer registry.timer(opcua.read.latency); } public DataValue instrumentedRead(OpcUaClient client, NodeId nodeId) { readOperations.increment(); return readTimer.record(() - { try { DataValue value client.readValue(0, TimestampsToReturn.Both, nodeId).get(); if (value.getStatusCode().isBad()) { failedReads.increment(); } return value; } catch (Exception e) { failedReads.increment(); throw new OpcUaOperationException(Read failed, e); } }); } }5.2 批量操作优化实现并行读取多个节点的工具方法public ListDataValue batchRead(OpcUaClient client, ListNodeId nodeIds, int parallelism) throws Exception { ExecutorService executor Executors.newFixedThreadPool(parallelism); ListCompletableFutureDataValue futures nodeIds.stream() .map(nodeId - CompletableFuture.supplyAsync( () - { try { return client.readValue(0, TimestampsToReturn.Both, nodeId).get(); } catch (Exception e) { throw new CompletionException(e); } }, executor)) .collect(Collectors.toList()); CompletableFutureVoid allDone CompletableFuture.allOf( futures.toArray(new CompletableFuture[0])); try { allDone.get(10, TimeUnit.SECONDS); return futures.stream() .map(CompletableFuture::join) .collect(Collectors.toList()); } finally { executor.shutdown(); } }6. 与测试框架深度集成6.1 测试用例工厂模式创建可生成动态测试用例的工厂public class DynamicTestFactory { public static StreamDynamicTest createNodeValidationTests( OpcUaClient client, ListNodeValidationSpec specs) { return specs.stream().map(spec - DynamicTest.dynamicTest( Validate node spec.getNodeId(), () - { DataValue value client.readValue( 0, TimestampsToReturn.Both, spec.getNodeId()).get(); spec.getValidator().validate(value); })); } } public interface NodeValidator { void validate(DataValue value) throws AssertionError; } Data public class NodeValidationSpec { private final NodeId nodeId; private final NodeValidator validator; }6.2 CI/CD流水线集成示例Jenkinsfile配置示例pipeline { agent any stages { stage(OPC UA Test) { steps { sh mvn test -Dopcua.endpointopc.tcp://test-server:4840/prod junit **/target/surefire-reports/*.xml } post { always { opcuaPublishMetrics( endpoint: System.getenv(METRICS_ENDPOINT), readLatency: readMetric(opcua.read.latency), errorRate: errorMetric(opcua.read.failures) ) } } } } }在项目实际部署中我们发现将节点配置外部化为YAML文件可以大幅提升测试套件的可维护性testCases: - name: Counter validation nodeId: ns3;i1001 validations: - type: valueType expected: Int32 - type: valueRange min: 0 max: 10000 - name: Sine wave validation nodeId: ns3;i1003 validations: - type: valueType expected: Double - type: valueRange min: -1.0 max: 1.0