com.baidu.brpc.server

Class CommunicationServer

java.lang.Object

com.baidu.brpc.server.CommunicationServer

Direct Known Subclasses:

InterceptCommunicationServer

public class CommunicationServer
extends Object

Created by wenweihu86 on 2019/12/07.

Field Summary

Fields

Modifier and Type	Field and Description
protected io.netty.bootstrap.ServerBootstrap	bootstrap netty bootstrap
protected io.netty.channel.EventLoopGroup	bossGroup netty io thread pool
protected List<ThreadPool>	customThreadPools
protected String	host host to bind
protected int	port port to bind
protected Protocol	protocol
protected RpcServerOptions	rpcServerOptions
protected ServerStatus	serverStatus
protected List<Object>	serviceList
protected ServiceManager	serviceManager
protected AtomicBoolean	stop
protected ThreadPool	threadPool
protected io.netty.util.Timer	timeoutTimer
protected io.netty.channel.EventLoopGroup	workerGroup

Constructor Summary

Constructors

Constructor and Description
CommunicationServer(int port)
CommunicationServer(int port, RpcServerOptions options)
CommunicationServer(String host, int port)
CommunicationServer(String host, int port, RpcServerOptions options)

Method Summary

Modifier and Type	Method and Description
void	execute(Request request, Response response)
Protocol	getProtocol()
boolean	isShutdown()
void	registerService(Object service)
void	registerService(Object service, Class targetClass, NamingOptions namingOptions)
void	registerService(Object service, Class targetClass, NamingOptions namingOptions, RpcServerOptions serverOptions) register service which can be accessed by client
void	registerService(Object service, NamingOptions namingOptions)
void	registerService(Object service, RpcServerOptions serverOptions)
<T> AsyncAwareFuture<T>	sendServerPush(Request request)
void	setProtocol(Protocol protocol)
boolean	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

rpcServerOptions

protected RpcServerOptions rpcServerOptions

host

protected String host

host to bind

port

protected int port

port to bind

bootstrap

protected io.netty.bootstrap.ServerBootstrap bootstrap

netty bootstrap

bossGroup

protected io.netty.channel.EventLoopGroup bossGroup

netty io thread pool

workerGroup

protected io.netty.channel.EventLoopGroup workerGroup

protocol

protected Protocol protocol

threadPool

protected ThreadPool threadPool

customThreadPools

protected List<ThreadPool> customThreadPools

serviceList

protected List<Object> serviceList

serverStatus

protected ServerStatus serverStatus

stop

protected AtomicBoolean stop

timeoutTimer

protected io.netty.util.Timer timeoutTimer

serviceManager

protected ServiceManager serviceManager

Constructor Detail

CommunicationServer

public CommunicationServer(int port)

CommunicationServer

public CommunicationServer(String host,
                           int port)

CommunicationServer

public CommunicationServer(int port,
                           RpcServerOptions options)

CommunicationServer

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

Method Detail

registerService

public void registerService(Object service)

registerService

public void registerService(Object service,
                            NamingOptions namingOptions)

registerService

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

registerService

public void registerService(Object service,
                            RpcServerOptions serverOptions)

registerService

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

register service which can be accessed by client

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()

shutdown

public boolean shutdown()

isShutdown

public boolean isShutdown()

getProtocol

public Protocol getProtocol()

setProtocol

public void setProtocol(Protocol protocol)

sendServerPush

public <T> AsyncAwareFuture<T> sendServerPush(Request request)

execute

public void execute(Request request,
                    Response response)
             throws RpcException

Throws:

RpcException