Spring Boot优雅使用RocketMQ的方法实例
版权申诉
5星 · 超过95%的资源 22 浏览量
2020-08-25
04:58:04
上传
评论
收藏 104KB PDF 举报 
Spring Boot优雅使用优雅使用RocketMQ的方法实例的方法实例
主要给大家介绍了关于Spring Boot优雅使用RocketMQ的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用Spring
Boot具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
前言前言
MQ，是一种跨进程的通信机制，用于上下游传递消息。在传统的互联网架构中通常使用MQ来对上下游来做解耦合。
举例：当A系统对B系统进行消息通讯，如A系统发布一条系统公告，B系统可以订阅该频道进行系统公告同步，整个过程中A系统并不关系B系统会不
会同步，由订阅该频道的系统自行处理。
什么是什么是RocketMQ？？#
官方说明:
随着使用越来越多的队列和虚拟主题，ActiveMQ IO模块遇到了瓶颈。我们尽力通过节流，断路器或降级来解决此问题，但效果不佳。因此，我们那时
开始关注流行的消息传递解决方案Kafka。不幸的是，Kafka不能满足我们的要求，特别是在低延迟和高可靠性方面。
看到这里可以很清楚的知道RcoketMQ 是一款低延迟、高可靠、可伸缩、易于使用的消息中间件。
具有以下特性：
支持发布/订阅（Pub/Sub）和点对点（P2P）消息模型
能够保证严格的消息顺序，在一个队列中可靠的先进先出（FIFO）和严格的顺序传递
提供丰富的消息拉取模式，支持拉（pull）和推（push）两种消息模式
单一队列百万消息的堆积能力，亿级消息堆积能力
支持多种消息协议，如 JMS、MQTT 等
分布式高可用的部署架构,满足至少一次消息传递语义
RocketMQ环境安装环境安装#
下载地址：https://rocketmq.apache.org/dowloading/releases/
从官方下载二进制或者源码来进行使用。源码编译需要Maven3.2x，JDK8
在根目录进行打包:
mvn -Prelease-all -DskipTests clean packager -U
distribution/target/apache-rocketmq文件夹中会存在一个文件夹版,zip,tar三个可运行的完整程序。
使用rocketmq-4.6.0.zip:
启动名称服务 mqnamesrv.cmd
启动数据中心 mqbroker.cmd -n localhost:9876
SpringBoot环境中使用环境中使用RocketMQ#
SpringBoot 入门：https://www.jb51.net/article/177449.htm
SpringBoot 常用start:https://www.jb51.net/article/177451.htm
当前环境版本为:
SpringBoot 2.0.6.RELEASE
SpringCloud Finchley.RELEASE
SpringCldod Alibaba 0.2.1.RELEASE
RocketMQ 4.3.0
在项目工程中导入:
<!-- MQ Begin -->
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-client</artifactId>
<version>${rocketmq.version}</version>
</dependency>
<!-- MQ End -->
由于我们这边已经有工程了所以就不在进行创建这种过程了。主要是看看如何使用RocketMQ。
创建RocketMQProperties配置属性类,类中内容如下:
@ConfigurationProperties(prefix = "rocketmq")
public class RocketMQProperties {
private boolean isEnable = false;
private String namesrvAddr = "localhost:9876";
private String groupName = "default";
private int producerMaxMessageSize = 1024;
private int producerSendMsgTimeout = 2000;
private int producerRetryTimesWhenSendFailed = 2;
private int consumerConsumeThreadMin = 5;
private int consumerConsumeThreadMax = 30;
private int consumerConsumeMessageBatchMaxSize = 1;
//省略get set
}
资源评论
qq_206404732023-04-19资源内容详细，总结地很全面，与描述的内容一致，对我启发很大，学习了。
