“消息队列”是设计模式或软件工程组件，其定义用于两个或更多相互关联的过程或系统之间的通信的规则或API。消息队列强制执行异步处理和松散耦合。根据实施情况，它们还可以提供消息的传递和订单保证。消息处理保证明确排除在设计之外。
我在下面的代码中，了解了Linux中消息队列的线程安全性。但不确定该程序为什么会卡住。虽然在应用正确的锁之后它不会卡住。但是如果消息队列......
Amazon SQS如何处理不向同一服务的不同实例发送相同的消息？
我有一个队列（在这种情况下是Amazon SQS）并且有N个运行相同服务的节点正在消耗来自SQS的消息。我怎样才能确保在任何时间点，不超过一个......
我有以下场景，我收到一个包含100,000多个条目的XML。对于每个项目，我必须同时处理消息，一旦批量/批量完成，我必须......
我有spring-3.2.0.RC1.jar的spring jar，并尝试从这里给出的教程实现Apache ActiveMQ helloWorld程序。 xml配置文件是：
我在生产系统中运行ActiveMQ。我们的一些队列的音量非常高，而且有些音量非常低。我有兴趣镜像其中一个低容量队列，这样我就可以构建非正式的...
我正在Celery中设置一个任务，让它从某个主题交换中“消费”。当我将消息发送到有问题的交换机时，我收到错误：“收到并删除了一条未知消息。...
我正在编写一个旨在受其他应用程序约束的Android服务。它使用Messenger作为IBinder。现在我已经解决了一个问题：如果我想发送一条只包含什么的消息而且......
此应用程序从数据库事件接收和转发消息到客户端应用程序。当客户端浏览器具有Web套接字会话时，会立即传递消息。但是，当没有......
MessageQueue.BeginReceive如何工作以及如何正确使用它？
我目前有一个后台主题。在这个线程中是一个无限循环。这个循环偶尔更新数据库中的一些值，然后在MessageQueue上侦听1秒（使用queue.Receive（...
Anyevent :: RabbitMQ Perl QoS prefetch_count无法正常工作
我一直在尝试使用RabbitMQ perl库Net :: RabbitFoot，它下面使用AnyEvent :: RabbitMQ。根据RabbitMQ教程，将prefetch_count设置为1应确保公平分派，如...
我被要求评估RabbitMQ而不是Kafka，但发现很难找到一个比Kafka做得更好的原因。有谁知道它在吞吐量，耐用性方面是否真的更好......
我正在使用Python 3.6编写一个小型并发程序。我有一个问题：我的程序有一个小的Thread类（模拟一个线程）;这个类有3个方法，执行为...
PHP + Stomp + ActiveMq，“AMQ_SCHEDULED_DELAY”不起作用
我正在使用基于php.And Stomp + activeMQ的laravel框架。在这里我需要发送一些东西到mq，但是消息应该在180秒后消耗，而不是立即消耗。选项1，我发送它...
跨c＃，c ++和可能更多语言的进程间pub / sub模型
我想制作一个包含多个通信流程的系统。主过程正在引发事件。将有不同的事件，每个事件包含结构化数据。几个奴隶进程是......
我正在使用带有Python的celery库来并行处理一些相当大的数据集。但我运行的每日cronjob，每隔两三天就会中断，会出现以下错误。危急/...
我正在创建一个应用程序，其中有几个进程通过提升消息队列进行通信。使用消息队列构造函数创建队列作为message_queue（open_or_create，...
我正在尝试使用以下步骤在同一代码中实现许多IPC方法：1 - Process1打开一个消息队列并读取从Process2发送的消息 - Process1关闭和取消链接...
RabbitMQ：如何防止QueueDeclare自动生成新的队列
使用RabbitMQ，我正在做类似的事情：channel.QueueDeclare（QueueName，true，false，false，null）;默认情况下，如果现有名称与名称不匹配，RabbitMQ会创建一个新队列...
请参阅下面的代码片段：amqmdnet（这可行，但我们更喜欢IBM.XMS，因为我们可以进行异步消费）XMS与CCDT文件XMS具有压缩属性我们尝试了所有...
我之前没有任何使用* MQ的经验，而且我希望通常能够构建有关JMS和消息队列的知识。这样，我想知道我是应该从ActiveMQ开始还是“忽略”它......