com.baidu.brpc.client.channel

Class BrpcSingleChannel

java.lang.Object

com.baidu.brpc.client.channel.AbstractBrpcChannel

com.baidu.brpc.client.channel.BrpcSingleChannel

All Implemented Interfaces:

BrpcChannel

public class BrpcSingleChannel
extends AbstractBrpcChannel

BrpcSingleChannel class keeps single persistent connection with one server

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BrpcSingleChannel.ReConnectTask

Field Summary

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

bootstrap, bootstrapManager, communicationOptions, serviceInstance

Constructor Summary

Constructors

Constructor and Description
BrpcSingleChannel(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	updateChannel(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

Methods inherited from class java.lang.Object

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

Constructor Detail

BrpcSingleChannel

public BrpcSingleChannel(ServiceInstance serviceInstance,
                         CommunicationOptions communicationOptions)

Method Detail

getChannel

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

Throws:

Exception

NoSuchElementException

IllegalStateException

removeChannel

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

updateChannel

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

Specified by:

updateChannel in interface BrpcChannel

Overrides:

updateChannel in class AbstractBrpcChannel

close

public void close()

Specified by:

close in interface BrpcChannel

Overrides:

close in class AbstractBrpcChannel

getCurrentMaxConnection

public int getCurrentMaxConnection()

getActiveConnectionNum

public int getActiveConnectionNum()

getIdleConnectionNum

public int getIdleConnectionNum()

returnChannel

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

updateMaxConnection

public void updateMaxConnection(int num)

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

updateLatencyWithReadTimeOut

public void updateLatencyWithReadTimeOut()

Specified by:

updateLatencyWithReadTimeOut in interface BrpcChannel

Overrides:

updateLatencyWithReadTimeOut in class AbstractBrpcChannel