public class BrpcChannelGroup extends Object
| 构造器和说明 |
|---|
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() |
public io.netty.channel.Channel getChannel()
throws Exception,
NoSuchElementException,
IllegalStateException
public void returnChannel(io.netty.channel.Channel channel)
public void removeChannel(io.netty.channel.Channel channel)
public void close()
public io.netty.channel.Channel connect(String ip, int port)
public String getIp()
public int getPort()
public long getFailedNum()
public void incFailedNum()
public void updateLatency(int latency)
public void updateLatencyWithReadTimeOut()
Copyright © 2018 Baidu, Inc.. All rights reserved.