分布式消息队列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版本相同-->
* * * *