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