com.baidu.brpc.client.channel

类 BrpcPooledChannel

java.lang.Object

com.baidu.brpc.client.channel.AbstractBrpcChannelGroup

com.baidu.brpc.client.channel.BrpcPooledChannel

所有已实现的接口:

BrpcChannelGroup

public class BrpcPooledChannel
extends AbstractBrpcChannelGroup

BrpcPooledChannelGroup class keeps fixed connections with one server Created by wenweihu86 on 2017/9/29.

字段概要

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

bootstrap, ip, port, protocol

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
void	close()
boolean	equals(Object obj)
int	getActiveConnectionNum()
io.netty.channel.Channel	getChannel()
int	getCurrentMaxConnection()
long	getFailedNum()
int	getIdleConnectionNum()
Queue<Integer>	getLatencyWindow()
int	hashCode()
void	incFailedNum()
void	removeChannel(io.netty.channel.Channel channel)
void	returnChannel(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, updateChannel

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

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

构造器详细资料

BrpcPooledChannel

public BrpcPooledChannel(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()

equals

public boolean equals(Object obj)

覆盖:

equals 在类中 Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object

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

updateMaxConnection

public void updateMaxConnection(int num)

getCurrentMaxConnection

public int getCurrentMaxConnection()

getActiveConnectionNum

public int getActiveConnectionNum()

getIdleConnectionNum

public int getIdleConnectionNum()

updateLatencyWithReadTimeOut

public void updateLatencyWithReadTimeOut()

指定者:

updateLatencyWithReadTimeOut 在接口中 BrpcChannelGroup

覆盖:

updateLatencyWithReadTimeOut 在类中 AbstractBrpcChannelGroup