| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-public static final java.lang.String |
-RESNAME_APP_ADDR |
-"APP_ADDR" |
-
-
-public static final java.lang.String |
-RESNAME_APP_GRES |
-"APP_GRES" |
-
-
-public static final java.lang.String |
-RESNAME_APP_HOME |
-"APP_HOME" |
-
-
-public static final java.lang.String |
-RESNAME_APP_NODE |
-"APP_NODE" |
-
-
-public static final java.lang.String |
-RESNAME_APP_TIME |
-"APP_TIME" |
-
-
-public static final java.lang.String |
-RESNAME_SERVER_ADDR |
-"SERVER_ADDR" |
-
-
-public static final java.lang.String |
-RESNAME_SERVER_GROUP |
-"SERVER_GROUP" |
-
-
-public static final java.lang.String |
-RESNAME_SERVER_ROOT |
-"SERVER_ROOT" |
-
| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-public static final java.lang.String |
-LINE_SEPARATOR |
-"\r\n" |
-
| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-public static final short |
-SIGN_NOLENGTH |
--2 |
-
-
-public static final short |
-SIGN_NULL |
--1 |
-
| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-public static final byte |
-SIGN_HASNEXT |
-1 |
-
-
-public static final byte |
-SIGN_NONEXT |
-0 |
-
-
-public static final short |
-SIGN_OBJECTB |
-187 |
-
-
-public static final short |
-SIGN_OBJECTE |
-238 |
-
-
-public static final byte |
-VERBOSE_NO |
-1 |
-
-
-public static final byte |
-VERBOSE_YES |
-2 |
-
| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-public static final java.lang.String |
-RESNAME_SERVER_ROOT |
-"SERVER_ROOT" |
-
| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-public static final java.lang.String |
-DEFAULT_PROTOCOL |
-"TCP" |
-
| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-public static final int |
-RET_METHOD_ERROR |
-18000002 |
-
-
-public static final int |
-RET_SERVER_ERROR |
-18000001 |
-
| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-protected static final java.lang.String |
-SESSIONID_NAME |
-"JSESSIONID" |
-
| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-public static final java.lang.String |
-REST_HEADER_RESOURCE_NAME |
-"rest-resource-name" |
-
| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-public static final int |
-RETCODE_ENGINE_NULL |
-32 |
-
-
-public static final int |
-RETCODE_GROUP_EMPTY |
-128 |
-
-
-public static final int |
-RETCODE_ILLEGALBUFFER |
-8 |
-
-
-public static final int |
-RETCODE_NODESERVICE_NULL |
-64 |
-
-
-public static final int |
-RETCODE_SEND_ILLPACKET |
-2 |
-
-
-public static final int |
-RETCODE_SENDEXCEPTION |
-16 |
-
-
-public static final int |
-RETCODE_WSOCKET_CLOSED |
-4 |
-
-
-public static final int |
-RETCODE_WSOFFLINE |
-256 |
-
| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-public static final int |
-DEFAILT_LIVEINTERVAL |
-60 |
-
-
-public static final java.lang.String |
-WEBPARAM__LIVEINTERVAL |
-"liveinterval" |
-
| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-public static final int |
-HEADER_SIZE |
-60 |
-
| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-public static final int |
-RETCODE_ILLACTIONID |
-32768 |
-
-
-public static final int |
-RETCODE_ILLSERVICEID |
-1024 |
-
-
-public static final int |
-RETCODE_ILLSERVICEVER |
-2048 |
-
-
-public static final int |
-RETCODE_THROWEXCEPTION |
-1073741824 |
-
| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-public static final java.lang.String |
-DATASOURCE_CONFPATH |
-"DATASOURCE_CONFPATH" |
-
| 限定符和类型 | -常量字段 | -值 | -
|---|---|---|
-
-public static final java.lang.String |
-RESOURCE_PARENT_NAME |
-"$" |
-
K - SessionID的类型C - Context的子类型R - Request的子类型P - Response的子类型S - Servlet的子类型public abstract class PrepareServlet<K extends java.io.Serializable,C extends Context,R extends Request<C>,P extends Response<C,R>,S extends Servlet<C,R,P>> -extends Servlet<C,R,P>-
- 详情见: https://redkale.org
| 限定符和类型 | -字段和说明 | -
|---|---|
protected java.util.concurrent.atomic.AtomicLong |
-executeCounter |
-
protected java.util.concurrent.atomic.AtomicLong |
-illRequestCounter |
-
protected java.util.Map<K,S> |
-mappings |
-
protected java.util.Set<S> |
-servlets |
-
| 构造器和说明 | -
|---|
PrepareServlet() |
-
| 限定符和类型 | -方法和说明 | -
|---|---|
abstract void |
-addServlet(S servlet,
- java.lang.Object attachment,
- AnyValue conf,
- K... mappings) |
-
protected AnyValue |
-getServletConf(Servlet servlet) |
-
java.util.Set<S> |
-getServlets() |
-
void |
-prepare(java.nio.ByteBuffer buffer,
- R request,
- P response) |
-
protected void |
-setServletConf(Servlet servlet,
- AnyValue conf) |
-
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprotected final java.util.concurrent.atomic.AtomicLong executeCounter-
protected final java.util.concurrent.atomic.AtomicLong illRequestCounter-
public abstract void addServlet(S servlet, - java.lang.Object attachment, - AnyValue conf, - K... mappings)-
public final void prepare(java.nio.ByteBuffer buffer, - R request, - P response) - throws java.io.IOException-
java.io.IOExceptionpublic java.util.Set<S> getServlets()-
K - 请求ID的数据类型， 例如HTTP协议请求标识为url，请求ID的数据类型就是StringC - ContextR - RequestP - ResponseS - Servletpublic abstract class Server<K extends java.io.Serializable,C extends Context,R extends Request<C>,P extends Response<C,R>,S extends Servlet<C,R,P>>
-extends java.lang.Object
-- 详情见: https://redkale.org
| 限定符和类型 | -字段和说明 | -
|---|---|
protected java.net.InetSocketAddress |
-address |
-
protected int |
-backlog |
-
protected int |
-bufferCapacity |
-
protected int |
-bufferPoolSize |
-
protected java.nio.charset.Charset |
-charset |
-
protected AnyValue |
-config |
-
protected C |
-context |
-
protected java.util.concurrent.ExecutorService |
-executor |
-
protected java.util.logging.Logger |
-logger |
-
protected int |
-maxbody |
-
protected java.lang.String |
-name |
-
protected PrepareServlet<K,C,R,P,S> |
-prepare |
-
protected java.lang.String |
-protocol |
-
protected int |
-readTimeoutSecond |
-
static java.lang.String |
-RESNAME_SERVER_ROOT |
-
protected int |
-responsePoolSize |
-
protected ProtocolServer |
-serverChannel |
-
protected long |
-serverStartTime |
-
protected int |
-threads |
-
protected WatchFactory |
-watch |
-
protected int |
-writeTimeoutSecond |
-
| 限定符 | -构造器和说明 | -
|---|---|
protected |
-Server(long serverStartTime,
- java.lang.String protocol,
- PrepareServlet<K,C,R,P,S> servlet,
- WatchFactory watch) |
-
| 限定符和类型 | -方法和说明 | -
|---|---|
void |
-addServlet(S servlet,
- java.lang.Object attachment,
- AnyValue conf,
- K... mappings) |
-
protected abstract C |
-createContext() |
-
protected java.text.Format |
-createFormat() |
-
void |
-destroy(AnyValue config) |
-
C |
-getContext() |
-
java.util.logging.Logger |
-getLogger() |
-
java.lang.String |
-getName() |
-
PrepareServlet<K,C,R,P,S> |
-getPrepareServlet() |
-
java.lang.String |
-getProtocol() |
-
java.net.InetSocketAddress |
-getSocketAddress() |
-
void |
-init(AnyValue config) |
-
static java.net.URL[] |
-loadLib(java.util.logging.Logger logger,
- java.lang.String lib) |
-
void |
-shutdown() |
-
void |
-start() |
-
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic static final java.lang.String RESNAME_SERVER_ROOT-
protected final java.util.logging.Logger logger-
protected final long serverStartTime-
protected final WatchFactory watch-
protected java.lang.String name-
protected final java.lang.String protocol-
protected final PrepareServlet<K extends java.io.Serializable,C extends Context,R extends Request<C>,P extends Response<C,R>,S extends Servlet<C,R,P>> prepare-
protected AnyValue config-
protected java.nio.charset.Charset charset-
protected java.net.InetSocketAddress address-
protected int backlog-
protected ProtocolServer serverChannel-
protected int bufferCapacity-
protected int threads-
protected java.util.concurrent.ExecutorService executor-
protected int bufferPoolSize-
protected int responsePoolSize-
protected int maxbody-
protected int readTimeoutSecond-
protected int writeTimeoutSecond-
protected Server(long serverStartTime, - java.lang.String protocol, - PrepareServlet<K,C,R,P,S> servlet, - WatchFactory watch)-
public void init(AnyValue config) - throws java.lang.Exception-
java.lang.Exceptionpublic void destroy(AnyValue config) - throws java.lang.Exception-
java.lang.Exceptionpublic java.net.InetSocketAddress getSocketAddress()-
public java.lang.String getName()-
public java.lang.String getProtocol()-
public java.util.logging.Logger getLogger()-
public C getContext()-
public void addServlet(S servlet, - java.lang.Object attachment, - AnyValue conf, - K... mappings)-
public void start() - throws java.io.IOException-
java.io.IOExceptionprotected abstract C createContext()-
public void shutdown() - throws java.io.IOException-
java.io.IOExceptionprotected java.text.Format createFormat()-
public static java.net.URL[] loadLib(java.util.logging.Logger logger, - java.lang.String lib) - throws java.lang.Exception-
java.lang.ExceptionT - Service的子类public final class ServiceWrapper<T extends Service> -extends java.lang.Object -implements java.lang.Comparable<ServiceWrapper>-
| 构造器和说明 | -
|---|
ServiceWrapper(java.lang.Class<T> type,
- T service,
- java.lang.String name,
- java.lang.String sncpGroup,
- java.util.Set<java.lang.String> groups,
- AnyValue conf) |
-
ServiceWrapper(T service,
- java.lang.String name,
- java.lang.String sncpGroup,
- java.util.Set<java.lang.String> groups,
- AnyValue conf) |
-
| 限定符和类型 | -方法和说明 | -
|---|---|
int |
-compareTo(ServiceWrapper o) |
-
boolean |
-equals(java.lang.Object obj) |
-
AnyValue |
-getConf() |
-
java.util.Set<java.lang.String> |
-getGroups() |
-
java.lang.String |
-getName() |
-
Service |
-getService() |
-
java.lang.Class[] |
-getTypes() |
-
int |
-hashCode() |
-
boolean |
-isRemote() |
-
static java.lang.Class[] |
-parseTypes(java.lang.Class<? extends Service> servicetype) |
-
java.lang.String |
-toSimpleString() |
-
java.lang.String |
-toString() |
-
clone, finalize, getClass, notify, notifyAll, wait, wait, waitpublic ServiceWrapper(T service, - java.lang.String name, - java.lang.String sncpGroup, - java.util.Set<java.lang.String> groups, - AnyValue conf)-
public static java.lang.Class[] parseTypes(java.lang.Class<? extends Service> servicetype)-
public java.lang.String toString()-
toString 在类中 java.lang.Objectpublic java.lang.String toSimpleString()-
public boolean equals(java.lang.Object obj)-
equals 在类中 java.lang.Objectpublic int hashCode()-
hashCode 在类中 java.lang.Objectpublic int compareTo(ServiceWrapper o)-
compareTo 在接口中 java.lang.Comparable<ServiceWrapper>public java.lang.Class[] getTypes()-
public Service getService()-
public AnyValue getConf()-
public java.lang.String getName()-
public boolean isRemote()-
public java.util.Set<java.lang.String> getGroups()-
public abstract class Sncp
-extends java.lang.Object
-| 限定符和类型 | -方法和说明 | -
|---|---|
static <T extends Service> |
-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> |
-createLocalServiceClass(java.lang.String name,
- java.lang.Class<T> serviceClass)
-
- public class TestService implements Service{
-
- public String findSomeThing(){
- return "hello";
- }
-
- @RpcMultiRun(selfrun = false)
- public void createSomeThing(TestBean bean){
- //do something
- }
-
- @RpcMultiRun
- 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_bsonConvert;
-
- @Resource
- private JsonConvert _redkale_jsonConvert;
-
- 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> |
-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_bsonConvert;
-
- @Resource
- private JsonConvert _redkale_jsonConvert;
-
- 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) |
-
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic static long nodeid(java.net.InetSocketAddress ip)-
public static DLong hash(java.lang.reflect.Method method)-
public static DLong hash(java.lang.String name)-
name - Stringpublic static boolean isRemote(Service service)-
public static SncpClient getSncpClient(Service 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";
- }
-
- @RpcMultiRun(selfrun = false)
- public void createSomeThing(TestBean bean){
- //do something
- }
-
- @RpcMultiRun
- 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_bsonConvert;
-
- @Resource
- private JsonConvert _redkale_jsonConvert;
-
- 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_bsonConvert, _redkale_jsonConvert, _sameGroupTransport, 0, true, false, false, bean);
- if (diffrunnable) _redkale_client.remoteDiffGroup(_redkale_bsonConvert, _redkale_jsonConvert, _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_bsonConvert, _redkale_jsonConvert, _sameGroupTransport, 1, true, false, false, id);
- if (diffrunnable) _redkale_client.remoteDiffGroup(_redkale_bsonConvert, _redkale_jsonConvert, _diffGroupTransports, 1, true, true, false, id);
- return rs;
- }
- }
- T - Service子类name - 资源名serviceClass - Service类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)-
T - Service泛型name - 资源名executor - 线程池resourceFactory - 资源容器serviceClass - Service类clientAddress - 本地IP地址sameGroupTransport - 同组的通信组件diffGroupTransports - 异组的通信组件列表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_bsonConvert;
-
- @Resource
- private JsonConvert _redkale_jsonConvert;
-
- 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_bsonConvert, _redkale_jsonConvert, _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_bsonConvert, _redkale_jsonConvert, _redkale_transport, 1, selfrunnable, samerunnable, diffrunnable, id);
- }
-
- @Override
- public void createSomeThing(TestBean bean){
- _redkale_client.remote(_redkale_bsonConvert, _redkale_jsonConvert, _redkale_transport, 2, bean);
- }
-
- @Override
- public String findSomeThing(){
- return _redkale_client.remote(_redkale_bsonConvert, _redkale_jsonConvert, _redkale_transport, 3);
- }
-
- @Override
- public String updateSomeThing(String id){
- return _redkale_client.remote(_redkale_bsonConvert, _redkale_jsonConvert, _redkale_transport, 4, id);
- }
- }
- T - Service泛型name - 资源名executor - 线程池serviceClass - Service类clientAddress - 本地IP地址transport - 通信组件protected static final class SncpClient.SncpAction
-extends java.lang.Object
-| 限定符和类型 | -字段和说明 | -
|---|---|
protected DLong |
-actionid |
-
protected int |
-addressSourceParamIndex |
-
protected int |
-addressTargetParamIndex |
-
protected java.lang.reflect.Method |
-method |
-
protected Attribute[] |
-paramAttrs |
-
protected java.lang.reflect.Type[] |
-paramTypes |
-
protected java.lang.reflect.Type |
-resultTypes |
-
| 构造器和说明 | -
|---|
SncpAction(java.lang.reflect.Method method,
- DLong actionid) |
-
protected final DLong actionid-
protected final java.lang.reflect.Method method-
protected final java.lang.reflect.Type resultTypes-
protected final java.lang.reflect.Type[] paramTypes-
protected final Attribute[] paramAttrs-
protected final int addressTargetParamIndex-
protected final int addressSourceParamIndex-
public final class SncpClient
-extends java.lang.Object
-- 详情见: https://redkale.org
| 限定符和类型 | -类和说明 | -
|---|---|
protected static class |
-SncpClient.SncpAction |
-
protected static class |
-SncpClient.SncpFuture<T> |
-
| 限定符和类型 | -字段和说明 | -
|---|---|
protected SncpClient.SncpAction[] |
-actions |
-
protected java.net.InetSocketAddress |
-clientAddress |
-
protected JsonConvert |
-convert |
-
protected java.util.function.Consumer<java.lang.Runnable> |
-executor |
-
protected boolean |
-finest |
-
protected static java.util.logging.Logger |
-logger |
-
protected java.lang.String |
-name |
-
protected boolean |
-remote |
-
protected DLong |
-serviceid |
-
protected int |
-serviceversion |
-
| 构造器和说明 | -
|---|
SncpClient(java.lang.String serviceName,
- java.lang.Class<T> serviceType,
- T service,
- java.util.function.Consumer<java.lang.Runnable> executor,
- boolean remote,
- java.lang.Class serviceClass,
- java.net.InetSocketAddress clientAddress) |
-
| 限定符和类型 | -方法和说明 | -
|---|---|
void |
-asyncRemoteDiffGroup(BsonConvert bsonConvert,
- JsonConvert jsonConvert,
- Transport[] transports,
- int index,
- java.lang.Object... params) |
-
void |
-asyncRemoteSameGroup(BsonConvert bsonConvert,
- JsonConvert jsonConvert,
- Transport transport,
- int index,
- java.lang.Object... params) |
-
int |
-getActionCount() |
-
java.net.InetSocketAddress |
-getClientAddress() |
-
DLong |
-getServiceid() |
-
int |
-getServiceversion() |
-
static java.util.List<java.lang.reflect.Method> |
-parseMethod(java.lang.Class serviceClass) |
-
<T> void |
-remote(BsonConvert bsonConvert,
- JsonConvert jsonConvert,
- Transport[] transports,
- int index,
- java.lang.Object... params) |
-
<T> T |
-remote(BsonConvert bsonConvert,
- JsonConvert jsonConvert,
- Transport transport,
- int index,
- java.lang.Object... params) |
-
void |
-remoteDiffGroup(BsonConvert bsonConvert,
- JsonConvert jsonConvert,
- Transport[] transports,
- int index,
- java.lang.Object... params) |
-
void |
-remoteSameGroup(BsonConvert bsonConvert,
- JsonConvert jsonConvert,
- Transport transport,
- int index,
- java.lang.Object... params) |
-
java.lang.String |
-toString() |
-
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitprotected static final java.util.logging.Logger logger-
protected final boolean finest-
protected final JsonConvert convert-
protected final java.lang.String name-
protected final boolean remote-
protected final java.net.InetSocketAddress clientAddress-
protected final DLong serviceid-
protected final int serviceversion-
protected final SncpClient.SncpAction[] actions-
protected final java.util.function.Consumer<java.lang.Runnable> executor-
public SncpClient(java.lang.String serviceName, - java.lang.Class<T> serviceType, - T service, - java.util.function.Consumer<java.lang.Runnable> executor, - boolean remote, - java.lang.Class serviceClass, - java.net.InetSocketAddress clientAddress)-
public java.net.InetSocketAddress getClientAddress()-
public DLong getServiceid()-
public int getServiceversion()-
public int getActionCount()-
public java.lang.String toString()-
toString 在类中 java.lang.Objectpublic static java.util.List<java.lang.reflect.Method> parseMethod(java.lang.Class serviceClass)-
public void remoteSameGroup(BsonConvert bsonConvert, - JsonConvert jsonConvert, - Transport transport, - int index, - java.lang.Object... params)-
public void asyncRemoteSameGroup(BsonConvert bsonConvert, - JsonConvert jsonConvert, - Transport transport, - int index, - java.lang.Object... params)-
public void remoteDiffGroup(BsonConvert bsonConvert, - JsonConvert jsonConvert, - Transport[] transports, - int index, - java.lang.Object... params)-
public void asyncRemoteDiffGroup(BsonConvert bsonConvert, - JsonConvert jsonConvert, - Transport[] transports, - int index, - java.lang.Object... params)-
public <T> T remote(BsonConvert bsonConvert, - JsonConvert jsonConvert, - Transport transport, - int index, - java.lang.Object... params)-
public <T> void remote(BsonConvert bsonConvert, - JsonConvert jsonConvert, - Transport[] transports, - int index, - java.lang.Object... params)-
public class SncpContext -extends Context-
- 详情见: https://redkale.org
bsonFactory, bufferCapacity, bufferPool, charset, executor, jsonFactory, logger, maxbody, prepare, readTimeoutSecond, responsePool, serverStartTime, watch, writeTimeoutSecond| 构造器和说明 | -
|---|
SncpContext(long serverStartTime,
- java.util.logging.Logger logger,
- java.util.concurrent.ExecutorService executor,
- int bufferCapacity,
- ObjectPool<java.nio.ByteBuffer> bufferPool,
- ObjectPool<Response> responsePool,
- int maxbody,
- java.nio.charset.Charset charset,
- java.net.InetSocketAddress address,
- PrepareServlet prepare,
- WatchFactory watch,
- int readTimeoutSecond,
- int writeTimeoutSecond) |
-
getBsonConvert, getBufferCapacity, getBufferSupplier, getCharset, getJsonConvert, getLogger, getMaxbody, getReadTimeoutSecond, getServerAddress, getServerStartTime, getWriteTimeoutSecond, offerBuffer, pollBuffer, submitclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic SncpContext(long serverStartTime, - java.util.logging.Logger logger, - java.util.concurrent.ExecutorService executor, - int bufferCapacity, - ObjectPool<java.nio.ByteBuffer> bufferPool, - ObjectPool<Response> responsePool, - int maxbody, - java.nio.charset.Charset charset, - java.net.InetSocketAddress address, - PrepareServlet prepare, - WatchFactory watch, - int readTimeoutSecond, - int writeTimeoutSecond)-
@Inherited
- @Documented
- @Target(value={METHOD,TYPE})
- @Retention(value=RUNTIME)
-public @interface SncpDyn
-详情见: https://redkale.org
public final class SncpDynServlet -extends SncpServlet-
| 限定符和类型 | -类和说明 | -
|---|---|
static class |
-SncpDynServlet.SncpServletAction |
-
| 构造器和说明 | -
|---|
SncpDynServlet(BsonConvert convert,
- java.lang.String serviceName,
- java.lang.Class<? extends Service> type,
- Service service) |
-
| 限定符和类型 | -方法和说明 | -
|---|---|
int |
-compareTo(SncpServlet o0) |
-
void |
-execute(SncpRequest request,
- SncpResponse response) |
-
DLong |
-getServiceid() |
-
java.lang.String |
-toString() |
-
equals, hashCodeclone, finalize, getClass, notify, notifyAll, wait, wait, waitpublic SncpDynServlet(BsonConvert convert, - java.lang.String serviceName, - java.lang.Class<? extends Service> type, - Service service)-
public java.lang.String toString()-
toString 在类中 java.lang.Objectpublic DLong getServiceid()-
getServiceid 在类中 SncpServletpublic int compareTo(SncpServlet o0)-
compareTo 在接口中 java.lang.Comparable<SncpServlet>compareTo 在类中 SncpServletpublic void execute(SncpRequest request, - SncpResponse response) - throws java.io.IOException-
execute 在类中 Servlet<SncpContext,SncpRequest,SncpResponse>java.io.IOExceptionpublic final class SncpRequest -extends Request<SncpContext>-
- 详情见: https://redkale.org
| 限定符和类型 | -字段和说明 | -
|---|---|
protected BsonConvert |
-convert |
-
static byte[] |
-DEFAULT_HEADER |
-
static int |
-HEADER_SIZE |
-
attributes, bsonConvert, channel, context, createtime, jsonConvert, keepAlive| 限定符 | -构造器和说明 | -
|---|---|
protected |
-SncpRequest(SncpContext context) |
-
| 限定符和类型 | -方法和说明 | -
|---|---|
DLong |
-getActionid() |
-
byte[] |
-getBody() |
-
java.net.InetSocketAddress |
-getRemoteAddress() |
-
long |
-getSeqid() |
-
DLong |
-getServiceid() |
-
int |
-getServiceversion() |
-
protected boolean |
-isPing() |
-
protected void |
-prepare() |
-
protected int |
-readBody(java.nio.ByteBuffer buffer)
-读取buffer，并返回读取的有效数据长度
- |
-
protected int |
-readHeader(java.nio.ByteBuffer buffer)
-返回值：Integer.MIN_VALUE: 帧数据； -1：数据不合法； 0：解析完毕； >0: 需再读取的字节数。
- |
-
protected void |
-recycle() |
-
java.lang.String |
-toString() |
-
getAttribute, getAttributes, getContext, getCreatetime, getProperties, getProperty, removeAttribute, removeProperty, setAttribute, setPropertyclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitpublic static final int HEADER_SIZE-
public static final byte[] DEFAULT_HEADER-
protected final BsonConvert convert-
protected SncpRequest(SncpContext context)-
protected int readHeader(java.nio.ByteBuffer buffer)-
RequestreadHeader 在类中 Request<SncpContext>buffer - ByteBuffer对象protected int readBody(java.nio.ByteBuffer buffer)-
RequestreadBody 在类中 Request<SncpContext>buffer - ByteBuffer对象protected void prepare()-
prepare 在类中 Request<SncpContext>public java.lang.String toString()-
toString 在类中 java.lang.Objectprotected void recycle()-
recycle 在类中 Request<SncpContext>protected boolean isPing()-
public byte[] getBody()-
public long getSeqid()-
public int getServiceversion()-
public DLong getServiceid()-
public DLong getActionid()-
public java.net.InetSocketAddress getRemoteAddress()-
public final class SncpResponse -extends Response<SncpContext,SncpRequest>-
- 详情见: https://redkale.org
| 限定符和类型 | -字段和说明 | -
|---|---|
static int |
-RETCODE_ILLACTIONID |
-
static int |
-RETCODE_ILLSERVICEID |
-
static int |
-RETCODE_ILLSERVICEVER |
-
static int |
-RETCODE_THROWEXCEPTION |
-
| 限定符 | -构造器和说明 | -
|---|---|
protected |
-SncpResponse(SncpContext context,
- SncpRequest request) |
-
| 限定符和类型 | -方法和说明 | -
|---|---|
static ObjectPool<Response> |
-createPool(java.util.concurrent.atomic.AtomicLong creatCounter,
- java.util.concurrent.atomic.AtomicLong cycleCounter,
- int max,
- Creator<Response> creator) |
-
void |
-finish(int retcode,
- BsonWriter out) |
-
static java.lang.String |
-getRetCodeInfo(int retcode) |
-
finish, finish, finish, finish, finish, finish, getContext, init, prepare, recycle, refuseAlive, removeChannel, send, send, setRecycleListenerclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic static final int RETCODE_ILLSERVICEID-
public static final int RETCODE_ILLSERVICEVER-
public static final int RETCODE_ILLACTIONID-
public static final int RETCODE_THROWEXCEPTION-
protected SncpResponse(SncpContext context, - SncpRequest request)-
public static ObjectPool<Response> createPool(java.util.concurrent.atomic.AtomicLong creatCounter, - java.util.concurrent.atomic.AtomicLong cycleCounter, - int max, - Creator<Response> creator)-
public static java.lang.String getRetCodeInfo(int retcode)-
public void finish(int retcode, - BsonWriter out)-
public abstract class SncpServlet -extends Servlet<SncpContext,SncpRequest,SncpResponse> -implements java.lang.Comparable<SncpServlet>-
- 详情见: https://redkale.org
| 构造器和说明 | -
|---|
SncpServlet() |
-
| 限定符和类型 | -方法和说明 | -
|---|---|
int |
-compareTo(SncpServlet o) |
-
boolean |
-equals(java.lang.Object obj) |
-
abstract DLong |
-getServiceid() |
-
int |
-hashCode() |
-
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, waitpublic abstract DLong getServiceid()-
public final boolean equals(java.lang.Object obj)-
equals 在类中 java.lang.Objectpublic final int hashCode()-
hashCode 在类中 java.lang.Objectpublic int compareTo(SncpServlet o)-
compareTo 在接口中 java.lang.Comparable<SncpServlet>| 类 | -说明 | -
|---|---|
| ServiceWrapper<T extends Service> | -
- Service对象的封装类
-
-
- 详情见: https://redkale.org
- |
-
| Sncp | -
- Service Node Communicate Protocol
- 生成Service的本地模式或远程模式Service-Class的工具类
-
-
- 详情见: https://redkale.org
- |
-
| SncpClient | -
-
- 详情见: https://redkale.org
- |
-
| SncpClient.SncpAction | -- |
| SncpClient.SncpFuture<T> | -- |
| SncpContext | -
-
- 详情见: https://redkale.org
- |
-
| SncpDynServlet | -
- 详情见: https://redkale.org
- |
-
| SncpDynServlet.SncpServletAction | -- |
| SncpPrepareServlet | -
-
- 详情见: https://redkale.org
- |
-
| SncpRequest | -
-
- 详情见: https://redkale.org
- |
-
| SncpResponse | -
-
- 详情见: https://redkale.org
- |
-
| SncpServer | -
- Service Node Communicate Protocol
-
-
- 详情见: https://redkale.org
- |
-
| SncpServlet | -
-
- 详情见: https://redkale.org
- |
-
| 注释类型 | -说明 | -
|---|---|
| SncpDyn | -
- 修饰由SNCP协议动态生成的class、和method
- 本地模式：动态生成的_DynLocalXXXXService类其带有@RpcMultiRun方法均会打上@SncpDyn(remote = false, index=N) 的注解
- 远程模式：动态生成的_DynRemoteXXXService类会打上@SncpDyn(remote = true) 的注解
-
- 详情见: https://redkale.org
- |
-
| 程序包 | -说明 | -
|---|---|
| org.redkale.boot | -
- 提供Redkale服务器的启动、初始化和加载功能
- |
-
| org.redkale.net.sncp | -
- SNCP协议包,提供SNCP协议服务器
- |
-
| 类和说明 | -
|---|
| ServiceWrapper
- Service对象的封装类
-
-
- 详情见: https://redkale.org
- |
-
| SncpServer
- Service Node Communicate Protocol
-
-
- 详情见: https://redkale.org
- |
-
| 类和说明 | -
|---|
| ServiceWrapper
- Service对象的封装类
-
-
- 详情见: https://redkale.org
- |
-
| SncpClient
-
- 详情见: https://redkale.org
- |
-
| SncpClient.SncpAction | -
| SncpContext
-
- 详情见: https://redkale.org
- |
-
| SncpDynServlet.SncpServletAction | -
| SncpRequest
-
- 详情见: https://redkale.org
- |
-
| SncpResponse
-
- 详情见: https://redkale.org
- |
-
| SncpServlet
-
- 详情见: https://redkale.org
- |
-