摘要:
概览 RocketMQ的存储读写是基于JDK NIO的内存映射机制的,消息存储时首先将消息追加到内存中。在根据不同的刷盘策略在不同的时间进行刷盘 。如果是同步刷盘,消息追加到内存后,将同步调用MappedByteBuffer的force()方法,同步等待刷盘结果,进行刷盘结果返回。如果是异步刷盘, 阅读全文
posted @ 2022-03-07 11:50
星空物语之韵
阅读(633)
评论(0)
推荐(0)
摘要:
队列(Queue)和主题(Topic)是JMS支持的两种消息传递模型: 1、点对点(point-to-point,简称PTP)Queue消息传递模型: 通过该消息传递模型,一个应用程序(即消息生产者)可以向另外一个应用程序(即消息消费者)发送消息。在此传递模型中, 消息目的地类型是队列(即Desti 阅读全文
posted @ 2022-03-07 11:36
星空物语之韵
阅读(1040)
评论(0)
推荐(0)

浙公网安备 33010602011771号