1. 首页
  2. 编程语言
  3. Java
  4. java rocketmq--消息的产生(普通消息)

java rocketmq--消息的产生(普通消息)

上传者: 2022-06-24 12:58:05上传 PDF文件 173.25 KB 热度 12次

与消息发送紧密相关的几行代码: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大概有如下几个方法:

下载地址
用户评论