18、RocketMQ实战:RocketMQ应用

分布式消息队列RocketMQ

四、 RocketMQ应用

4.1)普通消息

4、 1.1)消息发送分类;

Producer对于消息的发送方式也有多种选择,不同的方式会产生不同的系统效果

4、 1.1.1)同步发送消息;

同步发送消息是指,Producer发出⼀条消息后,会在收到MQ返回的ACK之后才发下⼀条消息;该方式 的消息可靠性高,但消息发送效率太低。

*

4、 1.1.2)异步发送消息;

异步发送消息是指,Producer发出消息后无需等待MQ返回ACK,直接发送下⼀条消息。该方式的消息可靠性可以得到保障,消息发送效率也可以。

*

4、 1.1.3)单向发送消息;

单向发送消息是指,Producer仅负责发送消息,不等待、不处理MQ的ACK。该发送方式时MQ也不返回ACK,该方式的消息发送效率高,但消息可靠性较差。

*

4、 1.2)代码实现案例;

4、 1.2.1)创建工程;

创建一个Maven的Java工程rocketMqTest,在其POM文件导入相关依赖:

 * *<properties>
 * * * *<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 * * * *<maven.compiler.source>8</maven.compiler.source>
 * * * *<maven.compiler.target>8</maven.compiler.target>
 * *</properties>
​
 * *<dependencies>
 * * * *<!--需要与RocketMQ版本相同-->
 * * * *