Java实现opc通信协议代码

import org.jinterop.dcom.common.JIException; import org.jinterop.dcom.core.JIString; import org.jinterop.dcom.core.JIVariant; import org.openscada.opc.lib.common.ConnectionInformation; import org.openscada.opc.lib.da.*; import java.util.Collection; import java.util.Iterator; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; //172.20.10.3 public class UtgardTutorial2 { public static void main(String[] args) throws Exception { // 连接信息 final ConnectionInformation ci = new ConnectionInformation(); ci.setHost("172.20.10.3"); // 本机IP ci.setDomain(""); // 域，为空就行 ci.setUser("OPCServer"); // 本机上自己建好的用户名 ci.setPassword("123456"); // 密码 // 使用MatrikonOPC Server的配置 // ci.setClsid("F8582CF2-88FB-11D0-B850-00C0F0104305"); // MatrikonOPC的注册表ID，可以在“组件服务”里看到 // final String itemId = "u.u"; // MatrikonOPC Server上配置的项的名字按实际 // 使用KEPServer的配置 ci.setClsid("7BC0CC8E-482C-47CA-ABDC-0FE7F9C6E729"); // KEPServer的注册表ID，可以在“组件服务”里看到，上面有图片说明 //final String itemId = "u.u.u"; // KEPServer上配置的项的名字，没有实际PLC，用的模拟器：simulator //final String[] itemId = {"通道 2.设备 1.TAG1","通道 2.设备 1.TAG3", "通道 2.设备 1.TAG5"}; // 启动服务 final Server server = new Server(ci, Executors.newSingleThreadScheduledExecutor()); server.connect(); GetName.dumpTree(server.getTreeBrowser().browse(), 0); Collection<String> itemId = GetName.dumpFlat(server.getFlatBrowser()); Iterator<String> iterator = itemId.iterator(); try { // 连接到服务 // add sync access, poll every 500 ms，启动一个同步的access用来读取地址上的值，线程池每500ms读值一次 // 这个是用来循环读值的，只读一次值不用这样 final AccessBase access = new SyncAccess(server, 500); // 这是个回调函数，就是读到值后执行这个打印，是用匿名类写的，当然也可以写到外面去 while(iterator.hasNext()){ access.addItem(iterator.next(), new DataCallback() { @Override public void changed(Item item, ItemState itemState) { int type = 0; try { type = itemState.getValue().getType(); // 类型实际是数字，用常量定义的 } catch (JIException e) { e.printStackTrace(); } System.out.println("监控项的数据类型是：-----" + type); System.out.println("监控项的时间戳是：-----" + itemState.getTimestamp().getTime()); System.out.println("监控项的详细信息是：-----" + itemState); // 如果读到是short类型的值 if (type == JIVariant.VT_I2) { short n = 0; try { n = itemState.getValue().getObjectAsShort(); } catch (JIException e) { e.printStackTrace(); } System.out.println("-----short类型值： " + n); } // 如果读到是字符串类型的值 if(type == JIVariant.VT_BSTR) { // 字符串的类型是8 JIString value = null; try { value = itemState.getValue().getObjectAsString(); } catch (JIException e) { e.printStackTrace(); } // 按字符串读取 String str = value.getString(); // 得到字符串 System.out.println("-----String类型值： " + str); } // 如果读到是浮点型类型的值 if(type == JIVariant.VT_R4) { float f = 0.0f; try { f = itemState.getValue().getObjectAsFloat(); } catch (JIException e) { e.printStackTrace(); } System.out.println("-----flaot类型值： " + f); } } }); // start reading，开始读值 access.bind(); // wait a little bit，有个10秒延时 Thread.sleep(10 * 1000); // stop reading，停止读取 access.unbind(); } } catch (final JIException e) { System.out.println(String.format("%08X: %s", e.getErrorCode(), server.getErrorMessage(e.getErrorCode()))); } } }