diff --git a/test/com/wentch/redkale/test/sncp/SncpTest.java b/test/com/wentch/redkale/test/sncp/SncpTest.java index 7d61e067e..bd75ad372 100644 --- a/test/com/wentch/redkale/test/sncp/SncpTest.java +++ b/test/com/wentch/redkale/test/sncp/SncpTest.java @@ -70,7 +70,14 @@ public class SncpTest { // } // bean.setContent(sb.toString()); // bean.setContent("hello sncp"); - final int count = 500; + SncpTestBean callbean = new SncpTestBean(); + callbean.setId(1); + callbean.setContent("数据X"); + + service.updateBean(callbean); + System.out.println("bean.id应该会被修改: " + callbean); + System.out.println("---------------------------------------------------"); + final int count = 10; final CountDownLatch cld = new CountDownLatch(count); final AtomicInteger ai = new AtomicInteger(); for (int i = 0; i < count; i++) { @@ -90,8 +97,8 @@ public class SncpTest { } bean.setContent(sb.toString()); - //service.queryResult(bean); - service.updateBean(bean); + service.queryResult(bean); + //service.updateBean(bean); } catch (Exception e) { e.printStackTrace(); } finally { diff --git a/test/com/wentch/redkale/test/sncp/SncpTestService.java b/test/com/wentch/redkale/test/sncp/SncpTestService.java index f79a45826..291fe5c5c 100644 --- a/test/com/wentch/redkale/test/sncp/SncpTestService.java +++ b/test/com/wentch/redkale/test/sncp/SncpTestService.java @@ -5,7 +5,9 @@ */ package com.wentch.redkale.test.sncp; +import com.wentch.redkale.net.sncp.*; import com.wentch.redkale.service.*; +import com.wentch.redkale.util.*; /** * @@ -13,13 +15,43 @@ import com.wentch.redkale.service.*; */ public class SncpTestService implements Service { + public static class CallAttribute implements Attribute { + + @Override + public Class type() { + return long.class; + } + + @Override + public Class declaringClass() { + return SncpTestBean.class; + } + + @Override + public String field() { + throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates. + } + + @Override + public Long get(SncpTestBean obj) { + return obj.getId(); + } + + @Override + public void set(SncpTestBean obj, Long value) { + obj.setId(value); + } + + } + public String queryResult(SncpTestBean bean) { System.out.println(Thread.currentThread().getName() + " 运行了queryResult方法"); return "result: " + bean; } @MultiRun - public String updateBean(SncpTestBean bean) { + public String updateBean(@SncpCall(CallAttribute.class) SncpTestBean bean) { + bean.setId(System.currentTimeMillis()); System.out.println(Thread.currentThread().getName() + " 运行了updateBean方法"); return "result: " + bean; }