From 9e7999da0f64e7dfac0a6a4f1ea43a03ade7df8d Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Wed, 22 Mar 2017 16:42:54 +0800 Subject: [PATCH] --- .../redkale/test/service/ABMainService.java | 12 +++++-- test/org/redkale/test/service/BCService.java | 33 ++++++++++++++----- .../redkale/test/service/MyAsyncHandler.java | 4 +-- .../test/service/MyAsyncInnerHandler.java | 18 ++++++++++ 4 files changed, 52 insertions(+), 15 deletions(-) create mode 100644 test/org/redkale/test/service/MyAsyncInnerHandler.java diff --git a/test/org/redkale/test/service/ABMainService.java b/test/org/redkale/test/service/ABMainService.java index a4b494cf8..9b88b0da9 100644 --- a/test/org/redkale/test/service/ABMainService.java +++ b/test/org/redkale/test/service/ABMainService.java @@ -43,6 +43,7 @@ public class ABMainService implements Service { //------------------------ 初始化 CService ------------------------------------ CService cservice = Sncp.createLocalService("", null, ResourceFactory.root(), CService.class, new InetSocketAddress("127.0.0.1", 5577), null, null); SncpServer cserver = new SncpServer(); + cserver.getLogger().setLevel(Level.WARNING); cserver.addSncpServlet(new ServiceWrapper(cservice, "", "", new HashSet<>(), null)); cserver.init(DefaultAnyValue.create("port", 5577)); cserver.start(); @@ -54,6 +55,7 @@ public class ABMainService implements Service { factory.inject(remoteCService); factory.register("", remoteCService); SncpServer bcserver = new SncpServer(); + bcserver.getLogger().setLevel(Level.WARNING); bcserver.addSncpServlet(new ServiceWrapper(bcservice, "", "", new HashSet<>(), null)); bcserver.init(DefaultAnyValue.create("port", 5588)); bcserver.start(); @@ -66,6 +68,7 @@ public class ABMainService implements Service { factory.register("", remoteBCService); HttpServer server = new HttpServer(); + server.getLogger().setLevel(Level.WARNING); server.addRestServlet("", ABMainService.class, service, DefaultRestServlet.class, "/pipes"); @@ -93,9 +96,6 @@ public class ABMainService implements Service { } public static void main(String[] args) throws Throwable { - Logger.getLogger(Server.class.getSimpleName()).setLevel(Level.WARNING); - Logger.getLogger(HttpServer.class.getSimpleName()).setLevel(Level.WARNING); - Logger.getLogger(SncpServer.class.getSimpleName()).setLevel(Level.WARNING); System.out.println("------------------- 本地模式调用 -----------------------------------"); final int abport = 8888; ResourceFactory factory = ResourceFactory.root(); @@ -109,6 +109,7 @@ public class ABMainService implements Service { factory.inject(service); HttpServer server = new HttpServer(); + server.getLogger().setLevel(Level.WARNING); server.addRestServlet("", ABMainService.class, service, DefaultRestServlet.class, "/pipes"); @@ -189,6 +190,11 @@ public class ABMainService implements Service { @Override public void failed(Throwable exc, Void attachment) { } + + @Override + public int id2() { + return 2; + } }, name); } } diff --git a/test/org/redkale/test/service/BCService.java b/test/org/redkale/test/service/BCService.java index 5bf42db42..5bf1368f9 100644 --- a/test/org/redkale/test/service/BCService.java +++ b/test/org/redkale/test/service/BCService.java @@ -6,7 +6,7 @@ package org.redkale.test.service; import javax.annotation.Resource; -import org.redkale.service.Service; +import org.redkale.service.*; import org.redkale.util.AsyncHandler; /** @@ -33,14 +33,29 @@ public class BCService implements Service { if (handler != null) handler.failed(t, a); }), name); } - + public void bcCurrentTime(final MyAsyncHandler handler, final String name) { - cService.ccCurrentTime(AsyncHandler.create((v, a) -> { - System.out.println("执行了 BCService.bcCurrentTime----异步方法2"); - String rs = "异步bcCurrentTime: " + (v == null ? null : v.getResult()); - if (handler != null) handler.completed(rs, null); - }, (t, a) -> { - if (handler != null) handler.failed(t, a); - }), name); + cService.mcCurrentTime(new MyAsyncHandler, Void>() { + @Override + public int id() { + return 1; + } + + @Override + public void completed(RetResult v, Void a) { + System.out.println("执行了 BCService.bcCurrentTime----异步方法2"); + String rs = "异步bcCurrentTime: " + (v == null ? null : v.getResult()); + if (handler != null) handler.completed(rs, null); + } + + @Override + public void failed(Throwable exc, Void attachment) { + } + + @Override + public int id2() { + return 2; + } + }, name); } } diff --git a/test/org/redkale/test/service/MyAsyncHandler.java b/test/org/redkale/test/service/MyAsyncHandler.java index 302c6eb86..bad9729ea 100644 --- a/test/org/redkale/test/service/MyAsyncHandler.java +++ b/test/org/redkale/test/service/MyAsyncHandler.java @@ -5,15 +5,13 @@ */ package org.redkale.test.service; -import org.redkale.util.AsyncHandler; - /** * * @author zhangjx * @param V * @param A */ -public abstract class MyAsyncHandler implements AsyncHandler { +public abstract class MyAsyncHandler extends MyAsyncInnerHandler { public abstract int id(); diff --git a/test/org/redkale/test/service/MyAsyncInnerHandler.java b/test/org/redkale/test/service/MyAsyncInnerHandler.java new file mode 100644 index 000000000..e83460c41 --- /dev/null +++ b/test/org/redkale/test/service/MyAsyncInnerHandler.java @@ -0,0 +1,18 @@ +/* + * To change this license header, choose License Headers in Project Properties. + * To change this template file, choose Tools | Templates + * and open the template in the editor. + */ +package org.redkale.test.service; + +import org.redkale.util.AsyncHandler; + +/** + * + * @author zhangjx + */ +public abstract class MyAsyncInnerHandler implements AsyncHandler { + + protected abstract int id2(); + +}