修改rmi中一些警告

liurunyu

2023-11-20 aab5b6fc250e074c8cac9e5d244bab011b9d9a32

修改rmi中一些警告

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/channel/rmi/RmiClient.java

@@ -5,7 +5,7 @@

public class RmiClient {

    private static Logger log = LogManager.getLogger(RmiClient.class.getName()) ;
    private static final Logger log = LogManager.getLogger(RmiClient.class.getName()) ;

    private String rmiServerIp;
    private Integer rmiServerPort;
@@ -19,19 +19,17 @@
    
    /**
     * 得到中间件RMI
     * @return
     * @return RmiFrameWork
     */
    @SuppressWarnings("finally")
    public RmiFrameWork getRmiInterface() { 
    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;
        }
        return rmiIntf;
    }

}

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/channel/rmi/RmiFrameWork.java

@@ -7,8 +7,8 @@

    /**
     * 关闭服务的请求
     * @return
     * @throws RemoteException
     * @return 命令结果的ID，如果为空，则说明出错
     * @throws RemoteException 异常
     */
    String shutRequest() throws RemoteException;

@@ -16,15 +16,15 @@
     * 异步请求
     * @param command 命令
     * @return 命令结果的ID，如果为空，则说明出错
     * @throws RemoteException
     * @throws RemoteException 异常
     */
    String asyncRequest(Object command) throws RemoteException;

    /**
     * 同步请求
     * @param command 命令
     * @return
     * @throws RemoteException
     * @return 命令结果，如果为空，则说明出错
     * @throws RemoteException 异常
     */
    Object syncRequest(Object command) throws RemoteException;
}

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/channel/rmi/RmiFrameWorkImpl.java

@@ -1,5 +1,6 @@
package com.dy.common.mw.channel.rmi;

import java.io.Serial;
import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;

@@ -8,12 +9,13 @@

public class RmiFrameWorkImpl extends UnicastRemoteObject implements RmiFrameWork {

    @Serial
    private static final long serialVersionUID = 201807220009001L;
    
    private RmiUnitAdapter adapter ;
    /**
     * 构造方法
     * @throws RemoteException
     * @throws RemoteException 异常
     */
    protected RmiFrameWorkImpl(RmiUnitAdapter adapter) throws RemoteException {
        super();
@@ -22,9 +24,9 @@

    /**
     * 同步请求
     * @param in
     * @param obj 命令参数
     * @return 返回命令结果
     * @throws RemoteException
     * @throws RemoteException 异常
     */
    @Override
    public Object syncRequest(Object obj) throws RemoteException {
@@ -36,9 +38,9 @@
    
    /**
     * 异步请求
     * @param command
     * @param obj 参数
     * @return 命令结果的ID，如果为空，则说明邮错
     * @throws RemoteException
     * @throws RemoteException 异常
     */
    @Override
    public String asyncRequest(Object obj) throws RemoteException {

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/channel/rmi/RmiRequestCallback.java

@@ -7,7 +7,7 @@
     * 同步请求
     * @param obj 请求提交对象
     * @return 返回命令结果
     * @throws RemoteException
     * @throws RemoteException 异常
     */
    Object syncRequest(Object obj) throws RemoteException  ;
    
@@ -15,7 +15,7 @@
     * 异步请求
     * @param obj  请求提交对象
     * @return 命令结果的ID，如果为空，则说明邮错
     * @throws RemoteException
     * @throws RemoteException 异常
     */
    String asyncRequest(Object obj) throws RemoteException  ;
}

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/channel/rmi/RmiUnit.java

@@ -19,7 +19,7 @@
    private static RmiFrameWork rmiFrm = null ;

    
    private RmiUnit(){} ;
    private RmiUnit(){}
    
    public static RmiUnit getInstance(){
        return instance ;
@@ -73,12 +73,10 @@
                e.printStackTrace();
                System.out.println("Rmi通信模块启动失败！");
                isException = true ;
            }finally{
                ;
            }

            if(!isException){
                if(vo.showStartInfo != null && vo.showStartInfo.booleanValue()){
                if(vo.showStartInfo != null && vo.showStartInfo){
                    System.out.println("Rmi模块成功启动，端口：" + vo.port + "，上下文为：" + vo.context );
                }
            }
@@ -87,7 +85,7 @@
    }

    @Override
    public void stop(UnitStartedCallbackInterface callback) throws Exception {
    public void stop(UnitStartedCallbackInterface callback) {
    }