RocketMQ之生产者（Producer）

1.生产者（Producer）

生产者是 Apache RocketMQ 系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务消息按照要求封装成 Apache RocketMQ 的消息（Message）并发送至服务端

2.生产者的传输行为

3.生产者和主题的关系

生产者和主题的关系为多对多关系，即同一个生产者可以向多个主题发送消息，同一个主题也可以接收多个生产者的消息

4.生产者的属性

（1）生产者客户端ID
生产者客户端的标识，用于区分不同的生产者。集群内全局唯一。客户端ID由Apache RocketMQ 的SDK自动生成，主要用于日志查看、问题定位等运维场景，不支持修改

（2）通信参数

（3）预绑定主题列表

主题列表：Apache RocketMQ 的生产者需要将消息发送到的目标主题列表

（4）发送重试策略
Apache RocketMQ 客户端连接服务端发起消息发送请求时，可能会因为网络故障、服务异常等原因导致调用失败。为保证消息的可靠性， Apache RocketMQ 在客户端SDK中内置请求重试逻辑，尝试通过重试发送达到最终调用成功的效果。同步发送和异步发送模式均支持消息发送重试

1）重试机制触发条件
备注：对于事务消息，只会进行透明重试（transparent retries），网络超时或异常等场景不会进行重试

• 客户端消息发送请求调用失败或请求超时
• 网络异常造成连接失败或请求超时
• Apache RocketMQ服务端节点处于重启或下线等状态造成连接失败
• Apache RocketMQ服务端运行慢造成请求超时
• Apache RocketMQ服务端返回失败错误码：系统逻辑错误（因运行逻辑不正确造成的错误）和系统流控错误（因容量超限造成的流控错误）

2）重试流程
生产者在初始化时设置消息发送最大重试次数，当出现上述触发条件的场景时，生产者客户端会按照设置的重试次数一直重试发送消息，直到消息发送成功或达到最大重试次数重试结束，并在最后一次重试失败后返回调用错误响应

• 同步发送：调用线程会一直阻塞，直到某次重试成功或最终重试失败，抛出错误码和异常
• 异步发送：调用线程不会阻塞，但调用结果会通过异常事件或者成功事件返回

3）重试间隔

• 除服务端返回系统流控错误场景，其他触发条件触发重试后，均会立即进行重试，无等待间隔
• 若由于服务端返回流控错误触发重试，系统会按照指数退避策略进行延迟重试。指数退避算法通过以下参数控制重试行为

4）功能约束

• 链路耗时阻塞评估：在重试流程中生产者仅能控制最大重试次数。若由于系统异常触发了SDK内置的重试逻辑，则服务端需要等待最终重试结果，可能会导致消息发送请求链路被阻塞。对于某些实时调用类场景，您需要合理评估每次调用请求的超时时间以及最大重试次数，避免影响全链路的耗时
• 最终异常兜底： Apache RocketMQ 客户端内置的发送请求重试机制并不能保证消息发送一定成功。当最终重试仍然失败时，业务方调用需要捕获异常，并做好冗余保护处理，避免消息发送结果不一致
• 消息重复问题：因远程调用的不确定性，当Apache RocketMQ客户端因请求超时触发消息发送重试流程，此时客户端无法感知服务端的处理结果，客户端进行的消息发送重试可能会产生消息重复问题，业务逻辑需要自行处理消息重复问题

5.生产者使用建议

（1）不建议单一进程创建大量生产者

Apache RocketMQ 的生产者和主题是多对多的关系，支持同一个生产者向多个主题发送消息。对于生产者的创建和初始化，建议遵循够用即可、最大化复用原则，如果有需要发送消息到多个主题的场景，无需为每个主题都创建一个生产者。

（2）不建议频繁创建和销毁生产者

Apache RocketMQ 的生产者是可以重复利用的底层资源，类似数据库的连接池。因此不需要在每次发送消息时动态创建生产者，且在发送结束后销毁生产者。这样频繁的创建销毁会在服务端产生大量短连接请求，严重影响系统性能。