springboot整合rocketmq多个示例

介绍

springboot-rocketmq-demo项目使用springboot+rocketmq整合 有消息生产者producer和消费消费consumer等示例

①生产者producer 1.异步消息发送controller 1.1普通异步消息/asyncMq/sendMqAsync1 1.2异步延迟消息/asyncMq/sendMqAsync2 2.单向消息/oneWayMq/sendOneWay1 只负责发送消息，不等待服务器回应且没有回调函数触发，即只发送请求不等待应答 3.顺序消息/orderMq/orderStr1 使用rocketmq-spring-boot-starter发送顺序消息就比较方便了，不像使用rocket-client那样，需要手动获取RocketMQ中当前topic的队列个数然后再通过hashKey值，mqs.size()取模，得到一个索引值，这里底层都帮我们做好了处理 4.同步消息

1、、、/syncMq/sync/send1
①发送普通同步消息-Object  
②发送普通同步消息-Object，并设置发送超时时间

2、、、/syncMq/sync/send2
发送普通同步消息-Message,topic带tags

3、、、/sync/send3
发送普通同步消息-msg
这里存在两种消息体，一种是Object的，另一种是Message<?>的形式的，其实我们发送Object的时候，底层是有帮我们做转换的

4、、、/sync/send4
①发送批量普通同步消息
②发送批量普通同步消息，并设置发送超时时间
使用Template发送批量消息时，发送的消息必须是org.springframework.messaging.Message的子类。批量发消息对消息的内容长度有限制，最大为4M，如果超过4M只能分为多批次发送

5、、、/sync/send5
同步延迟消息
rocketMQ的延迟消息发送其实是已发送就已经到broker端了，然后消费端会延迟收到消息
RocketMQ 目前只支持固定精度的定时消息
固定等级：1到18分别对应1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h
延迟的底层方法是用定时任务实现的。

5.事务消息 /transMq/trans1

②消费消费consumer 分普通消息和事务消息

软件架构

软件架构说明 springboot+rocketmq+lombak 示例基础的消息案例

安装教程

1. maven引入 org.apache.rocketmq rocketmq-spring-boot-starter 2.2.3

使用说明

1. 修改application.yml文件中rocketmq的地址
2. 启动后访问 http://localhost:8200/rocketMq/xxx/xxx
3. 启动成功

参与贡献

1. Fork 本仓库
2. 新建 Feat_xxx 分支
3. 提交代码
4. 新建 Pull Request

特技

1. 使用 Readme_XXX.md 来支持不同的语言，例如 Readme_en.md, Readme_zh.md
2. Gitee 官方博客 blog.gitee.com
3. 你可以 https://gitee.com/explore 这个地址来了解 Gitee 上的优秀开源项目
4. GVP 全称是 Gitee 最有价值开源项目，是综合评定出的优秀开源项目
5. Gitee 官方提供的使用手册 https://gitee.com/help
6. Gitee 封面人物是一档用来展示 Gitee 会员风采的栏目 https://gitee.com/gitee-stars/