From 656aa4f953eb52502a6414965e46642c31b6e8ee Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期二, 29 四月 2025 15:33:09 +0800 Subject: [PATCH] 设备会在多种功能码上报数据中携带报警与状态数据,这样数据库保存设备报警与状态数据可能很多,为此修改逻辑,当前实现为一设备一个小时内只保存一条报警与状态数据。 --- 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