| | |
|---|
| | | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 得到中间件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; |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
