package com.qianwen.mdc.service.opcua;
|
|
import org.eclipse.milo.opcua.sdk.client.OpcUaClient;
|
import org.eclipse.milo.opcua.sdk.client.api.subscriptions.UaMonitoredItem;
|
import org.eclipse.milo.opcua.sdk.client.api.subscriptions.UaMonitoredItem.ValueConsumer;
|
import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue;
|
import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId;
|
import org.junit.jupiter.api.Test;
|
|
public class MyOpcuaClientTest {
|
|
@Test
|
public void t() {
|
ValueConsumer vc = new ValueConsumer() {
|
|
@Override
|
public void onValueArrived(UaMonitoredItem item, DataValue value) {
|
//处理数据
|
System.out.println(value);
|
}
|
|
};
|
|
MyOpcuaClilent mc = new MyOpcuaClilent();
|
try {
|
OpcUaClient client = mc.connect("yangys-HW", 53530, "/OPCUA/SimulationServer");
|
mc.setValueConsumer(vc);
|
//mc.subscribe("1001");
|
|
|
//Object val = mc.readValue(3, 1001);
|
|
//System.out.println(val);
|
NodeId nodeId = new NodeId(3, "abcd");
|
mc.readNodeValue(client,nodeId);
|
}catch(Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|