Micronaut和rabbit将消息从生产者发送到消费者，在消费者端，它接受相同的参数值

文章/答案/技术大牛

发布

2回答

java、rabbitmq、micronaut、micronaut-rabbitmq

将rabbitMQ与Micronaut最新版本配合使用。在消费者上，这两个参数从生产者那里接受相同的值，然而，我从生产者那里发送不同的值。消费者的输出，因为categoryId和id的值相同在生产者端我发送不同的值，如下所示

浏览 50提问于2021-06-12得票数 0

1回答

不频繁发布消息的RabbitMQ最佳实践

multithreading、rabbitmq、pika

我有几个消息生成线程，它们只是偶尔发布消息(例如，短时间的消息突发，然后休眠6个小时)。在发布后启动一个新的连接并将其关闭是不是更好？或者，通过心跳来保持连接更好？至于消费者线程。处理每条消息并不需要很长时间(在心跳间隔内)，但大多数时候接收方连接是空闲的，因为没有发布消息。我注意到，通常情况下，如果连接处于空闲状态太长时间，它将被断开。这是预期的行为吗？我认为只有当整个使用者线程被长时间运行<e

浏览 0提问于2018-11-26得票数 0

3回答

Symfony2，RabbitMQ:我迷路了

symfony、rabbitmq

下面是我想要做的：但我迷路了。$msg = array('userid' => $someid); $this->get('old_sound_rabbit_mq.task_example_producer')->publish(serialize相

浏览 1提问于2015-05-28得票数 3

3回答

rabbitmq是双向的吗？

rabbitmq

生产者发送消息rabbitmq，消费者从rabbitmq接收消息，然后消费者通过rabbitmq将消息发送回生产者。有可能吗？

浏览 0提问于2013-01-30得票数 9

1回答

如何使用Spring Cloud Contract处理虚拟主题

spring-cloud-contract

我正在尝试使用Active MQ Virtual topics作为消息系统来设置spring-cloud-contract。我有一个问题，虚拟主题使用不同的名称来发送和接收消息。但在合同中，我们只能在outputMessage的SendTo部分中定义一个输出通道。有没有人知道如何处理这种情况？ outputMessage { sentTo“验证”正文(‘}

浏览 13提问于2019-11-11得票数 0

回答已采纳

1回答

Junit 5功能测试微型消息驱动的应用程序

java、junit、junit5、micronaut、micronaut-test

我有一个兔子Micronaut消息驱动应用程序。应用程序只包含使用者端，生产者端在另一个REST应用程序上。 }什么是执行Micronaut消息<

浏览 3提问于2021-01-04得票数 0

回答已采纳

2回答

不需要的循环调度

c#、.net、rabbitmq

我有以下内容:一个生产者，它生成3种类型的消息，3个消费者，每种消息一个。生产者P生成A、B和C消息。消费者收到以下消息: ConsumerA只收到A消息，消费者B只收到B消息，ConsumerC只收到C消息。这样做效果很好。然后我添加了第四个消费者D，它应该同时接收B和C

浏览 0提问于2015-07-22得票数 1

1回答

单一生产者到多个消费者(同一消费者群体)

python、producer-consumer、kafka-python

在将消息从单个生产者发送到具有不同消费者id的2个不同消费者之前，我已经尝试过了。结果是，两个使用者都能够读取完整的消息(两个消费者都得到相同的消息)。但是，我想问一问，这两个消费者在设置相同的消费者组名称时，是否可以读取不同的</

浏览 2提问于2016-09-21得票数 0

回答已采纳

3回答

Broker (Kafka和RabbitMQ)

rabbitmq、apache-kafka

在讨论卡夫卡和RabbitMQ的区别时，“哑巴经纪人”和“智能经纪人”在与消费者的互动中不断出现。卡夫卡被描述为有一个愚蠢的经纪人，而RabbitMQ据说有一个聪明的经纪人/愚蠢的消费者模型。我熟悉卡夫卡的基础知识，并对RabbitMQ有更多的了解。然而，RabbitMQ的哪些功能使经纪人比卡夫卡更聪明呢？

浏览 5提问于2017-08-28得票数 11

1回答

卡夫卡客户可以同时扮演消费者和生产者的角色吗？

performance、apache-kafka、kafka-consumer-api

我创建了一个场景，在这个场景中，一个具有生产者角色的客户端在kafka集群中发布一个主题中的消息，而一个具有消费者角色的客户端在这个主题中订阅并从日志中轮询消息。我的问题是，在此之后，具有消费者角色的客户端是否也成为一个进程(例如数据库处理)，并希望将一些数据发回，那么它必须将生产者角色<

浏览 0提问于2016-06-17得票数 3

回答已采纳

3回答

Kafka SSL安全的调试过程

ssl、apache-kafka

我能够在我的Kafka代理和客户端中设置SSL，并且我还能够看到，当我们使用9093端口(即SSL端口)生成消息时，消息由消费者使用。我尝试通过9093端口发送消息，消息从生产者发送到消费者。我的意思是，我如何才能证明9092不是SSL，而9093是SSL和安全的？

浏览 0提问于2016-03-03得票数 9

1回答

RabbitMQ:从队列中检索特定消息

rabbitmq、amqp

我在理解RabbitMQ中的路由时遇到了问题。考虑我有几个生产者(让他们称为客户端)，它们向队列产生消息。例如，客户端A、B和C向队列X1发送消息。让消费者对所有消息进行响应，将响应发送回队列。例如，消费者从队列X1获取消息，执行某些操作，并向队列X1发送响应。client A如何确定发送到它的X1消

浏览 1提问于2012-10-31得票数 0

回答已采纳

1回答

发送者如何知道消息已经被MQ JMS API消费？

jms、mq

我正在处理一个独立的MQ JMS应用程序，我们的应用程序需要“意识到”客户端已经使用了放在队列中的消息生产者。因为客户端app不是我们负责的。所以我们不能让他们自己写"msg.acknowledge();“之类的东西(在我的情况下，msg.acknowledge()不是正确的方法)。我在堆栈溢出中搜索历史答案。查找以下内容与我想要的内容

浏览 2提问于2012-01-06得票数 3

回答已采纳

2回答

当生产者的数量超过分区数时，Kafka默认的分区行为

apache-kafka、kafka-partition

来自 消费者如何知道生产者写信给哪个分区，从而可以直接从该分区消费？如果生产者多于分区，而multipe生产者正在写入同一个分区，那么如何排序偏移量，以便使用者可以使用来自特定<

浏览 1提问于2021-07-28得票数 0

1回答

当将数据从kafka导入到elasticsearch时，如何获得导入进度和错误日志？

elasticsearch、apache-kafka、spark-streaming、apache-kafka-connect

当用户上传时，Web客户端将处理csv文件，web客户端从csv文件中读取每10,000行，并将csv总行数的数据消息发送给生产者。生产者将消息发送给kafka，然后消费者提取消息，并将数据导入elasticsearch。同时，使用者使用数据消息长度和csv总计数来更新任务进度，如果有，也会更新错误日志。最后，我们的web客户<

浏览 2提问于2017-10-26得票数 0

1回答

Web服务中的生产者和消费者概念

api、rest、web-services

我对web服务很陌生，只是碰到了生产者(服务器)和消费者(客户端)的概念。由于我可以从其他来源搜索，生产者被定义为生成数据的应用程序，而消费者是消费这些数据的应用程序。这是可以理解的，当您以在线订购服务为生产者，并将订购数据发送到后端运输服务，在这种情况下，它是消费者。但当用户在移动应用程序上查询帐户报表时，当后端数据库

浏览 0提问于2022-08-07得票数 0

2回答

卡夫卡中的消费者Id和组Id :是什么使两个消费者相同？

apache-kafka、kafka-consumer-api、publish-subscribe

这就是我怀疑的开始。假设下面的场景 A和B均接

浏览 2提问于2019-05-16得票数 7

回答已采纳

2回答

Amazon MQ (ActiveMQ)在大消息上性能不佳

jms、activemq、amazon-mq

问题在于，与IBM MQ相比，Amazon MQ在使用JMS producer将较大的消息放入队列时的性能较差。我们还看到，IBM MQ在将消息发送到队列和从队列获取消息方面具有相同

浏览 3提问于2020-03-26得票数 1

1回答

针对不同用户的每个消息的主题

spring、spring-cloud、spring-cloud-stream

我要寻找的拓扑是到目前为止，我还没有看到在Cloud中定义每个消息的主题的方法。我知道消费者将被绑定到特定的主题，但是在将消息发送到交换之前，生产者如何设置每个消息的主题？更新由于bindingRoutingKey是2222，并且我正在与routeTo 1111一起发送，所以我希望不会在消费者中接收消息</

浏览 0提问于2018-05-05得票数 2

回答已采纳

1回答

如何在artemis宕机时从生产者端检索消息？

activemq-artemis

说明:我有一个消费者和生产者，我想看到当我从消费者端向JMS( artemis )推送消息时，如果artemis宕机，那么我的消息不会被artemis接受。这意味着当我打开artemis时，消息不在artemis队列bcz中，它们会丢失。我想知道我们是否可以在消费者端的context.xml中设置任何配置(比如缓冲区)，这样我们

浏览 0提问于2017-09-02得票数 1

点击加载更多