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