`package main import ( "fmt" "strconv" "time" ) //生产者结构体 type Productor struct var Chquit = make(chan interface, 2) var Bag = false func main() { fmt. ...
分类：
其他好文 时间：
2020-06-07 15:07:34
阅读次数：
65
1.MQ介绍 1.1 什么是MQ MQ是消息队列，也叫做消息中间件，通过生产者与消费者模型，生产者不断的向消息队列发送消息，消费者不断的从消息队列获取消息，因为发送消息和获取消息都是异步的，而且只关心消息的发送和接收，没有业务逻辑的侵入，可以轻松实现解耦。 1.2 MQ有哪些 MQ的实现有很多种，比 ...
分类：
其他好文 时间：
2020-06-07 11:09:15
阅读次数：
53
1.python Queue https://www.cnblogs.com/itogo/p/5635629.html Queue是python标准库中的线程安全的队列（FIFO）实现,提供了一个适用于多线程编程的先进先出的数据结构，即队列，用来在生产者和消费者线程之间的信息传递. 基本先进先出队列 ...
分类：
编程语言 时间：
2020-06-07 10:55:53
阅读次数：
77
fanout 扇出 也曾为广播 在广播模式下，消息发送流程是这样的： 可以有多个消费者 每个消费者有自己的queue(队列) 每个队列都要绑定到Exchange(交换机) 生产者发送的消息，只能够发送到交换机，交换机决堤要发送给那个队列，生产者无法决定 交换机把消息发送给绑定过的所有队列 队列的消费 ...
分类：
其他好文 时间：
2020-06-06 21:22:38
阅读次数：
161
急速入门 - 消息生成与消费 1. ConnectionFactory ： 获取连接工厂 2. Connection ： 一个连接 3. Channel：数据通信信道，可发送和接收消息 4. Queue：具体的消息存储队列 5. Producer & Consumer 生产者和消费者 RabbitM ...
分类：
其他好文 时间：
2020-06-06 13:17:57
阅读次数：
56
1.Dubbo结构图 生产者-消费者模型，生产者和消费者都需要在注册中心进行注册，生产者生产接口，通过api暴露给消费者使用 注册中心管理服务提供方的url 监控模块负责监控管理整个流程 生产者(Provider)整个发布，订阅流程： 启动容器，加载，运行服务提供者 服务提供者在启动时，在注册中心发 ...
分类：
其他好文 时间：
2020-06-05 13:13:06
阅读次数：
72
Kafka是一个高吞吐量的分布式的发布订阅消息系统，在全世界都很流行，在大数据项目里面使用尤其频繁。笔者看过多个大数据开源产品的源码，感觉Kafka的源码是其中质量比较上乘的一个，这得益于作者高超的编码水平和高超的架构设计能力。Kafka的核心源码分为两部分：客户端源码和服务端源码，客户端又分为生产者和消费者，而个人认为Kafka的源码里面生产者的源码技术含量最高，所以今天给大家剖析Kafka的生
分类：
其他好文 时间：
2020-06-04 01:31:44
阅读次数：
50
信号量, 生产者消费者问题, 吸烟者问题, 读者-写者问题, 哲学家就餐问题 ...
分类：
系统相关 时间：
2020-06-03 20:47:49
阅读次数：
112
1.锁 #线程中是不是会产生数据不安全# 共享内存a = 0def add_f(): global a for i in range(200000): a += 1?def sub_f(): global a for i in range(200000): a -= 1?from threading ...
分类：
其他好文 时间：
2020-06-03 18:49:10
阅读次数：
49
Kafka 是一个高吞吐量的分布式的发布订阅消息系统，在全世界都很流行，在大数据项目里面使用尤其频繁。笔者看过多个大数据开源产品的源码，感觉 Kafka 的源码是其中质量比较上乘的一个，这得益于作者高超的编码水平和高超的架构设计能力。 Kafka 的核心源码分为两部分：客户端源码和服务端源码，客户端 ...
分类：
其他好文 时间：
2020-06-03 17:29:19
阅读次数：
68
