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);
}
}
没有合适的资源?快使用搜索试试~ 我知道了~
spring boot rabbitmq学习练习demo源码
共61个文件
class:25个
java:25个
prefs:3个
1星 需积分: 9 21 下载量 163 浏览量
2017-12-09
17:07:19
上传
评论
收藏 36KB RAR 举报
温馨提示
spring boot rabbitmq框架组合练习学习做的一个完整的精简的小demo项目源码
资源推荐
资源详情
资源评论
收起资源包目录
spring-boot-rabbitmq.rar (61个子文件)
spring-boot-rabbitmq
pom.xml 1KB
target
test-classes
classes
META-INF
maven
com.xh
spring-boot-rabbitmq
pom.xml 1KB
pom.properties 281B
MANIFEST.MF 363B
application.properties 221B
com
xh
config
FanoutRabbitConfig.class 2KB
TopicRabbitConfig.class 2KB
RabbitConfig.class 856B
MyApplication.class 678B
model
User.class 1KB
test
HelloTest.class 828B
TopicTest.class 825B
FanoutTest.class 837B
ManyTest.class 1KB
ObjectTest.class 1KB
rabbitMQ
object
ObjectReceiver.class 1KB
ObjectSender.class 1KB
hello
HelloSender.class 1KB
HelloReceiver.class 996B
fanout
FanoutReceiverB.class 1KB
FanoutReceiverC.class 1KB
FanoutSender.class 1KB
FanoutReceiverA.class 1KB
many
ManyReceiver2.class 991B
ManySender1.class 1KB
ManyReceiver1.class 991B
ManySender2.class 1KB
topic
TopicReceiver.class 1KB
TopicSender.class 2KB
TopicReceiver2.class 1KB
.settings
org.eclipse.m2e.core.prefs 90B
org.eclipse.core.resources.prefs 250B
org.eclipse.jdt.core.prefs 736B
src
test
resources
java
main
resources
application.properties 221B
java
com
xh
config
TopicRabbitConfig.java 1KB
RabbitConfig.java 498B
FanoutRabbitConfig.java 1KB
model
User.java 658B
test
ObjectTest.java 599B
HelloTest.java 702B
ManyTest.java 879B
FanoutTest.java 736B
TopicTest.java 647B
rabbitMQ
object
ObjectReceiver.java 455B
ObjectSender.java 481B
hello
HelloSender.java 612B
HelloReceiver.java 456B
fanout
FanoutReceiverC.java 666B
FanoutReceiverB.java 666B
FanoutReceiverA.java 666B
FanoutSender.java 795B
many
ManyReceiver1.java 418B
ManyReceiver2.java 418B
ManySender1.java 490B
ManySender2.java 490B
topic
TopicReceiver.java 458B
TopicSender.java 972B
TopicReceiver2.java 461B
MyApplication.java 291B
.project 572B
.classpath 1KB
共 61 条
- 1
资源评论
- craze_learning2018-07-10根本不能用。。。
PandaCode辉
- 粉丝: 94
- 资源: 29
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功