“消息队列”是设计模式或软件工程组件，其定义用于两个或更多相互关联的过程或系统之间的通信的规则或API。消息队列强制执行异步处理和松散耦合。根据实施情况，它们还可以提供消息的传递和订单保证。消息处理保证明确排除在设计之外。
我正在尝试阅读有关Kafka主题的消息，但我无法阅读它。一段时间后该进程被杀死，无需读取任何消息。以下是我得到的再平衡错误：[2014-03-21 ...
我正在尝试创建一个能够发送数据然后接收它们的类。现在，它只适用于第一次发送/接收和另一次尝试.send（）它将引发错误...
我参与了一个由以下应用程序组成的项目：生产者应用程序：通过ASP.NET web api从客户端接收消息，并将消息排入消息队列。消费者应用：......
如果PUB首先启动并连接到XPUB / XSUB代理，则消息将被丢弃，直到SUB未连接为止
我已经实现了一个基于ZeroMQ的基础设施，使用c ++中的XPUB / XSUB-proxy将消息从多个PUB传递到多个SUB。多个PUB - > XSUB / XPUB代理 - >多个SUB（s）如果我......
我在laravel中使用数据库队列驱动程序在后台运行作业。我的一个作业在数据库中创建了一个给定的数字（数千到数十万）记录。我把代码包裹起来......
我正在尝试使用Celery来处理输入列表。我想只处理一次输入。问题是我的服务器都是超级计算机集群的一部分。我可以发送每个服务器一个...
我们正在构建一个Python应用程序来接收来自另一个应用程序的文件，处理收到的文件并将处理后的文件发送回该应用程序。对于文件传输，我们正在考虑SFTP和......的选项
Apache Flume - 由多个使用者从单个消息队列中提取数据
我目前正在开发Apache Flume代理，可以从单个消息队列（Solace）中提取数据。由于消息处理因大小而缓慢，并且会有很多消息需要摄取，我......
我想发送和接收带有两个线程到线程队列的消息。但我也无法创建队列。当我创造一个职业时，孩子就会工作。我可以在主要...之间发送和阅读消息
从最新的Kafka消费者版本开始，消费者不依赖于ZooKeeper。但是“https://kafka.apache.org/”说Kafka需要Zookeeper，所以启动zookeeper服务器。为什么会这样？ ...
我在我的项目中遇到了一些日志伏都。阅读以下内容后：QueueHandler QueueListener我在程序中设计了如下记录：在主进程中 - root logger ...
我有一个c程序，它应该通过msgq发送和接收ipc消息。我遇到的问题是，当我运行msgrcv（）时，它将我的全局int msqid设置为0.当然我需要它...
还有吗？对我来说，MB知道订阅者和发布者，并充当调解者，通知订阅者新消息（实际上是“推送”模型）。另一方面，MQ更像是“拉动”......
我正在构建一个运行另一个Python程序的监视程序计时器，如果它无法从任何线程中找到签入，则关闭整个程序。这样它最终能够......
我目前正在开发一个项目，我需要与IBM系统进行交互，该系统通过WebSphere MQ与外部世界进行通信。我需要在“请求 - 响应”中查询系统...