| New file | 
|  |  |  | 
|---|
|  |  |  | package com.dy.testServer.forRmi; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import java.rmi.RemoteException; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.dy.common.mw.channel.rmi.RmiRequestCallback; | 
|---|
|  |  |  | import org.apache.logging.log4j.LogManager; | 
|---|
|  |  |  | import org.apache.logging.log4j.Logger; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | public class RmiRequestedCallback implements RmiRequestCallback { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @SuppressWarnings("unused") | 
|---|
|  |  |  | private static Logger log = LogManager.getLogger(RmiRequestedCallback.class.getName()) ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public Object syncRequest(Object obj) throws RemoteException { | 
|---|
|  |  |  | String json ; | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | json = Manager.dealRequest(obj); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | throw new RemoteException("服务端异常" , e) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return json ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public String asyncRequest(Object obj) throws RemoteException { | 
|---|
|  |  |  | String json ; | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | json = Manager.dealRequest(obj); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | throw new RemoteException("服务端异常" , e) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return json ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|