xins
/
hwmom
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
master
2.X
main
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'b8d57862c3'
${ noResults }
hwmom/ruoyi-example/ruoyi-test-mq
History
疯狂的狮子Li dabf9b4a98 update 优化 !pr163 代码结构与重新实现 rabbitmq 延迟队列 8 months ago
..
src/main update 优化 !pr163 代码结构与重新实现 rabbitmq 延迟队列 8 months ago
README.md update 优化 !pr163 代码结构与重新实现 rabbitmq 延迟队列 8 months ago
pom.xml !163 将spring-cloud-stream改为普通的mq依赖用法 8 months ago

README.md
Unescape Escape

ruoyi-test-mq

模块说明

  1. rabbit: 普通消息、延迟队列
  2. rocket：普通消息、事务消息
  3. kafka：普通消息

后续可实现的：

  1. kafka stream流的使用
  2. rocket 顺序、异步、延时等

使用方式

rocketmq：

注意：需要进入到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 TestTopic -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

kafka:

kafka-topics.sh --create --topic <topic_name> --bootstrap-server <broker_list> --partitions <num_partitions> --replication-factor <replication_factor>

kafka-topics.sh --create --topic my_topic --bootstrap-server localhost:9092 --partitions 3 --replication-factor 1