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;
|
}
|
}
|
}
|
