一、初识RabbitMQ 百度百科有这么一句话: 他的官网中用大大的黑粗字体写着: 由此可见,RabbitMQ是一个消息中间件,生产者生成消息,消费者消费消息,它遵循AMQP(高级消息队列协议),是最广泛部署的开源消息代理。 另外,RabbitMQ是用Erlang语言实现的,它有几个概念: ...
本文源码:GitHub·点这里||GitEE·点这里更新进度(共6节):01:项目技术选型简介,架构图解说明02:业务架构设计,系统分层管理03:数据库选型,业务数据设计规划04:中间件集成,公共服务管理一、中间件简介中间件是基础软件的一类,属于复用性极高的软件。处于操作系统软件与应用程序的之间。是一种独立的系统软件,也可以是公共的服务程序,分布式架构系统借助中间件,可以在不同的技术之间共享资源,
分类:
其他好文 时间:
2019-11-05 10:54:34
阅读次数:
74
队列queue: 作用:程序之间解耦;提高运行效率 集群的基础: 经典的生产者消费者模型 ...
分类:
编程语言 时间:
2019-11-04 22:06:52
阅读次数:
107
生产者消费者模式是多线程中最为常见的模式:生产者线程(一个或多个)生成面包放进篮子里(集合或数组),同时,消费者线程(一个或多个)从篮子里(集合或数组)取出面包消耗。虽然它们任务不同,但处理的资源是相同的,这体现的是一种线程间通信方式。
分类:
编程语言 时间:
2019-11-03 22:14:48
阅读次数:
85
package test; import java.awt.List; import java.awt.image.AreaAveragingScaleFilter; import java.lang.reflect.Array; import java.math.BigDecimal; impor ...
分类:
编程语言 时间:
2019-11-03 20:19:42
阅读次数:
69
RPC RPC既做消费者也做生产者 rpc_client.py rpc_server.py ...
分类:
其他好文 时间:
2019-11-02 18:12:35
阅读次数:
58
import timeimport randomfrom multiprocessing import Queue# 生产者def producer(q, num): for i in range(1, num + 1): food = 'Spam-%d' % i # time.sleep(rand ...
分类:
编程语言 时间:
2019-11-01 14:37:21
阅读次数:
107
kafka介绍: 作用: 系统之间解耦和 峰值压力缓冲 异步通信 特点:生产者消费者模式,先进先出(FIFO)保证顺序,自己不丢数据,默认每隔7天清理数据,高吞吐量,没有主从关系,依靠Zk协调 结构: topic:消息队列/分类 kafka里面的消息是有topic来组织的,简单的我们可以想象为一个队 ...
分类:
其他好文 时间:
2019-11-01 09:56:38
阅读次数:
84
RabbitMQ 整体上是一个生产者与消费者模型,主要负责接收、存储和转发消息。可以把消息传递的过程想象成:当你讲一个包裹送到邮局,邮局会暂存并最终将邮件通过邮递员送到收件人的手上,RabbitMQ 就好比由邮局、邮箱和邮递员组成的一个系统。从计算机术语层面来说,RabbitMQ 模型更像是一种交换 ...
分类:
其他好文 时间:
2019-10-31 11:56:42
阅读次数:
103
一 .什么是 Disruptor 从功能上来看,Disruptor 是实现了“队列”的功能,而且是一个有界队列。那么它的应用场景自然就是“生产者-消费者”模型的应用场合了。 可以拿 JDK 的 BlockingQueue 做一个简单对比,以便更好地认识 Disruptor 是什么。 我们知道 Blo ...
分类:
其他好文 时间:
2019-10-28 01:04:20
阅读次数:
80