com.baidu.brpc.client.channel

类 AbstractBrpcChannel

java.lang.Object

com.baidu.brpc.client.channel.AbstractBrpcChannel

所有已实现的接口:

BrpcChannel

直接已知子类:

BrpcPooledChannel, BrpcShortChannel, BrpcSingleChannel

public abstract class AbstractBrpcChannel
extends Object
implements BrpcChannel

字段概要

字段

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

构造器概要

构造器

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

方法概要

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

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

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

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

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

构造器详细资料

AbstractBrpcChannel

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

方法详细资料

updateChannel

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

指定者:

updateChannel 在接口中 BrpcChannel

connect

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

指定者:

connect 在接口中 BrpcChannel

getIp

public String getIp()

指定者:

getIp 在接口中 BrpcChannel

getPort

public int getPort()

指定者:

getPort 在接口中 BrpcChannel

getFailedNum

public long getFailedNum()

指定者:

getFailedNum 在接口中 BrpcChannel

incFailedNum

public void incFailedNum()

指定者:

incFailedNum 在接口中 BrpcChannel

getLatencyWindow

public Queue<Integer> getLatencyWindow()

指定者:

getLatencyWindow 在接口中 BrpcChannel

updateLatency

public void updateLatency(int latency)

指定者:

updateLatency 在接口中 BrpcChannel

updateLatencyWithReadTimeOut

public void updateLatencyWithReadTimeOut()

指定者:

updateLatencyWithReadTimeOut 在接口中 BrpcChannel

getProtocol

public Protocol getProtocol()

指定者:

getProtocol 在接口中 BrpcChannel

hashCode

public int hashCode()

指定者:

hashCode 在接口中 BrpcChannel

覆盖:

hashCode 在类中 Object

equals

public boolean equals(Object object)

指定者:

equals 在接口中 BrpcChannel

覆盖:

equals 在类中 Object