com.baidu.brpc.client

Class RpcClient

java.lang.Object

com.baidu.brpc.client.RpcClient

public class RpcClient
extends Object

Created by huwenwei on 2017/4/25.

Constructor Summary

Constructors

Constructor and Description
RpcClient(Endpoint endPoint)
RpcClient(Endpoint endPoint, RpcClientOptions options)
RpcClient(Endpoint endPoint, RpcClientOptions options, List<Interceptor> interceptors)
RpcClient(List<Endpoint> endPoints)
RpcClient(List<Endpoint> endPoints, RpcClientOptions options)
RpcClient(List<Endpoint> endPoints, RpcClientOptions options, List<Interceptor> interceptors)
RpcClient(String namingServiceUrl)
RpcClient(String namingServiceUrl, RpcClientOptions options)
RpcClient(String namingServiceUrl, RpcClientOptions options, List<Interceptor> interceptors) parse naming service url, connect to servers

Method Summary

Modifier and Type	Method and Description
Response	execute(Request request, CommunicationOptions communicationOptions)
<T> T	getProxy(Class clazz)
<T> T	getProxy(Class clazz, NamingOptions namingOptions)
static <T> T	getProxy(RpcClient rpcClient, Class clazz)
static <T> T	getProxy(RpcClient rpcClient, Class clazz, NamingOptions namingOptions)
void	initGlobal(RpcClientOptions options)
boolean	isShutdown()
void	registerPushService(Object service)
void	setServiceInterface(Class clazz)
void	setServiceInterface(Class clazz, NamingOptions namingOptions)
void	shutdown()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

RpcClient

public RpcClient(String namingServiceUrl)

RpcClient

public RpcClient(String namingServiceUrl,
                 RpcClientOptions options)

RpcClient

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

parse naming service url, connect to servers

Parameters:

namingServiceUrl - 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(Endpoint endPoint,
                 RpcClientOptions options,
                 List<Interceptor> interceptors)

RpcClient

public RpcClient(List<Endpoint> endPoints)

RpcClient

public RpcClient(List<Endpoint> endPoints,
                 RpcClientOptions options)

RpcClient

public RpcClient(List<Endpoint> endPoints,
                 RpcClientOptions options,
                 List<Interceptor> interceptors)

Method Detail

getProxy

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

getProxy

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

registerPushService

public void registerPushService(Object service)

Parameters:

service -

getProxy

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

getProxy

public <T> T getProxy(Class clazz)

setServiceInterface

public void setServiceInterface(Class clazz)

setServiceInterface

public void setServiceInterface(Class clazz,
                                NamingOptions namingOptions)

shutdown

public void shutdown()

stop

public void stop()

isShutdown

public boolean isShutdown()

execute

public Response execute(Request request,
                        CommunicationOptions communicationOptions)
                 throws RpcException

Throws:

RpcException

initGlobal

public void initGlobal(RpcClientOptions options)