com.baidu.brpc.server

Class RpcServer

java.lang.Object

com.baidu.brpc.server.CommunicationServer

com.baidu.brpc.server.InterceptCommunicationServer

com.baidu.brpc.server.RpcServer

public class RpcServer
extends InterceptCommunicationServer

Created by wenweihu86 on 2017/4/24.

Field Summary

Fields inherited from class com.baidu.brpc.server.CommunicationServer

bootstrap, bossGroup, customThreadPools, host, port, protocol, rpcServerOptions, serverStatus, serviceList, serviceManager, threadPool, timeoutTimer, workerGroup

Constructor Summary

Constructors

Constructor and Description
RpcServer(int port)
RpcServer(int port, RpcServerOptions options)
RpcServer(int port, RpcServerOptions options, List<Interceptor> interceptors)
RpcServer(String host, int port)
RpcServer(String host, int port, RpcServerOptions options)
RpcServer(String host, int port, RpcServerOptions options, List<Interceptor> interceptors)

Method Summary

Modifier and Type	Method and Description
boolean	isShutdown()
void	registerService(Object service, Class targetClass, NamingOptions namingOptions, RpcServerOptions serverOptions) register service which can be accessed by client
boolean	shutdown()
void	start()

Methods inherited from class com.baidu.brpc.server.InterceptCommunicationServer

execute

Methods inherited from class com.baidu.brpc.server.CommunicationServer

getBootstrap, getBossGroup, getCustomThreadPools, getHost, getPort, getProtocol, getRpcServerOptions, getServerStatus, getServiceList, getServiceManager, getStop, getThreadPool, getTimeoutTimer, getWorkerGroup, registerService, registerService, registerService, registerService, sendServerPush, setProtocol

Methods inherited from class java.lang.Object

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

Constructor Detail

RpcServer

public RpcServer(int port)

RpcServer

public RpcServer(String host,
                 int port)

RpcServer

public RpcServer(int port,
                 RpcServerOptions options)

RpcServer

public RpcServer(String host,
                 int port,
                 RpcServerOptions options)

RpcServer

public RpcServer(int port,
                 RpcServerOptions options,
                 List<Interceptor> interceptors)

RpcServer

public RpcServer(String host,
                 int port,
                 RpcServerOptions options,
                 List<Interceptor> interceptors)

Method Detail

registerService

public void registerService(Object service,
                            Class targetClass,
                            NamingOptions namingOptions,
                            RpcServerOptions serverOptions)

register service which can be accessed by client

Overrides:

registerService in class CommunicationServer

Parameters:

service - the service object which implement rpc interface.

namingOptions - register center info

serverOptions - service own custom RpcServerOptions if not null, the service will not use the shared thread pool.

start

public void start()

Overrides:

start in class CommunicationServer

shutdown

public boolean shutdown()

Overrides:

shutdown in class CommunicationServer

isShutdown

public boolean isShutdown()

Overrides:

isShutdown in class CommunicationServer