● PHANTOM

🇮🇳 IN

✕

Name		Name	Last commit message	Last commit date
Latest commit History 11 Commits
Rabbitmq-Java-Api		Rabbitmq-Java-Api
Rabbitmq-springcloudstream-consumer		Rabbitmq-springcloudstream-consumer
Rabbitmq-springcloudstream-producer		Rabbitmq-springcloudstream-producer
common		common
rabbitmq-springboot-consumer		rabbitmq-springboot-consumer
rabbitmq-sptingboot-producer		rabbitmq-sptingboot-producer
.gitignore		.gitignore
README.md		README.md
pom.xml		pom.xml

Repository files navigation

RabbitMQ 使用案例

一项目结构说明

common:公用模块
Rabbitmq-Java-Api: java使用rabbitmq案例

Rabbitmq-Java-Api

com.chc.rabbitmq_java_api.exchange.direct: exchange的direct
com.chc.rabbitmq_java_api.exchange.fanout : exchange的fanou
com.chc.rabbitmq_java_api.exchange.topic : exchange的topic
com.chc.rabbitmq_java_api.message: massage的其他属性的使用和消息过期
com.chc.rabbitmq_java_api.confirm: confirm的消息回送机制
com.chc.rabbitmq_java_api.returnlistener: return消息回送机制
com.chc.rabbitmq_java_api.consumer: 自定义消费者
com.chc.rabbitmq_java_api.limit: 消费端限流
com.chc.rabbitmq_java_api.ack: 消费端nack,ack和重回队列
com.chc.rabbitmq_java_api.dlx: 死信队列
com.chc.rabbitmq_java_api.delayed: 延迟队列(安装rabbitmq_delayed_message_exchange插件)
com.chc.rabbitmq_java_api.affair 事务消息(并发高的情况下不推荐使用)

rabbitmq-springboot-consumer

springboot与rabbitmq整合的接收端

rabbitmq-sptingboot-producer

springboot与rabbitmq整合的发送端

Rabbitmq-springcloudstream-consumer

spring cloud stream 的接收端

Rabbitmq-springcloudstream-producer

spring cloud stream 的发送端

制定扩展

插件搜索地址:http://www.rabbitmq.com/community-plugins.html

延迟队列插件延迟插件名称:rabbitmq_delayed_message_exchange