com.baidu.brpc.client.channel

Class BrpcShortChannel

java.lang.Object

com.baidu.brpc.client.channel.AbstractBrpcChannel

com.baidu.brpc.client.channel.BrpcShortChannel

All Implemented Interfaces:

BrpcChannel

public class BrpcShortChannel
extends AbstractBrpcChannel

BrpcShortChannel build single & short connection with server and channel will be closed by brpc after communication with server

Field Summary

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

bootstrap, bootstrapManager, communicationOptions, serviceInstance

Constructor Summary

Constructors

Constructor and Description
BrpcShortChannel(ServiceInstance instance, CommunicationOptions communicationOptions)

Method Summary

Modifier and Type	Method and Description
void	close()
int	getActiveConnectionNum()
io.netty.channel.Channel	getChannel()
int	getCurrentMaxConnection()
int	getIdleConnectionNum()
void	removeChannel(io.netty.channel.Channel channel)
void	returnChannel(io.netty.channel.Channel channel)
void	updateMaxConnection(int num)

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

connect, equals, getFailedNum, getLatencyWindow, getProtocol, getServiceInstance, hashCode, incFailedNum, sendClientNameToServer, updateChannel, updateLatency, updateLatencyWithReadTimeOut

Methods inherited from class java.lang.Object

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

Constructor Detail

BrpcShortChannel

public BrpcShortChannel(ServiceInstance instance,
                        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

updateMaxConnection

public void updateMaxConnection(int num)

getCurrentMaxConnection

public int getCurrentMaxConnection()

getActiveConnectionNum

public int getActiveConnectionNum()

getIdleConnectionNum

public int getIdleConnectionNum()