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, NamingServiceFactory namingServiceFactory) parse naming service url, connect to servers

方法概要

限定符和类型	方法和说明
io.netty.bootstrap.Bootstrap	getBootstrap()
CopyOnWriteArrayList<EndPoint>	getEndPoints()
CopyOnWriteArrayList<BrpcChannelGroup>	getHealthyInstances()
List<Interceptor>	getInterceptors()
LoadBalanceStrategy	getLoadBalanceStrategy()
NamingService	getNamingService()
Protocol	getProtocol()
<T> T	getProxy(RpcClient rpcClient, Class clazz)
<T> T	getProxy(RpcClient rpcClient, Class clazz, NamingOptions namingOptions)
RpcClientOptions	getRpcClientOptions()
ThreadPool	getWorkThreadPool()
boolean	isLongConnection()
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(Request request, Type responseType, RpcCallback<T> callback, RpcFuture rpcFuture, boolean isFinalTry)
void	setServiceInterface(Class clazz)
void	setServiceInterface(Class clazz, NamingOptions namingOptions)
void	stop()
void	triggerCallback(Runnable runnable)

从类继承的方法 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,
                 NamingServiceFactory namingServiceFactory)

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)

方法详细资料

getProxy

public <T> T getProxy(RpcClient rpcClient,
                      Class clazz,
                      NamingOptions namingOptions)

getProxy

public <T> T getProxy(RpcClient rpcClient,
                      Class clazz)

setServiceInterface

public void setServiceInterface(Class clazz)

setServiceInterface

public void setServiceInterface(Class clazz,
                                NamingOptions namingOptions)

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(Request request,
                                 Type responseType,
                                 RpcCallback<T> callback,
                                 RpcFuture rpcFuture,
                                 boolean isFinalTry)

triggerCallback

public void triggerCallback(Runnable runnable)

removeLogId

public void removeLogId(long id)

getRpcClientOptions

public RpcClientOptions getRpcClientOptions()

getProtocol

public Protocol getProtocol()

getHealthyInstances

public CopyOnWriteArrayList<BrpcChannelGroup> getHealthyInstances()

getEndPoints

public CopyOnWriteArrayList<EndPoint> getEndPoints()

getInterceptors

public List<Interceptor> getInterceptors()

getBootstrap

public io.netty.bootstrap.Bootstrap getBootstrap()

getWorkThreadPool

public ThreadPool getWorkThreadPool()

getLoadBalanceStrategy

public LoadBalanceStrategy getLoadBalanceStrategy()

isLongConnection

public boolean isLongConnection()

getNamingService

public NamingService getNamingService()