首页 > 编程语言 >RabbitMQ Java代码声明队列和交换机(方法一)

RabbitMQ Java代码声明队列和交换机(方法一)

时间:2023-12-02 21:22:23浏览次数:51  
标签:return 队列 fanoutExchange RabbitMQ Bean 交换机 Java public

 

 

交换机和队列的声明一般写在消费者模块里

 

代码示例:

package com.itheima.config_RabbitMQ;

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class FanoutConfiguration {
@Bean
public FanoutExchange fanoutExchange() { //创建交换机
//方法一
return ExchangeBuilder.fanoutExchange("hmall.fanout2").build();

//方法二
//return new FanoutExchange("hmall.fanout2");
}

@Bean
public Queue fanoutQueue() { //创建队列
//方法一
return QueueBuilder.durable("fanout.queue3").build();

//方法二
//return new Queue("fanout.queue3");
}

@Bean
public Queue fanoutQueue4() { //创建队列
return QueueBuilder.durable("fanout.queue4").build();
}

@Bean
public Binding fanoutBinding(Queue fanoutQueue, FanoutExchange fanoutExchange) { //绑定交换机、队列 方法一
return BindingBuilder.bind(fanoutQueue).to(fanoutExchange);
}

@Bean
public Binding fanoutBinding2() { //绑定交换机、队列 方法二
return BindingBuilder.bind(fanoutQueue4()).to(fanoutExchange());
}
}

 

标签:return,队列,fanoutExchange,RabbitMQ,Bean,交换机,Java,public
From: https://www.cnblogs.com/gagaya2/p/17872234.html

相关文章

  • RabbitMQ Topic交换机
     代码示例:1.新建两个队列 2.创建交换机,名字叫hmall.topic,类型选择topic 3.hmall.topic交换机绑定第一步的两个队列,绑定过程中填写RoutingKey  4.编写消费者代码监听这两个队列@RabbitListener(queues="topic.queue1")publicvoidlistenQueue05(Str......
  • RabbitMQ Direct交换机
     代码示例:1.交换机绑定了两个队列,并给它们设置了RoutingKey2. publisher发送者给Direct交换机发消息时,第二个参数指定RoutingKey:@GetMapping("/mq03")publicvoidmq03(){StringexchangeName="hmall.direct";Stringmsg="hello,红色";//三个参数:......
  • RabbitMQ 发送消息到交换机
    发送消息到交换机的代码:@GetMapping("/mq02")//发送消息给交换机publicvoidmq02(){StringexchangeName="hmall.fanout";Stringmsg="hello,每个人";//三个参数:交换机名称、RoutingKey(暂时为空)、要发送的消息rabbitTemplate.convertAndSend(exchangeName,......
  • RabbitMQ Fanout交换机
     容易搞混的点:1.假如publisher给Fanout交换机发送了一条消息,那么Fanout交换机会给每一个绑定到它身上的队列都发送这条消息,也就是说有多少个队列跟它绑定了,这条消息就有几份,每个队列都收到一份。2.假如一个队列绑定了多个消费者,那么该队列在给消费者投递消息时就是轮询,一......
  • 算法之快速排序1初始(java)
    一:概述快速排序、归并排序、堆排序等都是比冒泡排序更快的算法。其中快速排序是从冒泡排序演变而来。快速排序之所以比冒泡排序要快是因为它用了分治法。    二:具体说明同冒泡排序一样,快速排序也属于交换排序,通过元素之间的比较进行比较和交换位置来达到排序的目的。不同的是......
  • 【算法 Java】递归,阶乘的递归实现,斐波那契数列的递归实现
    递归定义:方法直接或间接地调用方法本身思路:将大问题转化为一个与原问题相似的规模更小的问题注意:递归死循环会导致栈内存溢出一些使用递归求解的问题阶乘Factorial.javaimportjava.util.Scanner;publicclassFactorial{publicstaticvoidmain(String[]args)......
  • java: 未报告的异常错误java.io.UnsupportedEncodingException; 必须对其进行捕获或声
    原问题代码:/**MD5编码相关的类@authorwangjingtao*/publicclassMD5{//首先初始化一个字符数组,用来存放每个16进制字符privatestaticfinalchar[]hexDigits={'0','1','2','3','4','5','6','7'......
  • 前端学习-JavaScript学习-js基础-API02-轮播图案例
    自己写的<!DOCTYPEhtml><htmllang="en"><head><metacharset="UTF-8"><metaname="viewport"content="width=device-width,initial-scale=1.0"><title>Document</title>......
  • Java入门
    Java入门 Java帝国的诞生一场旷日持久的战争(1995)1972年C语言开始统治贴近硬件,运行极快,效率极高早期开发了很多操作系统,编译器,数据库,网络系统等指针和内存管理1982年C++诞生面向对象兼容C图形领域、游戏等我们要建立一个新的语言:语法有点像C没......
  • 【JavaSE】时间API
    JDK8版本之前的时间API(了解)Data类SimpleDateFormat类SimpleDateFormat类指定格式查API帮助文档即可SimpleDateFormatDemo.javaimportjava.text.ParseException;importjava.text.SimpleDateFormat;importjava.util.Date;publicclassSimpleDateFormatDemo{pu......