com.baidu.brpc.client.channel

类 BrpcSingleChannel

java.lang.Object

com.baidu.brpc.client.channel.AbstractBrpcChannelGroup

com.baidu.brpc.client.channel.BrpcSingleChannel

所有已实现的接口:

BrpcChannelGroup

public class BrpcSingleChannel
extends AbstractBrpcChannelGroup

BrpcSingleChannel class keeps single persistent connection with one server

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	BrpcSingleChannel.ReConnectTask

字段概要

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

bootstrap, ip, port, protocol

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
void	close()
int	getActiveConnectionNum()
io.netty.channel.Channel	getChannel()
int	getCurrentMaxConnection()
long	getFailedNum()
int	getIdleConnectionNum()
Queue<Integer>	getLatencyWindow()
void	incFailedNum()
void	removeChannel(io.netty.channel.Channel channel)
void	returnChannel(io.netty.channel.Channel channel)
void	updateChannel(io.netty.channel.Channel channel)
void	updateLatency(int latency)
void	updateLatencyWithReadTimeOut()
void	updateMaxConnection(int num)

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

connect, getIp, getPort, getProtocol

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

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

构造器详细资料

BrpcSingleChannel

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

方法详细资料

getChannel

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

抛出:

Exception

NoSuchElementException

IllegalStateException

removeChannel

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

updateChannel

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

指定者:

updateChannel 在接口中 BrpcChannelGroup

覆盖:

updateChannel 在类中 AbstractBrpcChannelGroup

close

public void close()

getCurrentMaxConnection

public int getCurrentMaxConnection()

getActiveConnectionNum

public int getActiveConnectionNum()

getIdleConnectionNum

public int getIdleConnectionNum()

returnChannel

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

updateMaxConnection

public void updateMaxConnection(int num)

getFailedNum

public long getFailedNum()

指定者:

getFailedNum 在接口中 BrpcChannelGroup

覆盖:

getFailedNum 在类中 AbstractBrpcChannelGroup

incFailedNum

public void incFailedNum()

指定者:

incFailedNum 在接口中 BrpcChannelGroup

覆盖:

incFailedNum 在类中 AbstractBrpcChannelGroup

getLatencyWindow

public Queue<Integer> getLatencyWindow()

指定者:

getLatencyWindow 在接口中 BrpcChannelGroup

覆盖:

getLatencyWindow 在类中 AbstractBrpcChannelGroup

updateLatency

public void updateLatency(int latency)

指定者:

updateLatency 在接口中 BrpcChannelGroup

覆盖:

updateLatency 在类中 AbstractBrpcChannelGroup

updateLatencyWithReadTimeOut

public void updateLatencyWithReadTimeOut()

指定者:

updateLatencyWithReadTimeOut 在接口中 BrpcChannelGroup

覆盖:

updateLatencyWithReadTimeOut 在类中 AbstractBrpcChannelGroup