org.redkale.net.sncp

类 Sncp

java.lang.Object

org.redkale.net.sncp.Sncp

public abstract class Sncp
extends java.lang.Object

Service Node Communicate Protocol 生成Service的本地模式或远程模式Service-Class的工具类 详情见: http://redkale.org

作者:

zhangjx

方法概要

限定符和类型	方法和说明
static <T extends Service> T	createLocalService(java.lang.String name, java.util.function.Consumer<java.lang.Runnable> executor, ResourceFactory resourceFactory, java.lang.Class<T> serviceClass, java.net.InetSocketAddress clientAddress, Transport sameGroupTransport, java.util.Collection<Transport> diffGroupTransports) 创建本地模式Service实例
protected static <T extends Service> java.lang.Class<? extends T>	createLocalServiceClass(java.lang.String name, java.lang.Class<T> serviceClass) public class TestService implements Service{ public String findSomeThing(){ return "hello"; } @MultiRun(selfrun = false) public void createSomeThing(TestBean bean){ //do something } @MultiRun public String updateSomeThing(String id){ return "hello" + id; } } @Resource(name = "") @SncpDyn(remote = false) @ResourceType({TestService.class}) public final class _DynLocalTestService extends TestService{ @Resource private BsonConvert _redkale_convert; private Transport _redkale_sameGroupTransport; private Transport[] _redkale_diffGroupTransports; private SncpClient _redkale_client; private String _redkale_selfstring; @Override public String toString() { return _redkale_selfstring == null ?
static <T extends Service> T	createRemoteService(java.lang.String name, java.util.function.Consumer<java.lang.Runnable> executor, java.lang.Class<T> serviceClass, java.net.InetSocketAddress clientAddress, Transport transport) @Resource(name = "") @SncpDyn(remote = true) @ResourceType({TestService.class}) public final class _DynRemoteTestService extends TestService{ @Resource private BsonConvert _redkale_convert; private Transport _redkale_transport; private SncpClient _redkale_client; private String _redkale_selfstring; @Override public String toString() { return _redkale_selfstring == null ?
static Transport[]	getDiffGroupTransports(Service service)
static Transport	getSameGroupTransport(Service service)
static SncpClient	getSncpClient(Service service)
static DLong	hash(java.lang.reflect.Method method)
static DLong	hash(java.lang.String name) 对类名或者name字符串进行hash。
static boolean	isRemote(Service service)
static long	nodeid(java.net.InetSocketAddress ip)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

方法详细资料

nodeid

public static long nodeid(java.net.InetSocketAddress ip)

hash

public static DLong hash(java.lang.reflect.Method method)

hash

public static DLong hash(java.lang.String name)

对类名或者name字符串进行hash。

参数:

name - String

返回:

hash值

isRemote

public static boolean isRemote(Service service)

getSncpClient

public static SncpClient getSncpClient(Service service)

getSameGroupTransport

public static Transport getSameGroupTransport(Service service)

getDiffGroupTransports

public static Transport[] getDiffGroupTransports(Service service)

createLocalServiceClass

protected static <T extends Service> java.lang.Class<? extends T> createLocalServiceClass(java.lang.String name,
                                                                                          java.lang.Class<T> serviceClass)

 public class TestService implements Service{
 
      public String findSomeThing(){
          return "hello";
      }
 
      @MultiRun(selfrun = false)
      public void createSomeThing(TestBean bean){
          //do something
      }
 
      @MultiRun
      public String updateSomeThing(String id){
          return "hello" + id;
      }
 }
 

 @Resource(name = "")
 @SncpDyn(remote = false)
 @ResourceType({TestService.class})
 public final class _DynLocalTestService extends TestService{
 
      @Resource
      private BsonConvert _redkale_convert;
 
      private Transport _redkale_sameGroupTransport;
 
      private Transport[] _redkale_diffGroupTransports;
 
      private SncpClient _redkale_client;
 
      private String _redkale_selfstring;
 
      @Override
      public String toString() {
          return _redkale_selfstring == null ? super.toString() : _redkale_selfstring;
      }
 
      @Override
      public void createSomeThing(TestBean bean){
          this._redkale_createSomeThing(false, true, true, bean);
      }
 
      @SncpDyn(remote = false, index = 0)
      public void _redkale_createSomeThing(boolean selfrunnable, boolean samerunnable, boolean diffrunnable, TestBean bean){
          if(selfrunnable) super.createSomeThing(bean);
          if (_redkale_client== null) return;
          if (samerunnable) _redkale_client.remoteSameGroup(_redkale_convert, _sameGroupTransport, 0, true, false, false, bean);
          if (diffrunnable) _redkale_client.remoteDiffGroup(_redkale_convert, _diffGroupTransports, 0, true, true, false, bean);
      }
 
      @Override
      public String updateSomeThing(String id){
          return this._redkale_updateSomeThing(true, true, true, id);
      }
 
      @SncpDyn(remote = false, index = 1)
      public String _redkale_updateSomeThing(boolean selfrunnable, boolean samerunnable, boolean diffrunnable, String id){
          String rs = super.updateSomeThing(id);
          if (_redkale_client== null) return;
          if (samerunnable) _redkale_client.remoteSameGroup(_redkale_convert, _sameGroupTransport, 1, true, false, false, id);
          if (diffrunnable) _redkale_client.remoteDiffGroup(_redkale_convert, _diffGroupTransports, 1, true, true, false, id);
          return rs;
      }
 }
 

创建Service的本地模式Class

类型参数:

T - Service子类

参数:

name - 资源名

serviceClass - Service类

返回:

Service实例

createLocalService

public static <T extends Service> T createLocalService(java.lang.String name,
                                                       java.util.function.Consumer<java.lang.Runnable> executor,
                                                       ResourceFactory resourceFactory,
                                                       java.lang.Class<T> serviceClass,
                                                       java.net.InetSocketAddress clientAddress,
                                                       Transport sameGroupTransport,
                                                       java.util.Collection<Transport> diffGroupTransports)

创建本地模式Service实例

类型参数:

T - Service泛型

参数:

name - 资源名

executor - 线程池

resourceFactory - 资源容器

serviceClass - Service类

clientAddress - 本地IP地址

sameGroupTransport - 同组的通信组件

diffGroupTransports - 异组的通信组件列表

返回:

Service的本地模式实例

createRemoteService

public static <T extends Service> T createRemoteService(java.lang.String name,
                                                        java.util.function.Consumer<java.lang.Runnable> executor,
                                                        java.lang.Class<T> serviceClass,
                                                        java.net.InetSocketAddress clientAddress,
                                                        Transport transport)

 @Resource(name = "")
 @SncpDyn(remote = true)
 @ResourceType({TestService.class})
 public final class _DynRemoteTestService extends TestService{
 
      @Resource
      private BsonConvert _redkale_convert;
 
      private Transport _redkale_transport;
 
      private SncpClient _redkale_client;
 
      private String _redkale_selfstring;
 
      @Override
      public String toString() {
          return _redkale_selfstring == null ? super.toString() : _redkale_selfstring;
      }
 
      @SncpDyn(remote = false, index = 0)
      public void _redkale_createSomeThing(boolean selfrunnable, boolean samerunnable, boolean diffrunnable, TestBean bean){
          _redkale_client.remote(_redkale_convert, _redkale_transport, 0, selfrunnable, samerunnable, diffrunnable, bean);
      }
 
      @SncpDyn(remote = false, index = 1)
      public String _redkale_updateSomeThing(boolean selfrunnable, boolean samerunnable, boolean diffrunnable, String id){
          return _redkale_client.remote(_redkale_convert, _redkale_transport, 1, selfrunnable, samerunnable, diffrunnable, id);
      }
 
      @Override
      public void createSomeThing(TestBean bean){
          _redkale_client.remote(_redkale_convert, _redkale_transport, 2, bean);
      }
 
      @Override
      public String findSomeThing(){
          return _redkale_client.remote(_redkale_convert, _redkale_transport, 3);
      }
 
      @Override
      public String updateSomeThing(String id){
          return  _redkale_client.remote(_redkale_convert, _redkale_transport, 4, id);
      }
 }
 

创建远程模式的Service实例

类型参数:

T - Service泛型

参数:

name - 资源名

executor - 线程池

serviceClass - Service类

clientAddress - 本地IP地址

transport - 通信组件

返回:

Service的远程模式实例