一、进程间的通信（Queue) 1、进程间的通信 IPC(Inter Process Communication) 2、队列 2.1 概念介绍(multiprocess.Queue) 创建共享的进程队列，Queue是多进程安全的队列，可以使用Queue实现多进程之间的数据传递。 创建共享的进程队列。 ...
分类：
系统相关 时间：
2019-09-23 10:14:58
阅读次数：
87
一、ipc机制 进程通讯 管道:pipe 基于共享的内存空间 队列:pipe+锁 queue 下面拿代码来实现Queue如何使用: 案例一: 案例二: 案例三:（从这往下都是了解） 案例四: 案例五: 案例六: 二、生产者消费者模型： ? 在并发编程中使用生产者和消费者模式能够解决绝大多数并发问题。 ...
分类：
系统相关 时间：
2019-09-16 21:41:47
阅读次数：
137
Topic：可以理解为一个队列，生产者和消费者面向的都是一个 topic。 Partition：主要为了做负载，实现扩展性，一个非常大的 topic 可以分布到多个 broker（即服务器）上，一个 topic 可以分为多个 partition，每个 partition 是一个有序的队列。 一、to ...
分类：
系统相关 时间：
2019-09-13 17:16:17
阅读次数：
90
生产者和消费者之间为什么隔着一个队列？ 首先，生产者与消费者由于速度的不一致，所以需要一个空间用于缓冲。这可以将生产者与消费者解耦，生产者产出数据的时候，不需要把数据交到消费者手上才行，只要把数据丢入缓冲区就好。这样就可以各做各的。 为什么缓冲区是一个队列？ 通常情况下，这个缓冲区的数据结构是一个有 ...
分类：
其他好文 时间：
2019-09-09 22:59:16
阅读次数：
146
一、消息积压的原因 消息积压的直接原因，一定是系统中某个部分出现了性能问题，来不及处理上游发送的消息，才会导致消息积压。 二、优化性能来避免消息积压 在使用消息队列的系统中，对于性能的优化，主要体现在生产者和消费者两部分的业务逻辑中。对于消息队列本身的性能，作为使用者不需要太关注。主要原因是对于绝大 ...
分类：
其他好文 时间：
2019-08-30 13:33:40
阅读次数：
104
生产者和消费者模型 1. 什么是生产者和消费者模型 生产者消费者模型具体来讲，就是在一个系统中，存在生产者和消费者两种角色，他们通过内存缓冲区进行通信，生产者生产消费者需要的资料，消费者把资料做成产品。 再具体一点： 1. 生产者生产数据到缓冲区中，消费者从缓冲区中取数据。 2. 如果缓冲区已经满了 ...
分类：
其他好文 时间：
2019-08-29 18:21:42
阅读次数：
93
订阅发布模式 [TOC] 1、交换器（Exchange） 在 背后，其实是 把每条任务消息只发给一个消费者。本篇中我们将要研究如何把一条消息推送给多个消费者，这种模式被称为 （发布/订阅） ![订阅发布模式][1] 的消息发送模型核心思想是生产者不直接把消息发送到消息队列中。事实上，生产者不知道自己 ...
分类：
其他好文 时间：
2019-08-21 21:43:57
阅读次数：
91
第17课-信号量同步编程 17.1 核心概念--进程同步 一组并发进程进行互相合作、互相等待，使得各进程按一定的顺序执行的过程称为进程间的同步。 17.2 生产者消费者问题 1. 问题描述 这里面有两个角色：生产者和消费者。假设生产者生产的产品需要两步才能完成并且使用。但是，当生产者刚刚完成了对产品 ...
分类：
其他好文 时间：
2019-08-14 14:38:01
阅读次数：
76
生产者-消费者模式是一个经典的多线程设计模式，它为多线程间的协作提供了良好的解决方案。这个模式中，通常有两类线程，即若干个生产者线程和若干个消费者线程。生产者线程负责提交用户请求，消费者线程则负责具体处理生产者提交的任务。生产者和消费者之间通过共享内存缓存区进行通信，这样就避免了生产者和消费者直接通 ...
分类：
编程语言 时间：
2019-08-10 18:58:43
阅读次数：
101
1、什么是MQ？ MQ全称为Message Queue, 顾名思义，即消息队列，它是一种应用程序对应用程序的通信方法。MQ是消费-生产者模型的一个典型的代表，生产者不断的往消息队列中不断写入消息，消费者则可以读取或者订阅队列中的消息，生产者和消费者不需要知道对方是谁，一个负责发消息，一个负责收消息， ...
分类：
其他好文 时间：
2019-08-03 11:20:22
阅读次数：
87
