com.baidu.brpc.client

类 BrpcChannelGroup

java.lang.Object

com.baidu.brpc.client.BrpcChannelGroup

public class BrpcChannelGroup
extends Object

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

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
void	close()
io.netty.channel.Channel	connect(String ip, int port)
boolean	equals(Object obj)
io.netty.channel.Channel	getChannel()
long	getFailedNum()
String	getIp()
Queue<Integer>	getLatencyWindow()
int	getPort()
int	hashCode()
void	incFailedNum()
void	removeChannel(io.netty.channel.Channel channel)
void	returnChannel(io.netty.channel.Channel channel)
void	updateLatency(int latency)
void	updateLatencyWithReadTimeOut()

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

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

构造器详细资料

BrpcChannelGroup

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

connect

public io.netty.channel.Channel connect(String ip,
                                        int port)

equals

public boolean equals(Object obj)

覆盖:

equals 在类中 Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object

getIp

public String getIp()

getPort

public int getPort()

getFailedNum

public long getFailedNum()

incFailedNum

public void incFailedNum()

getLatencyWindow

public Queue<Integer> getLatencyWindow()

updateLatency

public void updateLatency(int latency)

updateLatencyWithReadTimeOut

public void updateLatencyWithReadTimeOut()