com.baidu.brpc.client.channel

Class BrpcPooledChannel

java.lang.Object

com.baidu.brpc.client.channel.AbstractBrpcChannel

com.baidu.brpc.client.channel.BrpcPooledChannel

All Implemented Interfaces:

BrpcChannel

public class BrpcPooledChannel
extends AbstractBrpcChannel

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

Field Summary

Fields inherited from class com.baidu.brpc.client.channel.AbstractBrpcChannel

bootstrap, bootstrapManager, communicationOptions, serviceInstance

Constructor Summary

Constructors

Constructor and Description
BrpcPooledChannel(ServiceInstance serviceInstance, CommunicationOptions communicationOptions)

Method Summary

Modifier and Type	Method and Description
void	close()
int	getActiveConnectionNum()
io.netty.channel.Channel	getChannel()
int	getCurrentMaxConnection()
long	getFailedNum()
int	getIdleConnectionNum()
Queue<Integer>	getLatencyWindow()
void	incFailedNum()
void	removeChannel(io.netty.channel.Channel channel)
void	returnChannel(io.netty.channel.Channel channel)
void	updateLatency(int latency)
void	updateLatencyWithReadTimeOut()
void	updateMaxConnection(int num)

Methods inherited from class com.baidu.brpc.client.channel.AbstractBrpcChannel

connect, equals, getProtocol, getServiceInstance, hashCode, sendClientNameToServer, updateChannel

Methods inherited from class java.lang.Object

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

Constructor Detail

BrpcPooledChannel

public BrpcPooledChannel(ServiceInstance serviceInstance,
                         CommunicationOptions communicationOptions)

Method Detail

getChannel

public io.netty.channel.Channel getChannel()
                                    throws Exception,
                                           NoSuchElementException,
                                           IllegalStateException

Throws:

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

Specified by:

close in interface BrpcChannel

Overrides:

close in class AbstractBrpcChannel

getFailedNum

public long getFailedNum()

Specified by:

getFailedNum in interface BrpcChannel

Overrides:

getFailedNum in class AbstractBrpcChannel

incFailedNum

public void incFailedNum()

Specified by:

incFailedNum in interface BrpcChannel

Overrides:

incFailedNum in class AbstractBrpcChannel

getLatencyWindow

public Queue<Integer> getLatencyWindow()

Specified by:

getLatencyWindow in interface BrpcChannel

Overrides:

getLatencyWindow in class AbstractBrpcChannel

updateLatency

public void updateLatency(int latency)

Specified by:

updateLatency in interface BrpcChannel

Overrides:

updateLatency in class AbstractBrpcChannel

updateMaxConnection

public void updateMaxConnection(int num)

getCurrentMaxConnection

public int getCurrentMaxConnection()

getActiveConnectionNum

public int getActiveConnectionNum()

getIdleConnectionNum

public int getIdleConnectionNum()

updateLatencyWithReadTimeOut

public void updateLatencyWithReadTimeOut()

Specified by:

updateLatencyWithReadTimeOut in interface BrpcChannel

Overrides:

updateLatencyWithReadTimeOut in class AbstractBrpcChannel