zhubaomin
2025-04-17 b63eef2cfb054b1ead234ab93e05a2aa28775d91
pipIrr-platform/pipIrr-mw/pipIrr-mwTest-client/src/main/java/com/dy/testClient/rmiClient/RmiClient.java
New file
@@ -0,0 +1,40 @@
package com.dy.testClient.rmiClient;
import java.rmi.Naming;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import com.dy.common.mw.channel.rmi.RmiFrameWork;
public class RmiClient {
   private static Logger log = LogManager.getLogger(RmiClient.class.getName()) ;
   private String rmiServerIp;
   private Integer rmiServerPort;
   private String rmiServerContext ;
   public RmiClient(String rmiServerIp, Integer rmiServerPort, String rmiServerContext){
      this.rmiServerIp = rmiServerIp ;
      this.rmiServerPort = rmiServerPort ;
      this.rmiServerContext = rmiServerContext ;
   }
   /**
    * 得到中间件RMI
    * @return
    */
   @SuppressWarnings("finally")
   public RmiFrameWork getRmiInterface() {
      String rmiServerUrl = "rmi://" + this.rmiServerIp + ":" + this.rmiServerPort + "/" + this.rmiServerContext ;
      RmiFrameWork rmiIntf = null;
      try {
         rmiIntf = (RmiFrameWork) Naming.lookup(rmiServerUrl);
      } catch (Exception e) {
         log.error("连接RMI服务:" + rmiServerUrl + "时出错。", e);
      } finally {
         return rmiIntf;
      }
   }
}