public interface RemoteOpenService { public JSON executeOpenService(JSON json, String method);}public class RemoteOpenServiceImpl implements RemoteOpenService{ @Override public JSON executeOpenService(JSON json, String method) { JSON returnJson = null; BaseService service = (BaseService) OpenServiceRouter.getRouterMap().get(method); returnJson = service.execute(json, ExampleRequest.class); return returnJson; } }
OpenServiceRouter:
public class OpenServiceRouter { private static Map<String, Object> routerMap; public static Map<String, Object> getRouterMap(){ if(routerMap != null){ return routerMap; } routerMap = new HashMap<String, Object>(); routerMap.put("example", "exampleService"); return routerMap; } }
模版方法设计:实际执行的时service的excute方法,而这个方法执行中把业务部分的实现留给子类实现。
public interface BaseService { public JSON execute(JSON json, Class c);}public abstract class AbstractBaseService implements BaseService{ // TODO public final Request decode(JSON json, Class c){ ObjectMapper mapper = new ObjectMapper(); Request request = null; try { request = mapper.readValue(json.toJSONString(), c); } catch (JsonParseException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (JsonMappingException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } return request; } // TODO public final JSON encode(Response response){ ObjectMapper mapper = new ObjectMapper(); // Convert object to JSON string JSON json = null; try { String j = mapper.writeValueAsString(response); json = JSON.parSEObject(j); } catch (JsonGenerationException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (JsonMappingException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } return json; } /** * 子类不同实现具体逻辑 * @param request */ public abstract Response doService(Request request); /** * 模版执行方法 * @param json */ public final JSON execute(JSON json, Class c){ Request request = this.decode(json, c); Response response = doService(request); JSON retrunJson = this.encode(response); return retrunJson; }}
子类的实现:
public class ExampleServiceImpl extends AbstractBaseService{ @Override public Response doService(Request request) { ExampleRequest exampleRequest = (ExampleRequest)request; return null; }}
因为刚好需要设计一个这样的被调用的组件,我就想好多地方会遇到这个场景,所以值得深入进来研究一下,以上是我想,不参考任何框架,以最原始的方式去实现一个这样的请求路由。作为笔记的一部分,先开个头,后续研究下其他框架对这个问题的设计。
新闻热点
疑难解答