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