com.baidu.brpc.client

类 RpcClient

java.lang.Object

com.baidu.brpc.client.RpcClient

public class RpcClient
extends Object

Created by huwenwei on 2017/4/25.

构造器概要

构造器

构造器和说明
RpcClient(EndPoint endPoint)
RpcClient(EndPoint endPoint, RpcClientOptions options)
RpcClient(List<EndPoint> endPoints)
RpcClient(List<EndPoint> endPoints, RpcClientOptions option, List<Interceptor> interceptors)
RpcClient(String namingServiceUrl)
RpcClient(String namingServiceUrl, RpcClientOptions options)
RpcClient(String namingServiceUrl, RpcClientOptions options, List<Interceptor> interceptors)
RpcClient(String serviceUrl, RpcClientOptions options, List<Interceptor> interceptors, NamingService namingService) parse naming service url, connect to servers

方法概要

限定符和类型	方法和说明
void	addEndPoints(Collection<EndPoint> addList)
protected void	deleteEndPoints(Collection<EndPoint> deleteList)
io.netty.bootstrap.Bootstrap	getBootstrap()
CopyOnWriteArrayList<BrpcChannelGroup>	getHealthyInstances()
List<Interceptor>	getInterceptors()
Protocol	getProtocol()
RpcClientOptions	getRpcClientOptions()
ThreadPool	getThreadPool()
CopyOnWriteArrayList<BrpcChannelGroup>	getUnhealthyInstances()
void	removeChannel(io.netty.channel.Channel channel)
void	removeLogId(long id)
void	returnChannel(io.netty.channel.Channel channel)
io.netty.channel.Channel	selectChannel() 业务手动选择channel， 这类channel由业务自己调用returnChannel归还给连接池， 或者调用removeChannel从连接池中删除。
<T> Future<T>	sendRequest(RpcRequest rpcRequest, Type responseType, RpcCallback<T> callback)
void	setServiceInterface(Class clazz)
void	stop()
void	triggerCallback(Runnable runnable)
void	updateEndPoints(List<EndPoint> newEndPoints)

从类继承的方法 java.lang.Object

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

构造器详细资料

RpcClient

public RpcClient(String namingServiceUrl)

RpcClient

public RpcClient(String namingServiceUrl,
                 RpcClientOptions options)

RpcClient

public RpcClient(String namingServiceUrl,
                 RpcClientOptions options,
                 List<Interceptor> interceptors)

RpcClient

public RpcClient(String serviceUrl,
                 RpcClientOptions options,
                 List<Interceptor> interceptors,
                 NamingService namingService)

parse naming service url, connect to servers

参数:

serviceUrl - format like "list://127.0.0.1:8200"

options - rpc client options

RpcClient

public RpcClient(EndPoint endPoint)

RpcClient

public RpcClient(EndPoint endPoint,
                 RpcClientOptions options)

RpcClient

public RpcClient(List<EndPoint> endPoints)

RpcClient

public RpcClient(List<EndPoint> endPoints,
                 RpcClientOptions option,
                 List<Interceptor> interceptors)

方法详细资料

setServiceInterface

public void setServiceInterface(Class clazz)

stop

public void stop()

selectChannel

public io.netty.channel.Channel selectChannel()

业务手动选择channel， 这类channel由业务自己调用returnChannel归还给连接池， 或者调用removeChannel从连接池中删除。

返回:

netty channel

returnChannel

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

removeChannel

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

sendRequest

public <T> Future<T> sendRequest(RpcRequest rpcRequest,
                                 Type responseType,
                                 RpcCallback<T> callback)

triggerCallback

public void triggerCallback(Runnable runnable)

updateEndPoints

public void updateEndPoints(List<EndPoint> newEndPoints)

addEndPoints

public void addEndPoints(Collection<EndPoint> addList)

deleteEndPoints

protected void deleteEndPoints(Collection<EndPoint> deleteList)

removeLogId

public void removeLogId(long id)

getRpcClientOptions

public RpcClientOptions getRpcClientOptions()

getProtocol

public Protocol getProtocol()

getHealthyInstances

public CopyOnWriteArrayList<BrpcChannelGroup> getHealthyInstances()

getUnhealthyInstances

public CopyOnWriteArrayList<BrpcChannelGroup> getUnhealthyInstances()

getInterceptors

public List<Interceptor> getInterceptors()

getBootstrap

public io.netty.bootstrap.Bootstrap getBootstrap()

getThreadPool

public ThreadPool getThreadPool()