io.seata.core.rpc.netty

类 AbstractRpcRemotingClient

java.lang.Object

io.seata.core.rpc.netty.AbstractRpcRemoting

io.seata.core.rpc.netty.AbstractRpcRemotingClient

所有已实现的接口:

ClientMessageSender, Disposable, RegisterMsgListener

直接已知子类:

RmRpcClient, TmRpcClient

public abstract class AbstractRpcRemotingClient
extends AbstractRpcRemoting
implements RegisterMsgListener, ClientMessageSender

The type Rpc remoting client.

字段概要

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

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

构造器概要

构造器

构造器和说明
AbstractRpcRemotingClient(NettyClientConfig nettyClientConfig, io.netty.util.concurrent.EventExecutorGroup eventExecutorGroup, ThreadPoolExecutor messageExecutor, NettyPoolKey.TransactionRole transactionRole)

方法概要

限定符和类型	方法和说明
void	destroy() Destroy.
void	destroyChannel(String serverAddress, io.netty.channel.Channel channel) Destroy channel.
io.seata.core.rpc.netty.NettyClientChannelManager	getClientChannelManager()
ClientMessageListener	getClientMessageListener() Gets client message listener.
protected abstract Function<String,NettyPoolKey>	getPoolKeyFunction() Get pool key function.
protected abstract String	getTransactionServiceGroup() Get transaction service group.
void	init() Init.
Object	sendMsgWithResponse(Object msg) Send msg with response object.
Object	sendMsgWithResponse(Object msg, long timeout) Send msg with response object.
Object	sendMsgWithResponse(String serverAddress, Object msg, long timeout) Send msg with response object.
void	sendResponse(RpcMessage request, String serverAddress, Object msg) Send response.
void	setClientMessageListener(ClientMessageListener clientMessageListener) Sets client 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.netty.RegisterMsgListener

onRegisterMsgFail, onRegisterMsgSuccess

构造器详细资料

AbstractRpcRemotingClient

public AbstractRpcRemotingClient(NettyClientConfig nettyClientConfig,
                                 io.netty.util.concurrent.EventExecutorGroup eventExecutorGroup,
                                 ThreadPoolExecutor messageExecutor,
                                 NettyPoolKey.TransactionRole transactionRole)

方法详细资料

getClientChannelManager

public io.seata.core.rpc.netty.NettyClientChannelManager getClientChannelManager()

getPoolKeyFunction

protected abstract Function<String,NettyPoolKey> getPoolKeyFunction()

Get pool key function.

返回:

lambda function

getTransactionServiceGroup

protected abstract String getTransactionServiceGroup()

Get transaction service group.

返回:

transaction service group

init

public void init()

从类复制的说明: AbstractRpcRemoting

Init.

覆盖:

init 在类中 AbstractRpcRemoting

destroy

public void destroy()

从类复制的说明: AbstractRpcRemoting

Destroy.

指定者:

destroy 在接口中 Disposable

覆盖:

destroy 在类中 AbstractRpcRemoting

sendMsgWithResponse

public Object sendMsgWithResponse(Object msg,
                                  long timeout)
                           throws TimeoutException

从接口复制的说明: ClientMessageSender

Send msg with response object.

指定者:

sendMsgWithResponse 在接口中 ClientMessageSender

参数:

msg - the msg

timeout - the timeout

返回:

the object

抛出:

TimeoutException - the timeout exception

sendMsgWithResponse

public Object sendMsgWithResponse(Object msg)
                           throws TimeoutException

从接口复制的说明: ClientMessageSender

Send msg with response object.

指定者:

sendMsgWithResponse 在接口中 ClientMessageSender

参数:

msg - the msg

返回:

the object

抛出:

TimeoutException - the timeout exception

sendMsgWithResponse

public Object sendMsgWithResponse(String serverAddress,
                                  Object msg,
                                  long timeout)
                           throws TimeoutException

从接口复制的说明: ClientMessageSender

Send msg with response object.

指定者:

sendMsgWithResponse 在接口中 ClientMessageSender

参数:

serverAddress - the server address

msg - the msg

timeout - the timeout

返回:

the object

抛出:

TimeoutException - the timeout exception

sendResponse

public void sendResponse(RpcMessage request,
                         String serverAddress,
                         Object msg)

从接口复制的说明: ClientMessageSender

Send response.

指定者:

sendResponse 在接口中 ClientMessageSender

参数:

request - the msg id

serverAddress - the server address

msg - the msg

getClientMessageListener

public ClientMessageListener getClientMessageListener()

Gets client message listener.

返回:

the client message listener

setClientMessageListener

public void setClientMessageListener(ClientMessageListener clientMessageListener)

Sets client message listener.

参数:

clientMessageListener - the client message listener

destroyChannel

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

从类复制的说明: AbstractRpcRemoting

Destroy channel.

指定者:

destroyChannel 在类中 AbstractRpcRemoting

参数:

serverAddress - the server address

channel - the channel