他的首页
他的馆藏
他的动态
馆友反馈
关于他
| 共 15 篇文章 |
|
消息队列模式（点对点&发布订阅）消息生产者生产消息发送到queue中，然后消息消费者从queue中取出并且消费消息。消息被消费以后，queue中不再有存储，所以消息消费者不可能消费到已经被消费的消息。生产者发送一条消息到queue，一个queue可以有很多消费者，但是一个消息只能被一个消费者接受，当没有消费者可用时，这个消息会被保存直到有 ... 阅30 转0 评0 公众公开 20-10-23 01:38 |
Kafka、ActiveMQ、RabbitMQ、RocketMQ 都有什么区别，以及适合哪些场景？第三，既然你用了 MQ，可能是某一种 MQ，那么你当时做没做过调研？如果使用 MQ，A 系统产生一条数据，发送到 MQ 里面去，哪个系统需要数据自己去 MQ 里面消费。本来你就是 A 系统调用 BCD 三个系统的接口就好了，人 ABCD 四个系统好好的，没啥问题，你偏加个 MQ 进来，万... 阅100 转0 评0 公众公开 19-12-04 13:26 |
分布式发布订阅消息系统—Apache Kafka1.什么是Kafka.（物理上不同Topic的消息分开存储，逻辑上一个Topic的消息虽然保存于一个或多个broker上但用户只需指定消息的Topic即可生产或消费数据而不必关心数据存于何处）PartitionPartition是物理上的概念，每个Topic包含一个或多个Partition.Producer负责发布消息到Kafka brokerConsumer消息消费者... 阅273 转0 评0 公众公开 19-05-13 07:59 |
MQ消息队列的应用场景。P2P的特点每个消息只有一个消费者（Consumer）(即一旦被消费，消息就不再在消息队列中)发送者和接收者之间在时间上没有依赖性，也就是说当发送者发送了消息之后，不管接收者有没有正在运行，它不会影响到消息被发送到队列接收者在成功接收消息之后需向队列应答成功 如果希望发送的每个消息都会被成功处理的话，那么需要P... 阅67 转0 评0 公众公开 19-05-13 07:51 |
Kafka、RabbitMQ、RocketMQ等消息中间件的介绍和对比前言。现在常用的MQ组件有ActiveMQ、RabbitMQ、RocketMQ、ZeroMQ、MetaMQ，当然近年来火热的kafka,从某些场景来说，也是MQ，当然kafka的功能更加强大，虽然不同的MQ都有自己的特点和优势，但是，不管是哪种MQ，都有MQ本身自带的一些特点，下面，介绍MQ的特点。其他对比Rabbitmq比kafka可靠，... 阅43 转0 评0 公众公开 19-04-25 15:33 |
上图就展示了Kafka是如何写入数据的，每一个Partition其实都是一个文件，收到消息后Kafka会把数据插入到文件末尾（虚框部分）。使用这种方式可以获取很大的I/O提升，省去了用户空间到内核空间复制的开销（调用文件的read会把数据先放到内核空间的内存中，然后再复制到用户空间的内存中。）也有一个很明显的缺陷——不可靠，写到mmap中的数据并... 阅34 转0 评0 公众公开 19-04-25 15:32 |
mirror queue：镜像队列，作为master queue的备份。在master queue所在节点挂掉之后，系统把mirror queue提升为master queue，负责处理客户端队列操作请求。集群中有两个队列A和B，每个队列都分为master queue和mirror queue（备份）。RabbitMQ集群中的任何一个节点都拥有集群上所有队列的元信息，所以连接到集群中的任何一个节点都可以，主要... 阅48 转0 评0 公众公开 19-04-25 15:32 |
kafka中文教程。本网翻译整理Apache kafka，提供整理Apache kafka的完整学习文档。举个例子，生产者消费者，生产者生产鸡蛋，消费者消费鸡蛋，生产者生产一个鸡蛋，消费者就消费一个鸡蛋，假设消费者消费鸡蛋的时候噎住了（系统宕机了），生产者还在生产鸡蛋，那新生产的鸡蛋就丢失了。第一章：开始第二章：API第三章：kafka的配置第四章：kafk... 阅83 转0 评0 公众公开 19-04-25 15:31 |
Windows系统下载使用kafka安装ZooKeeper.7、 进入Kafka安装目录D:\Kafka\kafka_2.12-0.11.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入：1、 创建主题，进入Kafka安装目录D:\Kafka\kafka_2.12-0.11.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入：2、 创建生产者，进入Kafka安装目录D:\Kafka\kafka_2... 阅1078 转2 评0 公众公开 19-04-25 15:13 |
消息队列满了以后该怎么处理？（3）然后写一个临时的分发数据的consumer程序，这个程序部署上去消费积压的数据，消费之后不做耗时的处理，直接均匀轮询写入临时建立好的10倍数量的queue；假设你用的是rabbitmq，rabbitmq是可以设置过期时间的，就是TTL，如果消息在queue中积压超过一定的时间就会被rabbitmq给清理掉，这个数据就没了。如果走的... 阅30 转0 评0 公众公开 19-01-31 11:51 |
