1、OPC解释
-一系列接口、方法和属性的标准集
基于OLE、COM、DCOM技术、XML，采用客户端/服务器结构
将通讯协议与设备/应用隔离
2、使用openscada连接OPC
-OPC组成对象：
服务器 OPC Server
组对象 Group
项对象 Item
-openscada开源项目
ConnectionInformation中：
*Host 本地主机/网络主机IP
*Domain 域（默认localhost）
*User 用户名
*Password 用户登录密码
*Clsid 应用在注册表中相对应的CLSID值
*Grogid 应用在注册表中对应的程序名称
Clsid和Grogid只需设置一个，优先Clsid
3、开发过程
1）设置服务器信息
private static String host = "172.16.31.2";
private static String user = "admin";
private static String passwd = "123456";
private static String progId = "S7300ET200M station_1"
2）通过ServerList类获取服务端所有OPCServer
ServerList serverList = new ServerList(host,user,passwd);
showAllOPCServer(serverList);
3）创建ConnectionInformation类
final ConnectionInformation ci = new ConnectionInformation();
ci.setHost(host);
ci.setClsid(serverList.getClsidFromProgId("S7300ET200M station_1");
ci.setUser(user);
ci.setPassword(passwd);
4）创建Server类并连接，需要处理connect方法可能抛出的异常
ScheduledExecutorService exec = Executors.newSingleThreadScheduledExecutor();
Server server = new Server(ci, exec);
server.connect();
假如两次访问间隔较长，可以通过AutoReconnectController类来自动重新创立连接
ScheduledExecutorService exec = Executors.newSingleThreadScheduledExecutor();
Server server = new Server(ci, exec);
AutoReconnectController autoReconnectController = new AutoReconnectController ( server );
autoReconnectController.connect();
5）Utgard的数据访问方式
直接通过item的read/write方法或者使用AccessBase（读取数据）
需要注意的是，不管采用哪一种方式，返回结果都是通过ItemState
类来获取，通过调用ItemState的getValue方法可以获得访问结果，
返回结果是JIVarant类型的。
A:通过item的read/write方法
/**
* 使用Item类write方法写入数据，并直接通过Item的read方法同步读数据
* @throws Exception
*/
public static void syncWrite(Server server) throws Exception{
final String itemId="Bucket Brigade.Int4";
Group group = server.addGroup("test");
Item item = group.addItem(itemId); //get item for writing
//第一次读
ItemState itemState = item.read(true);
System.out.println("<<< first read: " + itemState.getValue());
final JIVariant value = new JIVariant(100);
try {
System.out.println(">>> writing value: " + value.getObjectAsInt());
item.write(value);
} catch (JIException e) {
e.printStackTrace();
}
itemState = item.read(true);
System.out.println("<<< after writing: " + itemState.getValue());
}
B:使用AccesBase类（读取数据）
AccesBase接口有两个实现类：SyncAccess类和Async20Access类
a）同步访问SyncAccess
/**
* 使用SyncAccess类隔时间段地进行同步读取数据
* SyncAccess实现了Runnable接口，实际上通过另一个线程进行同步读
* @throws Exception
*/
public static void syncRead(Server server) throws Exception{
final String itemId="Random.Int4";
//每隔1秒同步读
AccessBase access = new SyncAccess(server,1000);
access.addItem(itemId, new DataCallback() {
@Override
public void changed(Item item, ItemState itemState) {
System.out.println(itemState);
}
});
// start reading
access.bind();
// wait a little bit
Thread.sleep(5*1000);
// stop reading
access.unbind();
}
b）异步访问Async20Access类
/**
* 使用Async20Access类隔时间段地进行异步读取数据
* Async20Access实现了IOPCDataCallback接口，基于事件回调的实现
* @throws Exception
*/
public static void asyncRead(Server server) throws Exception{
final String itemId = "Random.Int4";
//第三个参数用于设置初始化时是否执行访问
AccessBase access = new Async20Access(server, 1000, false);
access.addItem(itemId, new DataCallback(){
@Override
public void changed(Item item, ItemState itemState) {
System.out.println(">>> Asynchronized read: value="
+ itemState.getValue());
}
});
access.bind();
Thread.sleep(5*1000);
access.unbind();
} 