模块 org.redkale

程序包 org.redkale.boot

类 NodeServer

java.lang.Object

org.redkale.boot.NodeServer

直接已知子类:

NodeHttpServer, NodeSncpServer

public abstract class NodeServer
extends Object

Server节点的初始化配置类

详情见: https://redkale.org

作者:

zhangjx

字段概要

字段

修饰符和类型	字段	说明
protected Application	application
protected Map<Service,Servlet>	dynServletMap
protected NodeInterceptor	interceptor
static String	LINE_SEPARATOR
protected Set<Service>	localServices
protected Logger	logger
protected Map<String,MessageAgent>	messageAgents
protected Set<Service>	remoteServices
protected ResourceFactory	resourceFactory
protected Server	server
protected RedkaleClassLoader	serverClassLoader
protected AnyValue	serverConf
protected Thread	serverThread
protected Set<Service>	servletServices
protected SncpClient	sncpClient
protected String	sncpGroup
protected Map<String,MessageAgent>	sncpRemoteAgents
protected String	threadName

构造器概要

构造器

构造器	说明
NodeServer(Application application, Server server)

方法概要

修饰符和类型	方法	说明
protected boolean	acceptsComponent(Class<? extends Service> serviceImplClass)
protected void	afterClusterDeregisterOnPreDestroyServices(ClusterAgent cluster, String protocol)
List<Object>	command(String cmd, String[] params)
static <T extends NodeServer> NodeServer	create(Class<T> clazz, Application application, AnyValue serconf)
protected ClassFilter	createClassFilter(String localGroup, Class<? extends Annotation> ref, Class inter, Class[] excludeSuperClasses, Class<? extends Annotation> ref2, String properties, String property)
protected abstract ClassFilter<Filter>	createFilterClassFilter()
protected List<ClassFilter>	createOtherClassFilters()
protected ClassFilter<Service>	createServiceClassFilter()
protected abstract ClassFilter<Servlet>	createServletClassFilter()
Application	getApplication()
Set<Service>	getLocalServices()
Logger	getLogger()
protected MessageAgent	getMessageAgent(AnyValue serviceConf)
Set<Service>	getRemoteServices()
ResourceFactory	getResourceFactory()
<T extends Server> T	getServer()
RedkaleClassLoader	getServerClassLoader()
AnyValue	getServerConf()
Set<Service>	getServletServices()
InetSocketAddress	getSncpAddress()
String	getSncpGroup()
abstract InetSocketAddress	getSocketAddress()
String	getThreadName()
void	init(AnyValue config)
protected boolean	interceptComponent(Service service)
boolean	isSNCP()
boolean	isWATCH()
protected abstract void	loadFilter(ClassFilter<? extends Filter> filterFilter)
protected void	loadOthers(List<ClassFilter> otherFilters)
protected void	loadService(ClassFilter<? extends Service> serviceFilter)
protected abstract void	loadServlet(ClassFilter<? extends Servlet> servletFilter)
protected void	postLoadServlets()
protected void	postStartServer(Set<Service> localServices, Set<Service> remoteServices, Set<Service> servletServices)
protected void	preDestroyServices(Set<Service> localServices, Set<Service> remoteServices, Set<Service> servletServices)
protected void	preInitServices(Set<Service> localServices, Set<Service> remoteServices, Set<Service> servletServices)
void	setServerClassLoader(RedkaleClassLoader serverClassLoader)
void	shutdown()
void	start()

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

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

字段详细资料

LINE_SEPARATOR

public static final String LINE_SEPARATOR

另请参阅:

常量字段值

logger

protected final Logger logger

application

protected final Application application

resourceFactory

protected final ResourceFactory resourceFactory

server

protected final Server server

serverClassLoader

protected RedkaleClassLoader serverClassLoader

serverThread

protected final Thread serverThread

serverConf

protected AnyValue serverConf

threadName

protected final String threadName

interceptor

protected NodeInterceptor interceptor

localServices

protected final Set<Service> localServices

remoteServices

protected final Set<Service> remoteServices

servletServices

protected final Set<Service> servletServices

dynServletMap

protected final Map<Service,Servlet> dynServletMap

messageAgents

protected final Map<String,MessageAgent> messageAgents

sncpRemoteAgents

protected final Map<String,MessageAgent> sncpRemoteAgents

sncpGroup

protected String sncpGroup

sncpClient

protected SncpClient sncpClient

构造器详细资料

NodeServer

public NodeServer(Application application,
                  Server server)

方法详细资料

create

public static <T extends NodeServer> NodeServer create(Class<T> clazz,
                                                       Application application,
                                                       AnyValue serconf)

init

public void init(AnyValue config)
          throws Exception

抛出:

Exception

loadOthers

protected void loadOthers(List<ClassFilter> otherFilters)
                   throws Exception

抛出:

Exception

loadFilter

protected abstract void loadFilter(ClassFilter<? extends Filter> filterFilter)
                            throws Exception

抛出:

Exception

loadServlet

protected abstract void loadServlet(ClassFilter<? extends Servlet> servletFilter)
                             throws Exception

抛出:

Exception

loadService

protected void loadService(ClassFilter<? extends Service> serviceFilter)
                    throws Exception

抛出:

Exception

acceptsComponent

protected boolean acceptsComponent(Class<? extends Service> serviceImplClass)

interceptComponent

protected boolean interceptComponent(Service service)

getMessageAgent

protected MessageAgent getMessageAgent(AnyValue serviceConf)

preInitServices

protected void preInitServices(Set<Service> localServices,
                               Set<Service> remoteServices,
                               Set<Service> servletServices)

postLoadServlets

protected void postLoadServlets()

preDestroyServices

protected void preDestroyServices(Set<Service> localServices,
                                  Set<Service> remoteServices,
                                  Set<Service> servletServices)

afterClusterDeregisterOnPreDestroyServices

protected void afterClusterDeregisterOnPreDestroyServices(ClusterAgent cluster,
                                                          String protocol)

postStartServer

protected void postStartServer(Set<Service> localServices,
                               Set<Service> remoteServices,
                               Set<Service> servletServices)

createFilterClassFilter

protected abstract ClassFilter<Filter> createFilterClassFilter()

createServletClassFilter

protected abstract ClassFilter<Servlet> createServletClassFilter()

createOtherClassFilters

protected List<ClassFilter> createOtherClassFilters()

createServiceClassFilter

protected ClassFilter<Service> createServiceClassFilter()

createClassFilter

protected ClassFilter createClassFilter(String localGroup,
                                        Class<? extends Annotation> ref,
                                        Class inter,
                                        Class[] excludeSuperClasses,
                                        Class<? extends Annotation> ref2,
                                        String properties,
                                        String property)

getSocketAddress

public abstract InetSocketAddress getSocketAddress()

isSNCP

public boolean isSNCP()

isWATCH

public boolean isWATCH()

getApplication

public Application getApplication()

getResourceFactory

public ResourceFactory getResourceFactory()

getServerClassLoader

public RedkaleClassLoader getServerClassLoader()

setServerClassLoader

public void setServerClassLoader(RedkaleClassLoader serverClassLoader)

getSncpAddress

public InetSocketAddress getSncpAddress()

getServerConf

public AnyValue getServerConf()

getLogger

public Logger getLogger()

getSncpGroup

public String getSncpGroup()

start

public void start()
           throws IOException

抛出:

IOException

shutdown

public void shutdown()
              throws IOException

抛出:

IOException

command

public List<Object> command(String cmd,
                            String[] params)
                     throws IOException

抛出:

IOException

getServer

public <T extends Server> T getServer()

getServletServices

public Set<Service> getServletServices()

getLocalServices

public Set<Service> getLocalServices()

getRemoteServices

public Set<Service> getRemoteServices()

getThreadName

public String getThreadName()