com.baidu.brpc.client.channel

类 AbstractBrpcChannelGroup

java.lang.Object

com.baidu.brpc.client.channel.AbstractBrpcChannelGroup

所有已实现的接口:

BrpcChannelGroup

直接已知子类:

BrpcPooledChannel, BrpcShortChannel, BrpcSingleChannel

public abstract class AbstractBrpcChannelGroup
extends Object
implements BrpcChannelGroup

字段概要

字段

限定符和类型	字段和说明
protected io.netty.bootstrap.Bootstrap	bootstrap
protected String	ip
protected int	port
protected Protocol	protocol

构造器概要

构造器

构造器和说明
AbstractBrpcChannelGroup(String ip, int port, io.netty.bootstrap.Bootstrap bootstrap, Protocol protocol)

方法概要

限定符和类型	方法和说明
io.netty.channel.Channel	connect(String ip, int port)
long	getFailedNum()
String	getIp()
Queue<Integer>	getLatencyWindow()
int	getPort()
Protocol	getProtocol()
void	incFailedNum()
void	updateChannel(io.netty.channel.Channel channel)
void	updateLatency(int latency)
void	updateLatencyWithReadTimeOut()

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

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

从接口继承的方法 com.baidu.brpc.client.channel.BrpcChannelGroup

close, getActiveConnectionNum, getChannel, getCurrentMaxConnection, getIdleConnectionNum, removeChannel, returnChannel, updateMaxConnection

字段详细资料

ip

protected String ip

port

protected int port

bootstrap

protected io.netty.bootstrap.Bootstrap bootstrap

protocol

protected Protocol protocol

构造器详细资料

AbstractBrpcChannelGroup

public AbstractBrpcChannelGroup(String ip,
                                int port,
                                io.netty.bootstrap.Bootstrap bootstrap,
                                Protocol protocol)

方法详细资料

updateChannel

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

指定者:

updateChannel 在接口中 BrpcChannelGroup

connect

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

指定者:

connect 在接口中 BrpcChannelGroup

getIp

public String getIp()

指定者:

getIp 在接口中 BrpcChannelGroup

getPort

public int getPort()

指定者:

getPort 在接口中 BrpcChannelGroup

getFailedNum

public long getFailedNum()

指定者:

getFailedNum 在接口中 BrpcChannelGroup

incFailedNum

public void incFailedNum()

指定者:

incFailedNum 在接口中 BrpcChannelGroup

getLatencyWindow

public Queue<Integer> getLatencyWindow()

指定者:

getLatencyWindow 在接口中 BrpcChannelGroup

updateLatency

public void updateLatency(int latency)

指定者:

updateLatency 在接口中 BrpcChannelGroup

updateLatencyWithReadTimeOut

public void updateLatencyWithReadTimeOut()

指定者:

updateLatencyWithReadTimeOut 在接口中 BrpcChannelGroup

getProtocol

public Protocol getProtocol()

指定者:

getProtocol 在接口中 BrpcChannelGroup