com.baidu.jprotobuf.pbrpc.client.ha

类 HaProtobufRpcProxy<T>

java.lang.Object

com.baidu.jprotobuf.pbrpc.client.ha.NamingServiceChangeListener

com.baidu.jprotobuf.pbrpc.client.ha.HaProtobufRpcProxy<T>

所有已实现的接口:

org.aopalliance.aop.Advice, org.aopalliance.intercept.Interceptor, org.aopalliance.intercept.MethodInterceptor

直接已知子类:

HaProtobufRpcProxyBean

public class HaProtobufRpcProxy<T>
extends NamingServiceChangeListener
implements org.aopalliance.intercept.MethodInterceptor

A enhanced ProtobufRpcProxy supports naming service and load blanace.

从以下版本开始:

2.16

作者:

xiemalin

字段概要

字段

限定符和类型	字段和说明
protected static org.apache.commons.logging.Log	LOGGER log this class

构造器概要

构造器

构造器和说明
HaProtobufRpcProxy(RpcClient rpcClient, Class<T> interfaceClass, NamingService namingService)
HaProtobufRpcProxy(RpcClient rpcClient, Class<T> interfaceClass, NamingService namingService, NamingServiceLoadBalanceStrategyFactory loadBalanceStrategyFactory, SocketFailOverInterceptor failOverInterceptor)

方法概要

方法

限定符和类型	方法和说明
void	close()
NamingService	getNamingService()
Object	invoke(org.aopalliance.intercept.MethodInvocation invocation)
boolean	isLookupStubOnStartup() get the lookupStubOnStartup
protected ProtobufRpcProxy<T>	onBuildProtobufRpcProxy(RpcClient rpcClient, Class<T> interfaceClass)
T	proxy()
protected void	reInit(String service, List<RegisterInfo> list)
void	setInterceptor(InvokerInterceptor interceptor) set interceptor value to interceptor
void	setLookupStubOnStartup(boolean lookupStubOnStartup) set lookupStubOnStartup value to lookupStubOnStartup

从类继承的方法 com.baidu.jprotobuf.pbrpc.client.ha.NamingServiceChangeListener

setDelay, setPeriod, startUpdateNamingServiceTask

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

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

字段详细资料

LOGGER

protected static final org.apache.commons.logging.Log LOGGER

log this class

构造器详细资料

HaProtobufRpcProxy

public HaProtobufRpcProxy(RpcClient rpcClient,
                  Class<T> interfaceClass,
                  NamingService namingService)

HaProtobufRpcProxy

public HaProtobufRpcProxy(RpcClient rpcClient,
                  Class<T> interfaceClass,
                  NamingService namingService,
                  NamingServiceLoadBalanceStrategyFactory loadBalanceStrategyFactory,
                  SocketFailOverInterceptor failOverInterceptor)

方法详细资料

setInterceptor

public void setInterceptor(InvokerInterceptor interceptor)

set interceptor value to interceptor

参数:

interceptor - the interceptor to set

isLookupStubOnStartup

public boolean isLookupStubOnStartup()

get the lookupStubOnStartup

返回:

the lookupStubOnStartup

setLookupStubOnStartup

public void setLookupStubOnStartup(boolean lookupStubOnStartup)

set lookupStubOnStartup value to lookupStubOnStartup

参数:

lookupStubOnStartup - the lookupStubOnStartup to set

onBuildProtobufRpcProxy

protected ProtobufRpcProxy<T> onBuildProtobufRpcProxy(RpcClient rpcClient,
                                          Class<T> interfaceClass)

proxy

public T proxy()
        throws Exception

抛出:

Exception

close

public void close()

覆盖:

close 在类中 NamingServiceChangeListener

getNamingService

public NamingService getNamingService()

指定者:

getNamingService 在类中 NamingServiceChangeListener

reInit

protected void reInit(String service,
          List<RegisterInfo> list)
               throws Exception

指定者:

reInit 在类中 NamingServiceChangeListener

抛出:

Exception

invoke

public Object invoke(org.aopalliance.intercept.MethodInvocation invocation)
              throws Throwable

指定者:

invoke 在接口中 org.aopalliance.intercept.MethodInterceptor

抛出:

Throwable