public abstract class NodeServer
extends java.lang.Object
详情见: http://www.redkale.org
| 限定符和类型 | 字段和说明 |
|---|---|
protected Application |
application |
protected java.util.function.Consumer<ServiceWrapper> |
consumer |
protected ResourceFactory |
factory |
protected boolean |
fine |
protected boolean |
finer |
static java.lang.String |
LINE_SEPARATOR |
protected java.util.Set<ServiceWrapper> |
localServiceWrappers |
protected java.util.logging.Logger |
logger |
protected java.util.Set<ServiceWrapper> |
remoteServiceWrappers |
protected Server |
server |
protected AnyValue |
serverConf |
| 构造器和说明 |
|---|
NodeServer(Application application,
Server server) |
| 限定符和类型 | 方法和说明 |
|---|---|
static <T extends NodeServer> |
create(java.lang.Class<T> clazz,
Application application,
AnyValue serconf) |
protected ClassFilter |
createClassFilter(java.lang.String localGroup,
java.lang.Class<? extends java.lang.annotation.Annotation> ref,
java.lang.Class inter,
java.lang.Class<? extends java.lang.annotation.Annotation> ref2,
java.lang.String properties,
java.lang.String property) |
protected ClassFilter<Service> |
createServiceClassFilter() |
protected abstract ClassFilter<Servlet> |
createServletClassFilter() |
protected java.util.function.Consumer<java.lang.Runnable> |
getExecutor() |
java.net.InetSocketAddress |
getSncpAddress() |
java.lang.String |
getSncpGroup() |
abstract java.net.InetSocketAddress |
getSocketAddress() |
void |
init(AnyValue config) |
boolean |
isSNCP() |
protected void |
loadService(ClassFilter serviceFilter) |
protected abstract void |
loadServlet(ClassFilter<? extends Servlet> servletFilter) |
protected Transport |
loadTransport(java.util.HashSet<java.lang.String> groups) |
protected Transport |
loadTransport(java.lang.String group) |
protected java.util.List<Transport> |
loadTransports(java.util.HashSet<java.lang.String> groups) |
void |
shutdown() |
void |
start() |
public static final java.lang.String LINE_SEPARATOR
protected final java.util.logging.Logger logger
protected final boolean fine
protected final boolean finer
protected final Application application
protected final ResourceFactory factory
protected final Server server
protected java.util.function.Consumer<ServiceWrapper> consumer
protected AnyValue serverConf
protected final java.util.Set<ServiceWrapper> localServiceWrappers
protected final java.util.Set<ServiceWrapper> remoteServiceWrappers
public NodeServer(Application application, Server server)
protected java.util.function.Consumer<java.lang.Runnable> getExecutor()
throws java.lang.Exception
java.lang.Exceptionpublic static <T extends NodeServer> NodeServer create(java.lang.Class<T> clazz, Application application, AnyValue serconf)
public void init(AnyValue config) throws java.lang.Exception
java.lang.Exceptionprotected abstract void loadServlet(ClassFilter<? extends Servlet> servletFilter) throws java.lang.Exception
java.lang.Exceptionprotected void loadService(ClassFilter serviceFilter) throws java.lang.Exception
java.lang.Exceptionprotected java.util.List<Transport> loadTransports(java.util.HashSet<java.lang.String> groups)
protected Transport loadTransport(java.util.HashSet<java.lang.String> groups)
protected Transport loadTransport(java.lang.String group)
protected abstract ClassFilter<Servlet> createServletClassFilter()
protected ClassFilter<Service> createServiceClassFilter()
protected ClassFilter createClassFilter(java.lang.String localGroup, java.lang.Class<? extends java.lang.annotation.Annotation> ref, java.lang.Class inter, java.lang.Class<? extends java.lang.annotation.Annotation> ref2, java.lang.String properties, java.lang.String property)
public abstract java.net.InetSocketAddress getSocketAddress()
public boolean isSNCP()
public java.net.InetSocketAddress getSncpAddress()
public java.lang.String getSncpGroup()
public void start()
throws java.io.IOException
java.io.IOExceptionpublic void shutdown()
throws java.io.IOException
java.io.IOException