生成器对象可以使用send()方法发送数据，发送的数据会成为生成器函数中通过yield表达式获得的值。这样，生成器就可以作为协程使用，协程简单的说就是可以相互协作的子程序。...

对系统增加MQ对峰值写流量做削峰填谷，对次要业务逻辑做异步，对不同系统模块做解耦。 因为业务逻辑从同步代码中移除了，所以也要有相应队列处理程序处理消息、执行业务逻辑。...

同时拥有两个或者多个线程，如果程序在单核处理器上运行多个线程将交替地换入或者换出内存,这些线程是同时“存在"的，每个线程都处于执行过程中的某个状态，如果运行在多核处理器上,此时，程序中的每个线程都将分配到一个处...

消息队列就是用于当两个系统之间或者两个模块之间实现消息传递时，基于队列机制实现数据缓存的中间件

上篇博文，我们介绍了什么是RocketMQ，以及如何安装单机版的RocketMQ。在安装的过程了，我们主要安装了两个服务，NameServer和Broker。在发送和接收消息时，又接触了两个概念，生产者和消费者。...

分布式实时消息队列Kafka（五）知识点01：课程回顾 一个消费者组中有多个消费者，消费多个Topic多个分区，分区分配给消费者的分配规则有哪些？ 分配场景 第一次消费：将分区分配给消费者负载均衡实现：在消费过程中，如果有部分消...

cord.key(); //获取Value String value = record.value(); System.out.println(topic+"t"+partition+"t"+offset+"t"+key+"t"+value); } ```

分布式实时消息队列Kafka（一）知识点01：课程回顾 Hbase是什么？ 分布式基于内存按列存储NoSQL数据库，用于实时、随机读写大量的数据 Hbase的设计思想是什么？ 冷热数据分离热数据：大概可能被使用的数据，新产生的数据 写入内...

秒杀读多写少。无需每次实时校验库存。库存预热，放到Redis，信号量控制进来秒杀的请求。

Linux进程间通信的方式： 管道（Pipe）、信号（Signal）、消息队列（Message）、共享内存（Share Memory）、套接字（Socket、中断 Binder： Binder 通信机制是在OpenBinder的基础上实现的，采用CS通信方式。 OpenBinder是一种进程间通信机制，...