package com.dy.common.mw.channel.rmi;

import java.io.Serial;
import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;

import com.dy.common.threadPool.ThreadPool;
import com.dy.common.threadPool.TreadPoolFactory;

public class RmiFrameWorkImpl extends UnicastRemoteObject implements RmiFrameWork {

	@Serial
	private static final long serialVersionUID = 201807220009001L;
	
	private RmiUnitAdapter adapter ;
	/**
	 * 构造方法
	 * @throws RemoteException 异常
	 */
	protected RmiFrameWorkImpl(RmiUnitAdapter adapter) throws RemoteException {
		super();
		this.adapter = adapter ;
	}

	/**
	 * 同步请求
	 * @param obj 命令参数
	 * @return 返回命令结果
	 * @throws RemoteException 异常
	 */
	@Override
	public Object syncRequest(Object obj) throws RemoteException {
		if(obj == null){
			throw new RemoteException("严重错误，输入命令参数为空！") ;
		}
		return adapter.newRequestCallback().syncRequest(obj) ;
	}
	
	/**
	 * 异步请求
	 * @param obj 参数
	 * @return 命令结果的ID，如果为空，则说明邮错
	 * @throws RemoteException 异常
	 */
	@Override
	public String asyncRequest(Object obj) throws RemoteException {
		try {
			TreadPoolFactory.getThreadPoolShort().putJob(new ThreadPool.Job() {
				public void execute() throws RemoteException {
					throw new RemoteException("此方法未实现") ;
				}
				@Override
				public void destroy() {
				}
				@Override
				public boolean isDestroy() {
					return false;
				}
				
			});
		}catch (RemoteException ee) {
			throw ee ;
		}catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}

	/**
	 * 关闭服务的请求
	 */
	@Override
	public String shutRequest() throws RemoteException {
		throw new RemoteException("此方法未实现") ;
	}
	

}