opcua代码提交

seatunnel-datasource/seatunnel-datasource-plugins/datasource-opcua-kepserver/src/main/java/org/apache/seatunnel/datasource/plugin/opcua/KeyStoreLoader.java

+package org.apache.seatunnel.datasource.plugin.opcua;
+/*
+ * Copyright (c) 2021 the Eclipse Milo Authors
+ *
+ * This program and the accompanying materials are made
+ * available under the terms of the Eclipse Public License 2.0
+ * which is available at https://www.eclipse.org/legal/epl-2.0/
+ *
+ * SPDX-License-Identifier: EPL-2.0
+ */
+
+import org.eclipse.milo.opcua.sdk.server.util.HostnameUtil;
+import org.eclipse.milo.opcua.stack.core.util.SelfSignedCertificateBuilder;
+import org.eclipse.milo.opcua.stack.core.util.SelfSignedCertificateGenerator;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.security.*;
+import java.security.cert.X509Certificate;
+import java.util.Arrays;
+import java.util.regex.Pattern;
+
+class KeyStoreLoader {
+
+    private static final Pattern IP_ADDR_PATTERN =
+            Pattern.compile(
+                    "^(([01]?\\d\\d?|2[0-4]\\d|25[0-5])\\.){3}([01]?\\d\\d?|2[0-4]\\d|25[0-5])$");
+
+    private static final String CLIENT_ALIAS = "client-ai";
+    private static final char[] PASSWORD = "password".toCharArray();
+
+    private final Logger logger = LoggerFactory.getLogger(getClass());
+
+    private X509Certificate[] clientCertificateChain;
+    private X509Certificate clientCertificate;
+    private KeyPair clientKeyPair;
+
+    KeyStoreLoader load(Path baseDir, String endPoint) throws Exception {
+        KeyStore keyStore = KeyStore.getInstance("PKCS12");
+
+        Path serverKeyStore = baseDir.resolve("example-client.pfx");
+
+        logger.info("Loading KeyStore at {}", serverKeyStore);
+
+        if (!Files.exists(serverKeyStore)) {
+            keyStore.load(null, PASSWORD);
+
+            KeyPair keyPair = SelfSignedCertificateGenerator.generateRsaKeyPair(2048);
+
+            SelfSignedCertificateBuilder builder =
+                    new SelfSignedCertificateBuilder(keyPair)
+                            .setCommonName("Eclipse Milo Example Client")
+                            .setOrganization("digitalpetri")
+                            .setOrganizationalUnit("dev")
+                            .setLocalityName("Folsom")
+                            .setStateName("CA")
+                            .setCountryCode("US")
+                            .setApplicationUri(endPoint);
+            //                    .addDnsName("localhost")
+            //                    .addIpAddress("192.168.0.101");
+
+            // Get as many hostnames and IP addresses as we can listed in the certificate.
+            for (String hostname : HostnameUtil.getHostnames("0.0.0.0")) {
+                if (IP_ADDR_PATTERN.matcher(hostname).matches()) {
+                    builder.addIpAddress(hostname);
+                } else {
+                    builder.addDnsName(hostname);
+                }
+            }
+
+            X509Certificate certificate = builder.build();
+
+            keyStore.setKeyEntry(
+                    CLIENT_ALIAS,
+                    keyPair.getPrivate(),
+                    PASSWORD,
+                    new X509Certificate[] {certificate});
+            try (OutputStream out = Files.newOutputStream(serverKeyStore)) {
+                keyStore.store(out, PASSWORD);
+            }
+        } else {
+            try (InputStream in = Files.newInputStream(serverKeyStore)) {
+                keyStore.load(in, PASSWORD);
+            }
+        }
+
+        Key clientPrivateKey = keyStore.getKey(CLIENT_ALIAS, PASSWORD);
+        if (clientPrivateKey instanceof PrivateKey) {
+            clientCertificate = (X509Certificate) keyStore.getCertificate(CLIENT_ALIAS);
+
+            clientCertificateChain =
+                    Arrays.stream(keyStore.getCertificateChain(CLIENT_ALIAS))
+                            .map(X509Certificate.class::cast)
+                            .toArray(X509Certificate[]::new);
+
+            PublicKey serverPublicKey = clientCertificate.getPublicKey();
+            clientKeyPair = new KeyPair(serverPublicKey, (PrivateKey) clientPrivateKey);
+        }
+
+        return this;
+    }
+
+    X509Certificate getClientCertificate() {
+        return clientCertificate;
+    }
+
+    public X509Certificate[] getClientCertificateChain() {
+        return clientCertificateChain;
+    }
+
+    KeyPair getClientKeyPair() {
+        return clientKeyPair;
+    }
+}

seatunnel-datasource/seatunnel-datasource-plugins/datasource-opcua/pom.xml

@@ -60,6 +60,11 @@
             <artifactId>sdk-client</artifactId>
             <version>0.6.8</version>
         </dependency>
+        <dependency>
+            <groupId>org.eclipse.milo</groupId>
+            <artifactId>sdk-server</artifactId>
+            <version>0.6.8</version>
+        </dependency>
 
     </dependencies>
 </project>

seatunnel-datasource/seatunnel-datasource-plugins/pom.xml

@@ -56,6 +56,7 @@
         <module>datasource-xml</module>
         <module>datasource-csv</module>
         <module>datasource-excel</module>
+        <module>datasource-opcua-kepserver</module>
     </modules>
 
     <build>