RocketMQ(12)——生产者介绍

Posted elim168

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了RocketMQ(12)——生产者介绍相关的知识,希望对你有一定的参考价值。

生产者介绍

RocketMQ的消费者有基于拉模式的DefaultMQPullConsumer和基于推模式的DefaultMQPushConsumer。而对于生产者而言基本上只有一个DefaultMQProducer,和一个支持事务的TransactionMQProducer。TransactionMQProducer继承自DefaultMQProducer,所以DefaultMQProducer有的功能TransactionMQProducer都有。之前已经介绍过发送事务消息的功能,所以本文将不再介绍它,主要介绍DefaultMQProducer。生产者发送消息时一条消息只会发送到一个队列。如下是使用DefaultMQProducer发送消息的基本流程,应用的是同步发送,这些大家都已经很熟了,它也不是本文想要介绍的重点,本文想要介绍的更多的是DefaultMQProducer可以配置的一些参数。

@Test
public void testProducer() throws Exception 
   
    DefaultMQProducer

以上是关于RocketMQ(12)——生产者介绍的主要内容,如果未能解决你的问题,请参考以下文章

RocketMQ(12)——生产者介绍

精选文章|RocketMQ源码分析

消息队列RocketMQ介绍

RocketMQ 消息队列单机部署及使用

RocketMQ Topic/Group/Tags介绍

RocketMQ实战