|  |  | 
 |  |  | package com.dy.common.mw.channel.rmi; | 
 |  |  |  | 
 |  |  | import java.io.Serial; | 
 |  |  | import java.rmi.RemoteException; | 
 |  |  | import java.rmi.server.UnicastRemoteObject; | 
 |  |  |  | 
 |  |  | 
 |  |  |  | 
 |  |  | public class RmiFrameWorkImpl extends UnicastRemoteObject implements RmiFrameWork { | 
 |  |  |  | 
 |  |  |    @Serial | 
 |  |  |    private static final long serialVersionUID = 201807220009001L; | 
 |  |  |     | 
 |  |  |    private RmiUnitAdapter adapter ; | 
 |  |  |    /** | 
 |  |  |     * 构造方法 | 
 |  |  |     * @throws RemoteException | 
 |  |  |     * @throws RemoteException 异常 | 
 |  |  |     */ | 
 |  |  |    protected RmiFrameWorkImpl(RmiUnitAdapter adapter) throws RemoteException { | 
 |  |  |       super(); | 
 |  |  | 
 |  |  |  | 
 |  |  |    /** | 
 |  |  |     * 同步请求 | 
 |  |  |     * @param in | 
 |  |  |     * @param obj 命令参数 | 
 |  |  |     * @return 返回命令结果 | 
 |  |  |     * @throws RemoteException | 
 |  |  |     * @throws RemoteException 异常 | 
 |  |  |     */ | 
 |  |  |    @Override | 
 |  |  |    public Object syncRequest(Object obj) throws RemoteException { | 
 |  |  | 
 |  |  |     | 
 |  |  |    /** | 
 |  |  |     * 异步请求 | 
 |  |  |     * @param command | 
 |  |  |     * @param obj 参数 | 
 |  |  |     * @return 命令结果的ID,如果为空,则说明邮错 | 
 |  |  |     * @throws RemoteException | 
 |  |  |     * @throws RemoteException 异常 | 
 |  |  |     */ | 
 |  |  |    @Override | 
 |  |  |    public String asyncRequest(Object obj) throws RemoteException { |