com.baidu.jprotobuf.pbrpc.client.ha.lb

类 LoadBalanceProxyFactoryBean

java.lang.Object

com.baidu.jprotobuf.pbrpc.client.ha.lb.ServiceInterfaceAccessor

com.baidu.jprotobuf.pbrpc.client.ha.lb.ServiceMultiInterfaceAccessor

com.baidu.jprotobuf.pbrpc.client.ha.lb.LoadBalanceProxyFactoryBean

所有已实现的接口:

org.aopalliance.aop.Advice, org.aopalliance.intercept.Interceptor, org.aopalliance.intercept.MethodInterceptor, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean, org.springframework.beans.factory.InitializingBean

public class LoadBalanceProxyFactoryBean
extends ServiceMultiInterfaceAccessor
implements org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.FactoryBean, org.springframework.beans.factory.InitializingBean, org.aopalliance.intercept.MethodInterceptor, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.BeanNameAware

a common utility proxy factory bean to support Spring beans load balance support.
a example

 <bean id="lbRmiService" class="com.baidu.jprotobuf.pbrpc.client.ha.lb.LoadBalanceProxyFactoryBean">
  <property name="serviceInterface" value="com.baidu.rigel.system.subsystem.submodule.service.TestService"></property>
  <property name="extraInterfaces">
      <list>
          <value>com.baidu.rigel.service.remote.support.transaction.TransactionManager</value>
      </list>
   </property>
  <property name="targetBeans">
      <map key-type="java.lang.String">
          <entry key="helloService1" value-ref="helloServiceClient" />
          <entry key="helloService2" value-ref="helloServiceClient2" />
      </map>
  </property>
  <property name="loadBalanceStrategy">
      <bean class="com.baidu.jprotobuf.pbrpc.client.ha.lb.strategy.RoundRobinLoadBalanceStrategy">
          <constructor-arg>
              <map key-type="java.lang.String" value-type="java.lang.Integer">
                  <entry key="helloService1" value="1" />
                  <entry key="helloService2" value="1" />
              </map>
          </constructor-arg>            
      </bean>
  </property>
  <property name="failOverInterceptor">
      <bean class="com.baidu.jprotobuf.pbrpc.client.ha.lb.failover.rmi.RmiFailOverInterceptor">
          <property name="recoverServiceUrls">
              <map key-type="java.lang.String">
                  <entry key="helloService1" value="rmi://localhost:1199/Service" />
                  <entry key="helloService2" value="rmi://localhost:1198/Service" />
              </map>                    
          </property>
      </bean>
  </property>
  <property name="recoverInterval" value="1000"></property>
 </bean>
 
 

从以下版本开始:

2.17

作者:

xiemalin

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	LoadBalanceProxyFactoryBean.FactoryBeanInvokeInfo

构造器概要

构造器

构造器和说明
LoadBalanceProxyFactoryBean()

方法概要

方法

限定符和类型	方法和说明
void	addTargetBean(java.lang.String key, java.lang.Object targetBean) add target bean
void	afterPropertiesSet()
void	destroy()
protected java.lang.ClassLoader	getBeanClassLoader() Return the ClassLoader that this accessor operates in, to be used for deserializing and for generating proxies.
java.util.Map<java.lang.String,LoadBalanceProxyFactoryBean.FactoryBeanInvokeInfo>	getFailedFactoryBeans()
FailOverInterceptor	getFailOverInterceptor()
java.lang.Object	getObject()
java.lang.Class	getObjectType()
long	getRecoverInterval()
boolean	hasFactoryBeanFailed()
java.lang.Object	invoke(org.aopalliance.intercept.MethodInvocation invocation)
boolean	isFailOver()
protected boolean	isHeartBeat()
boolean	isSingleton()
void	recoverFactoryBean(java.lang.String key)
void	setBeanClassLoader(java.lang.ClassLoader classLoader)
void	setBeanName(java.lang.String beanName)
void	setFailOverEvent(FailOverEvent failOverEvent)
void	setFailOverInterceptor(FailOverInterceptor failOverInterceptor)
void	setHeartBeat(boolean heartBeat)
void	setLoadBalanceStrategy(LoadBalanceStrategy loadBalanceStrategy)
void	setRecoverInterval(long recoverInterval)
void	setStrategyInterceptor(StrategyInterceptor strategyInterceptor)
void	setTargetBeans(java.util.Map<java.lang.String,java.lang.Object> targetFactoryBeans)

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

getExtraInterfaces, getExtraServiceInterfaces, setExtraInterfaces

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

getServiceInterface, setServiceInterface

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

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

构造器详细资料

LoadBalanceProxyFactoryBean

public LoadBalanceProxyFactoryBean()

方法详细资料

setFailOverEvent

public void setFailOverEvent(FailOverEvent failOverEvent)

setTargetBeans

public void setTargetBeans(java.util.Map<java.lang.String,java.lang.Object> targetFactoryBeans)

参数:

targetFactoryBeans -

addTargetBean

public void addTargetBean(java.lang.String key,
                 java.lang.Object targetBean)

add target bean

参数:

key -

targetBean -

setLoadBalanceStrategy

public void setLoadBalanceStrategy(LoadBalanceStrategy loadBalanceStrategy)

参数:

loadBalanceStrategy -

getFailOverInterceptor

public FailOverInterceptor getFailOverInterceptor()

返回:

the failOverInterceptor

setFailOverInterceptor

public void setFailOverInterceptor(FailOverInterceptor failOverInterceptor)

参数:

failOverInterceptor - the failOverInterceptor to set

isFailOver

public boolean isFailOver()

返回:

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

指定者:

afterPropertiesSet 在接口中 org.springframework.beans.factory.InitializingBean

抛出:

java.lang.Exception

getObject

public java.lang.Object getObject()

指定者:

getObject 在接口中 org.springframework.beans.factory.FactoryBean

getObjectType

public java.lang.Class getObjectType()

指定者:

getObjectType 在接口中 org.springframework.beans.factory.FactoryBean

isSingleton

public boolean isSingleton()

指定者:

isSingleton 在接口中 org.springframework.beans.factory.FactoryBean

setBeanClassLoader

public void setBeanClassLoader(java.lang.ClassLoader classLoader)

指定者:

setBeanClassLoader 在接口中 org.springframework.beans.factory.BeanClassLoaderAware

getBeanClassLoader

protected java.lang.ClassLoader getBeanClassLoader()

Return the ClassLoader that this accessor operates in, to be used for deserializing and for generating proxies.

invoke

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

指定者:

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

抛出:

java.lang.Throwable

getFailedFactoryBeans

public java.util.Map<java.lang.String,LoadBalanceProxyFactoryBean.FactoryBeanInvokeInfo> getFailedFactoryBeans()

返回:

the failedFactoryBeans

recoverFactoryBean

public void recoverFactoryBean(java.lang.String key)

hasFactoryBeanFailed

public boolean hasFactoryBeanFailed()

destroy

public void destroy()
             throws java.lang.Exception

指定者:

destroy 在接口中 org.springframework.beans.factory.DisposableBean

抛出:

java.lang.Exception

setStrategyInterceptor

public void setStrategyInterceptor(StrategyInterceptor strategyInterceptor)

参数:

strategyInterceptor - the strategyInterceptor to set

setRecoverInterval

public void setRecoverInterval(long recoverInterval)

参数:

recoverInterval - the recoverInterval to set

getRecoverInterval

public long getRecoverInterval()

返回:

the recoverInterval

isHeartBeat

protected boolean isHeartBeat()

返回:

the heartBeat

setHeartBeat

public void setHeartBeat(boolean heartBeat)

参数:

heartBeat - the heartBeat to set

setBeanName

public void setBeanName(java.lang.String beanName)

指定者:

setBeanName 在接口中 org.springframework.beans.factory.BeanNameAware