product_0">product线程分析
使用arthas如下
- MQClientFactoryScheduledThread
定时器任务，详情查看这篇文章Rocketmq 探索MQClientFactoryScheduledThread线程工作 - PullMessageService
该线程专为消息consumer服务，product没用 - RebalanceService
该线程专为消息consumer服务，product没用 - RequestHouseKeepingService1
每1秒检查一次，异步发送消息的响应超时后，构建超时异常，调用消息的回调方法。详细看
org.apache.rocketmq.client.producer.RequestFutureHolder#scanExpiredRequest
product_13">product启动流程
比较简单，不做详细分析了。
主要干了以下：
1、将producerGroup注册到org.apache.rocketmq.client.impl.factory.MQClientInstance#producerTable变量上
2、启动定时器任务现成MQClientFactoryScheduledThread
3、启动定时器任务RequestHouseKeepingService1处理响应超时的消息
