參考前輩的踩坑記錄https://blog.csdn.net/weixin_45411740/article/details/124275985?spm=1001.2014.3001.5502，我Hyb在2023-3-15調(diào)通了自己的JavaOpcUaDemo。具體Java代碼和KepServerEX延時(shí)補(bǔ)丁都在資源中。
第1步：安裝激活KepServer，補(bǔ)丁在資源中，不詳述。
第2步：在KepServer中做OpcUa配置。
2.1 先看桌面右下角有沒EX圖標(biāo)
2.2 如果沒有EX圖標(biāo)，要去開始菜單中找到KEPServerEX 6 Administration，點(diǎn)擊打開它后，桌面右下角就會(huì)出現(xiàn)EX圖標(biāo)：
2.3 右鍵點(diǎn)擊EX圖標(biāo)，選擇“OPC UA 配置”，設(shè)置過程看這個(gè)動(dòng)圖：（一定要關(guān)注動(dòng)圖中192.168.10.60這個(gè)ip及端口的設(shè)置，它要與你代碼中一致！）
第3步：在KepServer中設(shè)置用戶名密碼。
3.1 再一次點(diǎn)桌面右下角的EX圖標(biāo)，選擇“設(shè)置”，點(diǎn)“用戶管理器”，在Administrators右鍵選擇“添加用戶”。見圖操作：
第4步：在KepServer中設(shè)置opcua匿名賬戶登錄。
在KepServerEX界面，在“項(xiàng)目”右鍵，選擇“屬性”，選擇“OPC UA”。在“客戶端會(huì)話”、“允許匿名登錄”中，選擇“是”。如圖：
以上KepServerEX設(shè)置完成后，就可以構(gòu)建Java項(xiàng)目了。
第5步：首先搭建環(huán)境。下載Eclipse、配置Maven
上圖分別對(duì)應(yīng)：
5.1 從Maven下載安裝包：apache-maven-3.9.0-bin.zip
5.2 配置Maven本地倉庫在：conf/settings.xml
<localRepository>${MAVEN_HOME}/repoHyb</localRepository>5.3 配置Maven鏡像：從阿里云Maven鏡像同步和下載jar
<mirror><!--配置具體的倉庫的下載鏡像 從阿里云Maven倉庫下載-->
<id>nexus-aliyun</id><!-- 此鏡像的唯一標(biāo)識(shí)符，用來區(qū)分不同的mirror元素 -->
<mirrorOf>central</mirrorOf><!-- 對(duì)哪種倉庫進(jìn)行鏡像，簡單說就是替代哪個(gè)倉庫-->
<name>Nexus aliyun</name><!-- 鏡像名稱 -->
<url>http://maven.aliyun.com/nexus/content/groups/public</url>
</mirror>5.4 在Eclipse中設(shè)置Maven安裝路徑
5.5 在Eclipse中設(shè)置Maven的配置文件
第6步：以上環(huán)境搭建好后，就可以正式coding了。
6.1 在eclipse中創(chuàng)建maven項(xiàng)目，并在pom.xml中配置Milo客戶端依賴：
<dependency>
<groupId>org.eclipse.milo</groupId>
<artifactId>sdk-client</artifactId>
<version>0.6.3</version>
</dependency>
<dependency>
<groupId>org.eclipse.milo</groupId>
<artifactId>sdk-server</artifactId>
<version>0.6.3</version>
</dependency>
Milo是Eclipse旗下的一個(gè)物聯(lián)網(wǎng)的項(xiàng)目，是一個(gè)高性能的OPC UA棧，提供了一組客戶端和服務(wù)端的API，支持對(duì)實(shí)時(shí)數(shù)據(jù)的訪問，監(jiān)控，報(bào)警，訂閱數(shù)據(jù)，支持事件，歷史數(shù)據(jù)訪問，和數(shù)據(jù)建模。官網(wǎng)https://projects.eclipse.org/projects/iot.milo
在Milo中大量的采用了java 8的新特性CompletableFuture來進(jìn)行異步操作，Milo中有大量的操作都是直接返回CompletableFuture對(duì)象，所以JDK的版本必須要8.0，對(duì)CompletableFuture不太熟悉的可以先去了解CompletableFuture的相關(guān)概念在來看Milo的官方例子會(huì)輕松很多。
6.2 然后就是java代碼，只有一個(gè)類TestOpcUA.java，代碼全部在這一個(gè)java文件中。直接復(fù)制到你java文件中，不用再導(dǎo)入任何類，加個(gè)包名，直接可以運(yùn)行。
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicInteger;
import org.eclipse.milo.opcua.sdk.client.OpcUaClient;
import org.eclipse.milo.opcua.sdk.client.api.identity.AnonymousProvider;
import org.eclipse.milo.opcua.sdk.client.api.subscriptions.UaSubscription;
import org.eclipse.milo.opcua.sdk.client.api.subscriptions.UaSubscriptionManager;
import org.eclipse.milo.opcua.sdk.client.nodes.UaNode;
import org.eclipse.milo.opcua.sdk.client.subscriptions.ManagedDataItem;
import org.eclipse.milo.opcua.sdk.client.subscriptions.ManagedSubscription;
import org.eclipse.milo.opcua.stack.core.AttributeId;
import org.eclipse.milo.opcua.stack.core.Identifiers;
import org.eclipse.milo.opcua.stack.core.UaException;
import org.eclipse.milo.opcua.stack.core.security.SecurityPolicy;
import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue;
import org.eclipse.milo.opcua.stack.core.types.builtin.DateTime;
import org.eclipse.milo.opcua.stack.core.types.builtin.LocalizedText;
import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId;
import org.eclipse.milo.opcua.stack.core.types.builtin.StatusCode;
import org.eclipse.milo.opcua.stack.core.types.builtin.Variant;
import org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger;
import org.eclipse.milo.opcua.stack.core.types.enumerated.MonitoringMode;
import org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn;
import org.eclipse.milo.opcua.stack.core.types.structured.MonitoredItemCreateRequest;
import org.eclipse.milo.opcua.stack.core.types.structured.MonitoringParameters;
import org.eclipse.milo.opcua.stack.core.types.structured.ReadValueId;
public class TestOpcUA {
private final static String endPointUrl = "opc.tcp://192.168.10.60:49320";
/**
* 創(chuàng)建OPC UA客戶端
*/
private static OpcUaClient createClient() throws Exception {
//opc ua服務(wù)端地址
Path securityTempDir = Paths.get(System.getProperty("java.io.tmpdir"), "security");
Files.createDirectories(securityTempDir);
if (!Files.exists(securityTempDir)) {
throw new Exception("unable to create security dir: " + securityTempDir);
}
return OpcUaClient.create(endPointUrl, endpoints -> endpoints.stream().filter(e -> e.getSecurityPolicyUri().equals(SecurityPolicy.None.getUri())).findFirst(), configBuilder -> configBuilder.setApplicationName(LocalizedText.english("eclipse milo opc-ua client")).setApplicationUri("urn:eclipse:milo:examples:client")
//訪問方式
.setIdentityProvider(new AnonymousProvider()).setRequestTimeout(UInteger.valueOf(500)).build());
}
/**
* 遍歷樹形節(jié)點(diǎn)
*
* @param client OPC UA客戶端
* @param uaNode 節(jié)點(diǎn)
* @throws Exception
*/
private static void browseNode(OpcUaClient client, UaNode uaNode) throws Exception {
List<? extends UaNode> nodes;
if (uaNode == null) {
nodes = client.getAddressSpace().browseNodes(Identifiers.ObjectsFolder);
} else {
nodes = client.getAddressSpace().browseNodes(uaNode);
}
for (UaNode nd : nodes) {
//排除系統(tǒng)行性節(jié)點(diǎn)，這些系統(tǒng)性節(jié)點(diǎn)名稱一般都是以"_"開頭
if (Objects.requireNonNull(nd.getBrowseName().getName()).contains("_")) {
continue;
}
System.out.println("Node= " + nd.getBrowseName().getName());
browseNode(client, nd);
}
}
/**
* 讀取節(jié)點(diǎn)數(shù)據(jù)
*
* @param client OPC UA客戶端
* @throws Exception
*/
private static void readNode(OpcUaClient client) throws Exception {
int namespaceIndex = 2;
String identifier = "通道 1.設(shè)備 1.標(biāo)記 1";
//節(jié)點(diǎn)
NodeId nodeId = new NodeId(namespaceIndex, identifier);
//讀取節(jié)點(diǎn)數(shù)據(jù)
DataValue value = client.readValue(0.0, TimestampsToReturn.Neither, nodeId).get();
//標(biāo)識(shí)符
identifier = String.valueOf(nodeId.getIdentifier());
System.out.println(identifier + ": " + String.valueOf(value.getValue().getValue()));
}
/**
* 寫入節(jié)點(diǎn)數(shù)據(jù)
*
* @param client
* @throws Exception
*/
private static void writeNodeValue(OpcUaClient client) throws Exception {
//節(jié)點(diǎn)
NodeId nodeId = new NodeId(2, "通道 1.設(shè)備 1.標(biāo)記 4");
Short i = 48;
//創(chuàng)建數(shù)據(jù)對(duì)象,此處的數(shù)據(jù)對(duì)象一定要定義類型，不然會(huì)出現(xiàn)類型錯(cuò)誤，導(dǎo)致無法寫入
DataValue nowValue = new DataValue(new Variant(i), null, null);
//寫入節(jié)點(diǎn)數(shù)據(jù)
StatusCode statusCode = client.writeValue(nodeId, nowValue).join();
System.out.println("結(jié)果：" + statusCode.isGood());
}
/**
* 訂閱(單個(gè))
*
* @param client
* @throws Exception
*/
private static void subscribe(OpcUaClient client) throws Exception {
AtomicInteger a = new AtomicInteger();
//創(chuàng)建發(fā)布間隔1000ms的訂閱對(duì)象
client.getSubscriptionManager().createSubscription(1000.0).thenAccept(t -> {
//節(jié)點(diǎn)
NodeId nodeId = new NodeId(2, "通道 1.設(shè)備 1.標(biāo)記 1");
ReadValueId readValueId = new ReadValueId(nodeId, AttributeId.Value.uid(), null, null);
//創(chuàng)建監(jiān)控的參數(shù)
MonitoringParameters parameters = new MonitoringParameters(UInteger.valueOf(a.getAndIncrement()), 1000.0, null, UInteger.valueOf(10), true);
//創(chuàng)建監(jiān)控項(xiàng)請(qǐng)求
//該請(qǐng)求最后用于創(chuàng)建訂閱。
MonitoredItemCreateRequest request = new MonitoredItemCreateRequest(readValueId, MonitoringMode.Reporting, parameters);
List<MonitoredItemCreateRequest> requests = new ArrayList<>();
requests.add(request);
//創(chuàng)建監(jiān)控項(xiàng)，并且注冊(cè)變量值改變時(shí)候的回調(diào)函數(shù)。
t.createMonitoredItems(TimestampsToReturn.Both, requests, (item, id) -> item.setValueConsumer((it, val) -> {
System.out.println("nodeid :" + it.getReadValueId().getNodeId());
System.out.println("value :" + val.getValue().getValue());
}));
}).get();
//持續(xù)訂閱
Thread.sleep(Long.MAX_VALUE);
}
/**
* 批量訂閱
*
* @param client
* @throws Exception
*/
// private static void managedSubscriptionEvent(OpcUaClient client) throws Exception {
// final CountDownLatch eventLatch = new CountDownLatch(1);
//
// //處理訂閱業(yè)務(wù)
// handlerNode(client);
//
// //持續(xù)監(jiān)聽
// eventLatch.await();
// }
/**
* 處理訂閱業(yè)務(wù)
*
* @param client OPC UA客戶端
*/
private static void handlerNode(OpcUaClient client) {
try {
//創(chuàng)建訂閱
ManagedSubscription subscription = ManagedSubscription.create(client);
//你所需要訂閱的key
List<String> key = new ArrayList<>();
key.add("通道 1.設(shè)備 1.標(biāo)記 4");
key.add("通道 1.設(shè)備 1.標(biāo)記 1");
List<NodeId> nodeIdList = new ArrayList<>();
for (String s : key) {
nodeIdList.add(new NodeId(2, s));
}
//監(jiān)聽
List<ManagedDataItem> dataItemList = subscription.createDataItems(nodeIdList);
for (ManagedDataItem managedDataItem : dataItemList) {
managedDataItem.addDataValueListener((t) -> {
System.out.println(managedDataItem.getNodeId().getIdentifier().toString() + ":" + t.getValue().getValue().toString());
});
}
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 自定義訂閱監(jiān)聽
*/
private static class CustomSubscriptionListener implements UaSubscriptionManager.SubscriptionListener {
private OpcUaClient client;
CustomSubscriptionListener(OpcUaClient client) {
this.client = client;
}
public void onKeepAlive(UaSubscription subscription, DateTime publishTime) {
System.out.println("onKeepAlive");
}
public void onStatusChanged(UaSubscription subscription, StatusCode status) {
System.out.println("onStatusChanged");
}
public void onPublishFailure(UaException exception) {
System.out.println("onPublishFailure");
}
public void onNotificationDataLost(UaSubscription subscription) {
System.out.println("onNotificationDataLost");
}
/**
* 重連時(shí) 嘗試恢復(fù)之前的訂閱失敗時(shí) 會(huì)調(diào)用此方法
* @param uaSubscription 訂閱
* @param statusCode 狀態(tài)
*/
public void onSubscriptionTransferFailed(UaSubscription uaSubscription, StatusCode statusCode) {
System.out.println("恢復(fù)訂閱失敗 需要重新訂閱");
//在回調(diào)方法中重新訂閱
handlerNode(client);
}
}
/**
* 批量訂閱
*
* @param client
* @throws Exception
*/
private static void managedSubscriptionEvent(OpcUaClient client) throws Exception {
final CountDownLatch eventLatch = new CountDownLatch(1);
//添加訂閱監(jiān)聽器，用于處理斷線重連后的訂閱問題
client.getSubscriptionManager().addSubscriptionListener(new CustomSubscriptionListener(client));
//處理訂閱業(yè)務(wù)
handlerNode(client);
//持續(xù)監(jiān)聽
eventLatch.await();
}
public static void main(String[] args) throws Exception {
OpcUaClient client = createClient();
client.connect().get();
// browseNode(client, null);
// readNode(client);
// writeNodeValue(client);
subscribe(client);
// managedSubscriptionEvent(client);
}
}本文涉及的java項(xiàng)目代碼和KepServerEX補(bǔ)丁下載地址：https://download.csdn.net/download/qq_28530139/87579334文章來源：http://www.zghlxwxcb.cn/news/detail-482020.html
Hyb???本文結(jié)束，謝謝瀏覽【VX:m3920752】！個(gè)人資源的解壓密碼是: hyb文章來源地址http://www.zghlxwxcb.cn/news/detail-482020.html
到了這里，關(guān)于Java 001：通過OPC UA協(xié)議連接KepServerEx進(jìn)行讀、寫、訂閱操作的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
