RocketMQ 客户端最佳实践
1. Producer最佳实践
发送消息注意事项
1). 一个应用尽可能用一个Topic，消息子类型用tags来标识，tags可以由应用自由设置。
2). 消息发送成功或者失败，要打印消息日志，务必要打印sendresult和key字段。
SEND_OK，消息发送成功。
3). 对于消息不可丢失应用，务必要有消息重发机制，例如如果消息发送失败，存储到数据库，能有定时程序尝试重发，或者人工触发重发。
2. 消息发送失败如何处理:
1).重试
2).如果调用send同步方法发送失败，则尝试将消息存储到db，由后台线程定时重试，保证消息一定到达Broker。
3.Consumer 最佳实践
1). 消费过程要做到幂等
RocketMQ目前无法避免消息重复，所以如果业务对消费重复非常敏感，务必要在业务层面去重，有以下几种去重方式：
a).将消息的唯一键，可以是msgId，也可以是消息内容中的唯一标识字段，例如订单Id等，消费之前判断是否在Db或Tair(全局KV存储)中存在，如果不存在则插入，并消费，否则跳过。
b). 用业务层面的状态机去重。
2). 提高消费并行度
a). 同一个ConsumerGroup下，通过增加Consumer实例数量来提高并行度，超过订阅队列数的Consumer实例无效。可以通过加机器，或者在已有机器启动多个进程的方式。
b). 提高单个Consumer的消费并行线程，通过修改以下参数: consumeThreadMin consumeThreadMax
3). 消息批量消费
4). 跳过非重要消息
5). 优化每条消息消费过程