我是HornetQ的新手，请多多包涵。首先，让我告诉您我的要求： 我需要一种消息队列中间件，可以在不同进程之间传递大约1K大小的消息，具有低延迟和持久性（即它应该能够在系统崩溃后恢复）。我将有多个进程向同一队列写入，同样地，多个进程也将从同一队列读取。 因此，我选择了HornetQ，因为它...

我已经模拟了生产者消费者问题，并且有以下代码。我的问题是：如果消费者一直处于while(true)状态，他如何停止。 在下面的代码中，我添加了 if (queue.peek()==null) Thre...

尝试在一台机器上运行Kafka生产者，在另一台机器上运行消费者。 设置以下属性： advertised.host.name advertised.port 但是在控制台消费者上遇到以下错误： bin / kafka-console-consumer.sh --zookeeper ip：21...

我有两个BlockingCollection<T>对象，collection1和collection2。我想从这些集合中消费项目，并优先考虑collection1中的项目。也就是说，如果这两个集合都有项目，我想首先从collection1中取出项目。如果它们都没有项目，我想等待项目...

我需要单生产者、单消费者的FIFO查询，因为： 我需要按接收顺序处理信息。 我需要异步进行处理，因为调用者不应该在我处理消息时等待。 下一条消息的处理应该仅在前一条消息的处理完成后开始。有时，“接收”消息的频率高于“处理”消息的频率。但是平均而言，我应该能够处理所有消息，只是有时候我必须“...

我有一个简单的生产者/消费者代码，如下所示，但输出显示只有C2在消费。我的代码中是否有任何错误？ class Program { static void Main(string[] args) { Object lockObj = new object(); ...

我最初在这里提出了这个问题，但我意识到我的问题并不是关于while-true循环的。我想知道的是，在Java中进行高性能异步消息传递的正确方式是什么？ 我正在尝试做什么... 我有大约10,000个消费者，每个消费者都从其私有队列中消费消息。我有一个线程，按顺序生成消息并将它们放入正确的消...

我对生产者-消费者模式的理解是，可以使用一个队列来实现生产者和消费者之间的共享。生产者将工作提交到共享队列中，消费者获取并处理它。也可以通过生产者直接向消费者提交来实现（生产者线程直接向消费者的执行器服务提交）。 现在，我一直在研究Executors类，它提供了一些常见的线程池实现。据规范介...

根据"Effective Akka"，平衡调度程序即将被弃用。我要开始编写一些（单机）生产者/消费者代码，处理工作负载形状差异巨大的问题。我应该使用什么？ 我希望生产者能够阻塞（akka块或线程块，我不关心）（类似于此问题），因为它将从数据库游标中传入204,000个条目:D 编写自己模式...

我正在学习C#中的异步/等待模式。目前我试图解决这样一个问题： 有一个生产者(硬件设备)，每秒生成1000个数据包。我需要将这些数据记录到文件中。 该设备只有一个ReadAsync()方法，用于报告单个数据包。 我需要缓冲数据包并按照它们生成的顺序将它们写入文件，每秒钟只写一次。 如果在下...