activeMq的简介与安装 ##一,什么是消息中间件 消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流,并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型,它可以在分布式环境下扩展进程间的通信。对于消息中间件,常见的角色大致也就有Producer(生产者)、Consum ...
分类:
其他好文 时间:
2019-09-24 12:30:43
阅读次数:
110
python之路——进程 阅读目录 理论知识 操作系统背景知识 什么是进程 进程调度 进程的并发与并行 同步\异步\阻塞\非阻塞 进程的创建与结束 在python程序中的进程操作 multiprocess模块 进程的创建和multiprocess.Process 进程同步控制 —— 锁 进程间通信 ...
分类:
编程语言 时间:
2019-09-23 15:21:52
阅读次数:
84
一、进程间的通信(Queue) 1、进程间的通信 IPC(Inter Process Communication) 2、队列 2.1 概念介绍(multiprocess.Queue) 创建共享的进程队列,Queue是多进程安全的队列,可以使用Queue实现多进程之间的数据传递。 创建共享的进程队列。 ...
分类:
系统相关 时间:
2019-09-23 10:14:58
阅读次数:
87
一、 并发储备知识 1、1 什么是进程? 1、2 必备的理论基础 二、 操作系统发展史 2、1 为什么要有操作系统 现代的计算机系统主要是由一个或者多个处理器,主存,硬盘,键盘,鼠标,显示器,打印机,网络接口及其他输入输出设备组成。 一般而言,现代计算机系统是一个复杂的系统。 其一:如果每位应用程序 ...
分类:
其他好文 时间:
2019-09-23 09:20:40
阅读次数:
76
目录结构 引入 maven依赖 引入 application.yml配置 创建QueueConfig 创建生产者: 创建消费者的application.yml 创建消费者: 结果显示: ...
分类:
编程语言 时间:
2019-09-22 21:36:36
阅读次数:
141
上一篇文章介绍了condition的使用方法 https://www.cnblogs.com/liumy/p/11563772.html 这一篇文章介绍如何用condition来实现一个简单的阻塞队列 消费者 生产者模式。 消费者 生产者模式就是 生产者生产某些对象,消费者来消费这些对象。其中用对象 ...
分类:
编程语言 时间:
2019-09-21 21:16:26
阅读次数:
82
并发编程小结 进程 进程不是什么具体的东西,而是只一个过程,即程序运行起来的过程,是一个资源集合 开启进程的过程 右键运行,操作系统给CPU发送请求,为程序开辟一个内存空间,然后把代码都放进去执行代码,执行过程也是cpu参与 PS:(如果是python的话,则会将解释器的代码也放进去,先执行解释器代 ...
分类:
其他好文 时间:
2019-09-21 21:03:05
阅读次数:
83
基于队列实现生产者与消费者模型 上述代码中解决办法缺点:如果有N个消费者,是否还要生产者put进去N个None呢? 用JoinableQueue 解决消费者结束问题 是不是晕了,那就对了,代码执行顺序: 1、consumer 中把对列中所有的任务消耗完 q.task_done() 2、produce ...
分类:
编程语言 时间:
2019-09-21 18:48:26
阅读次数:
86
参考地址:https://blog.csdn.net/weixin_33985507/article/details/92460419 一、安装kafkacat kafkacat 是一个C语言编写的 kafka 生产者、消费者程序。 安装kafkacat 之前,需要安装一下依赖 二、重点是安装avr ...
分类:
数据库 时间:
2019-09-19 16:02:13
阅读次数:
511
一、三种消费 :1.普通消费 2. 顺序消费 3.事务消费1.1 顺序消费:在网购的时候,我们需要下单,那么下单需要假如有三个顺序,第一、创建订单 ,第二:订单付款,第三:订单完成。也就是这个三个环节要有顺序,这个订单才有意义。RocketMQ可以保证顺序消费,他的实现是生产者(一个生产者可以对多个 ...
分类:
其他好文 时间:
2019-09-19 14:36:04
阅读次数:
95