Backport resolution of OWLS-104983 to release/3.4 (#3894)

Author: anpanigr

integration-tests/src/test/java/oracle/weblogic/kubernetes/ItExternalLbTunneling.java

@@ -1,4 +1,4 @@
-// Copyright (c) 2020, 2022, Oracle and/or its affiliates.
+// Copyright (c) 2020, 2023, Oracle and/or its affiliates.
 // Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl.
 
 package oracle.weblogic.kubernetes;
@@ -251,7 +251,7 @@ void testExternalRmiAccessThruTraefik() {
 
     // Build the standalone JMS Client to send and receive messages
     buildClient();
-    buildClientOnPod();
+    // buildClientOnPod();
 
     // Prepare the ingress file from the template file by replacing
     // domain namespace, domain UID, cluster service name and tls secret
@@ -411,13 +411,18 @@ private void runExtHttpsClient(int httpsTunnelingPort, int serverCount, boolean
     runExtHttpsClient(null, httpsTunnelingPort, serverCount, checkConnection);
   }
 
+  // Run the RMI client outside the K8s Cluster using the JDK binary copied 
+  // from the Pod in the method buildClient()
   private void runExtHttpsClient(String routeHost, int httpsTunnelingPort, int serverCount, boolean checkConnection) {
     String hostAndPort = getHostAndPort(routeHost, httpsTunnelingPort);
     // Generate java command to execute client with classpath
     StringBuffer httpsUrl = new StringBuffer("https://");
     httpsUrl.append(hostAndPort);
 
-    StringBuffer javasCmd = new StringBuffer("java -cp ");
+    // StringBuffer javasCmd = new StringBuffer("java -cp ");
+    StringBuffer javasCmd = new StringBuffer("");
+    javasCmd.append(Paths.get(RESULTS_ROOT, "/jdk/bin/java "));
+    javasCmd.append("-cp ");
     javasCmd.append(Paths.get(RESULTS_ROOT, "wlthint3client.jar"));
     javasCmd.append(":");
     javasCmd.append(Paths.get(RESULTS_ROOT));
@@ -475,12 +480,17 @@ private void runExtClient(int httpTunnelingPort, int serverCount, boolean checkC
     runExtClient(null, httpTunnelingPort, serverCount, checkConnection);
   }
 
+  // Run the RMI client outside the K8s Cluster using the JDK binary copied 
+  // from the Pod in the method buildClient()
   private void runExtClient(String routeHost, int httpTunnelingPort, int serverCount, boolean checkConnection) {
     String hostAndPort = getHostAndPort(routeHost, httpTunnelingPort);
     // Generate java command to execute client with classpath
     StringBuffer httpUrl = new StringBuffer("http://");
     httpUrl.append(hostAndPort);
-    StringBuffer javaCmd = new StringBuffer("java -cp ");
+    // StringBuffer javaCmd = new StringBuffer("java -cp ");
+    StringBuffer javaCmd = new StringBuffer("");
+    javaCmd.append(Paths.get(RESULTS_ROOT, "/jdk/bin/java "));
+    javaCmd.append("-cp ");
     javaCmd.append(Paths.get(RESULTS_ROOT, "wlthint3client.jar"));
     javaCmd.append(":");
     javaCmd.append(Paths.get(RESULTS_ROOT));
@@ -501,13 +511,31 @@ private void runExtClient(String routeHost, int httpTunnelingPort, int serverCou
   // JMS client that sends messages to a Uniform Distributed Queue using
   // load balancer http(s) url which maps to custom channel on cluster member
   // server on WebLogic cluster.
+  // Copy the installed JDK from WebLogic server pod to local filesystem 
+  // to build and run the JMS client outside of K8s Cluster.
   private void buildClient() {
 
     assertDoesNotThrow(() -> copyFileFromPod(domainNamespace,
              adminServerPodName, "weblogic-server",
              "/u01/oracle/wlserver/server/lib/wlthint3client.jar",
              Paths.get(RESULTS_ROOT, "wlthint3client.jar")));
-    StringBuffer javacCmd = new StringBuffer("javac -cp ");
+
+    assertDoesNotThrow(() -> copyFileFromPod(domainNamespace,
+             adminServerPodName, "weblogic-server",
+             "/u01/jdk", Paths.get(RESULTS_ROOT, "jdk")));
+
+    StringBuffer chmodCmd = new StringBuffer("chmod +x ");
+    chmodCmd.append(Paths.get(RESULTS_ROOT, "jdk/bin/java "));
+    chmodCmd.append(Paths.get(RESULTS_ROOT, "jdk/bin/javac "));
+    ExecResult cresult = assertDoesNotThrow(
+        () -> exec(new String(chmodCmd), true));
+    logger.info("chmod command {0}", chmodCmd.toString());
+    logger.info("chmod command returned {0}", cresult.toString());
+
+    // StringBuffer javacCmd = new StringBuffer("javac -cp ");
+    StringBuffer javacCmd = new StringBuffer("");
+    javacCmd.append(Paths.get(RESULTS_ROOT, "/jdk/bin/javac "));
+    javacCmd.append(Paths.get(" -cp "));
     javacCmd.append(Paths.get(RESULTS_ROOT, "wlthint3client.jar "));
     javacCmd.append(Paths.get(RESOURCE_DIR, "tunneling", "JmsTestClient.java"));
     javacCmd.append(Paths.get(" -d "));

integration-tests/src/test/java/oracle/weblogic/kubernetes/ItExternalNodePortService.java

@@ -1,4 +1,4 @@
-// Copyright (c) 2021, 2022, Oracle and/or its affiliates.
+// Copyright (c) 2021, 2023, Oracle and/or its affiliates.
 // Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl.
 
 package oracle.weblogic.kubernetes;
@@ -209,7 +209,7 @@ void testExternalRmiAccessThruNodePortService() {
 
     // Build the standalone JMS Client to send and receive messages
     buildClient();
-    buildClientOnPod();
+    // buildClientOnPod();
 
     // Prepare the Nodeport service yaml file from the template file by
     // replacing domain namespace, domain UID, cluster name and host name
@@ -255,12 +255,18 @@ void testExternalRmiAccessThruNodePortService() {
     logger.info("External RMI tunneling works for NodePortService");
   }
 
-  // Run the RMI client outside the K8s Cluster
+  // Run the RMI client outside the K8s Cluster using the JDK binary copied 
+  // from the Pod in the method buildClient()
   private void runExtClient(String hostAndPort, int serverCount, boolean checkConnection) {
     // Generate java command to execute client with classpath
     StringBuffer httpUrl = new StringBuffer("http://");
     httpUrl.append(hostAndPort);
-    StringBuffer javaCmd = new StringBuffer("java -cp ");
+
+
+    // StringBuffer javaCmd = new StringBuffer("java -cp ");
+    StringBuffer javaCmd = new StringBuffer("");
+    javaCmd.append(Paths.get(RESULTS_ROOT, "/jdk/bin/java "));
+    javaCmd.append("-cp ");
     javaCmd.append(Paths.get(RESULTS_ROOT, "wlthint3client.jar"));
     javaCmd.append(":");
     javaCmd.append(Paths.get(RESULTS_ROOT));
@@ -280,13 +286,30 @@ private void runExtClient(String hostAndPort, int serverCount, boolean checkConn
   // JMS client that sends messages to a Uniform Distributed Queue using
   // load balancer http(s) url which maps to custom channel on cluster member
   // server on WebLogic cluster.
+  // Copy the installed JDK from WebLogic server pod to local filesystem to 
+  // build and run  the JMS client outside of K8s Cluster.
   private void buildClient() {
 
     assertDoesNotThrow(() -> copyFileFromPod(domainNamespace,
              adminServerPodName, "weblogic-server",
              "/u01/oracle/wlserver/server/lib/wlthint3client.jar",
              Paths.get(RESULTS_ROOT, "wlthint3client.jar")));
-    StringBuffer javacCmd = new StringBuffer("javac -cp ");
+
+    assertDoesNotThrow(() -> copyFileFromPod(domainNamespace,
+             adminServerPodName, "weblogic-server",
+             "/u01/jdk", Paths.get(RESULTS_ROOT, "jdk")));
+    StringBuffer chmodCmd = new StringBuffer("chmod +x ");
+    chmodCmd.append(Paths.get(RESULTS_ROOT, "jdk/bin/java "));
+    chmodCmd.append(Paths.get(RESULTS_ROOT, "jdk/bin/javac "));
+    ExecResult cresult = assertDoesNotThrow(
+        () -> exec(new String(chmodCmd), true));
+    logger.info("chmod command {0}", chmodCmd.toString());
+    logger.info("chmod command returned {0}", cresult.toString());
+
+    // StringBuffer javacCmd = new StringBuffer("javac -cp ");
+    StringBuffer javacCmd = new StringBuffer("");
+    javacCmd.append(Paths.get(RESULTS_ROOT, "/jdk/bin/javac "));
+    javacCmd.append(Paths.get(" -cp "));
     javacCmd.append(Paths.get(RESULTS_ROOT, "wlthint3client.jar "));
     javacCmd.append(Paths.get(RESOURCE_DIR, "tunneling", "JmsTestClient.java"));
     javacCmd.append(Paths.get(" -d "));