MQ STORE
2017-01-21 23:33:40 0 举报
MQ STORE是一款高性能、高可用的分布式消息中间件,它能够处理大量的消息存储和传输。它具有强大的消息持久化能力,可以确保在系统崩溃或网络故障时消息不会丢失。同时,它还支持多种消息模式,包括发布/订阅模式、点对点模式和请求响应模式,能够满足各种复杂的业务需求。此外,MQ STORE还提供了丰富的管理工具,包括监控、报警和统计等,可以帮助用户更好地管理和运维消息系统。总的来说,MQ STORE是一款强大而灵活的消息中间件,是构建大型分布式系统的理想选择。
作者其他创作
大纲/内容
ReputMesageService
behind()doReput()shutdown()
indexService
int hashSlotNumint indexNumlist indexFileList
load()queryOffset()buildIndex()buildKey()
MapedFile
storePathmapedFileSizeList mapedFiles
DefaultMessageStore
FlushConsumeQueueServiceCleanCommitLogServiceCommitLogIndexServiceHAServiceReputMessageService
CommitLog
DefaultMessageStoreMapFileQueue
flush()load()start()
indexFile
MapedFileFileChannelMapedByteBuffer
load()flush()putKey()
MapedFileQueue
consumeQueue
topicqueueIdmapedFileQueue
load()recover()getLastOffset()commit()
0 条评论
下一页