RocketMQ 客户端最佳实践

  1. 云栖社区>
  2. 博客>
  3. 正文

RocketMQ 客户端最佳实践

尘央 2016-12-09 15:32:16 浏览9212
展开阅读全文

本文站在消费者和生产者的角度给出一些RocketMQ客户端使用的实践意见。

一、Producer最佳实践

发送消息注意事项

  1. 一个应用尽可能用一个Topic,消息子类型用tags来标识,tags可以由应用自由设置。只有发送消息设置了tags,消费方在订阅消息时,才可以利用tags在broker做消息过滤。

    message.setTags("TagA");
  2. 每个消息在业务层面的唯一标识码,要设置到keys字段,方便将来定位消息丢失问题。服务器会为每个消息创建索引(哈希索引),应用可以通过topic,key来查询这条消息内容,以及消息被谁消费。由于是哈希索引,请务必保证key尽可能唯一,这样可以避免潜在的哈希冲突。
  3. 消息发送成功或者失败,要打印消息日志,务必要打印sendresult和key字段。

    • SEND_OK,消息发送成功。
    • FLUSH_DISK_

网友评论

登录后评论
0/500
评论
尘央
+ 关注