java - Spring Rabbit队列Xml : NoSuchBeanDefinition when Getting Property from 'Getter Bean'

Question

我正在使用 Spring Rabbit bean 和配置的 xml 文件来配置 Spring Rabbit。

我们使用自己的 propertyGetter 类来检索属性。在下面的 Spring Rabbit xml 中，除了一处之外，它在所有地方都有效。这是为什么？

下面是 xml。被调用的“propertyGetter.get(...)”方法返回一个字符串“my.queue”，但 RabbitMq xsd 解析器似乎正在尝试获取一个 bean。 (？)。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xmlns:rabbit="http://www.springframework.org/schema/rabbit"
        xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/rabbit
        http://www.springframework.org/schema/rabbit/spring-rabbit-1.4.xsd">

        <!-- This has the 'propertyGetter' bean -->
        <import resource="**/applicationContext.xml"/>

        <!--  RabbitMQ -->
        <rabbit:connection-factory id="rabbitConnectionFactory" addresses="#{propertyGetter.get('rabbitMq.hostName')}" username="#{propertyGetter.get('rabbitMq.userName')}" password="#{propertyGetter.get('rabbitMq.password')}" virtual-host="#{propertyGetter.get('rabbitMq.vHost')}"/>
        <rabbit:admin connection-factory="rabbitConnectionFactory"/>

        <!-- RabbitMQ Template -->
        <rabbit:template id="rabbitTemplate" connection-factory="rabbitConnectionFactory" message-converter="messageConverter" exchange="#{propertyGetter.get('rabbitMq.exchange')}"/>


        /*******************************************
         *
         *    THIS IS THE ONLY PLACE IT DOESN'T WORK
         *    <rabbit:queue name=""
         *        It does seem to get value 'my.queue'
         *        but the exception that's posted
         *        below indicates it's trying to 
         *        construct a bean!  Why is this?
        *******************************************/
        <!-- RabbitMQ Queue Definitions -->
        <!--<rabbit:queue name="my.queue" >--> <!--THIS WORKS-->
        <rabbit:queue name="#{propertyGetter.get('rabbitMq.queue.name')}" > <!--THIS DOESN'T-->
            <rabbit:queue-arguments>
                <entry key="x-ha-policy" value="all"/>
            </rabbit:queue-arguments>
        </rabbit:queue>

        <!-- RabbitMQ Exchange and Binding Definition -->
        <rabbit:direct-exchange name="#{propertyGetter.get('rabbitMq.exchange')}">
            <rabbit:bindings>
                <rabbit:binding key="#{propertyGetter.get('rabbitMq.routing.key')}" queue="#{propertyGetter.get('rabbitMq.queue.name')}"/>
            </rabbit:bindings>
        </rabbit:direct-exchange>

        <!-- Listeners -->
        <rabbit:listener-container id="listener" connection-factory="rabbitConnectionFactory" concurrency="3" max-concurrency="5" requeue-rejected="false">
            <rabbit:listener ref="eventNotificationAdapter" queues="#{propertyGetter.get('rabbitMq.queue.name')}" priority="#{propertyGetter.get('rabbitMq.queue.priority')}" />
        </rabbit:listener-container>

        <!-- Message Listener Adapters -->
        <bean id="eventNotificationAdapter" class="org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter">
            <constructor-arg name="delegate" ref="myQueueConsumer"/>
            <constructor-arg name="messageConverter" ref="messageConverter"/>
            <property name="defaultListenerMethod" value="process"/>
        </bean>

        <bean id="messageConverter" class="org.springframework.amqp.support.converter.JsonMessageConverter"/>

</beans>

应用程序首次初始化时的异常是“NoSuchBeanDefinitionException”，但我不确定为什么当方法调用返回 String 时，解析 xml 的任何内容都需要 bean。

这是我在尝试部署应用程序时获得的堆栈跟踪:

SEVERE: Exception sending context initialized event to listener instance of class org.jboss.resteasy.plugins.spring.SpringContextLoaderListener
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'org.springframework.amqp.rabbit.config.BindingFactoryBean#0': Cannot resolve reference to bean '#{propertyGetter.get('rabbitMq.queue.name')}' while setting bean property 'destinationQueue'; nested exception is org.springframework.beans.factory.NoSuchBeanDefinitionException: No bean named 'my.queue' is defined
    at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveReference(BeanDefinitionValueResolver.java:359)
    at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveValueIfNecessary(BeanDefinitionValueResolver.java:108)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyPropertyValues(AbstractAutowireCapableBeanFactory.java:1477)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1222)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:537)
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:476)
    at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:303)
    at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230)
    at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:299)
    at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:194)
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:736)
    at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:757)
    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:480)
    at org.springframework.web.context.ContextLoader.configureAndRefreshWebApplicationContext(ContextLoader.java:403)
    at org.springframework.web.context.ContextLoader.initWebApplicationContext(ContextLoader.java:306)
    at org.springframework.web.context.ContextLoaderListener.contextInitialized(ContextLoaderListener.java:106)
    at org.jboss.resteasy.plugins.spring.SpringContextLoaderListener.contextInitialized(SpringContextLoaderListener.java:48)
    at org.apache.catalina.core.StandardContext.listenerStart(StandardContext.java:5017)
    at org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5531)
    at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150)
    at org.apache.catalina.core.ContainerBase.addChildInternal(ContainerBase.java:901)
    at org.apache.catalina.core.ContainerBase.addChild(ContainerBase.java:877)
    at org.apache.catalina.core.StandardHost.addChild(StandardHost.java:652)
    at org.apache.catalina.startup.HostConfig.deployWAR(HostConfig.java:1095)
    at org.apache.catalina.startup.HostConfig$DeployWar.run(HostConfig.java:1930)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: org.springframework.beans.factory.NoSuchBeanDefinitionException: No bean named 'my.queue' is defined
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBeanDefinition(DefaultListableBeanFactory.java:687)
    at org.springframework.beans.factory.support.AbstractBeanFactory.getMergedLocalBeanDefinition(AbstractBeanFactory.java:1168)
    at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:281)
    at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:194)
    at org.springframework.beans.factory.support.BeanDefinitionValueResolver.resolveReference(BeanDefinitionValueResolver.java:351)
    ... 29 more 

其他说明:这是一个使用 spring-rabbit-1.3.xsd 的 xml 文件

该解决方案不使用 spring 属性。这是为了以另一种方式管理属性。

Answer 1

它们是两个不同的东西。

对于<bean/> ，name attribute 是 bean 名称的别名。如果没有id提供，第一个name用作 id。

对于<queue/> name attribute是rabbitmq代理中队列的名称； id始终是 bean 名称，如果不存在，则会生成唯一的 bean 名称。

有一些现有的逻辑来注册 name作为别名，但只有在解析时已知该值时才有效(正如您所发现的)。

事实上，这种别名的使用是不正确的，并且会导致其他问题 - 例如，您不能拥有具有相同 name 的交换器和队列。 - 参见this JIRA for a discussion about that .

为了解决这个问题，我们正在考虑完全删除别名并需要 id属性为 bean 命名。

我相信您可以通过为队列提供 id 来解决您的问题并在您的监听器容器中引用它 queues属性，或更改容器以使用 queue-names反而。