io.seata.core.rpc.netty

类 AbstractRpcRemoting

java.lang.Object

io.seata.core.rpc.netty.AbstractRpcRemoting

所有已实现的接口:

Disposable

直接已知子类:

AbstractRpcRemotingClient, AbstractRpcRemotingServer

public abstract class AbstractRpcRemoting
extends Object
implements Disposable

The type Abstract rpc remoting.

字段概要

字段

限定符和类型	字段和说明
protected ConcurrentHashMap<String,BlockingQueue<RpcMessage>>	basketMap The Basket map.
protected ConcurrentHashMap<Integer,MessageFuture>	futures The Futures.
protected PositiveAtomicCounter	idGenerator Id generator of this remoting
protected boolean	isSending The Is sending.
protected Object	mergeLock The Merge lock.
protected Map<Integer,MergeMessage>	mergeMsgMap The Merge msg map.
protected ThreadPoolExecutor	messageExecutor The Message executor.
protected long	nowMills The Now mills.
protected ScheduledExecutorService	timerExecutor The Timer executor.

构造器概要

构造器

构造器和说明
AbstractRpcRemoting(ThreadPoolExecutor messageExecutor) Instantiates a new Abstract rpc remoting.

方法概要

限定符和类型	方法和说明
protected void	defaultSendRequest(io.netty.channel.Channel channel, Object msg) Default Send request.
protected void	defaultSendResponse(RpcMessage request, io.netty.channel.Channel channel, Object msg) Default Send response.
void	destroy() Destroy.
void	destroyChannel(io.netty.channel.Channel channel) Destroy channel.
abstract void	destroyChannel(String serverAddress, io.netty.channel.Channel channel) Destroy channel.
protected String	getAddressFromChannel(io.netty.channel.Channel channel) Gets address from channel.
protected String	getAddressFromContext(io.netty.channel.ChannelHandlerContext ctx) Gets address from context.
String	getGroup() Gets group.
int	getNextMessageId() Gets next message id.
void	init() Init.
protected Object	sendAsyncRequestWithoutResponse(io.netty.channel.Channel channel, Object msg) Send async request without response object.
protected Object	sendAsyncRequestWithResponse(io.netty.channel.Channel channel, Object msg) Send async request with response object.
protected Object	sendAsyncRequestWithResponse(String address, io.netty.channel.Channel channel, Object msg, long timeout) Send async request with response object.
void	setGroup(String group) Sets group.

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

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

字段详细资料

timerExecutor

protected final ScheduledExecutorService timerExecutor

The Timer executor.

messageExecutor

protected final ThreadPoolExecutor messageExecutor

The Message executor.

idGenerator

protected final PositiveAtomicCounter idGenerator

Id generator of this remoting

futures

protected final ConcurrentHashMap<Integer,MessageFuture> futures

The Futures.

basketMap

protected final ConcurrentHashMap<String,BlockingQueue<RpcMessage>> basketMap

The Basket map.

mergeLock

protected final Object mergeLock

The Merge lock.

nowMills

protected volatile long nowMills

The Now mills.

isSending

protected volatile boolean isSending

The Is sending.

mergeMsgMap

protected final Map<Integer,MergeMessage> mergeMsgMap

The Merge msg map.

构造器详细资料

AbstractRpcRemoting

public AbstractRpcRemoting(ThreadPoolExecutor messageExecutor)

Instantiates a new Abstract rpc remoting.

参数:

messageExecutor - the message executor

方法详细资料

getNextMessageId

public int getNextMessageId()

Gets next message id.

返回:

the next message id

init

public void init()

Init.

destroy

public void destroy()

Destroy.

指定者:

destroy 在接口中 Disposable

sendAsyncRequestWithResponse

protected Object sendAsyncRequestWithResponse(io.netty.channel.Channel channel,
                                              Object msg)
                                       throws TimeoutException

Send async request with response object.

参数:

channel - the channel

msg - the msg

返回:

the object

抛出:

TimeoutException - the timeout exception

sendAsyncRequestWithResponse

protected Object sendAsyncRequestWithResponse(String address,
                                              io.netty.channel.Channel channel,
                                              Object msg,
                                              long timeout)
                                       throws TimeoutException

Send async request with response object.

参数:

address - the address

channel - the channel

msg - the msg

timeout - the timeout

返回:

the object

抛出:

TimeoutException - the timeout exception

sendAsyncRequestWithoutResponse

protected Object sendAsyncRequestWithoutResponse(io.netty.channel.Channel channel,
                                                 Object msg)
                                          throws TimeoutException

Send async request without response object.

参数:

channel - the channel

msg - the msg

返回:

the object

抛出:

TimeoutException - the timeout exception

defaultSendRequest

protected void defaultSendRequest(io.netty.channel.Channel channel,
                                  Object msg)

Default Send request.

参数:

channel - the channel

msg - the msg

defaultSendResponse

protected void defaultSendResponse(RpcMessage request,
                                   io.netty.channel.Channel channel,
                                   Object msg)

Default Send response.

参数:

request - the msg id

channel - the channel

msg - the msg

getGroup

public String getGroup()

Gets group.

返回:

the group

setGroup

public void setGroup(String group)

Sets group.

参数:

group - the group

destroyChannel

public void destroyChannel(io.netty.channel.Channel channel)

Destroy channel.

参数:

channel - the channel

destroyChannel

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

Destroy channel.

参数:

serverAddress - the server address

channel - the channel

getAddressFromContext

protected String getAddressFromContext(io.netty.channel.ChannelHandlerContext ctx)

Gets address from context.

参数:

ctx - the ctx

返回:

the address from context

getAddressFromChannel

protected String getAddressFromChannel(io.netty.channel.Channel channel)

Gets address from channel.

参数:

channel - the channel

返回:

the address from channel