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)——生产者介绍的主要内容,如果未能解决你的问题,请参考以下文章