疯狂的狮子Li e0f68ef605 remove 重大改动 删除sentinel所有相关功能(为什么删除 查看文档详细说明 https://plus-doc.dromara.org/#/questions/sentinel_404) hai 1 ano
..
src fcfa6dc976 !223 更新 RabbitMQ 优化发送和消费手动确认机制 hai 1 ano
README.md cb2ff94226 remove 删除 kafka-streams 所有人都不会用也不学怎么用 删除了事 %!s(int64=2) %!d(string=hai) anos
pom.xml e0f68ef605 remove 重大改动 删除sentinel所有相关功能(为什么删除 查看文档详细说明 https://plus-doc.dromara.org/#/questions/sentinel_404) hai 1 ano

README.md

ruoyi-test-mq

模块说明

  1. rabbitmq: 普通消息、延迟队列
  2. rocketmq:普通消息、事务消息、延迟消息
  3. kafka:普通消息

使用方式

rocketmq:

注意:由于rocketmq并没有自动创建topic的功能, 所以需要进入到rockerMQ文件路径中执行

创建普通消息的topic

sh mqadmin updateTopic -n <nameserver_address> -t <topic_name> -c <cluster_name> -a +message.type=NORMAL
bin/mqadmin updatetopic -n localhost:9876 -t test-topic -c DefaultCluster

创建事务消息的topic

sh mqadmin updateTopic -n <nameserver_address> -t <topic_name> -c <cluster_name> -a +message.type=TRANSACTION
bin/mqadmin updatetopic -n localhost:9876 -t transaction-topic -c DefaultCluster -a +message.type=TRANSACTION