0

我有 2 个问题。他们来了：

  1. 有什么方法可以确定在 spring 集成通道中等待处理的消息数量，而客户数量一直在增加？

  2. 在应用程序上下文中，我希望能够定义 bean y 的 x 个实例，其中 x 和 y 都从通道 p 消耗，根据负载以编程方式增加或减少消费者。

spring 2gx 中显示了一个示例，但它用于rabbitmq确定负载。

4

1 回答 1

0
  • 对于 1)，Spring 集成通道就像任何其他 bean 一样只是 bean。假设您使用的是标准可轮询通道，您可以按名称自动连接它，然后获取等待的消息数：

http://docs.spring.io/spring-integration/api/org/springframework/integration/channel/QueueChannel.html#getQueueSize()

如果您愿意，您也可以通过 JMX 进行内省。

  • 对于 2)... 为此，您需要在对象池之上使用 AOP 代理，然后将代理连接到（我假设是）Service Activator。这些属性可以使用 PropertyPlaceholderConfigurer 进行外部化。所以，举个例子：

    <bean id="propertyPlaceholder" 
    class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
    <property name="systemPropertiesMode" value="2" />
    <property name="locations" value="classpath:my_config_params.properties" />
</bean>

<bean id="myBusinessObjectImpl" class="com.mycompany.whatever.impl.MyServiceImpl"
      scope="prototype" autowire-candidate="false" />

<bean id="myBusinessObjPool" class="org.springframework.aop.target.CommonsPoolTargetSource">
    <property name="targetBeanName" value="myBusinessObjectImpl" />
    <!-- THIS IS THE KEY.  myconfig.params.poolsize is the name of the property in the my_config_params.properties above. -->
    <property name="maxSize" value="${myconfig.params.poolsize}" /> 
</bean>

<bean id="myBusinessObject" class="org.springframework.aop.framework.ProxyFactoryBean">
    <property name="targetSource" ref="myBusinessObjPool" />
</bean>

<int:channel id="myInputChannel">
    <int:queue size="500" />
</int:channel>

<int:service-activator inputChannel="myInputChannel" ref="myBusinessObject" method="processMessages">
    <int:poller max-messages-per-poll="10" fixed-rate="5000"/>
</int:service>

这也允许您使服务激活器有状态。对象池功能的强制性链接：

http://docs.spring.io/spring/docs/3.0.x/spring-framework-reference/html/aop-api.html#aop-ts-pool

于 2013-09-27T22:09:09.093 回答