一 、RabbitMQ的介绍 RabbitMQ是消息中间件的一种，消息中间件即分布式系统中完成消息的发送和接收的基础软件，消息中间件的工作过程可以用生产者消费者模型来表示.即,生产者不断的向消息队列发送信息，而消费者从消息队列中消费信息.具体过程如下： 从上图可看出，对于消息队列来说，生产者、消息队 ...
分类：
编程语言 时间：
2018-12-23 11:10:37
阅读次数：
201
基于版本：CDH5.4.2 上述版本较老，但是目前生产上是使用这个版本，所以以此为例。 1. 概要 说明： 客户端API发送的请求将会被RPCServer的Listener线程监听到。 Listener线程将分配Reader给到此Channel用户后续请求的相应。 Reader线程将请求包装成Cal ...
分类：
其他好文 时间：
2018-12-12 15:45:16
阅读次数：
278
一、队列在多线程的程序必须安全的在多个线程之间交互的时候是非常有用的。 1、 先入先出 执行结果： 2、先入后出 执行结果： 3、存储数据时可设置优先级的队列，优先级越大越先被获取 执行结果： 二、生产者消费者模型 1、先进先出 ...
分类：
编程语言 时间：
2018-12-01 20:27:06
阅读次数：
261
一.进程：1.定义：进程最小的资源单位，本质就是一个程序在一个数据集上的一次动态执行(运行)的过程2.组成：进程一般由程序，数据集，进程控制三部分组成:(1)程序：用来描述进程要完成哪些功能以及如何完成(2)数据集：是程序在执行过程中所需要使用的一切资源(3)进程控制块：用来记录进程外部特征，描述进 ...
分类：
编程语言 时间：
2018-11-29 14:58:38
阅读次数：
184
思路： 利用thread类中，run方法在子线程中调用，其他方法在主线程调用，所以将生产者写入主线程，将消费者写入run函数中在子线程中执行，完成生产者消费者模型 注意： 1. 要在 init 函数中实例化一个Queue队列作为生产者消费者中介 2. 要在 init 函数中把daemon值设为Tru ...
分类：
编程语言 时间：
2018-11-22 14:28:52
阅读次数：
235
一 生产者消费者模型介绍 为什么要使用生产者消费者模型 生产者指的是生产数据的任务，消费者指的是处理数据的任务，在并发编程中，如果生产者处理速度很快，而消费者处理速度很慢，那么生产者就必须等待消费者处理完，才能继续生产数据。同样的道理，如果消费者的处理能力大于生产者，那么消费者就必须等待生产者。为了 ...
分类：
其他好文 时间：
2018-11-18 11:27:34
阅读次数：
188
目录： 1. 基础概念 2. 创建进程和结束进程 3. 进程之间内存空间物理隔离 4. 进程的属性方法 5. 守护进程 6. 互斥锁 7. IPC通信机制 8. 生产者消费者模型 一. 基础概念 二. 创建进程和结束进程 第一种创建进程的方式 第二种创建进程的方式 三. 进程之间内存空间物理隔离 四 ...
分类：
系统相关 时间：
2018-11-10 15:03:32
阅读次数：
162
模型 设计模型 三层结构 等等表示的都是一种编程套路 生产者指的是能够产生数据结构的一类任务 消费者指的是处理数据的一类任务 消费者指的是处理数据的一类任务 需求: 文件夹里有十个文本文档 要求你找出文件夹中包含习大大关键字的文件 打开斌读取文件数据就是生产者 查找关键字的过程就是消费者 生产者消费 ...
分类：
其他好文 时间：
2018-11-09 21:05:35
阅读次数：
166
import time,random from multiprocessing import Process,Queue # 制作热狗 def make_hotdog(queue,name): for i in range(3): time.sleep(random.randint(1,2)) pr ...
分类：
其他好文 时间：
2018-11-09 20:55:10
阅读次数：
204
