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-mw/pipIrr-mwTest-client/src/main/java/com/dy/testClient/rmiClient/RmiClient.java | 40 ++++++++++++++++++++++++++++++++++++++++ 1 files changed, 40 insertions(+), 0 deletions(-) diff --git a/pipIrr-platform/pipIrr-mw/pipIrr-mwTest-client/src/main/java/com/dy/testClient/rmiClient/RmiClient.java b/pipIrr-platform/pipIrr-mw/pipIrr-mwTest-client/src/main/java/com/dy/testClient/rmiClient/RmiClient.java new file mode 100644 index 0000000..c78b6ed --- /dev/null +++ b/pipIrr-platform/pipIrr-mw/pipIrr-mwTest-client/src/main/java/com/dy/testClient/rmiClient/RmiClient.java @@ -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 ; + } + + /** + * 寰楀埌涓棿浠禦MI + * @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; + } + } +} -- Gitblit v1.8.0