在第二篇文章中介绍了如何利用工作队列将耗时任务分发到多个消费者工作程序中。 考虑下另一种情况：如果需要在一个远程机器上执行一个函数然后等待它的返回结果应该怎样？这个过程称之为远程过程调用(RPC:Remote Procedure Call)…

在上一篇文章中，我们对之前的日志系统进行了改进，使用direct类型的exchange替代了只能广播消息的fanout类型，让日志系统能够有选择性的接收处理消息。 虽然使用direct类型的exchange提升了日志系统的扩展性，但还是有它…

在上一篇文章中，我们实现了一个可以广播消息给多个接收者的日志系统。在本篇中，将介绍如何对消息进行过滤，从而只处理我们感兴趣的消息。如只把一些严重的错误信息写入磁盘，但对所有类型的消息都打印到屏幕。 Binding 前面例子中我们使用了如下绑…

在前一篇介绍中实现了一个工作队列，它假设队列中的每一个任务都只会被分发到一个工作者进行处理。在本篇中，我们尝试将同一个消息发送给多个消费者进行处理，这就是广为人知的发布/订阅模式。 本篇通过搭建一个日志系统来阐述发布/订阅模式，它包含两部分…

在上一篇介绍中我们实现了从消息产生程序发送简单消息到命名队列的过程，本篇将实现一个将耗时任务分发到多个消费者程序的工作队列。 工作队列的主要思想是避免对资源密集型任务处理时的等待，而是先将任务压入队列，后期再进行计划处理。我们将任务封装成消…

本系列教程主要介绍rabbitMq,主要分6个部分来帮助大家入门掌握rabbitMq. rabbitMq学习笔记 (1) 基本概念 rabbitMq学习笔记 (2) 工作队列 rabbitMq学习笔记 (3) 发布/订阅模式 rabbitM…