io.seata.core.rpc.netty

类 RpcServer

java.lang.Object

io.seata.core.rpc.netty.AbstractRpcRemoting

io.seata.core.rpc.netty.AbstractRpcRemotingServer

io.seata.core.rpc.netty.RpcServer

所有已实现的接口:

Disposable, ServerMessageSender

public class RpcServer
extends AbstractRpcRemotingServer

The type Abstract rpc server.

字段概要

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

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

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
void	destroy() Destroy.
void	init() Init.
Object	sendASyncRequest(io.netty.channel.Channel channel, Object message) Send request with response object.
void	sendResponse(RpcMessage request, io.netty.channel.Channel channel, Object msg) Send response.
Object	sendSyncRequest(io.netty.channel.Channel clientChannel, Object message) Send request with response object.
Object	sendSyncRequest(io.netty.channel.Channel clientChannel, Object message, long timeout) Send request with response object.
Object	sendSyncRequest(String resourceId, String clientId, Object message) Send request with response object.
Object	sendSyncRequest(String resourceId, String clientId, Object message, long timeout) Send request with response object.

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

debugLog, destroyChannel, getCheckAuthHandler, getListenPort, getServerMessageListener, getTransactionMessageHandler, setChannelHandlers, setHandler, setListenPort, setServerMessageListener

从类继承的方法 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

构造器详细资料

RpcServer

public RpcServer(ThreadPoolExecutor messageExecutor)

Instantiates a new Abstract rpc server.

参数:

messageExecutor - the message executor

方法详细资料

init

public void init()

Init.

覆盖:

init 在类中 AbstractRpcRemotingServer

destroy

public void destroy()

Destroy.

指定者:

destroy 在接口中 Disposable

覆盖:

destroy 在类中 AbstractRpcRemotingServer

sendResponse

public void sendResponse(RpcMessage request,
                         io.netty.channel.Channel channel,
                         Object msg)

Send response. rm reg,rpc reg,inner response

参数:

request - the request

channel - the channel

msg - the msg

sendSyncRequest

public Object sendSyncRequest(String resourceId,
                              String clientId,
                              Object message,
                              long timeout)
                       throws TimeoutException

Send request with response object. send syn request for rm

参数:

resourceId - the db key

clientId - the client ip

message - the message

timeout - the timeout

返回:

the object

抛出:

TimeoutException - the timeout exception

sendSyncRequest

public Object sendSyncRequest(io.netty.channel.Channel clientChannel,
                              Object message)
                       throws TimeoutException

Send request with response object. send syn request for rm

参数:

clientChannel - the client channel

message - the message

返回:

the object

抛出:

TimeoutException - the timeout exception

sendSyncRequest

public Object sendSyncRequest(io.netty.channel.Channel clientChannel,
                              Object message,
                              long timeout)
                       throws TimeoutException

Send request with response object. send syn request for rm

参数:

clientChannel - the client channel

message - the message

timeout - the timeout

返回:

the object

抛出:

TimeoutException - the timeout exception

sendSyncRequest

public Object sendSyncRequest(String resourceId,
                              String clientId,
                              Object message)
                       throws TimeoutException

Send request with response object.

参数:

resourceId - the db key

clientId - the client ip

message - the msg

返回:

the object

抛出:

TimeoutException - the timeout exception

sendASyncRequest

public Object sendASyncRequest(io.netty.channel.Channel channel,
                               Object message)
                        throws TimeoutException

Send request with response object.

参数:

channel - the channel

message - the msg

返回:

the object

抛出:

TimeoutException - the timeout exception