公司网站设计规范,php做公司网站,学做网站论坛VIP怎么样,高端网站建设专业公司1.生产端
不要使用oneway方式发送#xff0c;因为这种方式不会有返回结果设置重试次数发送失败添加回调对消息进行处理
2.broker端
开启同步刷盘flushDiskType SYNC_FLUSH #xff0c;这样在刷盘失败的时候会返回SendStatus.FLUSH_DISK_TIMEOUT开启主从同步复制#xff…1.生产端
不要使用oneway方式发送因为这种方式不会有返回结果设置重试次数发送失败添加回调对消息进行处理
2.broker端
开启同步刷盘flushDiskType SYNC_FLUSH 这样在刷盘失败的时候会返回SendStatus.FLUSH_DISK_TIMEOUT开启主从同步复制brokerRoleSYNC_MASTER这样在从写失败的情况下会返回SendStatus.FLUSH_SLAVE_TIMEOUT
## master 节点配置
flushDiskType SYNC_FLUSH
brokerRoleSYNC_MASTER## slave 节点配置
brokerRoleslave
flushDiskType SYNC_FLUSH
3.消费端
RocketMQ在消息消费时采用了ACK机制即消息客户端从Broker拉取消息到消费端只有消息消费端成功将消息消费才会发送ACK到Brokerbroker才会认为该消息消费成功保证消息不丢失。而且消息在消费时是采取最小位点提交机制 会导致重复消费所以同样要消费端幂等
