Commit Graph

42 Commits

Author SHA1 Message Date
HuangLei 7633bc5d5e refactor(mq): 移除 RocketMQ 消费者和生产者示例代码
- 删除了 yudao-spring-boot-starter-mq 模块中的 Consumer 和 Product 类
- 在 yudao-server 模块中添加了 yudao-spring-boot-starter-mq 依赖
- 更新了 YudaoServerApplication 类,扫描 framework 包
- 在 pom.xml 中添加了 maven-compiler-plugin配置,支持 Java 17
2025-06-18 15:38:09 +08:00
HuangLei 19889c1f89 feat(mq): 添加 RocketMQ相关的常量接口
- 新增 GroupConstants 接口,定义了多个消费者组常量- 新增 TopicNameConstants 接口,定义了多个主题名常量
- 新增 TopicTagConstants 接口,定义了多个主题标签常量
2025-06-18 15:03:59 +08:00
HuangLei 2b74e4ac50 build: 更新 RocketMQ 配置并调整依赖项
- 在 application-dev.yaml 和 application-local.yaml 文件中更新 RocketMQ 名称服务器地址为 192.168.201.58:9876
- 在 yudao-spring-boot-starter-mq/pom.xml 中取消 rocketmq-spring-boot-starter 依赖项的 optional 标记
2025-06-18 14:34:41 +08:00
YunaiV 361e50e5de feat:Redis Stream 增加清理 Job,避免占用内存过多 2025-04-30 19:41:24 +08:00
YunaiV 1d239c9877 修改 rabbitmq 序列化方式,使用 Jackson2JsonMessageConverter 替代 2024-04-16 09:17:11 +08:00
YunaiV a597eb17d4 websocket:修复 RedisWebSocketMessageConsumer 注册失效的问题 2023-11-24 18:56:19 +08:00
YunaiV c886e7eff2 mq:增加 Rabbitmq 教程内容 2023-11-02 20:18:45 +08:00
YunaiV 20725e3dfd mq:增加 rabbitmq 配置项 2023-11-02 08:22:05 +08:00
YunaiV b8d5a665be mq:增加 rocketmq 配置项 2023-11-02 00:07:38 +08:00
YunaiV e1c34e9124 mq:优化 redis stream 的命名 2023-11-01 22:46:02 +08:00
zhijiantianya@gmail.com f8ed0e15f0 mq:增加 kafka、rocketmq、rabbitmq 的实现支持 2023-11-01 19:58:56 +08:00
YunaiV c066ea46f9 mq 重构:默认的 redis 实现:
1)默认 channel 和 stream key
2)移除 enabled 开关,通过 listener 是否存在来实现
3)调整包名,为接入 rocketmq 作为 mq 实现做准备
2023-10-30 21:15:22 +08:00
YunaiV 68049b85b9 基于 Redis 实现的 pubsub、stream 消息队列,支持开启或关闭。默认为关闭状态,项目启动更快 2023-07-29 12:04:50 +08:00
YunaiV ecfe0b864b 优化 RedisPendingMessageResendJob 代码排版,以及注释 2023-06-17 12:41:56 +08:00
wfm 4faf61a475 增加日志 2023-05-16 10:22:46 +08:00
wfm 86be0bdf80 fix PR 2023-05-16 09:58:58 +08:00
wfm 494928ed88 feat:重放消息判断过期时间 2023-05-12 17:23:21 +08:00
筱龙缘 edc52d5f4f
修复 Redis Pub/Sub 广播消费的容器 默认未启动的问题
默认配置没有启动Redis Pub/Sub 广播消费的容器 导致发出消息后 消费者收不到消息

Signed-off-by: 筱龙缘 <794334212@qq.com>
2023-02-17 09:58:38 +00:00
gaibu 604266d33c fix: 解决 redis mq 消息丢失问题 2022-12-27 22:52:19 +08:00
gaibu 0e6b4e463f fix: 解决 redis mq 消息丢失问题 2022-12-23 10:33:38 +08:00
gaibu 2d7d3f1511 fix: 解决 redis mq 消息丢失问题 2022-12-23 10:32:18 +08:00
gaibu e9645d7054 fix: 解决 redis mq 消息丢失问题 2022-12-23 10:31:41 +08:00
gaibu 46f3790492 fix: 解决 redis mq 消息丢失问题 2022-12-23 10:28:59 +08:00
gaibu a6c92816f0 fix: 解决 redis mq 消息丢失问题 2022-12-15 15:33:15 +08:00
gaibu 0f31ce7ecf fix: 解决 redis mq 消息丢失问题 2022-12-15 14:36:17 +08:00
YunaiV ffab0b1d6a 1. 优化 menu 本地缓存的刷新策略,在修改或删除菜单时,强制刷新缓存
2. 修复 pub/sub 未初始化的问题
3. 优化 Job 定时的 mybatis 日志输出,避免一直打印
2022-12-06 20:38:05 +08:00
xingyu 283aae1da2 feat: 适配springboot 2.7 configuration ==> AutoConfiguration 2022-11-30 01:20:20 +08:00
xingyu 1aa05e0198 feat: 适配 springboot 2.7 2022-11-30 01:03:56 +08:00
xingyu 0d0f64e30a feat: 删除过期方法 2022-11-23 22:54:44 +08:00
zy 9b667448ea fix: 加入异步注解配置后redis消费者不能正常消费 2022-11-18 09:51:19 +08:00
YunaiV 1819e0e1d6 异步化 Redis MQ 的初始化,提升启动速度 2022-11-12 20:57:28 +08:00
YunaiV f5ef87094d 优化,使用 @Configuration(proxyBeanMethods = false) 提升启动速度 2022-11-12 20:17:58 +08:00
YunaiV 81d89ba350 增加租户、租户套餐的单元测试 2022-02-27 00:15:13 +08:00
YunaiV 66ebb71b8a Redis 最低版本 5.0.0 检测,解决搭建环境过程中无法理解 XREADGROUP 指令的报错 2022-02-26 00:41:27 +08:00
Jelly 5e43efc555 fix:修复 Maven 构建一些提示 2022-02-10 11:16:17 +08:00
YunaiV 2cef84bdc8 * 【修复】自定义 DefaultStreamMessageListenerContainerX 实现,解决 Redisson Stream 读取不到数据返回 `null` 导致 NPE 问题 2022-02-10 08:20:06 +08:00
YunaiV eda2b11dad 增加数据权限的 SQL 重写的上下文 2021-12-10 10:08:29 +08:00
YunaiV 1ce2c09f47 增加 Tenant MQ 的支持 2021-12-06 01:32:41 +08:00
YunaiV a231582637 增强 mq starter 组件,支持 interceptor 拦截器机制 2021-12-05 23:50:17 +08:00
YunaiV d29b0beb9b 优化 mq starter 组件,增加 RedisMQTemplate 模板类 2021-12-05 23:00:41 +08:00
YunaiV ab4e6d0819 项目结构调整 x 21 : 解决 opentracing 版本的冲突问题 2021-05-03 10:31:29 +08:00
YunaiV 0b5662b698 项目结构调整 x 20 : 拆分出独立的 yudao-spring-boot-starter-mq 组件,整理更加清晰 2021-05-03 01:49:56 +08:00