io.seata.core.rpc.netty

类 AbstractRpcRemotingServer

java.lang.Object

io.seata.core.rpc.netty.AbstractRpcRemoting

io.seata.core.rpc.netty.AbstractRpcRemotingServer

所有已实现的接口:

Disposable, ServerMessageSender

直接已知子类:

RpcServer

public abstract class AbstractRpcRemotingServer
extends AbstractRpcRemoting
implements ServerMessageSender

The type Rpc remoting server.

字段概要

从类继承的字段 io.seata.core.rpc.netty.AbstractRpcRemoting

basketMap, futures, idGenerator, isSending, mergeLock, mergeMsgMap, messageExecutor, nowMills, timerExecutor

构造器概要

构造器

构造器和说明
AbstractRpcRemotingServer(ThreadPoolExecutor messageExecutor, NettyServerConfig nettyServerConfig) Instantiates a new Rpc remoting server.

方法概要

限定符和类型	方法和说明
void	debugLog(String info) Debug log.
void	destroy() Destroy.
void	destroyChannel(String serverAddress, io.netty.channel.Channel channel) Destroy channel.
RegisterCheckAuthHandler	getCheckAuthHandler()
int	getListenPort() Gets listen port.
ServerMessageListener	getServerMessageListener() Gets server message listener.
TransactionMessageHandler	getTransactionMessageHandler()
void	init() Init.
void	setChannelHandlers(io.netty.channel.ChannelHandler... handlers) Sets channel handlers.
void	setHandler(TransactionMessageHandler transactionMessageHandler) Sets transactionMessageHandler.
void	setListenPort(int listenPort) Sets listen port.
void	setServerMessageListener(ServerMessageListener serverMessageListener) Sets server message listener.

从类继承的方法 io.seata.core.rpc.netty.AbstractRpcRemoting

defaultSendRequest, defaultSendResponse, destroyChannel, getAddressFromChannel, getAddressFromContext, getGroup, getNextMessageId, sendAsyncRequestWithoutResponse, sendAsyncRequestWithResponse, sendAsyncRequestWithResponse, setGroup

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

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

从接口继承的方法 io.seata.core.rpc.ServerMessageSender

sendASyncRequest, sendResponse, sendSyncRequest, sendSyncRequest, sendSyncRequest, sendSyncRequest

构造器详细资料

AbstractRpcRemotingServer

public AbstractRpcRemotingServer(ThreadPoolExecutor messageExecutor,
                                 NettyServerConfig nettyServerConfig)

Instantiates a new Rpc remoting server.

参数:

messageExecutor - the message executor

nettyServerConfig - the netty server config

方法详细资料

setHandler

public void setHandler(TransactionMessageHandler transactionMessageHandler)

Sets transactionMessageHandler.

参数:

transactionMessageHandler - the transactionMessageHandler

getTransactionMessageHandler

public TransactionMessageHandler getTransactionMessageHandler()

getCheckAuthHandler

public RegisterCheckAuthHandler getCheckAuthHandler()

setServerMessageListener

public void setServerMessageListener(ServerMessageListener serverMessageListener)

Sets server message listener.

参数:

serverMessageListener - the server message listener

getServerMessageListener

public ServerMessageListener getServerMessageListener()

Gets server message listener.

返回:

the server message listener

setChannelHandlers

public void setChannelHandlers(io.netty.channel.ChannelHandler... handlers)

Sets channel handlers.

参数:

handlers - the handlers

setListenPort

public void setListenPort(int listenPort)

Sets listen port.

参数:

listenPort - the listen port

getListenPort

public int getListenPort()

Gets listen port.

返回:

the listen port

init

public void init()

从类复制的说明: AbstractRpcRemoting

Init.

覆盖:

init 在类中 AbstractRpcRemoting

destroy

public void destroy()

从类复制的说明: AbstractRpcRemoting

Destroy.

指定者:

destroy 在接口中 Disposable

覆盖:

destroy 在类中 AbstractRpcRemoting

debugLog

public void debugLog(String info)

Debug log.

参数:

info - the info

destroyChannel

public void destroyChannel(String serverAddress,
                           io.netty.channel.Channel channel)

从类复制的说明: AbstractRpcRemoting

Destroy channel.

指定者:

destroyChannel 在类中 AbstractRpcRemoting

参数:

serverAddress - the server address

channel - the channel