一、架构简述 RocketMQ阿里开源的一个分布式消息传递和流媒体平台，具有低延迟，高性能和可靠性， 万亿级容量和灵活的可伸缩性。跟其它中间件相比，RocketMQ的特点是纯JAVA实现,在发生宕机和其它故障时消息丢失率更低。 它由四个部分组成：nameserver，broker，生产者和消费者。它 ...
分类：
其他好文 时间：
2020-06-21 15:31:30
阅读次数：
60
生产者的线程专门用来生产一些数据，存放到一个中间变量中。消费者再从这个中间的变量中取出数据进行消费。但是因为要使用中间变量，中间变量通常是一些全局变量，因此需要使用锁来保证数据完整性。 import random import threading gMoney = 1000 gTimes = 0 g ...
分类：
其他好文 时间：
2020-06-21 11:36:18
阅读次数：
44
案例: 哲学家问题,生产者和消费者问题 ###临界资源 临界资源指的是一 些虽作为共享资源却又无法同时被多个线程共同 访问的共享资源。当有进程在使用临界资源时，其他进程必须依据 操作系统的同步机制等待占用进程释放该共享资源才可重新竞争使 用共享资源。 ###进程间的同步 ◆空闲让进:资源无占用，允许 ...
分类：
系统相关 时间：
2020-06-13 00:49:55
阅读次数：
89
1. 在生产者和消费者问题中，mutex，empty，full信号量的作用是什么？如果将生产者和消费者问题中的两次wait操作和两次signal操作次序进行交换会产生什么问题？ 解答：在生产者和消费者问题中，mutex信号量是互斥信号量，确保生产者和消费者对缓冲区资源的互斥访问。empty和full ...
分类：
系统相关 时间：
2020-06-10 14:38:56
阅读次数：
97
前言 版本：RocketMQ4.4.0 RocketMQ架构 摘自《RocketMQ开发手册》 Name Server是一个几乎无状态节点，可集群部署，节点之间无任何信息同步。 Broker部署相对复杂，Broker分为Master和Slave，一个Master可以对应多个Slave，但是一个Sla ...
分类：
其他好文 时间：
2020-06-07 21:32:55
阅读次数：
59
1.python Queue https://www.cnblogs.com/itogo/p/5635629.html Queue是python标准库中的线程安全的队列（FIFO）实现,提供了一个适用于多线程编程的先进先出的数据结构，即队列，用来在生产者和消费者线程之间的信息传递. 基本先进先出队列 ...
分类：
编程语言 时间：
2020-06-07 10:55:53
阅读次数：
77
急速入门 - 消息生成与消费 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
前言 消息队列：可以将原本同步执行的程序 解耦成异步执行，加上分布式的生产者和消费者架构 可以在一定程度上支撑大并发。 NSQ是go语言开发的消息队列，对nsqd进行水平扩展是它的部署、配置相对简单。 NSQ介绍 NSQ是1个分布式(distributed)、可扩展（scalable）、配置简单（O ...
分类：
其他好文 时间：
2020-05-14 19:03:34
阅读次数：
62
