|
|
|
@ -5,19 +5,6 @@ import cn.hutool.core.util.ObjectUtil; |
|
|
|
import cn.hutool.core.util.StrUtil; |
|
|
|
import com.alibaba.fastjson.JSON; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
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.subscriptions.UaSubscription; |
|
|
|
import org.eclipse.milo.opcua.sdk.client.api.subscriptions.UaSubscriptionManager; |
|
|
|
import org.eclipse.milo.opcua.sdk.client.subscriptions.ManagedDataItem; |
|
|
|
import org.eclipse.milo.opcua.sdk.client.subscriptions.ManagedSubscription; |
|
|
|
import org.eclipse.milo.opcua.stack.core.UaException; |
|
|
|
import org.eclipse.milo.opcua.stack.core.security.SecurityPolicy; |
|
|
|
import org.eclipse.milo.opcua.stack.core.types.builtin.DateTime; |
|
|
|
import org.eclipse.milo.opcua.stack.core.types.builtin.LocalizedText; |
|
|
|
import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId; |
|
|
|
import org.eclipse.milo.opcua.stack.core.types.builtin.StatusCode; |
|
|
|
import org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger; |
|
|
|
import org.nl.acs.AcsConfig; |
|
|
|
import org.nl.acs.instruction.service.InstructionService; |
|
|
|
import org.nl.acs.opc.service.dto.OpcServerManageDto; |
|
|
|
@ -25,18 +12,13 @@ import org.nl.acs.udw.UnifiedDataAccessor; |
|
|
|
import org.nl.acs.udw.UnifiedDataAccessorFactory; |
|
|
|
import org.nl.acs.udw.UnifiedDataAppService; |
|
|
|
import org.nl.common.enums.LogTypeEnum; |
|
|
|
import org.nl.common.exception.BadRequestException; |
|
|
|
import org.nl.config.SpringContextHolder; |
|
|
|
import org.nl.config.lucene.service.LuceneExecuteLogService; |
|
|
|
import org.nl.config.lucene.service.dto.LuceneLogDto; |
|
|
|
import org.nl.system.service.param.ISysParamService; |
|
|
|
import org.openscada.opc.lib.da.*; |
|
|
|
|
|
|
|
import java.nio.file.Files; |
|
|
|
import java.nio.file.Path; |
|
|
|
import java.nio.file.Paths; |
|
|
|
import java.util.*; |
|
|
|
import java.util.concurrent.CountDownLatch; |
|
|
|
import java.util.regex.Pattern; |
|
|
|
|
|
|
|
|
|
|
|
@ -112,7 +94,6 @@ public class DeviceOpcProtocolRunable implements Runnable, DataCallback, ServerC |
|
|
|
private void runOld() { |
|
|
|
OpcServerService opcServerService = SpringContextHolder.getBean(OpcServerService .class); |
|
|
|
while (true) { |
|
|
|
|
|
|
|
start: |
|
|
|
try { |
|
|
|
if (this.group != null) { |
|
|
|
@ -174,134 +155,132 @@ public class DeviceOpcProtocolRunable implements Runnable, DataCallback, ServerC |
|
|
|
tag = tag + "," + this.getOpcGroupID(); |
|
|
|
} |
|
|
|
} |
|
|
|
OpcServerManageDto opcServer = this.getOpcServer(); |
|
|
|
if (opcServer.getOpc_code().equals("MXDDHJ")) { |
|
|
|
UnifiedDataAccessor accessor_value = UnifiedDataAccessorFactory.getAccessor(OpcConfig.udw_opc_value_key); |
|
|
|
boolean time_out = false; |
|
|
|
|
|
|
|
while (DeviceOpcSynchronizeAutoRun.isRun) { |
|
|
|
long begin = System.currentTimeMillis(); |
|
|
|
if (log.isTraceEnabled()) { |
|
|
|
log.trace("{} 开始记时{}", tag, DateUtil.now()); |
|
|
|
} |
|
|
|
|
|
|
|
Map<Item, ItemState> itemStatus = group.read(true, (Item[]) itemsMap.values().toArray(new Item[0])); |
|
|
|
long end = System.currentTimeMillis(); |
|
|
|
long duration = end - begin; |
|
|
|
if (log.isTraceEnabled()) { |
|
|
|
log.trace("{} 读取耗时：{}", tag, duration); |
|
|
|
UnifiedDataAccessor accessor_value = UnifiedDataAccessorFactory.getAccessor(OpcConfig.udw_opc_value_key); |
|
|
|
boolean time_out = false; |
|
|
|
|
|
|
|
while (DeviceOpcSynchronizeAutoRun.isRun) { |
|
|
|
long begin = System.currentTimeMillis(); |
|
|
|
if (log.isTraceEnabled()) { |
|
|
|
log.trace("{} 开始记时{}", tag, DateUtil.now()); |
|
|
|
} |
|
|
|
|
|
|
|
Map<Item, ItemState> itemStatus = group.read(true, (Item[]) itemsMap.values().toArray(new Item[0])); |
|
|
|
long end = System.currentTimeMillis(); |
|
|
|
long duration = end - begin; |
|
|
|
if (log.isTraceEnabled()) { |
|
|
|
log.trace("{} 读取耗时：{}", tag, duration); |
|
|
|
} |
|
|
|
|
|
|
|
if (duration > 1000L) { |
|
|
|
if (!time_out) { |
|
|
|
log.warn("{} 读取超时 : {}", tag, duration); |
|
|
|
} |
|
|
|
|
|
|
|
if (duration > 1000L) { |
|
|
|
if (!time_out) { |
|
|
|
log.warn("{} 读取超时 : {}", tag, duration); |
|
|
|
} |
|
|
|
time_out = true; |
|
|
|
} else { |
|
|
|
time_out = false; |
|
|
|
} |
|
|
|
|
|
|
|
time_out = true; |
|
|
|
boolean valueAllNotNull = false; |
|
|
|
Set<Item> items = itemStatus.keySet(); |
|
|
|
Iterator var18 = items.iterator(); |
|
|
|
|
|
|
|
while (var18.hasNext()) { |
|
|
|
Item item = (Item) var18.next(); |
|
|
|
ItemState itemState = (ItemState) itemStatus.get(item); |
|
|
|
Object value = OpcUtl.getValue(item, itemState); |
|
|
|
if (value != null) { |
|
|
|
valueAllNotNull = true; |
|
|
|
} else { |
|
|
|
time_out = false; |
|
|
|
log.info("item:{},velue为空，value:{}", item.getId(), value); |
|
|
|
} |
|
|
|
|
|
|
|
boolean valueAllNotNull = false; |
|
|
|
Set<Item> items = itemStatus.keySet(); |
|
|
|
Iterator var18 = items.iterator(); |
|
|
|
|
|
|
|
while (var18.hasNext()) { |
|
|
|
Item item = (Item) var18.next(); |
|
|
|
ItemState itemState = (ItemState) itemStatus.get(item); |
|
|
|
Object value = OpcUtl.getValue(item, itemState); |
|
|
|
if (value != null) { |
|
|
|
valueAllNotNull = true; |
|
|
|
} else { |
|
|
|
log.info("item:{},velue为空，value:{}", item.getId(), value); |
|
|
|
} |
|
|
|
String itemId = item.getId(); |
|
|
|
Object his = accessor_value.getValue(itemId); |
|
|
|
if (!ObjectUtl.isEquals(itemState.getQuality(), QualityTypeValue.OPC_QUALITY_GOOD) && his != null) { |
|
|
|
log.warn("opc 值不健康 item: {}, 状态: {}", itemId, itemState.getQuality()); |
|
|
|
valueAllNotNull = false; |
|
|
|
} |
|
|
|
|
|
|
|
String itemId = item.getId(); |
|
|
|
Object his = accessor_value.getValue(itemId); |
|
|
|
if (!ObjectUtl.isEquals(itemState.getQuality(), QualityTypeValue.OPC_QUALITY_GOOD) && his != null) { |
|
|
|
log.warn("opc 值不健康 item: {}, 状态: {}", itemId, itemState.getQuality()); |
|
|
|
valueAllNotNull = false; |
|
|
|
if (!UnifiedDataAppService.isEquals(value, his)) { |
|
|
|
OpcItemDto itemDto = this.getItem(itemId); |
|
|
|
if (true) { |
|
|
|
this.logItemChanged(itemId, accessor_value, value, itemDto); |
|
|
|
} |
|
|
|
|
|
|
|
if (!UnifiedDataAppService.isEquals(value, his)) { |
|
|
|
OpcItemDto itemDto = this.getItem(itemId); |
|
|
|
if (true) { |
|
|
|
this.logItemChanged(itemId, accessor_value, value, itemDto); |
|
|
|
} |
|
|
|
if (!ObjectUtil.isEmpty(value) || "".equals(value)) { |
|
|
|
accessor_value.setValue(itemId, value); |
|
|
|
} |
|
|
|
if (ObjectUtil.isEmpty(value) && !"".equals(value)) { |
|
|
|
accessor_value.removeValue(itemId); |
|
|
|
} |
|
|
|
if(!ObjectUtil.isEmpty(value) || "".equals(value)){ |
|
|
|
accessor_value.setValue(itemId, value); |
|
|
|
} |
|
|
|
if(ObjectUtil.isEmpty(value) && !"".equals(value)){ |
|
|
|
accessor_value.removeValue(itemId); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
end = System.currentTimeMillis(); |
|
|
|
if (log.isTraceEnabled()) { |
|
|
|
log.trace("{}", itemsString); |
|
|
|
log.trace("{} 计算完成耗时{}", tag, end - begin); |
|
|
|
} |
|
|
|
end = System.currentTimeMillis(); |
|
|
|
if (log.isTraceEnabled()) { |
|
|
|
log.trace("{}", itemsString); |
|
|
|
log.trace("{} 计算完成耗时{}", tag, end - begin); |
|
|
|
} |
|
|
|
|
|
|
|
ThreadUtl.sleep((long) OpcConfig.synchronized_millisecond); |
|
|
|
if (this.error_num != 0) { |
|
|
|
this.error_num = 0; |
|
|
|
this.message = null; |
|
|
|
} |
|
|
|
ThreadUtl.sleep((long) OpcConfig.synchronized_millisecond); |
|
|
|
if (this.error_num != 0) { |
|
|
|
this.error_num = 0; |
|
|
|
this.message = null; |
|
|
|
} |
|
|
|
|
|
|
|
if (!valueAllNotNull) { |
|
|
|
if (this.all_null < 3) { |
|
|
|
if (log.isWarnEnabled()) { |
|
|
|
log.warn("OPC数据源: {} 所有内容都为空,检查网络, all_null:{} ,暂定{}s", tag, all_null, 3); |
|
|
|
} |
|
|
|
while (var18.hasNext()) { |
|
|
|
Item item = (Item) var18.next(); |
|
|
|
String itemId = item.getId(); |
|
|
|
OpcItemDto itemDto = this.getItem(itemId); |
|
|
|
LuceneLogDto logDto = LuceneLogDto.builder() |
|
|
|
.device_code("OPC数据源") |
|
|
|
.content("OPC数据源:" + tag + "内容为：" + itemDto) |
|
|
|
.build(); |
|
|
|
logDto.setLog_level(4); |
|
|
|
luceneExecuteLogService.deviceExecuteLog(logDto); |
|
|
|
} |
|
|
|
ThreadUtl.sleep(3000); |
|
|
|
break start; |
|
|
|
} else if (this.all_null < 6) { |
|
|
|
if (log.isWarnEnabled()) { |
|
|
|
log.warn(tag + "重新创建server"); |
|
|
|
log.warn("{} 所有内容都为空, all_null:{} ,暂定{}s", tag, all_null, 3); |
|
|
|
} |
|
|
|
ThreadUtl.sleep(3000); |
|
|
|
break start; |
|
|
|
} else if (this.all_null < 12) { |
|
|
|
if (log.isWarnEnabled()) { |
|
|
|
log.warn(tag + "重新创建server"); |
|
|
|
log.warn("{} 所有内容都为空, all_null:{} ,暂定{}s", tag, all_null, 3); |
|
|
|
} |
|
|
|
ThreadUtl.sleep(3000); |
|
|
|
break start; |
|
|
|
} else { |
|
|
|
if (log.isWarnEnabled()) { |
|
|
|
log.warn("{} 所有内容都为空, all_null:{} ,暂定{}ms", tag, all_null, 5000); |
|
|
|
} |
|
|
|
if (!valueAllNotNull) { |
|
|
|
if (this.all_null < 3) { |
|
|
|
if (log.isWarnEnabled()) { |
|
|
|
log.warn("OPC数据源: {} 所有内容都为空,检查网络, all_null:{} ,暂定{}s", tag, all_null,3); |
|
|
|
} |
|
|
|
while (var18.hasNext()) { |
|
|
|
Item item = (Item) var18.next(); |
|
|
|
String itemId = item.getId(); |
|
|
|
OpcItemDto itemDto = this.getItem(itemId); |
|
|
|
LuceneLogDto logDto = LuceneLogDto.builder() |
|
|
|
.device_code("OPC数据源") |
|
|
|
.content("OPC数据源:" + tag + "内容为：" + all_null) |
|
|
|
.content("OPC数据源:" + tag + "内容为：" + itemDto) |
|
|
|
.build(); |
|
|
|
logDto.setLog_level(4); |
|
|
|
luceneExecuteLogService.deviceExecuteLog(logDto); |
|
|
|
ThreadUtl.sleep((long) (5000)); |
|
|
|
break start; |
|
|
|
} |
|
|
|
|
|
|
|
// ++this.all_null;
|
|
|
|
ThreadUtl.sleep( 3000); |
|
|
|
break start; |
|
|
|
} else if (this.all_null < 6) { |
|
|
|
if (log.isWarnEnabled()) { |
|
|
|
log.warn(tag + "重新创建server"); |
|
|
|
log.warn("{} 所有内容都为空, all_null:{} ,暂定{}s", tag, all_null,3); |
|
|
|
} |
|
|
|
ThreadUtl.sleep(3000); |
|
|
|
break start; |
|
|
|
} else if (this.all_null < 12) { |
|
|
|
if (log.isWarnEnabled()) { |
|
|
|
log.warn(tag + "重新创建server"); |
|
|
|
log.warn("{} 所有内容都为空, all_null:{} ,暂定{}s", tag, all_null,3); |
|
|
|
} |
|
|
|
ThreadUtl.sleep(3000); |
|
|
|
break start; |
|
|
|
} else { |
|
|
|
this.all_null = 0; |
|
|
|
if (log.isWarnEnabled()) { |
|
|
|
log.warn("{} 所有内容都为空, all_null:{} ,暂定{}ms", tag, all_null, 5000); |
|
|
|
} |
|
|
|
LuceneLogDto logDto = LuceneLogDto.builder() |
|
|
|
.device_code("OPC数据源") |
|
|
|
.content("OPC数据源:" + tag + "内容为：" + all_null) |
|
|
|
.build(); |
|
|
|
logDto.setLog_level(4); |
|
|
|
luceneExecuteLogService.deviceExecuteLog(logDto); |
|
|
|
ThreadUtl.sleep((long) (5000)); |
|
|
|
break start; |
|
|
|
} |
|
|
|
// break start;
|
|
|
|
|
|
|
|
// ++this.all_null;
|
|
|
|
} else { |
|
|
|
this.all_null = 0; |
|
|
|
} |
|
|
|
// break start;
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
log.warn("opc线程停止。。。"); |
|
|
|
@ -337,165 +316,68 @@ public class DeviceOpcProtocolRunable implements Runnable, DataCallback, ServerC |
|
|
|
|
|
|
|
|
|
|
|
private void runNew() { |
|
|
|
try{ |
|
|
|
OpcUaClient client = createClient(); |
|
|
|
client.connect().get(); |
|
|
|
managedSubscriptionEvent(client); |
|
|
|
} catch (Exception e){ |
|
|
|
e.printStackTrace(); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// private final static String endPointUrl = "opc.tcp://127.0.0.1:49320";
|
|
|
|
|
|
|
|
private static OpcUaClient createClient() throws Exception { |
|
|
|
ISysParamService paramService = SpringContextHolder.getBean(ISysParamService.class); |
|
|
|
String endPointUrl = paramService.findByCode(AcsConfig.OPCURL).getValue(); |
|
|
|
if (StrUtil.isEmpty(endPointUrl)){ |
|
|
|
throw new BadRequestException("opc地址未配置!"); |
|
|
|
} |
|
|
|
//opc ua服务端地址
|
|
|
|
Path securityTempDir = Paths.get(System.getProperty("java.io.tmpdir"), "security"); |
|
|
|
Files.createDirectories(securityTempDir); |
|
|
|
if (!Files.exists(securityTempDir)) { |
|
|
|
throw new Exception("unable to create security dir: " + securityTempDir); |
|
|
|
} |
|
|
|
return OpcUaClient.create(endPointUrl, endpoints -> endpoints.stream().filter(e -> e.getSecurityPolicyUri().equals(SecurityPolicy.None.getUri())).findFirst(), configBuilder -> configBuilder.setApplicationName(LocalizedText.english("eclipse milo opc-ua client")).setApplicationUri("urn:eclipse:milo:examples:client") |
|
|
|
//访问方式
|
|
|
|
.setIdentityProvider(new AnonymousProvider()).setRequestTimeout(UInteger.valueOf(5000)).build()); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 批量订阅 |
|
|
|
* |
|
|
|
* @param client |
|
|
|
* @throws Exception |
|
|
|
*/ |
|
|
|
private void managedSubscriptionEvent(OpcUaClient client) throws Exception { |
|
|
|
final CountDownLatch eventLatch = new CountDownLatch(1); |
|
|
|
//添加订阅监听器，用于处理断线重连后的订阅问题
|
|
|
|
client.getSubscriptionManager().addSubscriptionListener(new DeviceOpcProtocolRunable.CustomSubscriptionListener(client)); |
|
|
|
//处理订阅业务
|
|
|
|
handlerNode(client); |
|
|
|
//持续监听
|
|
|
|
eventLatch.await(); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
* 处理订阅业务 |
|
|
|
* |
|
|
|
* @param client OPC UA客户端 |
|
|
|
*/ |
|
|
|
public void handlerNode(OpcUaClient client) { |
|
|
|
try { |
|
|
|
//创建订阅
|
|
|
|
ManagedSubscription subscription = ManagedSubscription.create(client); |
|
|
|
|
|
|
|
//你所需要订阅的key
|
|
|
|
List<String> key = new ArrayList<>(); |
|
|
|
|
|
|
|
List<String> itemsString = new ArrayList(); |
|
|
|
Iterator var3 = this.protocols.iterator(); |
|
|
|
|
|
|
|
while (var3.hasNext()) { |
|
|
|
OpcItemDto protocol = (OpcItemDto) var3.next(); |
|
|
|
String item = protocol.getItem_code(); |
|
|
|
key.add(item); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
List<NodeId> nodeIdList = new ArrayList<>(); |
|
|
|
for (String s : key) { |
|
|
|
nodeIdList.add(new NodeId(2, s)); |
|
|
|
} |
|
|
|
|
|
|
|
//监听
|
|
|
|
List<ManagedDataItem> dataItemList = subscription.createDataItems(nodeIdList); |
|
|
|
|
|
|
|
UnifiedDataAccessor accessor_value = UnifiedDataAccessorFactory.getAccessor(OpcConfig.udw_opc_value_key); |
|
|
|
|
|
|
|
if (!OpcStartTag.is_run) { |
|
|
|
OpcStartTag.is_run = true; |
|
|
|
} |
|
|
|
|
|
|
|
for (ManagedDataItem managedDataItem : dataItemList) { |
|
|
|
managedDataItem.addDataValueListener((t) -> { |
|
|
|
if(ObjectUtil.isNotEmpty(managedDataItem.getNodeId().getIdentifier())){ |
|
|
|
//managedDataItem.getNodeId().getIdentifier() ZJXXHJ.ZJXXHJ.ZXQ_05.to_command
|
|
|
|
//System.out.println(managedDataItem.getNodeId().getIdentifier().toString() + ":" + t.getValue().getValue());
|
|
|
|
//需要判断连接是否正常
|
|
|
|
if( t.getStatusCode().isGood()){ |
|
|
|
//字符串存在为空的情况
|
|
|
|
if(ObjectUtil.isNotEmpty(t.getValue().getValue())){ |
|
|
|
if(!ObjectUtil.equal(accessor_value.getValue(managedDataItem.getNodeId().getIdentifier().toString()),t.getValue().getValue().toString())){ |
|
|
|
OpcItemDto itemDto = this.getItem(managedDataItem.getNodeId().getIdentifier().toString()); |
|
|
|
this.logItemChanged(managedDataItem.getNodeId().getIdentifier().toString(), accessor_value, OpcUtl.getValue(t.getValue().getValue()),itemDto); |
|
|
|
accessor_value.setValue(managedDataItem.getNodeId().getIdentifier().toString(), OpcUtl.getValue(t.getValue().getValue())); |
|
|
|
} |
|
|
|
} else { |
|
|
|
if(!ObjectUtil.equal(accessor_value.getValue(managedDataItem.getNodeId().getIdentifier().toString()),t.getValue().getValue())){ |
|
|
|
OpcItemDto itemDto = this.getItem(managedDataItem.getNodeId().getIdentifier().toString()); |
|
|
|
this.logItemChanged(managedDataItem.getNodeId().getIdentifier().toString(), accessor_value, OpcUtl.getValue(t.getValue()),itemDto); |
|
|
|
accessor_value.setValue(managedDataItem.getNodeId().getIdentifier().toString(), OpcUtl.getValue(t.getValue().getValue())); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
Async20Access accessor = null; |
|
|
|
|
|
|
|
while (true) { |
|
|
|
String opcGroupId = this.getOpcGroupID(); |
|
|
|
|
|
|
|
try { |
|
|
|
if (this.server == null) { |
|
|
|
// this.server = OpcServerUtl.getServerWithOutException(this.OpcServer.getOpc_host(), this.OpcServer.getCls_id(), this.OpcServer.getUser(), this.OpcServer.getPassword(), this.OpcServer.getDomain());
|
|
|
|
this.server = OpcUtl.getServer(this.OpcServer.getOpc_host(), this.OpcServer.getCls_id(), this.OpcServer.getUser(), this.OpcServer.getPassword(), this.OpcServer.getDomain()); |
|
|
|
this.server.addStateListener(this); |
|
|
|
accessor = new Async20Access(this.server, OpcConfig.synchronized_millisecond, true); |
|
|
|
Iterator var9 = this.protocols.iterator(); |
|
|
|
|
|
|
|
while (var9.hasNext()) { |
|
|
|
OpcItemDto protocol = (OpcItemDto) var9.next(); |
|
|
|
String itemId = protocol.getItem_code(); |
|
|
|
accessor.addItem(itemId, this); |
|
|
|
} |
|
|
|
}); |
|
|
|
} |
|
|
|
} catch (Exception e) { |
|
|
|
e.printStackTrace(); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
* 自定义订阅监听 |
|
|
|
*/ |
|
|
|
private class CustomSubscriptionListener implements UaSubscriptionManager.SubscriptionListener { |
|
|
|
accessor.bind(); |
|
|
|
log.info("Async20Access bind {}", opcGroupId); |
|
|
|
} |
|
|
|
|
|
|
|
private OpcUaClient client; |
|
|
|
Thread.sleep((long) (OpcConfig.synchronized_exception_wait_second * 1000)); |
|
|
|
} catch (Exception var8) { |
|
|
|
if (accessor != null) { |
|
|
|
try { |
|
|
|
log.warn("Async20Access unbind {}", opcGroupId); |
|
|
|
accessor.unbind(); |
|
|
|
} catch (Exception var7) { |
|
|
|
var7.printStackTrace(); |
|
|
|
} |
|
|
|
|
|
|
|
CustomSubscriptionListener(OpcUaClient client) { |
|
|
|
this.client = client; |
|
|
|
} |
|
|
|
accessor = null; |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void onKeepAlive(UaSubscription subscription, DateTime publishTime) { |
|
|
|
// System.out.println("onKeepAlive");
|
|
|
|
} |
|
|
|
if (this.server != null) { |
|
|
|
try { |
|
|
|
this.server.disconnect(); |
|
|
|
} catch (Exception var6) { |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void onStatusChanged(UaSubscription subscription, StatusCode status) { |
|
|
|
// System.out.println("onStatusChanged");
|
|
|
|
} |
|
|
|
this.server = null; |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void onPublishFailure(UaException exception) { |
|
|
|
// System.out.println("onPublishFailure");
|
|
|
|
} |
|
|
|
if (var8 instanceof InterruptedException) { |
|
|
|
log.warn("OPC 同步线程(%s)被中断", opcGroupId); |
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void onNotificationDataLost(UaSubscription subscription) { |
|
|
|
// System.out.println("onNotificationDataLost");
|
|
|
|
} |
|
|
|
log.warn("设备信息同步异常", var8); |
|
|
|
ThreadUtl.sleep((long) (OpcConfig.synchronized_exception_wait_second * 1000)); |
|
|
|
String error_message = var8.getMessage(); |
|
|
|
if (error_message == null) { |
|
|
|
error_message = var8.toString(); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 重连时 尝试恢复之前的订阅失败时 会调用此方法 |
|
|
|
* @param uaSubscription 订阅 |
|
|
|
* @param statusCode 状态 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public void onSubscriptionTransferFailed(UaSubscription uaSubscription, StatusCode statusCode) { |
|
|
|
System.out.println("恢复订阅失败 需要重新订阅"); |
|
|
|
//在回调方法中重新订阅
|
|
|
|
handlerNode(client); |
|
|
|
++this.error_num; |
|
|
|
if (this.error_num > 3 && !StrUtil.equals(this.message, error_message)) { |
|
|
|
this.message = error_message; |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
yanps
2 months ago