我需要使用“某物”来协调我的系统与运行在不同操作系统上的多个消费者/生产者之间的通信。我一直在研究使用MySql来实现这一点，但似乎非常困难。 我的要求很简单：我希望能够随时添加或删除消费者/生产者，因此它们不应相互依赖。自然地，数据库可以很好地将它们分离开来。 我一直在研究用于MySql...

我有以下代码，其中包括一个生产者线程和多个消费者线程。您是否知道多个消费者是否是线程安全的？例如，线程1正在使用某个项目时，是否有可能并行运行线程2并更改该项目的值？ namespace BlockingColl { public partial class Form1 : Form { ...

我有一个升级我们生产者/消费者基础设施的需求。 当前设置如下： 一组具有不同优先级（低、中、高）的队列。 当我们的客户生成任务时（如处理图像）： 生产者将消息添加到相关队列中。 其中一个工作进程对其进行处理。 这种方法的问题在于，如果一个客户生成大量任务，则可能会占用队列中所有...

我正在使用来自Kafka网站的ConsumerGroupExample代码测试Kafka高级消费者。我想要检索Kafka服务器配置中名为“test”的主题上存在的所有现有消息。查看其他博客时，应将auto.offset.reset设置为“smallest”以获取所有消息: private ...

使用 disruptor 时，可能会有一个或多个消费者滞后，由于这些缓慢的消费者，整个应用程序都会受到影响。 要注意每个生产者（发布者）和消费者（事件处理器）都在单个线程上运行，那么如何解决缓慢消费者问题呢？ 我们能否在单个消费者上使用多个线程？如果不能，有什么更好的替代方案？

我有一个RabbitMQ队列，里面有数千条消息。我需要一个后台服务来完成以下操作： 批量检索100个消息 将这100个消息存储到数据库中 一次性确认所有100个消息 继续处理下一个批次的100个消息 我使用RabbitMQ客户端来监听消息，但我不知道如何“分批”获取它们。 请问是否有...

我希望每次接收到消息时，消费者都能执行一些操作。那么消费者必须全天候“监听”队列吗？还是只有在接收到适当的消息时才运行消费者？

我有一个与此很相似的问题：http://camel.465427.n5.nabble.com/FTP-ConsumerTemplate-Threads-remaining-alive-td5548338.html。 如何终止不同端点上的卡住的Camel线程？我尝试删除端点并在设置doneUo...

我想学习如何使用Java Lambda函数，使得Consumer可以处理由Supplier提供的所有对象，并且摆脱显式的while循环和null检查。 我有一个数据库字符串键的Supplier，我想使用Consumer来处理每个键。 Supplier<String> keyGe...