如何在SpringBoot项目中使用Milo库正确地实现OPC UA协议的取消订阅功能？

在Spring Boot项目中使用Milo库实现OPC UA（Object Protocols for Real-Time Automation）的取消订阅功能，你需要按照以下步骤操作：

1. **添加依赖**：首先，确保你的Maven或Gradle构建工具中已经包含了Milo和相关的Spring Boot集成依赖。例如，如果你使用Maven，可以在pom.xml文件中添加：

<dependency>
    <groupId>com.github.nielsmaeda</groupId>
    <artifactId>milo-core</artifactId>
    <version>最新版本号</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>
</dependency>

注意替换`最新版本号`为Milo的最新稳定版本。

2. **配置连接**：创建并配置OPCUA客户端连接。这通常涉及到设置服务器地址、证书和其他必要的认证信息。例如：

OpcUaClientSettings settings = OpcUaClientSettings.builder()
        .endpoint("opc.tcp://your-server-url:4840")
        .securityMode(SecurityPolicyMode.None)
        .build();
OpcUaClient client = OpcUaClient.create(settings);

3. **订阅数据**：在需要取消订阅的地方，先创建一个订阅：

String nodeId = "ns=2;s=YourNodeID";
client.getSubscriptionService().createSubscription(5000, new SubscriptionDescription.Builder()
        .nodesToMonitor(Collections.singletonList(new QualifiedName(nodeId)))
        .build());

这里设置了订阅周期为5秒，并指定了监控的节点。

4. **处理事件**：当有新数据到达时，监听`OpcUaSubscriptionListener`中的回调：

client.getSubscriptionService().addSubscriptionListener(subscription, new DefaultSubscriptionListener() {
    @Override
    public void onDataChange(OpcUaDataChange change) {
        // 处理接收到的数据
    }

    @Override
    public void onError(Throwable cause) {
        // 错误处理
    }
});

5. **取消订阅**：在不再需要订阅时，调用`unsubscribe()`方法：

subscription.unsubscribe();

6. **清理资源**：在Spring Boot应用停止时，记得关闭连接：

@PreDestroy
public void shutdown() {
    client.shutdown();
}