io.seata.core.rpc.netty

类 RpcClientBootstrap

java.lang.Object

io.seata.core.rpc.netty.RpcClientBootstrap

所有已实现的接口:

RemotingClient, RemotingService

public class RpcClientBootstrap
extends Object
implements RemotingClient

Rpc client.

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
io.netty.channel.Channel	getNewChannel(InetSocketAddress address) Gets new channel.
protected void	setChannelHandlers(io.netty.channel.ChannelHandler... handlers) Sets channel handlers.
void	shutdown() Shutdown.
void	start() Start.

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

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

构造器详细资料

RpcClientBootstrap

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

方法详细资料

setChannelHandlers

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

Sets channel handlers.

参数:

handlers - the handlers

start

public void start()

从接口复制的说明: RemotingService

Start.

指定者:

start 在接口中 RemotingService

shutdown

public void shutdown()

从接口复制的说明: RemotingService

Shutdown.

指定者:

shutdown 在接口中 RemotingService

getNewChannel

public io.netty.channel.Channel getNewChannel(InetSocketAddress address)

Gets new channel.

参数:

address - the address

返回:

the new channel