OPC UA Milo -回调onDataChangeNotification中监控项的集合

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.UsernameIdentityProvider;
import org.eclipse.milo.opcua.stack.client.UaTcpStackClient;
import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue;
import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId;
import org.eclipse.milo.opcua.stack.core.types.builtin.Variant;
import org.eclipse.milo.opcua.stack.core.types.structured.ReadResponse;
import org.eclipse.milo.opcua.stack.core.types.structured.WriteResponse;

public class OpcUaClientExample {

    public static void main(String[] args) throws Exception {
        // 创建客户端配置
        OpcUaClientConfig config = OpcUaClientConfig.builder()
            .setEndpoint(UaTcpStackClient.getEndpoint("opc.tcp://localhost:4840").get())
            .setIdentityProvider(new UsernameIdentityProvider("username", "password"))
            .build();

        // 创建OPC UA客户端
        try (OpcUaClient client = new OpcUaClient(config)) {
            client.connect().get();

            // 订阅监控项
            NodeId monitoredItemId = new NodeId(2, "MyMonitoredItem");
            client.getSubscriptionManager().createSubscription(1000.0).thenAccept(subscription -> {
                subscription.createMonitoredItem(monitoredItemId, item -> {
                    item.setValueConsumer(value -> {
                        DataValue dataValue = value.getValue();
                        Variant variant = dataValue.getValue();
                        System.out.println("Data changed: " + variant.getValue());
                    });
                }).get();
            }).get();

            // 保持客户端运行
            Thread.currentThread().join();
        }
    }
}