RocketMq学习笔记
2020-04-16 08:41:28 0 举报AI智能生成
RcoketMq
作者其他创作
大纲/内容
RocketMq
角色
发信者（producer）
收信者（consumer）
broker（负责暂存，信件传输的邮局）
nameServer（负责协调各地方邮局的管理机构）
配置参数
namerSrvAddr
brokerId
brokerClusterName
fileReservedTime
deleteWhen
brokerName
brokerRole
SYNC_MASTER
ASYNC_MASTER
SLAVE
flushDiskType（刷盘策略）
ASYNC_FLUSH
SYNC_FLUSH
storePathRootDir
brokerIP1（对外IP）
常用命令
updateTopic
deleteTopic
updateSubGroup
deleteSubGroup
updateBrokerConfig
updateTiptopPerm
topicRoute
topicList
topicStatus
printMsg
queryMsgById
clusterList
消费者
获取消息方式
被动接收（PushConsumer）
主动拉取（PullConsumer）
状态
FOUND
NO_NEW_MSG
NO_MATCHED_MSG
OFFSET_ILLEGAL
消息模式
Clustering
Broadcasting
主要参数
groupName
NameSvrAddr
tags
生产者
GroupName
InstanceName
设置重试策略
组装消息
消息发送
方式
异步
同步
发送延迟消息
返回状态
FLUSH_DISK_TIMEOUT
FLUSH_SLAVE_TIMEOUT
SLAVE_NOT_AVAILABLE
SEND_OK
自定义发送规则
重写MessageQueueSelector
事务
LocalTransactionExecuter
TransactionMQProducer
LocalTransactionState
如何存储队列位置消息
offset
Broker代存（RemoteBrokerOffsetStore）
DefaultMQPushConsumer的clustering模式
本地文件类型（LocalFileOffsetStore）
DefaultMQPushConsumer的broadcasting模式
PullConsumer需要写处理OffsetStore的逻辑
消费者消费顺序
CONSUME_FROM_LAST_OFFSET
CONSUME_FROM_FIRST_OFFSET
CONSUME_FROM_TIMESTAMP
日志
默认存储位置：${user.home}/Logs/rocketmqLogs
修改配置文件
NameServer
集群状态的存储结构
RouteInfoManager类
topicQueueTable
brokerAddrTable
clusterAddrTable
brokerLiveTable
filterServerTable
0 条评论
回复 删除
下一页
