本系列文章主要是学习记录Linux下进程间通信的方式。 常用的进程间通信方式:管道、FIFO、消息队列、信号量以及共享存储。 参考文档:《UNIX环境高级编程(第三版)》 参考视频:Linux进程通信 推荐看看,老师讲得很不错 Linux核心版本:2.6.32-431.el6.x86_64 注:本文 ...
分类:
系统相关 时间:
2020-06-04 00:56:50
阅读次数:
81
1.1.2 消息队列的两种模式 1)点对点模式(一对一,消费者主动拉取数据,消息收到后消息清除) 消息生产者生产消息发送到Queue中,然后消息消费者从Queue中取出并且消费消息。 消息被消费以后,queue中不再有存储,所以消息消费者不可能消费到已经被消费的消息。Queue支持存在多个消费者,但 ...
分类:
其他好文 时间:
2020-06-03 00:41:04
阅读次数:
180
redis除了5种数据类型之外,还提供了其他功能,如:慢查询,pipeline,事务,发布订阅和消息队列,Bitmap,HyperLogLog,GEO ###1.Bitmap(位图) BitMap,即位图,其实也就是 byte 数组,用二进制表示,只有 0 和 1 两个数字。 就是通过一个bit位来 ...
分类:
其他好文 时间:
2020-05-31 22:02:10
阅读次数:
63
使用列表实现任务队列 优先级队列 按照规则订阅 Redis也可以作为任务队列。任务队列顾名思义,就是“传递任务的队列”。任务队列与消息队列什么区别呢?任务队列是逻辑模型,而消息队列是通信模型,两者是不同层次的抽象,用消息队列可以实现任务队列。 与任务队列进行交互的实体有两类,一类是生产者(produ ...
分类:
其他好文 时间:
2020-05-31 21:21:46
阅读次数:
63
简介 随着近些年微服务在国内的盛行,消息驱动被提到的越来越多。主要原因是系统被拆分成多个模块后,一个业务往往需要在多个服务间相互调用,不管是采用HTTP还是RPC都是同步的,不可避免快等慢的情况发生,系统性能上很容易遇到瓶颈。在这样的背景下,将业务中实时性要求不是特别高且非主干的部分放到消息队列中是 ...
分类:
编程语言 时间:
2020-05-31 00:41:19
阅读次数:
78
1:18 1.什么是高并发系统的消息队列? 队列:对头+队列容器+对尾 消息队列(MessageQueue MQ):有一个队列容器,生产者(入队列),消费者(出队列) 2.使用消息队列的场景(使用消息队列的原因): 2.1 分布式场景 2.1.1 异步处理 多线程可以节省时间,但是会降低cpu吞吐量 ...
分类:
其他好文 时间:
2020-05-30 19:56:13
阅读次数:
59
第1章 Kafka概述 1.1 消息队列 1)点对点模式(一对一,消费者主动拉取数据,消息收到后消息清除) 点对点模型通常是一个基于拉取或者轮询的消息传送模型,这种模型从队列中请求信息,而不是将消息推送到客户端。这个模型的特点是发送到队列的消息被一个且只有一个接收者接收处理,即使有多个消息监听者也是 ...
分类:
其他好文 时间:
2020-05-30 19:39:36
阅读次数:
63
复习要点 本文主要围绕如下几点进行阐述: 为什么使用消息队列? 使用消息队列有什么缺点? 消息队列如何选型? 如何保证消息队列是高可用的? 如何保证消息不被重复消费? 如何保证消费的可靠性传输? 如何保证消息的顺序性? 下面围绕以上七点进行阐述。需要说明一下,本文不是《消息队列从入门到精通》这种教程 ...
分类:
其他好文 时间:
2020-05-30 15:55:25
阅读次数:
85
前篇 消息队列客户端开发向导(基于 Spring 的 amqp 实现) 一、应答模式与重试机制 NONE 自动应答 即 autoAck 等于 true,rabbitmq 会自动把发送出去的消息置为确认,然后从内存/磁盘中删除,而不管消费者是否真正消费了消息。 MANUAL 需要手动 ACK/NACK ...
分类:
编程语言 时间:
2020-05-29 23:11:36
阅读次数:
120
部署单机版的kafka消息队列,参考了网上很多的教程,发现网上的教程不是很详细,特别是kafak的配置文件相关的,于是自己搭建完成之后,重新整理并标注了配置文件。 ...
分类:
其他好文 时间:
2020-05-29 10:41:16
阅读次数:
58