当前位置: 首页 > 知识库问答 >
问题:

Spring兔AMQP

养鸿运
2023-03-14

在XML文件中配置RabbitMQ时,我试图理解Spring RabbitMQ代码。在接收方xml文件中,我有

<rabbit:queue id="springQueue" name="spring.queue" auto-delete="true" durable="false"/>

<rabbit:queue name="springQueue" auto-delete="true" durable="false"/>

<rabbit:listener-container connection-factory="connectionFactory">
    <rabbit:listener queues="springQueue" ref="messageListener"/>
</rabbit:listener-container>

<bean id="messageListener" class="com.ndpar.spring.rabbitmq.MessageHandler"/>

<!-- Bindings -->

<rabbit:fanout-exchange name="amq.fanout">
    <rabbit:bindings>
        <rabbit:binding queue="springQueue"/>
    </rabbit:bindings>
</rabbit:fanout-exchange>

我的问题是-交换绑定到哪个队列??springQueue或spring。队列我的意思是,在标签中,它是指队列id还是队列名称??同样在标签中,“队列”属性指的是队列id或队列名称??请帮忙。我查看了模式(xsd),但没有弄清楚。请帮忙。

共有1个答案

苏丰茂
2023-03-14

queues(在侦听器中)和queue(在绑定中)应该引用queueid属性。

在侦听器中,可以在队列名称属性中使用队列名称,但绑定始终需要id。

 类似资料:
  • 我正在执行这个JCR SQL2查询: 并得到警告,我应该创建索引: 我就是这样做的: 其中propertyName是以下字符串之一:deleted、state、jcr:localname、jcr:path、jcr:property、jcr:fullText、property、localname、path、user、fullText 但我还是得到了警告,我想这意味着我的指数不会被使用。当我打印出所有

  • 我正在做一个尝试采用消息驱动框架的项目。(不同的独立组件与消息代理路由的消息通信) RabbitMQ最终被选为经纪人。 对于框架,起初我们尝试使用Spring Cloud Stream,但当我们尝试利用Rabbit特性时,例如:Exchange、路由密钥、备用交换......我们发现很难在Spring Cloud Stream中使用它们。 所以我的问题是: 我必须使用SpringRabbit(或者

  • 我的设置面临一些问题,我正在尝试增加心跳间隔,以测试可能的修复。我正在使用 下面是实例化连接工厂的代码 问题是心跳间隔没有改变。我在AMQConnection中快速查看以下内容 来自服务器的值是60。方法negotiatedMaxValue将不尊重客户端的首选项(不能禁用心跳信号,也不能增加心跳信号)。我错过什么了吗?

  • 我们正在使用spring云配置服务器。Spring配置客户端使用Spring控制总线(RabbitMQ)获取更新。 看起来每个配置客户端实例都会创建一个连接到'spring.cloud.bus'交换的队列。 对有多少应用程序实例可以连接到“spring.cloud.bus”交换有任何可伸缩性限制? 我想RabbitMQ可以扩展来处理这个问题。 寻找这方面的指导方针。 许多感谢,

  • 是否可以使用RabbitMQ主题交换实现以下场景。 假设我有两个队列: 队列1:路由关键字MainRoute。路线1 Queue2:路由密钥MainRoute.Route2 使用路由密钥发布邮件时: 主要路线。路线1- 主干道。路线2 - 主要路线- 是否可以实现这一点,而不需要实施一些特殊的过滤、路由过程? 如果没有,你能建议一个可能的解决方案吗? 谢谢你。

  • 2023.02.08晚,感觉答得不是很好,但是面试官人很好,刚挂了电话没一会就约我二面时间 自我评价:整体来说mysql的log日志、mq的底层理解有点模糊,然后要答到点上,不要答无关的东西显示自己理解有多深,不然就给自己挖坑而且让面试官感到厌烦,然后就是组织好语言,知道就知道,不知道就不知道,节约双方时间。 ​ 🔥1. Java 线程安全集合: hashtable,vector, courre