最近接了一个项目，需要访问工业的实时数据库，数据库的对外开放接口是OPCUA协议的，经过多方比对，发现github上milo的评星较高，尝试了一下，还比较方便好用，现在把使用过程中的坑和大家介绍一下，网上比较全的资料不多，下面是整个过程全部的资料：
本次采用KEPServerEX5模拟服务端，使用milo开发的程序作为客户端
一、搭建服务端，KEPServerEX5的安装省略掉，下面是配置过程 设置通道、设备、标签

文章图片

设置访问的用户名和密码

文章图片

设置通过opc-ua访问的节点

文章图片

二、使用milo的框架，开发客户端访问opcua服务 1、在pom文件中追击以下依赖

org.eclipse.milosdk-client0.2.4org.bouncycastlebcpkix-jdk15on1.57org.eclipse.milosdk-server0.2.4

2、OPC UA协议对象接口

package com.jndj.platform.common.milo; import org.eclipse.milo.opcua.sdk.client.OpcUaClient; import org.eclipse.milo.opcua.sdk.client.api.identity.AnonymousProvider; import org.eclipse.milo.opcua.sdk.client.api.identity.IdentityProvider; import org.eclipse.milo.opcua.stack.core.security.SecurityPolicy; import org.eclipse.milo.opcua.stack.core.types.structured.EndpointDescription; import java.util.concurrent.CompletableFuture; import java.util.function.Predicate; /** * @author yaohj * @date 2020/7/30 * OPC UA协议对象接口 */public interface OpcUAClientService {/*** OPC UA服务器地址和接口*/default String getEndpointUrl() {return "opc.tcp://127.0.0.1:49320"; }/*** 过滤返回的server endpoint*/default Predicate endpointFilter() {return e -> true; }/*** 连接服务器的安全策略* None、Basic128Rsa15、Basic256、Basic256Sha256、Aes128_Sha256_RsaOaep、Aes256_Sha256_RsaPss*/default SecurityPolicy getSecurityPolicy() {return SecurityPolicy.None; }/*** 提供身份验证*/default IdentityProvider getIdentityProvider() {return new AnonymousProvider(); }/*** 实际操作服务、由实现类重写实现*/void run(OpcUaClient client, CompletableFuture future) throws Exception; }

3、OPC UA协议对象实体类

package com.jndj.platform.common.milo; import com.google.common.collect.ImmutableList; import org.eclipse.milo.opcua.sdk.client.OpcUaClient; import org.eclipse.milo.opcua.stack.core.types.builtin.*; import org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn; import org.springframework.stereotype.Service; import java.util.List; import java.util.concurrent.CompletableFuture; @Service("OpcUAClientService")public class OpcUAClientServiceImpl implements OpcUAClientService {/*** 覆盖接口的方法，建立和OPC UA的服务*/@Overridepublic void run(OpcUaClient client, CompletableFuture future) throws Exception {// 同步建立连接client.connect().get(); // 异步读取数据readTagData(client).thenAccept(values -> {DataValue nodeId_Tag1 = values.get(0); DataValue nodeId_Tag2 = values.get(1); System.out.println("#########Tag1=" + nodeId_Tag1.getValue().getValue()); System.out.println("#########Tag2=" + nodeId_Tag2.getValue().getValue()); future.complete(client); }); }/*** 读取标签点的数据*/private CompletableFuture> readTagData(OpcUaClient client) {NodeId nodeId_Tag1 = new NodeId(2, "Channel1.Device1.Tag1"); NodeId nodeId_Tag2 = new NodeId(2, "Channel1.Device1.Tag2"); List nodeIds = ImmutableList.of(nodeId_Tag1, nodeId_Tag2); return client.readValues(0.0, TimestampsToReturn.Both, nodeIds); }}

【使用java的milo框架访问OPCUA服务的过程】4、OPC UA协议运行对象

package com.jndj.platform.common.milo; import org.eclipse.milo.opcua.sdk.client.OpcUaClient; import org.eclipse.milo.opcua.sdk.client.api.config.OpcUaClientConfig; import org.eclipse.milo.opcua.sdk.client.api.identity.UsernameProvider; import org.eclipse.milo.opcua.stack.client.UaTcpStackClient; import org.eclipse.milo.opcua.stack.core.Stack; import org.eclipse.milo.opcua.stack.core.types.builtin.LocalizedText; import org.eclipse.milo.opcua.stack.core.types.structured.EndpointDescription; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Service; import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; import java.util.Arrays; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; import java.util.concurrent.TimeUnit; import static org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.Unsigned.uint; @Service("OpcUAClientRunner")public class OpcUAClientRunner {private final Logger logger = LoggerFactory.getLogger(getClass()); private final CompletableFuture future = new CompletableFuture<>(); private final OpcUAClientService opcUAClientService; public OpcUAClientRunner(OpcUAClientService opcUAClientService) {this.opcUAClientService = opcUAClientService; }/*** OPC UA的运行入口程序*/public void run() {try {// 创建OPC UA客户端OpcUaClient opcUaClient = createClient(); // future执行完毕后，异步判断状态future.whenCompleteAsync((c, ex) -> {if (ex != null) {logger.error("连接OPC UA服务错误: {}", ex.getMessage(), ex); }// 关闭OPC UA客户端try {opcUaClient.disconnect().get(); Stack.releaseSharedResources(); } catch (InterruptedException | ExecutionException e) {logger.error("OPC UA服务关闭错误: {}", e.getMessage(), e); }}); try {// 获取OPC UA服务器的数据opcUAClientService.run(opcUaClient, future); future.get(5, TimeUnit.SECONDS); } catch (Throwable t) {logger.error("OPC UA客户端运行错误: {}", t.getMessage(), t); future.completeExceptionally(t); }} catch (Throwable t) {logger.error("OPC UA客户端创建错误: {}", t.getMessage(), t); future.completeExceptionally(t); }}/*** 创建OPC UA的服务连接对象*/private OpcUaClient createClient() throws Exception {Path securityTempDir = Paths.get(System.getProperty("java.io.tmpdir"), "security"); Files.createDirectories(securityTempDir); if (!Files.exists(securityTempDir)) {throw new Exception("不能够创建安全路径: " + securityTempDir); }KeyStoreLoader loader = new KeyStoreLoader().load(securityTempDir); // 获取OPC UA的服务器端节点EndpointDescription[] endpoints =UaTcpStackClient.getEndpoints(opcUAClientService.getEndpointUrl()).get(); EndpointDescription endpoint = Arrays.stream(endpoints).filter(e -> e.getEndpointUrl().equals(opcUAClientService.getEndpointUrl())).findFirst().orElseThrow(() -> new Exception("没有节点返回")); // 设置OPC UA的配置信息OpcUaClientConfig config =OpcUaClientConfig.builder().setApplicationName(LocalizedText.english("OPC UA SCREEN")).setApplicationUri("urn:DATA-TRANSFER:OPC UA SCREEN").setCertificate(loader.getClientCertificate()).setKeyPair(loader.getClientKeyPair()).setEndpoint(endpoint).setIdentityProvider(new UsernameProvider("Administrator", "123456")).setRequestTimeout(uint(5000)).build(); // 创建OPC UA客户端return new OpcUaClient(config); }}

5、OPC UA访问证书类

package com.jndj.platform.common.milo; import org.eclipse.milo.opcua.sdk.server.util.HostnameUtil; import org.eclipse.milo.opcua.stack.core.util.SelfSignedCertificateBuilder; import org.eclipse.milo.opcua.stack.core.util.SelfSignedCertificateGenerator; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.InputStream; import java.io.OutputStream; import java.nio.file.Files; import java.nio.file.Path; import java.security.*; import java.security.cert.X509Certificate; import java.util.regex.Pattern; class KeyStoreLoader {private final Logger logger = LoggerFactory.getLogger(getClass()); private static final Pattern IP_ADDR_PATTERN = Pattern.compile("^(([01]?\\d\\d?|2[0-4]\\d|25[0-5])\\.){3}([01]?\\d\\d?|2[0-4]\\d|25[0-5])$"); // 证书别名private static final String CLIENT_ALIAS = "client-ai"; // 获取私钥的密码private static final char[] PASSWORD = "password".toCharArray(); // 证书对象private X509Certificate clientCertificate; // 密钥对对象private KeyPair clientKeyPair; KeyStoreLoader load(Path baseDir) throws Exception {// 创建一个使用`PKCS12`加密标准的KeyStore。KeyStore在后面将作为读取和生成证书的对象。KeyStore keyStore = KeyStore.getInstance("PKCS12"); // PKCS12的加密标准的文件后缀是.pfx，其中包含了公钥和私钥。// 而其他如.der等的格式只包含公钥，私钥在另外的文件中。Path serverKeyStore = baseDir.resolve("example-client.pfx"); logger.info("Loading KeyStore at {}", serverKeyStore); // 如果文件不存在则创建.pfx证书文件。if (!Files.exists(serverKeyStore)) {keyStore.load(null, PASSWORD); // 用2048位的RAS算法。`SelfSignedCertificateGenerator`为Milo库的对象。KeyPair keyPair = SelfSignedCertificateGenerator.generateRsaKeyPair(2048); // `SelfSignedCertificateBuilder`也是Milo库的对象，用来生成证书。// 中间所设置的证书属性可以自行修改。SelfSignedCertificateBuilder builder = new SelfSignedCertificateBuilder(keyPair).setCommonName("Eclipse Milo Example Client").setOrganization("digitalpetri").setOrganizationalUnit("dev").setLocalityName("Folsom").setStateName("CA").setCountryCode("US").setApplicationUri("urn:eclipse:milo:examples:client").addDnsName("localhost").addIpAddress("127.0.0.1"); // Get as many hostnames and IP addresses as we can listed in the certificate.for (String hostname : HostnameUtil.getHostnames("0.0.0.0")) {if (IP_ADDR_PATTERN.matcher(hostname).matches()) {builder.addIpAddress(hostname); } else {builder.addDnsName(hostname); }}// 创建证书X509Certificate certificate = builder.build(); // 设置对应私钥的别名，密码，证书链keyStore.setKeyEntry(CLIENT_ALIAS, keyPair.getPrivate(), PASSWORD, new X509Certificate[]{certificate}); try (OutputStream out = Files.newOutputStream(serverKeyStore)) {// 保存证书到输出流keyStore.store(out, PASSWORD); }} else {try (InputStream in = Files.newInputStream(serverKeyStore)) {// 如果文件存在则读取keyStore.load(in, PASSWORD); }}// 用密码获取对应别名的私钥。Key serverPrivateKey = keyStore.getKey(CLIENT_ALIAS, PASSWORD); if (serverPrivateKey instanceof PrivateKey) {// 获取对应别名的证书对象。clientCertificate = (X509Certificate) keyStore.getCertificate(CLIENT_ALIAS); // 获取公钥PublicKey serverPublicKey = clientCertificate.getPublicKey(); // 创建Keypair对象。clientKeyPair = new KeyPair(serverPublicKey, (PrivateKey) serverPrivateKey); }return this; }// 返回证书X509Certificate getClientCertificate() {return clientCertificate; }// 返回密钥对KeyPair getClientKeyPair() {return clientKeyPair; }}

6、业务service类

package com.jndj.platform.phase2.service.impl; import com.jndj.platform.common.milo.OpcUAClientRunner; import com.jndj.platform.common.milo.OpcUAClientService; import com.jndj.platform.phase2.service.Phase2Service; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; /** * @author yaohj * @date 2020/7/22 * 获取二期发电数据（三、四号机组） */@Service("phase2Service")public class Phase2ServiceImpl implements Phase2Service {@Autowiredprivate OpcUAClientService opcUAClientService; /*** 获取二期发电数据（三、四号机组），保存到数据库中*/@Overridepublic void searchPhase2ElectricData() {new OpcUAClientRunner(opcUAClientService).run(); }}

7、业务Controller类、定时调度

package com.jndj.platform.phase2.controller; import com.jndj.platform.phase2.service.Phase2Service; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Controller; import java.text.SimpleDateFormat; import java.util.Date; /** * @author yaohj * @date 2020/7/22 * 获取二期发电数据（三、四号机组） */@Controllerpublic class Phase2Controller {private static final Logger logger = LoggerFactory.getLogger(Phase2Controller.class); private static final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy:mm:dd HH:mm:ss"); @Autowiredprivate Phase2Service phase2Service; /*** 获取二期发电数据（三、四号机组），保存到数据库中(x分钟调度一次)*/@Scheduled(initialDelay = 30000, fixedRate = 30000)public void searchGasData() {logger.info("####获取二期发电数据（三、四号机组） - 定时任务执行时间："+ dateFormat.format(new Date())); phase2Service.searchPhase2ElectricData(); }}

8、运行结果、定时获取到opcua服务中的数据

文章图片

OK，以上是所有的源代码，大家的问题基本能够解决。
到此这篇关于使用java的milo框架访问OPCUA服务的方法的文章就介绍到这了,更多相关java访问OPCUA服务内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

推荐阅读

• 

  人民币1元硬币背面什么花 人民币硬币1角是什么花
• 

  安德烈娅·盖兹|安德烈娅·盖兹 银河系中心的芭蕾舞者
• 

  西门子冰箱工作时声音大正常吗常见故障,以及处理方式？
• 

  安县美食 安县美食都有哪些
• 

  笔记本屏幕发黄修复小技巧 笔记本屏幕发黄修复小技巧有哪些
• 

  绿色底纹怎么设置
• 

  苦参内服的功效与作用 苦参内服有哪些功效作用
• 

  移动html5动画效果，html5做动画
• 

  安卓qq卡住怎么办,手机出现办卡空间不足问题四大注意事项
• 

  背影的作者是谁作者简介 背影的作者是哪个作者简介
• 

  等价无穷小的错误用法 等价无穷小的适用范围
• 

  2018/12/28|2018/12/28 胡萝卜鸡蛋煎饼
• 

  如何用心理学解释星座学是伪科学？
• 

  mini|欧亚监管文件曝光新款 Mac/Apple Watch
• 

  可以用电视机做电脑显示器吗 电视和显示器有什么区别
• 

  幼儿园设计|幼儿园设计|地面空间不够（那试试在屋顶开辟活动空间吧）
• 

  电脑在哪里设置开机密码
• 

  移动服务器传奇私服，手机传奇服务端下载
• 

  编程软件的图标，编程的图标是哪个啊
• 

  地薄者大物不产

• 聊聊SpringBoot整合Nacos自动刷新配置的问题
• resty的缓存技术设计及使用
• 使用resty|使用resty Quartz执行定时任务的配置方法
• MongoDB连接和创建数据库的方法讲解
• .NET|.NET Core中简单的邮箱格式校验方式
• 使用Feign配置请求头以及支持Https协议
• resty|resty client使用Java客户端来访问Api
• Python中转换数据类型的函数
• Python中常用数据类型转换函数的使用方法和步骤
• Pycharm交互式开发环境的使用方法