package org.example.opc;
|
|
import org.jinterop.dcom.common.JIException;
|
import org.openscada.opc.lib.common.ConnectionInformation;
|
import org.openscada.opc.lib.da.*;
|
|
|
import java.util.concurrent.Executors;
|
|
|
import static org.example.opc.conf.OPCConfiguration.getCLSIDConnectionInfomation;
|
|
/**
|
* 功能：OPC通信线程 描述：通过循环读取心跳和状态控制字，按照商议好的交互流程读写变量
|
*/
|
public class OPCComm {
|
|
private Server server;
|
|
|
private Item ZYYSTART;//开始
|
private Item ZYYEND;//结束
|
private Item P1;//心跳
|
|
|
/**
|
* 单例模式
|
*/
|
private static class SingletonHolder {
|
static final OPCComm doOPCComm = new OPCComm();
|
}
|
public static OPCComm getInstance() {
|
return SingletonHolder.doOPCComm;
|
}
|
/**
|
* 启动server 创建一个监控线程 创建一个写入线程
|
*/
|
public void init() throws Exception {
|
|
|
// 加载配置文件
|
final ConnectionInformation ci = getCLSIDConnectionInfomation();
|
// 创建server
|
final Server server = new Server(ci, Executors.newSingleThreadScheduledExecutor());
|
|
try {
|
// 启动server
|
server.connect();
|
GlobalVariable.textArea.append("OPC连接成功………………………………………………"+"\r\n");
|
this.server = server;
|
// 同步读取，500ms一次
|
final AccessBase access = new SyncAccess(server, 500);
|
|
//OP010组
|
final Group OP010_GROUP = server.addGroup("OP140_ZYY");
|
ZYYSTART = OP010_GROUP.addItem((OPCElement.ZYYSTART));//心跳
|
ZYYEND = OP010_GROUP.addItem((OPCElement.ZYYEND));//心跳
|
P1 = OP010_GROUP.addItem((OPCElement.P1));//心跳
|
|
// start reading
|
access.bind();
|
} catch (final JIException e) {
|
GlobalVariable.textArea.append("OPC连接失败………………………………………………"+"\r\n");
|
GlobalVariable.textArea.append(e.getMessage()+"\r\n");
|
Thread.sleep(1000*10);
|
//init();
|
System.out.println(String.format("%08X: %s", e.getErrorCode(), server.getErrorMessage(e.getErrorCode())));
|
}
|
}
|
|
public Server getServer() {
|
return server;
|
}
|
|
public Item getZYYSTART() {
|
return ZYYSTART;
|
}
|
|
public Item getZYYEND() {
|
return ZYYEND;
|
}
|
|
public Item getP1() {
|
return P1;
|
}
|
}
|
