使用 OPC UA milo 断开服务器或重新启动服务器后，如何处理重新订阅？

问题描述

您好，我想知道如何（正确）处理 OPC UA milo 的重新订阅。目前我使用此代码来创建订阅：

private CompletableFuture<DataValue> subscribe(NodeId nodetoSubscribe,double samplingInterval,Consumer<DataValue> onChangeDo){
    CompletableFuture<DataValue> result = new CompletableFuture<>();
    try{
        //sets parameters of subscription
        ManagedSubscription subscription = ManagedSubscription.create(client,samplingInterval);
        subscription.setDefaultSamplingInterval(samplingInterval);
        subscription.setDefaultQueueSize(uint(10));

        //adds "onChange" action
        ManagedDataItem managedDataItem = subscription.createDataItem(nodetoSubscribe,item -> item.addDataValueListener(onChangeDo));

        //wait till first value was read
        ManagedDataItem.DataValueListener listener = managedDataItem.addDataValueListener(result::complete);
        result.whenComplete((v,e) -> managedDataItem.removeDataValueListener(listener));
    } catch (UaException e){
        result.completeExceptionally(e);
    }

    return result;
}

但是每当服务器重新启动或客户端和服务器之间的连接中断时，订阅就不起作用。

我可以添加会话活动侦听器，并在连接中断时清除这样的订阅管理器（星星之间的代码）。

addSessionActivityListener(new SessionActivityListener(){
                @Override
                public void onSessionActive(UaSession session) {
                    log.info("Connecting PLC with IP address {}",ipAddress);
                        setConnectionStatus(ConnectionStatus.CONNECTED);
                        **subscribeAll();**

                }

                @Override
                public void onSessionInactive(UaSession session) {
                    log.info("disconnecting PLC with IP address {}",ipAddress);
                    setConnectionStatus(ConnectionStatus.disCONNECTED);
                    **uaClient.getSubscriptionManager().clearSubscriptions();**
                }
});

但也许有更好的方法来处理这个问题。我所有的代码都可以在这里找到GitHub

更新： 根据凯文哈伦的回复，我可以看到它应该自动完成，但每次服务器断开连接时我都会收到此信息（我的订阅日志和状态代码）：

ON SUBSCRIPTION TRANSFER Failed: subscription org.eclipse.milo.opcua.sdk.client.subscriptions.OpcuaSubscription@3f344a79,status code StatusCode{name=Bad_ServiceUnsupported,value=0x800B0000,quality=bad}

如您所见，可能存在问题，该服务器不支持订阅转移。 Kevin 建议我应该使用 SubscriptionListener::onSubscriptionTransferFailed 来处理，所以我是这样实现的：

uaClient.getSubscriptionManager().addSubscriptionListener(new UaSubscriptionManager.SubscriptionListener() {
               
                @Override
                public void onSubscriptionTransferFailed(UaSubscription subscription,StatusCode statusCode) {
                    uaClient.getSubscriptionManager().clearSubscriptions();
                    subscribeAll();

                }

它接缝工作，但我想知道这是最好的方法还是我错过了什么。谢谢大家的回答。

解决方法

正确的方法大多是什么都不做 - 重新连接和重新订阅的所有细节都会自动处理。

您需要处理的唯一情况是在创建新会话后无法转移订阅。实现 SubscriptionListener::onSubscriptionTransferFailed 以重新创建此回调指示传输失败的任何订阅。

实际上没有任何其他情况需要您手动清除和重新创建订阅。 onPublishFailure() 回调主要提供信息，不需要操作。 onSessionActive() 和 onSessionInactive() 仅提供信息，不需要您执行任何操作。

java java milo opc-ua