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

Browse Source
This commit is contained in:
RedKale
2016-04-13 16:45:49 +08:00
parent 4b15ee3183
commit 784c504dfb
3 changed files with 17 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
test/org/redkale/test/sncp/SncpTest.java
View File

@@ -5,26 +5,20 @@
*/ */
package org.redkale.test.sncp; package org.redkale.test.sncp;
import org.redkale.net.sncp.Sncp;
import org.redkale.convert.bson.BsonFactory;
import org.redkale.net.Transport;
import org.redkale.service.Service;
import org.redkale.net.sncp.SncpServer;
import org.redkale.convert.bson.BsonConvert;
import org.redkale.util.Utility;
import org.redkale.net.sncp.ServiceWrapper;
import org.redkale.util.AnyValue;
import org.redkale.watch.WatchFactory;
import org.redkale.util.ResourceFactory;
import java.io.*; import java.io.*;
import java.net.*; import java.net.InetSocketAddress;
import java.nio.*; import java.nio.ByteBuffer;
import java.nio.channels.*; import java.nio.channels.AsynchronousChannelGroup;
import java.util.*; import java.util.*;
import java.util.concurrent.*; import java.util.concurrent.*;
import java.util.concurrent.atomic.*; import java.util.concurrent.atomic.*;
import java.util.logging.*; import java.util.logging.LogManager;
import org.redkale.convert.bson.*;
import org.redkale.net.Transport;
import org.redkale.net.sncp.*;
import org.redkale.service.Service;
import org.redkale.util.*; import org.redkale.util.*;
import org.redkale.watch.WatchFactory;
/** /**
* *
@@ -160,7 +154,7 @@ public class SncpTest {
final Transport transport = new Transport("", WatchFactory.root(), newBufferPool(), newChannelGroup(), null, set); final Transport transport = new Transport("", WatchFactory.root(), newBufferPool(), newChannelGroup(), null, set);
SncpTestService service = Sncp.createLocalService("", null, ResourceFactory.root(), SncpTestService.class, addr, transport, null); SncpTestService service = Sncp.createLocalService("", null, ResourceFactory.root(), SncpTestService.class, addr, transport, null);
ResourceFactory.root().inject(service); ResourceFactory.root().inject(service);
server.addService(new ServiceWrapper(SncpTestService.class, service, "", "", new HashSet<>(), null)); server.addService(new ServiceWrapper(service, "", "", new HashSet<>(), null));
System.out.println(service); System.out.println(service);
AnyValue.DefaultAnyValue conf = new AnyValue.DefaultAnyValue(); AnyValue.DefaultAnyValue conf = new AnyValue.DefaultAnyValue();
conf.addValue("host", "0.0.0.0"); conf.addValue("host", "0.0.0.0");
@@ -193,7 +187,7 @@ public class SncpTest {
//String name, WatchFactory, ObjectPool<ByteBuffer>, AsynchronousChannelGroup, InetSocketAddress clientAddress, Collection<InetSocketAddress> //String name, WatchFactory, ObjectPool<ByteBuffer>, AsynchronousChannelGroup, InetSocketAddress clientAddress, Collection<InetSocketAddress>
final Transport transport = new Transport("", WatchFactory.root(), newBufferPool(), newChannelGroup(), null, set); final Transport transport = new Transport("", WatchFactory.root(), newBufferPool(), newChannelGroup(), null, set);
Service service = Sncp.createLocalService("", null, ResourceFactory.root(), SncpTestService.class, addr, transport, null); Service service = Sncp.createLocalService("", null, ResourceFactory.root(), SncpTestService.class, addr, transport, null);
server.addService(new ServiceWrapper(SncpTestService.class, service, "", "", new HashSet<>(), null)); server.addService(new ServiceWrapper(service, "", "", new HashSet<>(), null));
AnyValue.DefaultAnyValue conf = new AnyValue.DefaultAnyValue(); AnyValue.DefaultAnyValue conf = new AnyValue.DefaultAnyValue();
conf.addValue("host", "0.0.0.0"); conf.addValue("host", "0.0.0.0");
conf.addValue("port", "" + port2); conf.addValue("port", "" + port2);

4
test/org/redkale/test/sncp/SncpTestIService.java
View File

@@ -6,7 +6,7 @@
package org.redkale.test.sncp; package org.redkale.test.sncp;
import org.redkale.service.*; import org.redkale.service.*;
import org.redkale.source.*; import org.redkale.source.DataCallArrayAttribute;
/** /**
* *
@@ -14,6 +14,8 @@ import org.redkale.source.*;
*/ */
public interface SncpTestIService extends Service { public interface SncpTestIService extends Service {
public String queryResult(SncpTestBean bean);
public void insert(@DynCall(DataCallArrayAttribute.class) SncpTestBean... beans); public void insert(@DynCall(DataCallArrayAttribute.class) SncpTestBean... beans);
public String updateBean(@DynCall(SncpTestService.CallAttribute.class) SncpTestBean bean); public String updateBean(@DynCall(SncpTestService.CallAttribute.class) SncpTestBean bean);

7
test/org/redkale/test/sncp/SncpTestService.java
View File

@@ -5,11 +5,10 @@
*/ */
package org.redkale.test.sncp; package org.redkale.test.sncp;
import java.lang.reflect.*; import java.lang.reflect.Method;
import java.net.*; import java.net.InetSocketAddress;
import org.redkale.net.sncp.*; import org.redkale.net.sncp.*;
import org.redkale.service.*; import org.redkale.service.*;
import org.redkale.util.Attribute;
import org.redkale.source.DataCallArrayAttribute; import org.redkale.source.DataCallArrayAttribute;
import org.redkale.util.*; import org.redkale.util.*;
@@ -17,7 +16,7 @@ import org.redkale.util.*;
* *
* @author zhangjx * @author zhangjx
*/ */
@ResourceType({SncpTestIService.class}) @ResourceType({SncpTestIService.class, SncpTestService.class})
public class SncpTestService implements SncpTestIService { public class SncpTestService implements SncpTestIService {
public static class CallAttribute implements Attribute<SncpTestBean, Long> { public static class CallAttribute implements Attribute<SncpTestBean, Long> {