From d9d08181a94d727a4fe5933ac9efd1ff5c8a7c5a Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期三, 16 七月 2025 13:49:13 +0800 Subject: [PATCH] 中间件修改内容: 1、当没农业综合站时即没相关配置项目内容为空时,启动时会产生bug; 2、整理优化代码。 --- pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/channel/rmi/RmiClient.java | 35 +++++++++++++++++++++++++++++++++++ 1 files changed, 35 insertions(+), 0 deletions(-) diff --git a/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/channel/rmi/RmiClient.java b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/channel/rmi/RmiClient.java new file mode 100644 index 0000000..c072013 --- /dev/null +++ b/pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/channel/rmi/RmiClient.java @@ -0,0 +1,35 @@ +package com.dy.common.mw.channel.rmi; + +import java.rmi.Naming; +import org.apache.logging.log4j.* ; + +public class RmiClient { + + private static final 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 ; + } + + /** + * 寰楀埌涓棿浠禦MI + * @return RmiFrameWork + */ + 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); + } + return rmiIntf; + } + +} -- Gitblit v1.8.0