| | |
| | | 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 { |