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();
		}
	}
}