com.baidu.brpc.client.channel

类 BrpcShortChannel

java.lang.Object

com.baidu.brpc.client.channel.AbstractBrpcChannelGroup

com.baidu.brpc.client.channel.BrpcShortChannel

所有已实现的接口:

BrpcChannelGroup

public class BrpcShortChannel
extends AbstractBrpcChannelGroup

BrpcShortChannel build single & short connection with server and channel will be closed by brpc after communication with server

字段概要

从类继承的字段 com.baidu.brpc.client.channel.AbstractBrpcChannelGroup

bootstrap, ip, port, protocol

构造器概要

构造器

构造器和说明
BrpcShortChannel(String ip, int port, RpcClient rpcClient)

方法概要

限定符和类型	方法和说明
void	close()
int	getActiveConnectionNum()
io.netty.channel.Channel	getChannel()
int	getCurrentMaxConnection()
int	getIdleConnectionNum()
void	removeChannel(io.netty.channel.Channel channel)
void	returnChannel(io.netty.channel.Channel channel)
void	updateMaxConnection(int num)

从类继承的方法 com.baidu.brpc.client.channel.AbstractBrpcChannelGroup

connect, getFailedNum, getIp, getLatencyWindow, getPort, getProtocol, incFailedNum, updateChannel, updateLatency, updateLatencyWithReadTimeOut

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

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

构造器详细资料

BrpcShortChannel

public BrpcShortChannel(String ip,
                        int port,
                        RpcClient rpcClient)

方法详细资料

getChannel

public io.netty.channel.Channel getChannel()
                                    throws Exception,
                                           NoSuchElementException,
                                           IllegalStateException

抛出:

Exception

NoSuchElementException

IllegalStateException

returnChannel

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

removeChannel

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

close

public void close()

updateMaxConnection

public void updateMaxConnection(int num)

getCurrentMaxConnection

public int getCurrentMaxConnection()

getActiveConnectionNum

public int getActiveConnectionNum()

getIdleConnectionNum

public int getIdleConnectionNum()