public abstract class ProtocolServer
extends java.lang.Object
详情见: https://redkale.org
限定符和类型 | 字段和说明 |
---|---|
protected java.util.concurrent.atomic.AtomicLong |
closedCounter |
protected Context |
context |
protected java.util.concurrent.atomic.AtomicLong |
createCounter |
protected java.util.concurrent.atomic.AtomicLong |
livingCounter |
protected int |
maxconns |
限定符 | 构造器和说明 |
---|---|
protected |
ProtocolServer(Context context) |
限定符和类型 | 方法和说明 |
---|---|
abstract void |
accept(Server server) |
abstract void |
bind(java.net.SocketAddress local,
int backlog) |
abstract void |
close() |
static ProtocolServer |
create(java.lang.String protocol,
Context context,
java.lang.ClassLoader classLoader,
java.lang.String netimpl) |
long |
getClosedCount() |
long |
getCreateCount() |
long |
getLivingCount() |
abstract void |
open(AnyValue config) |
abstract <T> void |
setOption(java.net.SocketOption<T> name,
T value) |
abstract <T> java.util.Set<java.net.SocketOption<?>> |
supportedOptions() |
protected final java.util.concurrent.atomic.AtomicLong createCounter
protected final java.util.concurrent.atomic.AtomicLong closedCounter
protected final java.util.concurrent.atomic.AtomicLong livingCounter
protected final Context context
protected int maxconns
protected ProtocolServer(Context context)
public abstract void open(AnyValue config) throws java.io.IOException
java.io.IOException
public abstract void bind(java.net.SocketAddress local, int backlog) throws java.io.IOException
java.io.IOException
public abstract <T> java.util.Set<java.net.SocketOption<?>> supportedOptions()
public abstract <T> void setOption(java.net.SocketOption<T> name, T value) throws java.io.IOException
java.io.IOException
public abstract void accept(Server server) throws java.io.IOException
java.io.IOException
public abstract void close() throws java.io.IOException
java.io.IOException
public long getCreateCount()
public long getClosedCount()
public long getLivingCount()
public static ProtocolServer create(java.lang.String protocol, Context context, java.lang.ClassLoader classLoader, java.lang.String netimpl)