org.redkale.net

类 Server<K extends java.io.Serializable,C extends Context,R extends Request<C>,P extends Response<C,R>,S extends Servlet<C,R,P>>

java.lang.Object

org.redkale.net.Server<K,C,R,P,S>

类型参数:

K - 请求ID的数据类型， 例如HTTP协议请求标识为url，请求ID的数据类型就是String

C - Context

R - Request

P - Response

S - Servlet

直接已知子类:

HttpServer, SncpServer

public 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	aliveTimeoutSeconds
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.ThreadPoolExecutor	executor
protected java.util.logging.Logger	logger
protected int	maxbody
protected int	maxconns
protected java.lang.String	name
protected PrepareServlet<K,C,R,P,S>	prepare
protected java.lang.String	protocol
protected int	readTimeoutSeconds
static java.lang.String	RESNAME_SERVER_EXECUTOR
static java.lang.String	RESNAME_SERVER_RESFACTORY
static java.lang.String	RESNAME_SERVER_ROOT
protected ResourceFactory	resourceFactory
protected int	responsePoolSize
protected ProtocolServer	serverChannel
protected RedkaleClassLoader	serverClassLoader
protected long	serverStartTime
protected javax.net.ssl.SSLContext	sslContext
protected int	threads
protected int	writeTimeoutSeconds

构造器概要

构造器

限定符	构造器和说明
protected	Server(long serverStartTime, java.lang.String protocol, ResourceFactory resourceFactory, PrepareServlet<K,C,R,P,S> servlet)

方法概要

限定符和类型	方法和说明
void	addServlet(S servlet, java.lang.Object attachment, AnyValue conf, K... mappings)
void	changeAddress(java.net.InetSocketAddress addr)
void	changeAliveTimeoutSeconds(int newAliveTimeoutSeconds)
void	changeCharset(java.nio.charset.Charset newcharset)
void	changeMaxbody(int newmaxbody)
void	changeMaxconns(int newmaxconns)
void	changeReadTimeoutSeconds(int newReadTimeoutSeconds)
void	changeWriteTimeoutSeconds(int newWriteTimeoutSeconds)
<T extends Filter> boolean	containsFilter(java.lang.Class<T> filterClass) 判断是否存在Filter
<T extends Filter> boolean	containsFilter(java.lang.String filterClassName) 判断是否存在Filter
boolean	containsServlet(java.lang.Class<? extends S> servletClass) 判断是否存在Servlet
boolean	containsServlet(java.lang.String servletClassName) 判断是否存在Servlet
protected abstract ObjectPool<java.nio.ByteBuffer>	createBufferPool(java.util.concurrent.atomic.AtomicLong createCounter, java.util.concurrent.atomic.AtomicLong cycleCounter, int bufferPoolSize)
protected abstract C	createContext()
protected java.text.Format	createFormat()
protected abstract Creator<Response>	createResponseCreator(ObjectPool<java.nio.ByteBuffer> bufferPool, ObjectPool<Response> responsePool)
protected abstract ObjectPool<Response>	createResponsePool(java.util.concurrent.atomic.AtomicLong createCounter, java.util.concurrent.atomic.AtomicLong cycleCounter, int responsePoolSize)
void	destroy(AnyValue config)
void	destroyServlet(S servlet) 销毁Servlet
protected static java.lang.String	formatLenth(long value)
int	getAliveTimeoutSeconds()
int	getBacklog()
int	getBufferCapacity()
int	getBufferPoolSize()
java.nio.charset.Charset	getCharset()
long	getClosedConnectionCount()
C	getContext()
long	getCreateConnectionCount()
java.util.concurrent.ThreadPoolExecutor	getExecutor()
long	getLivingConnectionCount()
java.util.logging.Logger	getLogger()
int	getMaxbody()
int	getMaxconns()
java.lang.String	getName()
PrepareServlet<K,C,R,P,S>	getPrepareServlet()
java.lang.String	getProtocol()
int	getReadTimeoutSeconds()
ResourceFactory	getResourceFactory()
int	getResponsePoolSize()
RedkaleClassLoader	getServerClassLoader()
long	getServerStartTime()
java.net.InetSocketAddress	getSocketAddress()
int	getThreads()
int	getWriteTimeoutSeconds()
void	init(AnyValue config)
static java.net.URL[]	loadLib(RedkaleClassLoader classLoader, java.util.logging.Logger logger, java.lang.String lib)
protected static int	parseLenth(java.lang.String value, int defValue)
protected static long	parseLenth(java.lang.String value, long defValue)
protected void	postStart()
void	setServerClassLoader(RedkaleClassLoader serverClassLoader)
void	setThreads(int threads)
void	shutdown()
void	start()

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

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

字段详细资料

RESNAME_SERVER_ROOT

public static final java.lang.String RESNAME_SERVER_ROOT

另请参阅:

常量字段值

RESNAME_SERVER_EXECUTOR

public static final java.lang.String RESNAME_SERVER_EXECUTOR

另请参阅:

常量字段值

RESNAME_SERVER_RESFACTORY

public static final java.lang.String RESNAME_SERVER_RESFACTORY

另请参阅:

常量字段值

logger

protected final java.util.logging.Logger logger

serverStartTime

protected final long serverStartTime

name

protected java.lang.String name

protocol

protected final java.lang.String protocol

resourceFactory

protected final ResourceFactory resourceFactory

prepare

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

serverClassLoader

protected RedkaleClassLoader serverClassLoader

sslContext

protected javax.net.ssl.SSLContext sslContext

context

protected C extends Context context

config

protected AnyValue config

charset

protected java.nio.charset.Charset charset

address

protected java.net.InetSocketAddress address

backlog

protected int backlog

serverChannel

protected ProtocolServer serverChannel

bufferCapacity

protected int bufferCapacity

threads

protected int threads

executor

protected java.util.concurrent.ThreadPoolExecutor executor

bufferPoolSize

protected int bufferPoolSize

responsePoolSize

protected int responsePoolSize

maxconns

protected int maxconns

maxbody

protected int maxbody

aliveTimeoutSeconds

protected int aliveTimeoutSeconds

readTimeoutSeconds

protected int readTimeoutSeconds

writeTimeoutSeconds

protected int writeTimeoutSeconds

构造器详细资料

Server

protected Server(long serverStartTime,
                 java.lang.String protocol,
                 ResourceFactory resourceFactory,
                 PrepareServlet<K,C,R,P,S> servlet)

方法详细资料

init

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

抛出:

java.lang.Exception

parseLenth

protected static int parseLenth(java.lang.String value,
                                int defValue)

parseLenth

protected static long parseLenth(java.lang.String value,
                                 long defValue)

formatLenth

protected static java.lang.String formatLenth(long value)

destroy

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

抛出:

java.lang.Exception

getResourceFactory

public ResourceFactory getResourceFactory()

getExecutor

public java.util.concurrent.ThreadPoolExecutor getExecutor()

getSocketAddress

public java.net.InetSocketAddress getSocketAddress()

getName

public java.lang.String getName()

getProtocol

public java.lang.String getProtocol()

getLogger

public java.util.logging.Logger getLogger()

getPrepareServlet

public PrepareServlet<K,C,R,P,S> getPrepareServlet()

getContext

public C getContext()

getServerStartTime

public long getServerStartTime()

getCharset

public java.nio.charset.Charset getCharset()

getBacklog

public int getBacklog()

getBufferCapacity

public int getBufferCapacity()

getThreads

public int getThreads()

getBufferPoolSize

public int getBufferPoolSize()

getResponsePoolSize

public int getResponsePoolSize()

getMaxbody

public int getMaxbody()

getAliveTimeoutSeconds

public int getAliveTimeoutSeconds()

getReadTimeoutSeconds

public int getReadTimeoutSeconds()

getWriteTimeoutSeconds

public int getWriteTimeoutSeconds()

getMaxconns

public int getMaxconns()

setThreads

public void setThreads(int threads)

addServlet

public void addServlet(S servlet,
                       java.lang.Object attachment,
                       AnyValue conf,
                       K... mappings)

start

public void start()
           throws java.io.IOException

抛出:

java.io.IOException

postStart

protected void postStart()

changeAddress

public void changeAddress(java.net.InetSocketAddress addr)
                   throws java.io.IOException

抛出:

java.io.IOException

changeMaxconns

public void changeMaxconns(int newmaxconns)

changeCharset

public void changeCharset(java.nio.charset.Charset newcharset)

changeMaxbody

public void changeMaxbody(int newmaxbody)

changeReadTimeoutSeconds

public void changeReadTimeoutSeconds(int newReadTimeoutSeconds)

changeWriteTimeoutSeconds

public void changeWriteTimeoutSeconds(int newWriteTimeoutSeconds)

changeAliveTimeoutSeconds

public void changeAliveTimeoutSeconds(int newAliveTimeoutSeconds)

createContext

protected abstract C createContext()

createBufferPool

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

createResponsePool

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

createResponseCreator

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

shutdown

public void shutdown()
              throws java.io.IOException

抛出:

java.io.IOException

getServerClassLoader

public RedkaleClassLoader getServerClassLoader()

setServerClassLoader

public void setServerClassLoader(RedkaleClassLoader serverClassLoader)

containsFilter

public <T extends Filter> boolean containsFilter(java.lang.Class<T> filterClass)

判断是否存在Filter

类型参数:

T - 泛型

参数:

filterClass - Filter类

返回:

boolean

containsFilter

public <T extends Filter> boolean containsFilter(java.lang.String filterClassName)

判断是否存在Filter

类型参数:

T - 泛型

参数:

filterClassName - Filter类

返回:

boolean

containsServlet

public boolean containsServlet(java.lang.Class<? extends S> servletClass)

判断是否存在Servlet

参数:

servletClass - Servlet类

返回:

boolean

containsServlet

public boolean containsServlet(java.lang.String servletClassName)

判断是否存在Servlet

参数:

servletClassName - Servlet类

返回:

boolean

destroyServlet

public void destroyServlet(S servlet)

销毁Servlet

参数:

servlet - Servlet

getCreateConnectionCount

public long getCreateConnectionCount()

getClosedConnectionCount

public long getClosedConnectionCount()

getLivingConnectionCount

public long getLivingConnectionCount()

createFormat

protected java.text.Format createFormat()

loadLib

public static java.net.URL[] loadLib(RedkaleClassLoader classLoader,
                                     java.util.logging.Logger logger,
                                     java.lang.String lib)
                              throws java.lang.Exception

抛出:

java.lang.Exception