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