RabbitMQ 整体上是一个生产者与消费者模型，主要负责接收、存储和转发消息。可以把消息传递的过程想象成：当你讲一个包裹送到邮局，邮局会暂存并最终将邮件通过邮递员送到收件人的手上，RabbitMQ 就好比由邮局、邮箱和邮递员组成的一个系统。从计算机术语层面来说，RabbitMQ 模型更像是一种交换 ...
分类：
其他好文 时间：
2019-10-31 11:56:42
阅读次数：
103
1、描述zookeeper集群中leader，follower，observer几种角色 Zookeeper： 分布式系统：是一个硬件或软件组件分布在网络中的不同的计算机之上，彼此间仅通过消息传递进行通信和协作的系统。 特征： 分布性、对等性、并发性、缺乏全局时钟、故障必然会发生 典型问题： 通信异 ...
分类：
其他好文 时间：
2019-10-29 13:53:12
阅读次数：
159
Apache kafka kafka 是一个分布式的基于发布订阅的消息队列，主要应用于大数据实时处理领域。 什么是消息系统 消息系统负责将数据从一个应用程序传输到另一个应用程序，分布式消息传递基于可靠消息队列的概念。有两种类型的消息模式可用，一种是点对点， 另一种是 发布-订阅（pub-sub）消息 ...
分类：
其他好文 时间：
2019-10-28 12:30:24
阅读次数：
84
一：消息中间件的描述1、简介消息中间件也可以称消息队列，是指用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息队列模型，可以在分布式环境下扩展进程的通信。当下主流的消息中间件有RabbitMQ、Kafka、ActiveMQ、RocketMQ等2、消息中间件主要作用?冗余(存储)?扩展性?可恢复性?顺序保证?缓冲?异步通信?削峰：消息队列中
分类：
其他好文 时间：
2019-10-20 09:21:01
阅读次数：
144
一、MQ 全称为 Message Queue, 消息队列（ MQ ） 是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连接来链接它们。 消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远 ...
分类：
其他好文 时间：
2019-10-15 21:26:27
阅读次数：
118
队列介绍 进程彼此之间互相隔离，要实现进程间通信（IPC），multiprocessing模块支持两种形式：队列和管道，这两种方式都是使用消息传递的 创建队列的类（底层就是以管道和锁定的方式实现） ： 参数介绍： 主要方法介绍： 队列的使用 ...
分类：
其他好文 时间：
2019-10-13 11:20:28
阅读次数：
70
样例1 输入： 3 2R1 S1S0 R0R1 S1R0 S0R1 R1 R1 R1 S1 S1 S1 S1S0 S0 S0 S0 R0 R0 R0 R0 输出： 0 1 0 样例二: 输入： 2 3R1 S1R2 S0 R0 S2S1 R1R1R2 S0 R0S1 R1 输出： 0 1 思路： 1 ...
分类：
其他好文 时间：
2019-10-12 23:10:44
阅读次数：
165
上一节的内容最后，我们提出了一个思考。如果消息确认响应在网络传输过程中丢失了，那么消息队列的服务端、客户端会认为消息没有被正确传递，从而尝试进行下一次发送。这时候就会产生一些重复消息，那么应该怎么处理这个问题呢？ 一. 重复消息一定存在吗？ 在MQTT协议中，给出了三种消息传递过程中能够提供的服务质 ...
分类：
其他好文 时间：
2019-10-12 18:53:39
阅读次数：
83
发布/订阅模式 Pub/Sub模式包含三个角色主题（Topic），发布者（Publisher），订阅者（Subscriber） 。多个发布者将消息发送到Topic,系统将这些消息传递给多个订阅者。 Pub/Sub的特点 每个消息可以有多个消费者 发布者和订阅者之间有时间上的依赖性。针对某个主题（To ...
分类：
其他好文 时间：
2019-10-12 10:49:57
阅读次数：
98
一、MQ 全称为 Message Queue, 消息队列（ MQ ） 是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连接来链接它们。 消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远 ...
分类：
其他好文 时间：
2019-10-10 20:27:56
阅读次数：
84
