lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2017-03-21 12:32:42 +08:00
parent c735874cff
commit 58d02f6471
2 changed files with 50 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/org/redkale/net/sncp/SncpAsyncHandler.java
View File

@@ -20,6 +20,7 @@ import org.redkale.util.AsyncHandler;
*/ */
public abstract class SncpAsyncHandler<V, A> implements AsyncHandler<V, A> { public abstract class SncpAsyncHandler<V, A> implements AsyncHandler<V, A> {
//为了在回调函数中调用_callParameter方法
protected Object[] params; protected Object[] params;
public Object[] getParams() { public Object[] getParams() {

55
src/org/redkale/net/sncp/SncpDynServlet.java
View File

@@ -187,17 +187,25 @@ public final class SncpDynServlet extends SncpServlet {
/** /**
* <blockquote><pre> * <blockquote><pre>
* public class TestService implements Service { * public class TestService implements Service {
*
* public boolean change(TestBean bean, String name, int id) { * public boolean change(TestBean bean, String name, int id) {
* * return false;
* } * }
* }
* *
* public class DynActionTestService_change extends SncpServletAction { * public void insert(AsyncHandler&#60;Boolean, TestBean&#62; handler, TestBean bean, String name, int id) {
* }
*
* public void update(long show, short v2, AsyncHandler&#60;Boolean, TestBean&#62; handler, TestBean bean, String name, int id) {
* }
* }
*
*
* class DynActionTestService_change extends SncpServletAction {
* *
* public TestService service; * public TestService service;
* *
* &#64;Override * &#064;Override
* public void action(final BsonReader in, final BsonWriter out) throws Throwable { * public void action(BsonReader in, BsonWriter out, SncpAsyncHandler handler) throws Throwable {
* TestBean arg1 = convert.convertFrom(paramTypes[1], in); * TestBean arg1 = convert.convertFrom(paramTypes[1], in);
* String arg2 = convert.convertFrom(paramTypes[2], in); * String arg2 = convert.convertFrom(paramTypes[2], in);
* int arg3 = convert.convertFrom(paramTypes[3], in); * int arg3 = convert.convertFrom(paramTypes[3], in);
@@ -205,7 +213,42 @@ public final class SncpDynServlet extends SncpServlet {
* _callParameter(out, arg1, arg2, arg3); * _callParameter(out, arg1, arg2, arg3);
* convert.convertTo(out, paramTypes[0], rs); * convert.convertTo(out, paramTypes[0], rs);
* } * }
* } * }
*
* class DynActionTestService_insert extends SncpServletAction {
*
* public TestService service;
*
* &#064;Override
* public void action(BsonReader in, BsonWriter out, SncpAsyncHandler handler) throws Throwable {
* SncpAsyncHandler arg0 = handler;
* convert.convertFrom(AsyncHandler.class, in);
* TestBean arg1 = convert.convertFrom(paramTypes[2], in);
* String arg2 = convert.convertFrom(paramTypes[3], in);
* int arg3 = convert.convertFrom(paramTypes[4], in);
* handler.setParams(arg0, arg1, arg2, arg3);
* service.insert(arg0, arg1, arg2, arg3);
* }
* }
*
* class DynActionTestService_update extends SncpServletAction {
*
* public TestService service;
*
* &#064;Override
* public void action(BsonReader in, BsonWriter out, SncpAsyncHandler handler) throws Throwable {
* long a1 = convert.convertFrom(paramTypes[1], in);
* short a2 = convert.convertFrom(paramTypes[2], in);
* SncpAsyncHandler a3 = handler;
* convert.convertFrom(AsyncHandler.class, in);
* TestBean arg1 = convert.convertFrom(paramTypes[4], in);
* String arg2 = convert.convertFrom(paramTypes[5], in);
* int arg3 = convert.convertFrom(paramTypes[6], in);
* handler.setParams(a1, a2, a3, arg1, arg2, arg3);
* service.update(a1, a2, a3, arg1, arg2, arg3);
* }
* }
*
* </pre></blockquote> * </pre></blockquote>
* *
* @param service Service * @param service Service