RocketMq搭建并集成 springboot

作者: 阿琦 | 2021-06-04 | 阅读

   

前言叨逼叨

  • 如何安装.
  • 集成 springboot 并把 同步、异步、批量、延时、事务消息都跑一遍.
  • 配合机械工业出版社《RocketMQ实战与原理解析》perfect ! 我一下午就看完了.

安装

rocketmq官方文档: https://github.com/apache/rocketmq/tree/master/docs/cn

下载地址: https://rocketmq.apache.org/docs/quick-start/

上面截图这个界面后,下面有下载下来后怎么安装,怎么启动。


  > unzip rocketmq-all-4.8.0-source-release.zip
  > cd rocketmq-all-4.8.0/
  > mvn -Prelease-all -DskipTests clean install -U
  > cd distribution/target/rocketmq-4.8.0/rocketmq-4.8.0

图形化界面

图形化管理控制台: git clone -b release-rocketmq-console-1.0.0 https://github.com/apache/rocketmq-externals.git

对应文档: https://github.com/apache/rocketmq-externals/blob/master/rocketmq-console/doc/1_0_0/UserGuide_CN.md

完成后界面:

web1

web2

web3

web4

web5

web6

内存不足启动失败修改JVM 参数

  bin pwd
/Users/ian/rocketmq-all-4.8.0-source-release/distribution/bin

 bin vim runbroker.sh

bin vim runserver.sh

集群配置

多Master多Slave模式(异步) 多Master多Slave模式(同步) 多Master模式
2m-2s-async 2m-2s-sync 2m-noslave

集成

GitHub: https://github.com/apache/rocketmq-spring

这个工程下面的 rocketmq-spring-boot-samples 示例

<!--add dependency in pom.xml-->
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>${RELEASE.VERSION}</version>
</dependency>

支持:

  • 同步发送消息
  • 异步发送消息
  • 以单向模式发送消息
  • 发送有序消息
  • 发送批量消息
  • 发送交易消息
  • 发送具有延迟级别的预定消息
  • 以并发模式(广播/集群)消费消息
  • 消费有序消息
  • 使用标记或 sql92 表达式过滤消息
  • 支持消息追踪
  • 支持认证和授权
  • 支持请求-回复消息交换模式
  • 使用推/拉模式消费消息

consumer1

consumer2

consumer3

producer1

producer2

producer3

发现 mac 有自带压缩图片

Mac 自带拉动滑条压缩图片

参考

MAC上安装rocketmq磁盘空间不足的问题: https://blog.csdn.net/dmsdr/article/details/54710368

RocketMQ踩坑记: https://www.cnblogs.com/2YSP/p/11616376.html

rocketmq消息中台: https://github.com/sohutv/mqcloud

阿里云springboot集成: https://github.com/ThierrySquirrel/rocketmq-spring-boot-starter


版权声明:本文由 阿琦 在 2021年06月04日发表。本文采用CC BY-NC-SA 4.0许可协议,非商业转载请注明出处,不得用于商业目的。
文章题目及链接:《RocketMq搭建并集成 springboot》




  相关文章:


留言区:

TOP