org.redkale.boot.watch

类 TransportWatchService

java.lang.Object

org.redkale.service.AbstractService

org.redkale.boot.watch.AbstractWatchService

org.redkale.boot.watch.TransportWatchService

所有已实现的接口:

Service, WatchService

@RestService(name="transport",
             catalog="watch",
             repair=false)
public class TransportWatchService
extends AbstractWatchService

字段概要

字段

限定符和类型	字段和说明
protected Application	application
static int	RET_TRANSPORT_ADDR_EXISTS
static int	RET_TRANSPORT_ADDR_ILLEGAL
static int	RET_TRANSPORT_GROUP_NOT_EXISTS
protected TransportFactory	transportFactory

从类继承的字段 org.redkale.boot.watch.AbstractWatchService

RET_WATCH_PARAMS_ILLEGAL, RET_WATCH_RUN_EXCEPTION

构造器概要

构造器

构造器和说明
TransportWatchService()

方法概要

限定符和类型	方法和说明
RetResult	addNode(java.lang.String group, java.lang.String addr, int port)
java.util.List<TransportGroupInfo>	listNodes()
RetResult	removeNode(java.lang.String group, java.lang.String addr, int port)
RetResult	test1()
RetResult	test2()
RetResult	test3()
RetResult	test4()

从类继承的方法 org.redkale.service.AbstractService

getExecutor, runAsync

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

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

从接口继承的方法 org.redkale.service.Service

destroy, init

字段详细资料

RET_TRANSPORT_GROUP_NOT_EXISTS

@Comment(value="\u4e0d\u5b58\u5728\u7684Group\u8282\u70b9")
public static final int RET_TRANSPORT_GROUP_NOT_EXISTS

另请参阅:

常量字段值

RET_TRANSPORT_ADDR_ILLEGAL

@Comment(value="\u975e\u6cd5\u7684Node\u8282\u70b9IP\u5730\u5740")
public static final int RET_TRANSPORT_ADDR_ILLEGAL

另请参阅:

常量字段值

RET_TRANSPORT_ADDR_EXISTS

@Comment(value="Node\u8282\u70b9IP\u5730\u5740\u5df2\u5b58\u5728")
public static final int RET_TRANSPORT_ADDR_EXISTS

另请参阅:

常量字段值

application

protected Application application

transportFactory

protected TransportFactory transportFactory

构造器详细资料

TransportWatchService

public TransportWatchService()

方法详细资料

listNodes

@RestMapping(name="listnodes",
             auth=false,
             comment="\u83b7\u53d6\u6240\u6709Node\u8282\u70b9")
public java.util.List<TransportGroupInfo> listNodes()

addNode

@RestMapping(name="addnode",
             auth=false,
             comment="\u52a8\u6001\u589e\u52a0\u6307\u5b9aGroup\u7684Node\u8282\u70b9")
public RetResult addNode(@RestParam(name="group",comment="Group\u8282\u70b9\u540d")
                                                                                                                                                                          java.lang.String group,
                                                                                                                                                                          @RestParam(name="addr",comment="\u8282\u70b9IP")
                                                                                                                                                                          java.lang.String addr,
                                                                                                                                                                          @RestParam(name="port",comment="\u8282\u70b9\u7aef\u53e3")
                                                                                                                                                                          int port)
                                                                                                                                                                   throws java.io.IOException

抛出:

java.io.IOException

removeNode

@RestMapping(name="removenode",
             auth=false,
             comment="\u52a8\u6001\u5220\u9664\u6307\u5b9aGroup\u7684Node\u8282\u70b9")
public RetResult removeNode(@RestParam(name="group",comment="Group\u8282\u70b9\u540d")
                                                                                                                                                                                java.lang.String group,
                                                                                                                                                                                @RestParam(name="addr",comment="\u8282\u70b9IP")
                                                                                                                                                                                java.lang.String addr,
                                                                                                                                                                                @RestParam(name="port",comment="\u8282\u70b9\u7aef\u53e3")
                                                                                                                                                                                int port)
                                                                                                                                                                         throws java.io.IOException

抛出:

java.io.IOException

test1

@RestMapping(name="test1",
             auth=false,
             comment="\u9884\u7559")
public RetResult test1()

test2

@RestMapping(name="test2",
             auth=false,
             comment="\u9884\u7559")
public RetResult test2()

test3

@RestMapping(name="test3",
             auth=false,
             comment="\u9884\u7559")
public RetResult test3()

test4

@RestMapping(name="test4",
             auth=false,
             comment="\u9884\u7559")
public RetResult test4()