org.redkale.net.sncp

类 SncpServer

java.lang.Object

org.redkale.net.Server<DLong,SncpContext,SncpRequest,SncpResponse,SncpServlet>

org.redkale.net.sncp.SncpServer

public class SncpServer
extends Server<DLong,SncpContext,SncpRequest,SncpResponse,SncpServlet>

Service Node Communicate Protocol

详情见: https://redkale.org

字段概要

从类继承的字段 org.redkale.net.Server

address, aliveTimeoutSeconds, backlog, bufferCapacity, bufferPoolSize, charset, config, context, executor, logger, maxbody, maxconns, name, prepare, protocol, readTimeoutSeconds, RESNAME_SERVER_EXECUTOR, RESNAME_SERVER_RESFACTORY, RESNAME_SERVER_ROOT, resourceFactory, responsePoolSize, serverChannel, serverClassLoader, serverStartTime, sslContext, threads, writeTimeoutSeconds

构造器概要

构造器

构造器和说明
SncpServer()
SncpServer(long serverStartTime, ResourceFactory resourceFactory)
SncpServer(ResourceFactory resourceFactory)

方法概要

限定符和类型	方法和说明
SncpServer	addSncpFilter(SncpFilter filter, AnyValue conf) 添加SncpFilter
void	addSncpServlet(Service sncpService)
protected ObjectPool<java.nio.ByteBuffer>	createBufferPool(java.util.concurrent.atomic.AtomicLong createCounter, java.util.concurrent.atomic.AtomicLong cycleCounter, int bufferPoolSize)
protected SncpContext	createContext()
protected Creator<Response>	createResponseCreator(ObjectPool<java.nio.ByteBuffer> bufferPool, ObjectPool<Response> responsePool)
protected ObjectPool<Response>	createResponsePool(java.util.concurrent.atomic.AtomicLong createCounter, java.util.concurrent.atomic.AtomicLong cycleCounter, int responsePoolSize)
java.util.List<SncpFilter>	getSncpFilters()
java.util.List<SncpServlet>	getSncpServlets()
void	init(AnyValue config)
<T extends SncpFilter> T	removeSncpFilter(java.lang.Class<T> filterClass) 删除SncpFilter
SncpServlet	removeSncpServlet(Service sncpService) 删除SncpServlet

从类继承的方法 org.redkale.net.Server

addServlet, changeAddress, changeAliveTimeoutSeconds, changeCharset, changeMaxbody, changeMaxconns, changeReadTimeoutSeconds, changeWriteTimeoutSeconds, containsFilter, containsFilter, containsServlet, containsServlet, createFormat, destroy, destroyServlet, formatLenth, getAliveTimeoutSeconds, getBacklog, getBufferCapacity, getBufferPoolSize, getCharset, getClosedConnectionCount, getContext, getCreateConnectionCount, getExecutor, getLivingConnectionCount, getLogger, getMaxbody, getMaxconns, getName, getPrepareServlet, getProtocol, getReadTimeoutSeconds, getResourceFactory, getResponsePoolSize, getServerClassLoader, getServerStartTime, getSocketAddress, getThreads, getWriteTimeoutSeconds, loadLib, parseLenth, parseLenth, postStart, setServerClassLoader, setThreads, shutdown, start

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

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

构造器详细资料

SncpServer

public SncpServer()

SncpServer

public SncpServer(ResourceFactory resourceFactory)

SncpServer

public SncpServer(long serverStartTime,
                  ResourceFactory resourceFactory)

方法详细资料

init

public void init(AnyValue config)
          throws java.lang.Exception

覆盖:

init 在类中 Server<DLong,SncpContext,SncpRequest,SncpResponse,SncpServlet>

抛出:

java.lang.Exception

getSncpServlets

public java.util.List<SncpServlet> getSncpServlets()

getSncpFilters

public java.util.List<SncpFilter> getSncpFilters()

removeSncpFilter

public <T extends SncpFilter> T removeSncpFilter(java.lang.Class<T> filterClass)

删除SncpFilter

类型参数:

T - 泛型

参数:

filterClass - SncpFilter类

返回:

SncpFilter

addSncpFilter

public SncpServer addSncpFilter(SncpFilter filter,
                                AnyValue conf)

添加SncpFilter

参数:

filter - SncpFilter

conf - AnyValue

返回:

SncpServer

removeSncpServlet

public SncpServlet removeSncpServlet(Service sncpService)

删除SncpServlet

参数:

sncpService - Service

返回:

SncpServlet

addSncpServlet

public void addSncpServlet(Service sncpService)

createContext

protected SncpContext createContext()

指定者:

createContext 在类中 Server<DLong,SncpContext,SncpRequest,SncpResponse,SncpServlet>

createBufferPool

protected ObjectPool<java.nio.ByteBuffer> createBufferPool(java.util.concurrent.atomic.AtomicLong createCounter,
                                                           java.util.concurrent.atomic.AtomicLong cycleCounter,
                                                           int bufferPoolSize)

指定者:

createBufferPool 在类中 Server<DLong,SncpContext,SncpRequest,SncpResponse,SncpServlet>

createResponsePool

protected ObjectPool<Response> createResponsePool(java.util.concurrent.atomic.AtomicLong createCounter,
                                                  java.util.concurrent.atomic.AtomicLong cycleCounter,
                                                  int responsePoolSize)

指定者:

createResponsePool 在类中 Server<DLong,SncpContext,SncpRequest,SncpResponse,SncpServlet>

createResponseCreator

protected Creator<Response> createResponseCreator(ObjectPool<java.nio.ByteBuffer> bufferPool,
                                                  ObjectPool<Response> responsePool)

指定者:

createResponseCreator 在类中 Server<DLong,SncpContext,SncpRequest,SncpResponse,SncpServlet>