package com.xh.config;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class FanoutRabbitConfig {
//Fanout 就是我们熟悉的广播模式或者订阅模式,给Fanout交换机发送消息,绑定了这个交换机的所有队列都收到这个消息。
@Bean
public Queue AMessage() {
return new Queue("fanout.A");
}
@Bean
public Queue BMessage() {
return new Queue("fanout.B");
}
@Bean
public Queue CMessage() {
return new Queue("fanout.C");
}
@Bean
FanoutExchange fanoutExchange() {
return new FanoutExchange("fanoutExchange");
}
@Bean
Binding bindingExchangeA(Queue AMessage,FanoutExchange fanoutExchange) {
return BindingBuilder.bind(AMessage).to(fanoutExchange);
}
@Bean
Binding bindingExchangeB(Queue BMessage, FanoutExchange fanoutExchange) {
return BindingBuilder.bind(BMessage).to(fanoutExchange);
}
@Bean
Binding bindingExchangeC(Queue CMessage, FanoutExchange fanoutExchange) {
return BindingBuilder.bind(CMessage).to(fanoutExchange);
}
}
没有合适的资源?快使用搜索试试~ 我知道了~
RabbitMQ学习简单demo项目源码
共59个文件
class:24个
java:24个
properties:3个
需积分: 43 79 下载量 126 浏览量
2017-10-30
17:30:07
上传
评论
收藏 35KB RAR 举报
温馨提示
RabbitMQ学习过程中,写的一个简单完整的demo项目源码,各种模式的MQ都有一个简单的例子,喜欢实践学习的人看看
资源推荐
资源详情
资源评论
收起资源包目录
springBoot.RabbitMQ.rar (59个子文件)
springBoot.RabbitMQ
.project 571B
pom.xml 2KB
target
test-classes
classes
META-INF
maven
springBootRabbitMQ
springBoot.RabbitMQ
pom.xml 2KB
pom.properties 290B
MANIFEST.MF 373B
com
xh
test
ManyTest.class 1KB
TopicTest.class 825B
HelloTest.class 828B
ObjectTest.class 1KB
FanoutTest.class 837B
rabbitMQ
topic
TopicSender.class 2KB
TopicReceiver2.class 1KB
TopicReceiver.class 1KB
many
ManyReceiver1.class 991B
ManySender1.class 1KB
ManyReceiver2.class 991B
ManySender2.class 1KB
fanout
FanoutSender.class 1KB
FanoutReceiverC.class 1KB
FanoutReceiverB.class 1KB
FanoutReceiverA.class 1KB
hello
HelloSender.class 1KB
HelloReceiver.class 996B
object
ObjectSender.class 1KB
ObjectReceiver.class 1KB
model
User.class 1KB
config
FanoutRabbitConfig.class 2KB
TopicRabbitConfig.class 2KB
RabbitConfig.class 856B
application.properties 221B
.settings
org.eclipse.core.resources.prefs 250B
org.eclipse.jdt.core.prefs 243B
org.eclipse.m2e.core.prefs 90B
src
test
resources
java
main
resources
application.properties 221B
java
com
xh
test
FanoutTest.java 736B
TopicTest.java 647B
ObjectTest.java 599B
HelloTest.java 702B
ManyTest.java 879B
rabbitMQ
topic
TopicSender.java 972B
TopicReceiver.java 458B
TopicReceiver2.java 461B
many
ManyReceiver2.java 418B
ManySender1.java 490B
ManyReceiver1.java 418B
ManySender2.java 490B
fanout
FanoutReceiverC.java 666B
FanoutReceiverB.java 666B
FanoutReceiverA.java 666B
FanoutSender.java 795B
hello
HelloReceiver.java 456B
HelloSender.java 496B
object
ObjectSender.java 481B
ObjectReceiver.java 455B
model
User.java 658B
config
FanoutRabbitConfig.java 1KB
TopicRabbitConfig.java 1KB
RabbitConfig.java 468B
.classpath 1KB
共 59 条
- 1
资源评论
PandaCode辉
- 粉丝: 93
- 资源: 29
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功