像“在RabbitMq上消费？

2018-06-11 22:44:26

我是RabbitMq和AMQP的新手，但我对ActiveMQ和JMS有一些经验。我尝试在一个主题（像JMS中的主题这样的主题）中发布消息，并从几个监听器中消费这个消息。例如，我发布了一条消息，指出系统中有一个新用户，并且有一位消费者向该用户发送电子邮件，另一位消费者在elasticsearch中为该用户编制索引。因此，每消费必须阅读消息，直到它可以从主题中删除。

我试图用这种方式使用TopicExchange：

@Bean
public TopicExchange profileExchange() {
    return new TopicExchange(PROFILE_EXCHANGE, true, false);
}

@Bean
public Queue putProfileQueue() {
    return new Queue(this.PUT_PROFILE_QUEUE);
}

@Bean
public Binding putProfileBinding() {
    return BindingBuilder.bind(putProfileQueue()).to(profileExchange()).with(PUT_PROFILE_QUEUE);
}

我有两个宣布的听众。

但是，只要第一个侦听器读取消息，它就会从队列中删除，而第二个侦听器不会读取消息。

我不确定要正确理解不同的AMQP配置，以及我应该使用哪一个来模拟我在JMS中知道的“主题”模式。

你会使用fanout交换 - 每个消费者需要自己的队列绑定到交换。

请参阅教程。

链接地址: http://www.djcxy.com/p/34213.html

上一篇: like" consumption on RabbitMq?

下一篇: AMQP or HTTP