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