Java使用Milo实现OPC UA客户端，封装spring boot starter

文章目录

最新版本更新日志查看：https://github.com/kangaroo1122/milo-spring-boot-starter/blob/main/UPDATE.md、https://gitee.com/vampire001/milo-spring-boot-starter/blob/master/UPDATE.md，此处不再更新

一、milo库

由eclipse开源，地址：https://github.com/eclipse/milo，可以基于此开发OPC UA客户端或者服务端。

本文介绍基于milo 封装的spring boot starter，yml配置OPC UA地址，是否匿名等信息，即可连接OPC UA服务器。

二、OPC UA服务端

这里使用的是kepware 6.6 版本，可参考之前的文章配置：Kepware配置OPC UA实现匿名or用户名/密码连接

三、工具使用

3.1 依赖

引入maven仓库地址，当前最新为：3.0.2 ，代码已上传至GitHub，有问题issues，欢迎star

查看最新版本：https://central.sonatype.com/artifact/com.kangaroohy/milo-spring-boot-starter

<dependency><groupId>com.kangaroohy</groupId><artifactId>milo-spring-boot-starter</artifactId><version>${lastVersion}</version></dependency>

3.2 配置

yml配置OPC UA地址，是否匿名等信息

kangaroohy:milo:primary: default
    config:endpoint: opc.tcp://127.0.0.1:49320security-policy: none

kangaroohy:milo:primary: default
    config:endpoint: opc.tcp://127.0.0.1:49320security-policy: basic256sha256
      username: OPCUA
      password:123456

特别提醒：

在kepware中，用户名/密码访问时，opcua配置，安全策略中三个策略全部勾选

同时kepware选项属性中的OPC UA配置，不允许匿名访问

此时，security-policy可选值：basic256sha256，basic256，basic128rsa15都可

同时配置上 用户名/密码 即可访问服务器

3.3 连接池

由于kepware中OPC UA最多只能有128个连接，且milo创建、释放连接比较耗时，因此本工具封装自带了一个连接池配置，默认会生成3个连接，可配置如下信息，达到连接管理的目的

kangaroohy:milo:pool:max-idle:5max-total:20min-idle:2initial-size:3

3.4 写

注入MiloService即可使用，支持：批量读、单个写、批量写、遍历节点信息等

其中：写值时可能需要指定数据类型，视点位情况而定

Opc后边的字段对应Kepware中的tag数据类型（Ua除外，为通用类型）

3.4.1 通用类型

如Kep类型为：Boolean、LLong、Long、String、Float、Double，调用方法：

miloService.writeToOpcUa(ReadWriteEntity entity)

@SpringBootTest@RunWith(SpringRunner.class)publicclassMiloTest{@AutowiredMiloService miloService;@TestpublicvoidwriteToOpcUa(){
        miloService.writeToOpcUa(ReadWriteEntity.builder().identifier("GA.T1.Boolean")//Kep中是Boolean类型.value(true).build());
        miloService.writeToOpcUa(ReadWriteEntity.builder().identifier("GA.T1.LLong")//Kep中是LLong类型，即：Int64，Java中的Long类型.value(1235468L).build());
        miloService.writeToOpcUa(ReadWriteEntity.builder().identifier("GA.T1.Long")//Kep中是Long类型，即：Int32，Java中的int类型.value(123456).build());
        miloService.writeToOpcUa(ReadWriteEntity.builder().identifier("GA.T1.String").value("字符串").build());
        miloService.writeToOpcUa(ReadWriteEntity.builder().identifier("GA.T1.Float")//Kep中是Float类型.value(123.123F).build());
        miloService.writeToOpcUa(ReadWriteEntity.builder().identifier("GA.T1.Double")//Kep中是Double类型.value(123.123).build());}}

3.4.2 已提供方法的类型

如Kep类型为：Short、Word、Byte、Char，调用方法：

miloService.writeToOpcXXX(ReadWriteEntity entity)

，XXX对应kep类型

@SpringBootTest@RunWith(SpringRunner.class)publicclassMiloTest{@AutowiredMiloService miloService;@TestpublicvoidwriteToOpcUa(){
        miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("GA.T1.Short")//Kep中是Short类型，即：Int16，带符号整数.value(-123).build());
        miloService.writeToOpcWord(ReadWriteEntity.builder().identifier("GA.T1.Word")//Kep中是Word类型，即：UInt16，无符号整数.value(123).build());
        miloService.writeToOpcByte(ReadWriteEntity.builder().identifier("GA.BIT_8.Byte")//Kep中是Byte类型，8位无符号整数.value(123).build());
        miloService.writeToOpcChar(ReadWriteEntity.builder().identifier("GA.BIT_8.Char")//Kep中是Char类型，8位带符号整数.value(-123).build());}}

3.4.3 其他类型

其他的数据类型，则需要调用方法：

miloService.writeSpecifyType(WriteEntity entity)

，自行指定转换类型.variant(new Variant(xxx))

new Variant(xxx)：

new Variant(String[])

new Variant(Unsigned.ushort(“123”))

…

参数类型具体以标签数据类型为准，列如：

@SpringBootTest@RunWith(SpringRunner.class)publicclassMiloTest{@AutowiredMiloService miloService;@TestpublicvoidwriteToOpcUa(){UByte[] bytes =newUByte[10];
        bytes[0]=UByte.valueOf(1);
        bytes[1]=UByte.valueOf(2);
        bytes[2]=UByte.valueOf(3);
        bytes[3]=UByte.valueOf(4);

        miloService.writeSpecifyType(WriteEntity.builder().identifier("GA.BIT_8.Bytes")//Kep中是Byte Array类型.variant(newVariant(bytes)).build());}}

3.5 读

读比较简单，传相应的TAG id数组即可，调用方法：readFromOpcUa(List ids)

id格式：通道名.设备名.TAG

如：GA.T1.T1001R_1

3.6 遍历节点

可遍历指定节点相关信息

3.7 订阅

这里使用的是实现

ApplicationRunner

接口，实现在项目启动时，自动订阅相关点位

当点位数值发生改变，则会触发回调，根据回调即可实现相应的逻辑

每新增一个订阅都会长期占用一个opc ua连接，不会释放，支持配置订阅扫描时长，具体可查询方法参数

@Component@Slf4jpublicclassCustomRunnerimplementsApplicationRunner{@AutowiredprivateMiloService miloService;@Overridepublicvoidrun(ApplicationArguments args)throwsException{sub();}privatevoidsub()throwsException{List<String> ids =newArrayList<>();
        ids.add("GA.T1.T1001R");
        ids.add("GA.T1.String");
        miloService.subscriptionFromOpcUa(ids,(id, value)-> log.info("subscription 点位：{} 订阅到消息：{}", id, value));}}