public class ChannelInfo extends Object
| 限定符 | 构造器和说明 |
|---|---|
protected |
ChannelInfo() |
| 限定符和类型 | 方法和说明 |
|---|---|
long |
addRpcFuture(RpcFuture future) |
static ChannelInfo |
getClientChannelInfo(io.netty.channel.Channel channel) |
static ChannelInfo |
getOrCreateClientChannelInfo(io.netty.channel.Channel channel) |
static ChannelInfo |
getOrCreateServerChannelInfo(io.netty.channel.Channel channel) |
RpcFuture |
getRpcFuture(long logId) |
static ChannelInfo |
getServerChannelInfo(io.netty.channel.Channel channel) |
void |
handleChannelException(RpcException ex)
channel不可用时或者handler出现异常时处理逻辑
|
void |
handleRequestFail()
请求失败时处理逻辑
|
void |
handleResponseFail()
获取响应失败时处理逻辑
|
RpcFuture |
removeRpcFuture(long logId) |
public static ChannelInfo getOrCreateClientChannelInfo(io.netty.channel.Channel channel)
public static ChannelInfo getClientChannelInfo(io.netty.channel.Channel channel)
public static ChannelInfo getOrCreateServerChannelInfo(io.netty.channel.Channel channel)
public static ChannelInfo getServerChannelInfo(io.netty.channel.Channel channel)
public long addRpcFuture(RpcFuture future)
public RpcFuture getRpcFuture(long logId)
public RpcFuture removeRpcFuture(long logId)
public void handleRequestFail()
public void handleResponseFail()
public void handleChannelException(RpcException ex)
Copyright © 2018 Baidu, Inc.. All rights reserved.