1.消息发送 1.异步发送 消息生产者使用持久（persistent）传递模式发送消息的时候，Producer.send() 方法会被阻塞，直到 broker 发送一个确认消息给生产者，这个确认消息暗示生产者 broker已经成功地将它发送的消息路由到目标目的并把消息保存到二级存储中。这个过程通常称 ...
分类：
其他好文 时间：
2018-09-08 16:52:10
阅读次数：
167
1 RabbitMQ知识点 1.1 整体架构图 消息生产者将消息投递到exchange中，exchange会以某种路由机制将生产者投递的消息路由到queue中，消息消费者再从queue中获取消息进行消费。 1.2 核心概念 1.2.1 server 又称Broker，接收客户端的连接，实现AMQP实 ...
分类：
编程语言 时间：
2018-08-31 00:33:33
阅读次数：
313
基本概念 channel：消息通道 ，在客户端的每个连接里，可建立多个channel，每个channel代表一个 会话任务。 exchage：消息路由规则，四种模式（topic、direct、fanout、header） direct：默认，根据routingKey完全匹配，好处是先匹配再发送 to ...
分类：
其他好文 时间：
2018-07-09 15:25:25
阅读次数：
169
1.Celery模块调用 既然celery是一个分布式的任务调度模块，那么celery是如何和分布式挂钩呢，celery可以支持多台不通的计算机执行不同的任务或者相同的任务。 如果要说celery的分布式应用的话，就要提到celery的消息路由机制，AMQP协议。具体的可以查看AMQP的文档。简单地 ...
分类：
编程语言 时间：
2018-06-07 14:27:10
阅读次数：
258
队列： 从概念上来讲，AMQP消息路由必须有三部分：交换器、队列和绑定。生产者把消息发布到交换器上；消息最终到达队列，并被消费者接收；绑定决定了消息如何从路由器路由到特定的队列。 消费者通过以下两种方式从特定的队列中接收消息： 1）通过AMQP的basic.consume命令订阅。这样做会将信道置为 ...
分类：
其他好文 时间：
2018-02-12 18:38:05
阅读次数：
219
Kafka的概念： 1、 AMQP协议 1、 AMQP协议 1、 AMQP协议 Advanced Message Queuing Protocol （高级消息队列协议） The Advanced Message Queuing Protocol (AMQP)：是一个标准开放的应用层的消息中间件（Me ...
分类：
其他好文 时间：
2018-02-05 18:45:25
阅读次数：
150
一、前言 RabbitMQ还支持根据关键字发送，即：队列绑定关键字，发送者将数据根据关键字发送到消息exchange。direct类型的Exchange路由规则也很简单，它会把消息路由到那些binding key与routing key完全匹配的Queue中。 二、Exchange direct d ...
分类：
其他好文 时间：
2018-01-05 18:29:19
阅读次数：
149
celery是一个分布式的任务调度模块，那么celery是如何和分布式挂钩呢？celery可以支持多台不同的计算机执行不同的任务或者相同的任务。如果要说celery的分布式应用的话，就要提到celery的消息路由机制，提到AMQP协议。具体可以查看AMQP文档详细了解。简单理解：可以有多个"消息队列"（message Queue），不同的消息可以指定发送给不同的Message
分类：
编程语言 时间：
2017-12-20 22:46:53
阅读次数：
212
计算机科学中，消息队列和邮箱是用于进程间或者线程与同一进行间通讯的软件工程组件。他们都是消息传传输控制队列。 消息队列是发布/订阅模型的变种，是较大的面向消息的中间件的一部分。多数消息系统支持发布/订阅和消息队列模型的API，如JMS（Java Message Service）。 消息队列提供异... ...
分类：
其他好文 时间：
2017-11-04 19:32:57
阅读次数：
192
rabbit会始终记录以下四种类型的内部元数据 队列元数据 队列名称和它们的属性（是否可持久化，是否自动删除等） 交换器元数据 交换器名称、烈性和属性（可持久化等） 绑定元数据 一张简单的表格展示了如何将消息路由到队列 vhost 元数据 为vhost内的队列、交换器和绑定提供命名空间和安全属性 一 ...
分类：
其他好文 时间：
2017-10-20 18:36:32
阅读次数：
158
