JAVA 连接KepServer OPC连接配置说明
- 安装软件
- 安装步骤
- 安装步骤
- 安装步骤设置安装路径 默认即可
- 配置DCOM
- 获取KepServer内的值
- 读取OPC数据
- 读取成功如下
- 写入值如下
- 把helloopc莫这个值修改成24
- 常见问题:FAQ
安装软件
- KEPServerEX 6 网盘下载 提取码:1234
- VMware 16 以及激活码 网盘下载 提取码:1234
- 虚拟机系统使用的是 系统之家win10 地址
安装步骤
1.双击打开KEPServerEX 6.4.321.0.exe
安装步骤
安装步骤设置安装路径 默认即可
配置DCOM
参考链接:https://blog.csdn.net/u011051912/article/details/109282856
配置防火墙如觉得麻烦 直接关闭防火墙即可
获取KepServer内的值
可参考：https://www.cnblogs.com/ioufev/p/9366877.html
视频教程创建字段：https://www.bilibili.com/video/BV13V411f7Ch/
读取OPC数据
import java.util.concurrent.Executors;
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.AccessBase;
import org.openscada.opc.lib.da.DataCallback;
import org.openscada.opc.lib.da.Item;
import org.openscada.opc.lib.da.ItemState;
import org.openscada.opc.lib.da.Server;
import org.openscada.opc.lib.da.SyncAccess;
public class UtgardTutorial1 {
public static void main(String[] args) throws Exception {
// 连接信息
final ConnectionInformation ci = new ConnectionInformation();
ci.setHost("192.168.44.128"); // 安装opc电脑IP
ci.setDomain(""); // 域，为空就行
ci.setUser("OPCServer"); // 电脑上自己建好的用户名
ci.setPassword("123456"); // 用户名的密码
ci.setClsid("7BC0CC8E-482C-47CA-ABDC-0FE7F9C6E729"); // KEPServer的注册表ID，可以在“组件服务”里看到
// ci.setProgId("");
// 要读取的标记
String itemId = "通道 1.设备 2.tag1";
// final String itemId = "通道 1.设备 1.标记 1";
// 启动服务
final Server server = new Server(ci, Executors.newSingleThreadScheduledExecutor());
try {
// 连接到服务
server.connect();
// add sync access, poll every 500 ms，启动一个同步的access用来读取地址上的值，线程池每500ms读值一次
// 这个是用来循环读值的，只读一次值不用这样
final AccessBase access = new SyncAccess(server, 500);
// 这是个回调函数，就是读到值后执行这个打印，是用匿名类写的，当然也可以写到外面去
System.err.println(access);
access.addItem(itemId, 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);
}
}
});
// 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())));
}
}
}
读取成功如下
写入值如下
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import org.jinterop.dcom.common.JIException;
import org.jinterop.dcom.core.JIVariant;
import org.openscada.opc.lib.common.ConnectionInformation;
import org.openscada.opc.lib.da.AccessBase;
import org.openscada.opc.lib.da.DataCallback;
import org.openscada.opc.lib.da.Group;
import org.openscada.opc.lib.da.Item;
import org.openscada.opc.lib.da.ItemState;
import org.openscada.opc.lib.da.Server;
import org.openscada.opc.lib.da.SyncAccess;
public class UtgardTutorial2 {
public static void main(String[] args) throws Exception {
// 连接信息
final ConnectionInformation ci = new ConnectionInformation();
ci.setHost("192.168.44.128"); // 安装opc电脑IP
ci.setDomain(""); // 域，为空就行
ci.setUser("OPCServer"); // 电脑上自己建好的用户名
ci.setPassword("123456"); // 用户名的密码
ci.setClsid("7BC0CC8E-482C-47CA-ABDC-0FE7F9C6E729"); // KEPServer的注册表ID，可以在“组件服务”里看到
// ci.setProgId("");
// 要读取的标记
String itemId = "通道 2.设备 1.TAG5";
// create a new server，启动服务
final Server server = new Server(ci, Executors.newSingleThreadScheduledExecutor());
try {
// connect to server，连接到服务
System.err.println("启动成功~");
server.connect();
// add sync access, poll every 500 ms，启动一个同步的access用来读取地址上的值，线程池每500ms读值一次
// 这个是用来循环读值的，只读一次值不用这样
final AccessBase access = new SyncAccess(server, 500);
// 这是个回调函数，就是读到值后执行再执行下面的代码，是用匿名类写的，当然也可以写到外面去
access.addItem(itemId, new DataCallback() {
@Override
public void changed(Item item, ItemState state) {
// also dump value
try {
if (state.getValue().getType() == JIVariant.VT_UI4) { // 如果读到的值类型时UnsignedInteger，即无符号整形数值
System.out.println("<<< " + state + " / value = " + state.getValue().getObjectAsUnsigned().getValue());
} else {
System.out.println("<<< " + state + " / value = " + state.getValue().getObject());
}
} catch (JIException e) {
e.printStackTrace();
}
}
});
// Add a new group，添加一个组，这个用来就读值或者写值一次，而不是循环读取或者写入
// 组的名字随意，给组起名字是因为，server可以addGroup也可以removeGroup，读一次值，就先添加组，然后移除组，再读一次就再添加然后删除
final Group group = server.addGroup("test");
// Add a new item to the group，
// 将一个item加入到组，item名字就是MatrikonOPC Server或者KEPServer上面建的项的名字比如：u.u.TAG1，PLC.S7-300.TAG1
final Item item = group.addItem(itemId);
// start reading，开始循环读值
access.bind();
// add a thread for writing a value every 3 seconds
// 写入一次就是item.write(value)，循环写入就起个线程一直执行item.write(value)
ScheduledExecutorService writeThread = Executors.newSingleThreadScheduledExecutor();
writeThread.scheduleWithFixedDelay(new Runnable() {
@Override
public void run() {
final JIVariant value = new JIVariant("24"); // 写入24
try {
System.out.println(">>> " + "写入值： " + "24");
item.write(value);
} catch (JIException e) {
e.printStackTrace();
}
}
}, 5, 3, TimeUnit.SECONDS); // 启动后5秒第一次执行代码，以后每3秒执行一次代码
// wait a little bit ，延时20秒
Thread.sleep(20 * 1000);
writeThread.shutdownNow(); // 关掉一直写入的线程
// stop reading，停止循环读取数值
access.unbind();
} catch (final JIException e) {
System.out.println(String.format("%08X: %s", e.getErrorCode(), server.getErrorMessage(e.getErrorCode())));
}
}
}
把helloopc莫这个值修改成24
常见问题:FAQ
Message not found for errorCode: 0x80010111 这个错误
出现这个问题是windows问题windows10版本 2004之后的协议都是5.7，utgard的协议是5.6的，把win10降到1909就不会报这个错了
