spring-amqp一个队列多个监听器
spring-amqp是一个基于Spring框架的AMQP（Advanced Message Queuing Protocol）消息队列的集成库。它提供了在应用程序中使用消息队列进行异步通信的能力。
队列是AMQP中的一个基本概念，它是一种存储消息的数据结构。多个监听器可以订阅同一个队列，每个监听器都可以接收并处理队列中的消息。
优势：
- 异步通信：使用消息队列可以实现应用程序之间的异步通信，提高系统的可伸缩性和性能。
- 解耦：通过将消息发送到队列中，发送方和接收方之间的耦合度降低，可以独立开发和部署。
- 可靠性：消息队列提供了消息的持久化机制，即使在消息发送或接收失败的情况下，消息也不会丢失。
- 负载均衡：多个监听器可以同时处理队列中的消息，实现负载均衡，提高系统的处理能力。
应用场景：
- 异步任务处理：将耗时的任务放入消息队列中，由多个监听器异步处理，提高系统的响应速度。
- 事件驱动架构：通过发布订阅模式，将事件发布到消息队列中，多个监听器可以订阅并处理事件。
- 应用解耦：将不同模块之间的通信通过消息队列进行解耦，提高系统的可维护性和扩展性。
推荐的腾讯云相关产品：
腾讯云提供了消息队列服务（TencentMQ），它是一种高可靠、高可用的分布式消息队列服务，适用于各种场景下的消息通信。您可以使用腾讯云消息队列服务来实现spring-amqp中的队列多个监听器的功能。
产品介绍链接地址：腾讯云消息队列服务
相关·内容
使用Spring-AMQP抽象API，如何实现工作或任务队列？我只有一个生产者和多个工人消费者。消费者从队列中挑选下一项并对其进行处理。当您直接使用Spring时，这是受支持的，但我在RabbitMQ -AMQP中看不到任何支持。我是不是漏掉了什么？有没有其他实现工作队列的方法？
浏览 0提问于2015-04-17得票数 2
1回答
我遵循Stock Trading示例的说明，其中概述了如何在spring-amqp：中使用请求/回复消息
我调整了示例指令以创建一个客户机，它应该使用convertSendAndReceive而不是convertAndSend：来等待回复
现在，即使回复被放到responseQueue上，而且我已经更新了超时rabbitTemplate.setReplyTimeout(60000);，使其比5秒的默认时间长……在我的客户端，我收到null作为回复。
有人知道这是怎么回事吗？
Update#1
有人建议我将一个<reply-listener/>添加到<rabbit:templ
浏览 0提问于2013-06-13得票数 0
回答已采纳
其中有一个包含10000条消息的队列。启动使用者(autoack=true)时，我可以从rabbitmq_management中看到消息数量迅速变为零。这是否意味着所有10000条消息都在消费者一方？它存放在哪里(我正在使用Spring-AMQP)？如果我的使用者配置的并发性是1，并且处理一条消息需要很长时间，那么是否有可能耗尽内存(如果消息的数量很大)？
浏览 5提问于2021-02-19得票数 0
回答已采纳
2回答
我想使用Java API(Spring-AMQP)获取一台机器中的所有可用队列。我没有找到正确的API。有没有人能推荐同样的API。
浏览 1提问于2015-06-05得票数 1
我有一个spring应用程序，其中我们使用spring-amqp发布和侦听来自Rabbitmq的消息。如果我的监听器抛出异常，我想修改我的Rabbitmq消息。当侦听器抛出异常时，它将使用恢复程序和重试处理程序重新启动。我正在修改listener类中存在的catch块中的消息。一旦消息被修改，我将抛出一个异常，这样消息将在一段固定的持续时间后再次重试。 这是我用来修改消息的代码。 public void onMessage(Message message, Channel channel) throws Exception
{
try
{
浏览 44提问于2019-09-10得票数 1
回答已采纳
我正在使用Spring-AMQP来监控Play应用程序中的RabbitMQ消息队列。
问题是我不能从侦听器代码访问我的数据库，因为JPA上下文没有在这个作用域中打开。
我知道Play Framework管理JPA上下文，所以它在处理HTTP请求时是开放的，但是有没有一种方法可以从外部的Play控制器/作业使用JPA？
浏览 4提问于2012-05-30得票数 1
回答已采纳
3回答
我有这样的场景:一个客户端将一条消息发送到msmq队列实例中，有3个进程监听此队列。我希望能够让这些实例中的每一个选择不同的消息并处理它。
我知道这是一种常见的队列使用场景，我已经有了使用MSMQ、.NET和C#的可用代码。
然而，我想知道msmq是否是我在这里的最佳选择--文档中明确指出MSMQ是用于“一对一”通信的，这意味着不应该有超过一个监听器。
这让我想知道，我正在做的事情对我的用例来说是正确的解决方案吗？或者反过来，我是否必须为每个侦听器创建一个队列，并在工作流的前一部分中分发消息？
如能链接到演示MSMQ在此类场景中的使用的工作示例，将不胜感激。
谢谢
浏览 0提问于2011-06-15得票数 13
回答已采纳
我们有两个rabbitmq经纪人。
我们发布到Broker1的队列A，Broker2的队列B可以直接订阅到队列A，这样就没有延迟了，比如为它编写处理程序(使用@rabbitListener)，然后发布到另一个队列。
我的问题是，Broker2是否可以使用任何rabit处理程序直接订阅broker1，或者broker2(另一个队列)是否可以直接使用broker1中的队列数据？有可能吗？
如果是，如何通过spring-amqp实现？
注意:两个不同的RabbitMq服务器中的两个rabbitmq代理
浏览 2提问于2019-06-07得票数 0
1回答
我正在对用C++、Python语言和Java语言编写的客户机使用C++代理。如果我们在夜间运行系统，那么到早上它就不会可靠地发送/接收消息。所有消息都通过主题交换，主题指定目的地。我有三个问题：
1.)我们应该使用队列吗？使用队列比使用主题有优势吗？选择队列而不是主题的设计决策是什么？队列看起来更严格(即，如果您知道节点A发送了一个请求并希望得到响应，那么您应该立即发送一个响应；pub/sub)。
2.)如果消息未得到确认，会发生什么情况？我发现Python模块缺少一个session.acknowledge()。这可能是导致我们一夜之间失败的原因吗？我今天发现了这个问题，所以我希望明天能有更多
浏览 4提问于2013-04-12得票数 0
回答已采纳
实际上，我不能让它运行。也许我误解了什么，这无论如何都是不可能的。我正在尝试在同一个队列上配置两个监听器，相同的交换，但只有路由关键字应该不同。我的问题是，不知何故，事情变得一团糟。结果是监听器A收到了发往监听器B的消息。但只是有时，有时一切都很正常。有什么建议吗？
MyConfig
@Bean
public ConnectionFactory connectionFactory() {
CachingConnectionFactory connectionFactory = new CachingConnectionFactory(getHostname());
connec
浏览 9提问于2017-01-24得票数 2
回答已采纳
我想做什么
我有一个用Flask编写的HTTP服务，它是一个用于构建不同服务实例的模板。因此，这个模板需要是可泛化的，以处理实际使用和不包含Kafka消费的用例。
我的目标是让一个可选的Kafka消费者在API模板的背景下运行。我希望任何需要它的服务都能够异步地从Kafka主题读取数据，同时也像通常那样独立地响应HTTP请求。这两个进程(Kafka消费，HTTP请求处理)并不相关，只是它们将发生在同一服务的幕后。
我写的东西
这是我的装置：
# ./create_app.py
from flask_socketio import SocketIO
socketio = None
def
浏览 4提问于2019-10-23得票数 0
我有一个spring的amqp应用程序，我想使用，但我似乎不知道如何让它来注册我的听众服务。这是我的基于注释的配置文件。
package com.jerry.configuration;
import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbi
浏览 1提问于2017-12-20得票数 0
回答已采纳
3回答
我是JMS的新手，我正在使用Tomcat6和Spring来设置ActiveMQ。我已经配置了大部分基本的东西，但是我对Spring提供的消息侦听器容器有点困惑。阅读文档时，消息侦听器容器听起来像是用来“处理”订阅(我正在处理主题)、取消订阅并将消息传递给侦听器。我不确定我是否正确地思考了这一点。如果是这种情况，我没有看到任何关于如何让多个类使用Message Listener Container订阅同一主题的文档。我看到您可以设置messageListener属性，但这将只允许一个类能够订阅一个主题。仅仅为了让另一个订阅者(消息驱动POJO)侦听相同的主题而创建同一消息侦听器容器的另一个实例似
浏览 7提问于2009-06-04得票数 7
1回答
使用RabbitMQ 3.7.16和spring-amqp 2.2.3.RELEASE。
多个客户端使用唯一的路由密钥将消息发布到我们的DataExchange服务器中的RabbitMQ主题交换。在没有任何绑定的情况下，交换将通过AE将所有消息路由到data.queue.generic。
当某个客户端(图中的客户端ID 1和2 )发布大量消息时，为了独立于其他客户端来扩展它们的消息消耗，我们启动了使用者，并分配给他们只处理他们的客户机ID，为了实现这一点，每个客户端-使用者都定义了一个新的队列，并将其绑定到主题交换与路由密钥events.<clientID>。
因此，扩大规模是涵盖
浏览 0提问于2020-02-11得票数 2
回答已采纳
通常，我会看到一些示例，其中特定消息被放入一个队列中并转换为Java对象。目前，我想有一个事件队列，可以包含多种类型的事件，并为这些事件的特定类型的侦听器。有没有办法在一个队列中有多个事件类型，并在同一队列上有单独的消息侦听器？
浏览 1提问于2015-12-03得票数 1
是否有一个矩阵或映射来标识可以与spring-amqp的每个版本一起使用的rabbitmq版本？我们目前正在使用rabbitmq 3.5.4和spring-amqp 1.0.2。
浏览 1提问于2015-10-07得票数 1
1回答
目前，我正在收听使用spring boot和spring-amqp通过API调用创建的新队列，这是成功工作的片段代码 @RestController
@RequestMapping("/api/register/")
@NoArgsConstructor
public class RegisterQueuesController {
@Autowired
SimpleReceiver simpleReceiver;
@PostMapping(value = "/queues")
public ResponseEntity<
浏览 35提问于2021-03-17得票数 1
我想在Maven项目中同时使用spring-amqp和spring-data-mongodb。Spring-amqp依赖于Spring 3.0.7，而spring-data-mongodb依赖于Spring 3.1.2。最终的结果是，我的depdendency树中有来自Spring 3.0.7和3.1.2的包，这似乎会在运行时导致问题。
我应该如何解决这个问题？从spring-amqp和spring-data-mongodb的所有传递依赖项中，手动将具有特定版本的直接依赖项添加到我的项目中？重新编译一个或两个都依赖于一个通用的Spring版本？
浏览 4提问于2013-01-18得票数 1
回答已采纳
1回答
IBM MQ最大连接数
、、、、
我在应用程序中使用IBM MQ，连接工厂在Jboss级别定义。Jboss级别的最大池大小属性配置为50。通道的每个客户端配置的最大实例数设置为999999999。分享对话仍然是默认的10。如果有人能详细说明这些连接是如何工作的，我将不胜感激。 我知道JVM可以建立到Queue Manager的最大连接数是50 (最大连接池)。如果我有50个并行运行的消息侦听器线程，那么所有这些线程都将被消耗。但在通道级别，共享会话是10，这意味着在单个TCP连接上最多可以共享10个会话。在这种情况下，我们没有利用此功能，因为我们耗尽了50个连接。如果允许在一个连接上共享10个，我们应该看到50条消息只建立了
浏览 204提问于2020-07-24得票数 0
2回答
我使用Spring JMS和ActiveMQ通过ActiveMQ主题(发布/订阅)将消息从发送者发送到多个监听器。到目前为止，所有的监听器都可以接收来自发送者的消息。但是我想添加一个功能，当一个特定的监听器，比如listener1，收到消息时，listener1会向发送者发送一个回执确认。我遵循中的注释，在发送者中创建了一个TemporaryQueue，并在发送者和接收者中使用ReplyTo来获取从侦听器到发送者的确认消息。
我的发件人类是：
public class CustomerStatusSender {
private JmsTemplate jmsTemplate;
浏览 1提问于2013-11-23得票数 0
RabbitMQ是个新手，我们还在调查阶段，看看它是否适合我们的用例--
我们已经很容易得出结论，我们想要的拓扑结构将使我们部署一些基于主题的交换，然后从那里过滤到特定的队列。例如，假设我们有一个用户和一个上传交换，其中用户队列可能接收到主题为“新注册”或“好友请求”的消息，而上传交换可能接收到诸如“视频上传”或“图片上传”之类的消息。
创建队列，将它们路由到适当的队列，然后构建侦听器来处理各种队列的消息，这是非常简单的。
然而，我不清楚的是，是否可以在主题交换上进行一次扇出？
也就是说，我已经命名了绑定到我的主题交换的队列，但我希望能够在这些队列中抛出大量的监听器实例，以防止单点故障。但据我
浏览 0提问于2011-03-10得票数 4
我主要在RPC模式下使用rabbitMq，但我也希望将请求和响应消息复制到另一个队列。 最后，我想要实现的是，外部使用者通过监听一个队列来查看所有信息的可能性，让我们称之为“日志队列”。 复制传入消息是可以的，我只需要使用扇出交换，或者将我的日志队列绑定到与RPC调用使用的路由关键字相同的已用交换。 但是我找不到一种方法来“扇出”通过直接回复功能发送的消息。 到目前为止，我了解到响应消息被发送到默认的直接交换，并以amqp.rabbitmq.reply-to.generatedName的形式生成routing_key，并且由于默认交换是不可触及的，所以我不能复制这些消息。 你知道怎么做吗？
浏览 29提问于2020-01-30得票数 1
2回答
我已经安装了pip install pika==0.11.0，如自述文件中所示，之后我尝试了python receiver.py，它给出了以下错误：
Traceback (most recent call last):
File "receive.py", line 9, in <module>
channel.queue_declare(queue='hello')
File "C:\Python36\lib\site-packages\pika\adapters\blocking_connection.py", line 2400
浏览 0提问于2018-04-13得票数 2
我正在研究我们分布式系统中的Azure服务总线主题和订阅。我希望控制在任何给定时间可以处理的消息数量。比如说，我们在生产中有5个节点，我知道我可以在创建订阅者时指定并发调用的最大数量。因此，如果我将其值设为1，我将受到环境中活动节点数量的限制。
我想知道有没有办法进一步限制它。例如，即使有活动的空闲侦听器等待工作，一次也只处理订阅中的一条消息。
提亚
浏览 3提问于2020-05-12得票数 0
1回答
我使用的是RabbitMQ和MongoDB。我需要用java编写一个服务函数，当RabbitMQ从队列中触发消息时，将数据存储在MongoDB中。
架构将会是这样的
RabbitMQ是否有能力将XML文件从队列传递到拾取服务？请帮帮忙。我对所有这些技术都是新手。
浏览 1提问于2016-09-29得票数 0
我很难掌握RabbitMQ和Spring Cloud Stream如何协同工作的知识。我想做的是(基本解释)：
我有一个生产者来产生消息，比如: SendEmail，ReceiveEmail和ErrorOccurred。这些将被发送到消息总线上。然后我有3个消费者。一个LogService、一个Emailservice和一个ParserService。
EmailService将拾取所有的Email消息，LogService将拾取ErrorOccurred (也由其他生产者生成)和EmailSend消息。最后，ParserService将只获得ReceiveEmail消息。
我似乎不能用Spr
浏览 1提问于2018-10-11得票数 2
1回答
限制JMS目标实例
、、、
是否可以将JMS接收器实例的数量限制为单个实例？即，在任何时候只处理队列中的一条消息？
我问的原因是因为我有一个相当密集的呈现类型进程要为每条消息(可能有数千条)运行。我希望将这段代码的执行限制为一次只能执行一个实例。
我的应用服务器是JBoss AS 6.0
浏览 0提问于2010-03-24得票数 2
回答已采纳
2回答
Jquery慢反应时间
、、、
我尝试使用jQuery作为标题动画，添加之后动画速度减慢：
else if (headeranimated && $(this).scrollTop() > 1200)
else if (headeranimated2 && headeranimated && $(this).scrollTop() < 1000)
我得等几秒钟才能看到动画的第二部分。这个代码有什么问题吗？
谢谢
// header animation
var headeranimated2 = false;
var headeranimated = false
浏览 2提问于2014-11-24得票数 0
回答已采纳
我是WSO2堆栈的新手，从事各种WSO2中间件产品的工作。我有一个场景，比如我想发布一条消息到主题和子主题。有可能吗？
我参考了一些文章，我们可以使用*和#从主题和子主题订阅消息。但是如何发布到父主题的所有子主题呢？
例如，我有一个类似Region (父主题) StoreID1 (第一子主题) StoreID2 (第一子子主题) StoreID3 (第一子子主题)的层次结构。
如果我发送到父主题，是否可以将消息推送到所有子主题？请协助！
浏览 0提问于2016-02-12得票数 0
让我先概述一下我发现自己所处的具体情况，尽管我的问题实际上更笼统。我正在编写一个包含多个滑块的组件，并且我有监听来自这些滑块的事件的监听器。当其中一个滑块发生变化时，我希望我的组件向它自己的侦听器发送一个事件，通知它们它的状态发生了变化。然而，我想要限制发送的事件的数量，也就是说，如果在我的组件通知它的监听器时有几个事件在等待，我想将所有这些事件折叠成一个事件。
我的问题是，是否有标准的技术来实现这一点。如果是这样，任何例子都是受欢迎的，因为我找不到任何例子。(也许折叠不是正确的术语？)
浏览 0提问于2011-11-29得票数 3
回答已采纳
2回答
我知道有不同的方式(或组合)来实现JMS请求-应答机制，即请求队列和响应队列，请求主题和响应主题，或者两者的混合。
我想知道的是，(1)推荐的(或最常见的)方式是什么，以及(2)不同的排列是如何衡量的？
接下来，说一个更正确的说法是。“将消息发送到队列”或b。“通过队列发送消息”？
干杯!
浏览 3提问于2012-01-31得票数 4
回答已采纳
1回答
我使用的是rabbitMQ，我使用basic_get接收队列中的每条消息，而无需自动加标过程，这意味着消息将一直保持在队列中，直到我对消息进行攻击或nack。
有时，由于抛出一些异常，无法处理消息，从而阻止了它们的完全处理。
在这些情况下，我想再试一次，让我们立即说两次，如果结果仍然不能处理它们--我想在一小时内再试3次，如果所有的尝试都失败了，那么我想将消息插入并永久地从队列中删除。
问题是，rabbitMQ中是否有任何机制为我提供消息重试(也包括重试次数)，以及选择何时启动重试的能力-某种推迟机制？
浏览 3提问于2015-03-01得票数 0
回答已采纳
我正在使用Azure ServiceBus来处理多个客户端发送的项目。
我正在测试接收这些消息的部分，并同时运行2个侦听器。但是，如果我提交2个项目到队列中。只有一个监听器可以工作，第二个监听器不能接收另一个项目。
但是，我尝试在不同的机器上运行两个侦听器，它们都处理推入队列的两个项目。
是在同一台机器上运行多个监听器的问题吗?如果是，我做错了什么?我该如何修复？
耽误您时间，实在对不起。
丹
浏览 1提问于2017-05-06得票数 0
1回答
我的NodeJS rabbitmq worker经常抛出异常，如下所示：
events.js:72
throw er; // Unhandled 'error' event
Error: PRECONDITION_FAILED - unknown delivery tag 3
at Queue._onMethod (/Users/Rana/WebstormProjects/TS/ts-worker/node_modules/amqp/amqp.js:1720:15)
at Queue.Channel._onChannel
浏览 0提问于2015-04-12得票数 0
我有一个web应用程序，在该应用程序中，我使用spring-amqp侦听rabbitmq中的一条消息，并通过以下设置启用重试：
spring:
rabbitmq:
listener:
simple:
retry:
enabled: true
multiplier: 2
initial-interval: 15m
max-interval: 1h
org.springframework.retry.backoff.Sleeper最常用的实现是基于Thread.sleep的，哪个
浏览 1提问于2018-07-08得票数 2
回答已采纳
1回答
在我的项目中，我有一个听众：
@Service
@RequiredArgsConstructor
@Slf4j
public class ConsumerService {
@RabbitListener(queues = "${queue.treatment.request}")
public void handleQueueTreatmentRequestMessageReception(AppointmentPayloadDTO myAppointment) {
log.info(" ======================
浏览 6提问于2020-05-10得票数 0
1回答
我有一个微服务，它公开rest端点来显示计费数据。在同一个微服务中，我有消息侦听器(最大50和最小10 )，用于侦听队列和处理账单。在微服务中使用消息消费者是否是一种好的做法，因为它将长期运行。
浏览 3提问于2018-11-28得票数 0
我们正在开发一个Spring-AMQP - RabbitMQ应用程序。我们希望使用shovel将消息从本地队列复制到远程队列，但我们希望在spring应用程序中完成消息传递服务的几乎所有配置。
在这一点上，我们可以从应用程序本身创建队列，交换等，但我们不能找到一种方法来配置同一个应用程序的铲子。有没有办法做到这一点？
如果我们使用联邦插件而不是铲子，有没有更好的方法来配置它而不是使用Spring-AMQP呢？
浏览 1提问于2012-12-05得票数 0
回答已采纳
1回答
有没有办法将JMS9.x集群配置为在单个WebLogic队列地址上接收来自远程客户端的消息，并将消息发送到每个集群节点？任何链接都会很棒。
浏览 1提问于2009-12-08得票数 0
回答已采纳
2回答
我打算做一个服务，在那里人们可以向系统提交任务(特别是代码转换任务)，他们应该很快得到服务，但同时它不应该让其他任何人挨饿，即它必须是公平的。如果一个人提交了2000个任务，系统不应该总是只满足他的需求，而应该在其他人的请求中进行循环调度或类似的事情……
有没有可用的解决方案？我研究了rabbitMQ和其他消息系统，但它们并不能完全迎合我的问题。如何实现公平的任务队列？
浏览 4提问于2010-10-25得票数 3
回答已采纳
1回答
我是Spring-rabbitMQ.I的新手。如果我错了，我有下面的question..Please是正确的：
我有三个应用实例，即。
Instance1 Instance2 Instance3
注意:这些实例不需要修复这些实例监听相同的exchange..As实例的数量是不固定的，我的要求是相同的消息应该被所有三个/(数量可以)是variable..how来实现这一点使用spring-amqp
如果声明队列名称并绑定到交换消息将在instances..but上拆分，我希望rabbitmq消息(来自交换的消息)到所有的queues..How，我们可以实现这个..I听到一些东西，比如匿名队列……
浏览 6提问于2016-03-29得票数 1
1回答
Java侦听器和传递参数
、、、
我有一个处理rs232设备事件的侦听器，我想将String参数传递给另外两个临时侦听器。我该怎么做呢？
RS232监听器代码：
static class SerialPortReader implements SerialPortEventListener {
public void serialEvent(SerialPortEvent event) {
if(event.isRXCHAR()){
if(event.getEventValue() > 0){
try {
浏览 0提问于2013-05-28得票数 0
我需要基于配置值创建一个可变数量的消息，其目的是拥有多个使用者，每个使用者对应于一个物理资源，该物理资源一次只能由一个事物使用来处理消息。
浏览 1提问于2010-10-15得票数 3
我是AWS SQS和Laravel的新手。通过遵循Laravel 5.2文档，我已经将$customer_id(整数)派送到了AWS SQS。
控制器代码：
$this->dispatch(new ExampleJob($customer_id));
作业代码：[ ExampleJob \jobs
public function handle(Mailer $mailer)
{
$mailer->send('Customer.Queue', ['Customer' => $this->customer], function (
浏览 1提问于2016-06-08得票数 0
我有一个队列，其中的消息将由其他应用程序放置，我的应用程序所做的只是轮询队列，并获取所有消息，然后转换为其他对象并持久存储在数据库中。因此，对于这个1，我有两种方法。)使用spring调度器，每5秒轮询一次所有消息，然后使用Java8的并行流在数据库中持久化，因为所有流都是独立的。2.)有人建议使用spring batch，但不幸的是，我没有得到关于使用spring batch的充分解释。
你能提出一些建议和解释来帮助我吗，比如哪一个更有用，哪个更好？
浏览 0提问于2017-10-14得票数 2
1回答
我在IBM中使用spring-amqp，在初始化使用ssl的兔模板时，它使用sunx509，但是IBM与算法不兼容，所以我得到： java.security.NoSuchAlgorithmException: SunX509 KeyManagerFactory not available 我不确定如何覆盖sunx509的使用，因为使用的算法是在spring-amqp源代码中定义的 我初始化rabbitmq配置如下所示，有什么建议吗？ 谢谢 @Configuration
public class RabbitMQConfiguration {
@Bean
public Rab
浏览 31提问于2019-04-11得票数 1
回答已采纳
我有一个项目与Spring-AMQP。它工作正常。我使用CachingConnectionFactory和SimpleMessageListenerContainer，并且我有一个CompositeConnectionListener来检测连接何时关闭。
但是现在我需要检测代理何时关闭(我可以用CompositeConnectionListener检测到它)，然后在不同的服务器上建立到不同代理的新连接，并使用新连接重新启动SimpleMessageListenerContainer。
我已经试了一段时间了，但我还没找到路。
有人能帮上忙吗？
谢谢!
浏览 2提问于2015-04-24得票数 0
2回答
实现持久的发布/订阅？
、、、
假设我有一个发布者和多个监听器。当发布者发送消息时，它必须被所有侦听器接收。如果其中一个听众关闭了，他应该会在重新启动后立即收到消息。
我如何实现这一点？
我在考虑使用队列:每个监听器创建自己的队列，并向发布者发送一条带有队列位置的订阅消息。发布者将该位置保存到一个文件或DB中，并开始向该队列发送消息。
因此，这将是时间线：
Publisher已启动。目前还没有监听器。
发布者发送消息% 1。
发布者发送消息2。
发布者发送消息3。
侦听器1启动并订阅publisher。
发布者发送消息4。
监听程序1接收消息4。
Listener 2启动并订阅publisher。
发布者发送消息5。
监听程
浏览 2提问于2011-05-27得票数 0
回答已采纳
我正在创建一个日志记录服务。体系结构如下: Java，它接收来自网站的请求(请求可以是get或post)，请求被发送到Node.js消息队列，如果是post，则Java监听SQS消息，我将数据写入到Cassandra数据库中。如果是get，我从Cassandra读取必要的数据，执行一些计算并将其返回给Node.js应用程序接口，后者最终将其返回给客户端。
阅读部分对我来说有点模糊。可以在SQS中将数据作为消息返回吗？(我认为一条消息只能包含256KB的数据，读取的数据可以超过256KB)我将运行Node API的多个实例，那么有没有办法知道我需要将数据返回到哪个实例？我是否应该创建一个Java
浏览 7提问于2015-06-26得票数 0
我有一个名为CompanyUpdated的事件，该事件在每次更新公司配置文件时引发。我需要两个监听器来收听这个事件。一个用于搜索服务更新Azure search的数据，另一个用于更新Catalog Management中的公司详细信息。
我可以创建两个监听器来监听此事件吗？
另外，是否可以在两个不同的微服务中使用相同的名称命名两个侦听器？
浏览 34提问于2020-02-17得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
