Producer连接Broker

• 连接：生产者 跟 Topic 涉及的所有Broker 保持长连接。
• 心跳：默认情况下，生产者每隔30秒向所有broker发送心跳。broker每隔10秒钟(此时间无法更改)，扫描所有还存活的连接，若某个连接2分钟内(当前时间与最后更新时间差值超过2分钟，此时间无法更改)没有发送心跳数据，则关闭连接

Producer连接上Broker之后，消息会通过轮询的方式发送到Broker上，并且存储在Broker中的CommitLog中，这里面存储的是原始消息，还有一个ConsumeQueue用于存储投递到某一个queue的消息的位置信息。当然，消息队列会持久化到磁盘中的，不影响内存，当然也会定期清理消息。

那消费完的消息去了哪里呢?什么时候清理物理消息文件呢?还有这样设计的好处呢?

这些我们都留在下下一篇中，也就是Broker篇，让你透彻了解Broker这个大脑是如何助力RocketMQ支持这么高的吞吐量的

总之啊，这个问题值得大家深入研究一下，如果再面试的时候，你不仅能说出RocketMQ的用处，你还能说出它的存储原理和寻址原理，那面试官就爱上你了。此时你再拿出王炸，就是解决各种实际问题的能力，比如如何处理重复消息啊、如何保证消息的顺序性啊、在分布式系统中如何保证分布式事务啊

面试官当场给你发offer，say：How much money do you expect to work for us ?

（编辑：桂林站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!