与消息发送紧密相关的几行代码:1. DefaultMQProducer producer = new DefaultMQProducer;2. producer.start();3. Message msg = new Message(...)4. SendResult sendResult = producer.send;5. producer.shutdown();那这几行代码执行时,背后都做了什么?efaultMQProducerImpl.start()后,获取的MQClientInstance实例对象会调用sendHeartbeatToAllBroker()方法,不断向broker发送心跳包,yin'b可以使用下面一幅图大致描述DefaultMQProducerImpl.start()过程:上图中的三个部分中涉及的内容:一个客户端只能产生一个MQClientInstance实例对象,产生方式使用了工厂模式与单例模式。一个jvm中一个producerGroup只能有一个实例,MQClientInstance操作producerTable大概有如下几个方法:
暂无评论