openscada java_在Java环境中使用OpenSCADA的utgard子项目连接OPCserver

分别是：j-Interop三个，

utgrad两个，slf4j两个。

package com.casit;

import java.net.UnknownHostException;

import java.util.concurrent.Executors;

import org.jinterop.dcom.common.JIException;

import org.jinterop.dcom.common.JISystem;

import org.jinterop.dcom.core.JIVariant;

import org.openscada.opc.lib.common.ConnectionInformation;

import org.openscada.opc.lib.common.NotConnectedException;

import org.openscada.opc.lib.da.AddFailedException;

import org.openscada.opc.lib.da.AutoReconnectController;

import org.openscada.opc.lib.da.DuplicateGroupException;

import org.openscada.opc.lib.da.Group;

import org.openscada.opc.lib.da.Item;

import org.openscada.opc.lib.da.Server;

public class SCADA {

public static void main(String[] args){

AutoReconnectController autos = null;

try {

JISystem.setAutoRegisteration(true);

ConnectionInformation ci = new ConnectionInformation();

ci.setHost("localhost");

ci.setDomain("localhost");

ci.setClsid("6E6170F0-FF2D-11D2-8087-00105AA8F840");

ci.setUser("Administrator");

ci.setPassword("123");

final Server s = new Server(ci,Executors.newSingleThreadScheduledExecutor());

autos = new AutoReconnectController(s);

autos.connect();Thread.sleep(100);

//   dumpTree(s.getTreeBrowser().browse(),0);

Group group = s.addGroup("test");

group.setActive(true);

final Item item = group.addItem("Channel1.Device1.D0");

item.setActive(true);

Thread.sleep(100);

System.out.println("读取值："+item.read(false).getValue().getObjectAsUnsigned().getValue());

JIVariant value = JIVariant.makeVariant(new Integer(777));

item.write(value);

//   final AccessBase access = new Async20Access(s,100,false);

//            access.addItem ( "sim.test.D0", new DataCallbackDumper());

//            access.bind ();

//            Thread.sleep(100*1000);

//            access.unbind();

} catch (IllegalArgumentException e) {

e.printStackTrace();

} catch (UnknownHostException e) {

e.printStackTrace();

} catch (JIException e) {

e.printStackTrace();

} catch (NotConnectedException e) {

e.printStackTrace();

} catch (DuplicateGroupException e) {

e.printStackTrace();

} catch (AddFailedException e) {

e.printStackTrace();

} catch (InterruptedException e) {

e.printStackTrace();

}finally{

autos.disconnect();

}

}

}

中间注释的部分采用监听模式。