com.alipay.remoting

类 RemotingServer

java.lang.Object

com.alipay.remoting.RemotingServer

直接已知子类:

RpcServer

public abstract class RemotingServer
extends Object

Server template for remoting.

字段概要

字段

限定符和类型	字段和说明
protected int	port

构造器概要

构造器

构造器和说明
RemotingServer(int port)

方法概要

方法

限定符和类型	方法和说明
protected abstract void	doInit() Inject initialize logic here.
protected abstract boolean	doStart() Inject start logic here.
protected abstract boolean	doStart(String ip) Inject start logic here.
protected abstract void	doStop() Inject stop logic here.
int	getPort() Get the port of the server.
void	init() Initialize.
abstract void	registerDefaultExecutor(byte protocolCode, ExecutorService executor) Register default executor service for server.
abstract void	registerProcessor(byte protocolCode, CommandCode commandCode, RemotingProcessor<?> processor) Register processor for command with the command code.
abstract void	registerUserProcessor(UserProcessor<?> processor) Register user processor.
boolean	start() Start the server.
boolean	start(String ip) Start the server with ip and port.
void	stop() Stop the server.

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

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

字段详细资料

port

protected int port

构造器详细资料

RemotingServer

public RemotingServer(int port)

参数:

port -

方法详细资料

init

public void init()

Initialize.

start

public boolean start()

Start the server.

start

public boolean start(String ip)

Start the server with ip and port.

stop

public void stop()

Stop the server.

Notice:

Remoting server can not be used any more after shutdown. If you need, you should destroy it, and instantiate another one.

getPort

public int getPort()

Get the port of the server.

返回:

doInit

protected abstract void doInit()

Inject initialize logic here.

doStart

protected abstract boolean doStart()
                            throws InterruptedException

Inject start logic here.

抛出:

InterruptedException

doStart

protected abstract boolean doStart(String ip)
                            throws InterruptedException

Inject start logic here.

参数:

ip -

抛出:

InterruptedException

doStop

protected abstract void doStop()

Inject stop logic here.

registerProcessor

public abstract void registerProcessor(byte protocolCode,
                     CommandCode commandCode,
                     RemotingProcessor<?> processor)

Register processor for command with the command code.

参数:

commandCode -

processor -

registerDefaultExecutor

public abstract void registerDefaultExecutor(byte protocolCode,
                           ExecutorService executor)

Register default executor service for server.

参数:

protocolCode -

executor -

registerUserProcessor

public abstract void registerUserProcessor(UserProcessor<?> processor)

Register user processor.

参数:

processor -