RabbitMQ使用SpringAMQP

news2025/1/23 21:07:45

简介

绝对的简单，绝对的易懂，方便初学者，更加利于理解和上手使用（代码可直接复制粘贴进行使用）

如有其它问题，大家可以留言或私聊。

主要为了给大家展示各个代码使用

如果需要更加完整的文档，可以点击下方连接进行阅读
http://t.csdnimg.cn/WWdhG

配置

 消息发送配置

logging:
  pattern:
    dateformat: MM-dd HH:mm:ss:SSS
spring:
  rabbitmq:
    host: 8.137.59.245
    port: 5672
    username: itcast
    password: 123321

    # 设置虚拟主机路径
    virtual-host: /

消息接收配置

logging:
  pattern:
    dateformat: MM-dd HH:mm:ss:SSS
spring:
  rabbitmq:
    host: 8.137.59.245
    port: 5672
    username: itcast
    password: 123321
    virtual-host: /
    listener:
      simple:
        prefetch: 1 #每次只能接收一个消息，处理完后在队列中删除，在获取下一个消息

Basic Queue简单队列

简单介绍

        消息发送者直接发送消息给队列，消息接收者接收队列中发过来的信息，实现消息的接收。

消息发送者

//    Basic Queue简单队列
    @Test
    public void testSendMessage2SimpleQueue(){
        //队列名称
        String queueName = "simple.queue";
        //消息
        String message = "Hello World!spring amqp!!";
        //发送消息
        rabbitTemplate.convertAndSend(queueName, message);
        /**
         *
         *rabbitTemplate.convertAndSend(queueName, routingKey, message);
         * 发送消息，参数分别是：队列名称，RoutingKey(暂时为空)，消息
         */
    }

消息接收者

// Basic Queue简单队列
    @RabbitListener(queues = "simple.queue")
    public void listenSimpleQueue(String msg){
        System.out.println("消费者接收到simple.queue的消息：{"+msg+"}");
//        通过simple.queue队列接收消息，并答应出接收的消息
    }

Work Queue队列

简单介绍

Work Queue队列和Basic Queue队列比较。当发送多个信息需要处理Work Queue队列可以分别交给多个队列处理，增加处理消息速度

消息发送者

    //WorkQueue队列
    @Test
    public void testSendMessage2WorkQueue() throws InterruptedException {
        // 队列名称
        String queueName = "simple.queue";
        // 消息
        String message = "Hello World!spring amqp!!__";
        for (int i = 1; i < 50; i++) {
            // 发送消息
            rabbitTemplate.convertAndSend(queueName, message+i);
            Thread.sleep(20);
        }
//        发送50个消息到simple.queue队列中
    }

消息接收者


// Work Queue工作队列
    @RabbitListener(queues = "simple.queue")
    public void listenWorkQueue1(String msg) throws InterruptedException {
        System.out.println("消费者1接收到simple.queue的消息：{"+msg+"}"+ LocalTime.now());
        Thread.sleep(20);
    }
    @RabbitListener(queues = "simple.queue")
    public void listenWorkQueue2(String msg) throws InterruptedException {
        System.out.println("消费者2接收到simple.queue的消息：{"+msg+"}"+ LocalTime.now());
        Thread.sleep(50);
    }
//    分别用两个消息接收者来接收消息，防止同一个队列处理太快，所以使用sleep来减慢处理速度

发布订阅模型-Fanout交换机

简单介绍

这里添加交换机（主要将不同消息推送到不同队列中进行消费）

消息发送者

    // 发布订阅模型-Fanout交换机
    @Test
    public void testSendFanoutExchange(){
        //交换机名称
        String exchangeName = "itcast.fanout";
        //消息
        String message = "hello,every one!";
        //发送消息，参数分别是：交换机名称，RoutingKey(暂时为空)，消息
        rabbitTemplate.convertAndSend(exchangeName, "", message);
//        这里我们不给队列名，而给交换机名称，通过交换机来发送消息给不同的队列
    }

消息接收者

这里添加了交换机所以我们先写交换机和不同的队列进行绑定

这里我们使用类来操作，后面两不会使用这种比较繁琐的绑定方式

交换机

    //itcast.fanout(交换机)
    @Bean
    public FanoutExchange fanoutExchange(){
        return new FanoutExchange("itcast.fanout");
    }
    //itcast.queue1（队列一）
    @Bean
    public Queue fanoutQueue1(){
        return new Queue("fanout.queue1");
    }
    //绑定队列1到交换机
    @Bean
    public Binding fanoutBinding1(Queue fanoutQueue1, FanoutExchange fanoutExchange){
        return BindingBuilder
                .bind(fanoutQueue1).
                to(fanoutExchange);
    }

    //itcast.queue2（队列二）
    @Bean
    public Queue fanoutQueue2(){
        return new Queue("fanout.queue2");
    }
    //绑定队列2到交换机
    @Bean
    public Binding fanoutBinding2(Queue fanoutQueue2, FanoutExchange fanoutExchange){
        return BindingBuilder
               .bind(fanoutQueue2).
                to(fanoutExchange);
    }
/**
 *  这里先定义一个队列，用于接收消息发送者发送的消息
 *  然后再定义一个交换机，用于接收队列1和队列2的消息
 *  这里的交换机和前面消息发送者的交换机一样名字。
 */

消息接收者

// 发布订阅模型-Fanout交换机
    @RabbitListener(queues = "fanout.queue1")
    public void listenFanoutQueue1(String msg){
        System.out.println("消费者1接收到fanout.queue1的消息：{"+msg+"}");
    }
    @RabbitListener(queues = "fanout.queue2")
    public void listenFanoutQueue2(String msg){
        System.out.println("消费者2接收到fanout.queue2的消息：{"+msg+"}");
    }

订阅发布模型-Direct交换机

简单介绍

Direct交换机和Fanout交换机比较，不一样点在于RoutingKey给的值不一样

消息发送者

    // 订阅，发布模型-Direct交换机
    @Test
    public void testSendDirectExchange(){
        //交换机名称
        String exchangeName = "itcast.direct";
        //消息
        String message = "hello,blue one!";
        //发送消息，参数分别是：交换机名称，RoutingKey(暂时为空)，消息
        rabbitTemplate.convertAndSend(exchangeName, "blue", message);
        /**
         * 消息发送，参数分别是：交换机名称，RoutingKey，消息
         * routingKey: 用来区分不同的队列
         * 上面routingKey给“blue”的意义是将消息发送给blue队列
         * */
    }

消息接收者

// 订阅，发布模型-Direct交换机
    @RabbitListener(bindings = @QueueBinding(
            //队列
            value = @Queue(name = "direct.queue1"),
            //交换机
            exchange = @Exchange(name = "itcast.direct",type = ExchangeTypes.DIRECT),
            //邦定机置
            key = {"red","blue"}
    ))
    public void listenDirectQueue1(String msg){
        System.out.println("消费者接收到direct.queue1的消息：{"+msg+"}");
//        接收red和blue的消息并传入队列进行消费
    }
    @RabbitListener(bindings = @QueueBinding(
            //队列
            value = @Queue(name = "direct.queue2"),
            //交换机
            exchange = @Exchange(name = "itcast.direct",type = ExchangeTypes.DIRECT),
            //邦定机置
            key = {"red","yellow"}
    ))
    public void listenDirectQueue2(String msg){
        System.out.println("消费者接收到direct.queue2的消息：{"+msg+"}");
//        接收red和yellow的消息并传入队列进行消费
    }

发布订阅模型-Topic交换机

简单介绍

个人理解：算是对Direct交换机进行扩展吧，可以实现更多样性的订阅发布

消息发送者

    // 发布，-订阅模型-Topic交换机
    @Test
    public void testSendTopicExchange(){
        //交换机名称
        String exchangeName = "itcast.topic";
        //消息
        String message = "日本新闻!";
        //发送消息，参数分别是：交换机名称，RoutingKey，消息
        rabbitTemplate.convertAndSend(exchangeName, "china.news", message);
        /**
         * 这里需要慢足两个条件 “china”和“news“
         * */
    }

消息接收者

// 发布，订阅模型-Topic交换机
    @RabbitListener(bindings = @QueueBinding(
            value = @Queue(name = "topic.queue1"),
            exchange = @Exchange(name = "itcast.topic",type = ExchangeTypes.TOPIC),
            key = "china.#"
    ))
    public void listenTopicQueue1(String msg){
        System.out.println("消费者接收到topic.queue1的消息：{"+msg+"}");
//        满足china.#的条件，消费消息（”#“：表示所有）
    }
    @RabbitListener(bindings = @QueueBinding(
            value = @Queue(name = "topic.queue2"),
            exchange = @Exchange(name = "itcast.topic",type = ExchangeTypes.TOPIC),
            key = "#.news"
    ))
    public void listenTopicQueue2(String msg){
        System.out.println("消费者接收到topic.queue2的消息：{"+msg+"}");
//        满足#.news的条件，消费消息（”#“：表示所有）
    }

Json序列化

简单介绍

为什么要添加呢：大致就是实现可消息发送类型的更多

添加Maven

        <!--rabbitmq使用json序列化-->
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
        </dependency>

消息发送者


    // 使用json发送对象队列
    @Test
    public void testSendObjectQueue() {
        Map<String, Object> msg = new HashMap<>();
        msg.put("name", "留言");
        msg.put("age", 21);
        rabbitTemplate.convertAndSend("object.queue", msg);
//        发送Map类型的消息到object.queue队列中
    }

消息接收者

    @RabbitListener(queues = "object.queue")
    public void listenObjectQueue(Map<String,Object> msg){
        System.out.println("消费者接收到object.queue的消息：{"+msg+"}");
        msg.forEach((k,v)->{
            System.out.println(k+"="+v);
            System.out.println("{"+k+"}");
        });
//        接收消息并循环打印接收到的消息
    }

感悟

个人感觉使用其实不难，如果要看源码分析源码，可能就难起来了，希望以后有机会和大家一起分析分析其它项目的源码！谢谢！！！

愿各位道友披荆斩棘，登临顶峰

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1495355.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

关于 DevOps，如何应对IT服务交付中的问题？

关于 DevOps，如何应对IT服务交付中的问题？

文章目录 &#x1f4cb; 前言&#x1f3af; 如何应对IT服务交付中的问题&#xff1f;&#x1f3af;关于 DevOps 书籍推荐&#x1f4dd;最后&#x1f525; 参与方式 &#x1f4cb; 前言 DevOps 是一种软件开发方法论和实践&#xff0c;旨在通过缩短开发周期、提高交付速度和改进…
阅读更多...
Pytorch 复习总结 6

Pytorch 复习总结 6

Pytorch 复习总结&#xff0c;仅供笔者使用&#xff0c;参考教材&#xff1a; 《动手学深度学习》Stanford University: Practical Machine Learning 本文主要内容为&#xff1a;Pytorch 计算机视觉。 本文先介绍了计算机视觉中两种常见的改进模型泛化性能的方法&#xff1a…
阅读更多...
和鲸科技受邀参与湖南省气象信息中心开展人工智能研究型业务支撑平台学术交流

和鲸科技受邀参与湖南省气象信息中心开展人工智能研究型业务支撑平台学术交流

为推进湖南省机器学习统一平台建设&#xff0c;2 月 29 日&#xff0c;湖南省气象信息中心开展学术讲座活动&#xff0c;活动由中心副主任冯冼主持&#xff0c;中心业务骨干、湖南省气象台、湖南分院等技术人员参加。 本次讲座邀请上海和今信息科技有限公司&#xff08;简称“…
阅读更多...
STL容器之map和set的补充红黑树

STL容器之map和set的补充红黑树

三、红黑树 ​ 红黑树比起avl树是哟啊更优一点的。 3.1概念 ​ 红黑树&#xff0c;是一种二叉搜索树&#xff0c;但在每个结点上增加一个存储位表示结点的颜色&#xff0c;可以是Red或Black。 通过对任何一条从根到叶子的路径上各个结点着色方式的限制&#xff0c;红黑树确保…
阅读更多...
DataFunSummit 2023：洞察现代数据栈技术的创新与发展（附大会核心PPT下载）

DataFunSummit 2023：洞察现代数据栈技术的创新与发展（附大会核心PPT下载）

随着数字化浪潮的推进&#xff0c;数据已成为企业竞争的核心要素。为了应对日益增长的数据挑战&#xff0c;现代数据栈技术日益受到业界的关注。DataFunSummit 2023年现代数据栈技术峰会正是在这样的背景下应运而生&#xff0c;汇聚了全球数据领域的精英&#xff0c;共同探讨现…
阅读更多...
华为数通方向HCIP-DataCom H12-821题库(多选题：101-120)

华为数通方向HCIP-DataCom H12-821题库(多选题：101-120)

第101题 下面关于Network-Summary-LSA描述正确的是 A、Network-Summary-LSA中的Metric被设置成从该ABR到达目的网段的开销值 B、Network-Summary-LSA中 的Netmask被设置成目的网段的网络掩码 C、Network-Summary-LSA中的Link State ID被设置成目的网络的IP地址 D、Network-Sum…
阅读更多...
项目一：踏上Java开发之旅（2023软件1班）

项目一：踏上Java开发之旅（2023软件1班）

文章目录 一、实战概述二、实战步骤任务1&#xff1a;安装配置JDK开发第一个Java程序1、安装JDK2、配置Java环境变量3、开发第一个Java程序&#xff08;1&#xff09;编写源程序 - HelloWorld.java&#xff08;2&#xff09;编译成字节码文件 - HelloWorld.class&#xff08;3&…
阅读更多...
网络原理TCP_IP

网络原理TCP_IP

文章目录 应用层自定义协议 传输层udp协议TCP协议1.确认应答2.超时重传3.连接管理建立连接, 三次握手断开连接, 四次挥手tcp的状态 4.滑动窗口5.流量控制6.拥塞控制7.延时应答8.携带应答9.面向字节流10.异常情况 网络层IP协议地址管理路由选择 数据链路层以太网 应用层 自定义…
阅读更多...
【Greenhills】MULTIIDE集成第三方的编辑器进行源文件编辑工作

【Greenhills】MULTIIDE集成第三方的编辑器进行源文件编辑工作

【更多软件使用问题请点击亿道电子官方网站查询】 1、 文档目标 在使用GHS进行工作的时候&#xff0c;可以集成第三方的编辑器进行源文件编辑工作 2、 问题场景 用于解决在GHS中进行项目开发时&#xff0c;对于GHS的编辑器使用不习惯&#xff0c;想要切换到其他第三方的编辑…
阅读更多...
差分与前缀和模板题（蓝桥杯 C++ 题目 注解）

差分与前缀和模板题（蓝桥杯 C++ 题目 注解）

目录 题目一&#xff08;大学树木要打药 差分&#xff09;&#xff1a; 代码&#xff1a; 题目二&#xff08;小明的彩灯 差分&#xff09;&#xff1a; 代码&#xff1a; 题目三&#xff08;区间更新 差分&#xff09;&#xff1a; 代码&#xff1a; 题目四&#xff08;…
阅读更多...
python基于django的药品进销存管理系统elsb2

python基于django的药品进销存管理系统elsb2

本系统是通过面向对象的python语言搭建系统框架&#xff0c;通过关系型数据库MySQL存储数据。使用django框架进行药店药品的信息管理&#xff0c;用户只需要通过浏览器访问系统即可获取药店药品信息&#xff0c;并可以在线管理&#xff0c;实现了信息的科学管理与查询统计。本文…
阅读更多...
了解一下c++的小语法——步入c++

了解一下c++的小语法——步入c++

前言&#xff1a;c是一门既面向对象又面向过程的语言。 不同于java纯粹的面向对象和c纯粹的面向过程。 造成c该特性的原因是c是由本贾尼大佬在c的基础上增添语法创建出来的一门新的语言。 它既兼容了c&#xff0c; 身具面向过程的特性。 又有本身的面向对象的特性。 面向对象和…
阅读更多...
selenium-java 通过配置xml文件并发运行类或者方法

selenium-java 通过配置xml文件并发运行类或者方法

1、打开idea允许某个class类&#xff0c;可以在控制台看到运行路径的下的配置文件如下图&#xff1a; 2、将路径复制到本地路径中找到temp-testng-customsuite.xml文件 3、复制该文件到项目的根目录下&#xff0c;可以修改文件名称&#xff0c;如下图 4、如图所示&#xff0c;通…
阅读更多...
【Python】成功解决TypeError: ‘int‘ object is not iterable

【Python】成功解决TypeError: ‘int‘ object is not iterable

【Python】成功解决TypeError: ‘int’ object is not iterable &#x1f308; 个人主页&#xff1a;高斯小哥 &#x1f525; 高质量专栏&#xff1a;Matplotlib之旅&#xff1a;零基础精通数据可视化、Python基础【高质量合集】、PyTorch零基础入门教程&#x1f448; 希望得到…
阅读更多...
【Flink网络数据传输（4）】RecordWriter（下）封装数据并发送到网络的过程

【Flink网络数据传输（4）】RecordWriter（下）封装数据并发送到网络的过程

文章目录 一. RecordWriter封装数据并发送到网络1. 数据发送到网络的具体流程2. 源码层面2.1. Serializer的实现逻辑a. SpanningRecordSerializer的实现b. SpanningRecordSerializer中如何对数据元素进行序列化 2.2. 将ByteBuffer中间数据写入BufferBuilder 二. BufferBuilder申…
阅读更多...
java ~ word模板填充字符后输出到指定目录

java ~ word模板填充字符后输出到指定目录

word文件格式&#xff1a; jar包&#xff1a; <dependency><groupId>com.deepoove</groupId><artifactId>poi-tl</artifactId><version>1.10.0</version></dependency>样例代码&#xff1a; // 封装参数集合Map<String, Ob…
阅读更多...
【异常处理】BadSqlGrammarException低级SQL语法异常

【异常处理】BadSqlGrammarException低级SQL语法异常

报错 org.springframework.jdbc.BadSqlGrammarException: ### Error querying database. Cause: java.sql.SQLSyntaxErrorException: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use …
阅读更多...
MYSQL5.7报1205 - Lock wait timeout exceeded； try restarting transaction

MYSQL5.7报1205 - Lock wait timeout exceeded； try restarting transaction

简介 今天使用navicate操作添加时&#xff0c;mysql报错误&#xff0c;错误如下 原因 这个问题的原因是在mysql中产生了事务A&#xff0c;执行了修改的语句&#xff0c;比如&#xff1a; update t1 set aget18 where id1;此时事务并未进行提交&#xff0c;事务B开始运行&am…
阅读更多...
Linux_防火墙无法启动问题

Linux_防火墙无法启动问题

当查看防火墙状体的时候报如下错误 ● firewalld.service - firewalld - dynamic firewall daemonLoaded: loaded (/usr/lib/systemd/system/firewalld.service; enabled; vendor preset: enabled)Active: inactive (dead) since 四 2024-03-07 07:42:16 CST; 7s agoDocs: man…
阅读更多...
【黑马程序员】STL实战--演讲比赛管理系统

【黑马程序员】STL实战--演讲比赛管理系统

演讲比赛管理系统 需求说明 比赛规则 程序功能 创建管理类 功能描述 提供菜单界面与用户交互 对演讲比赛流程进行控制 与文件的读写交互 创建演讲比赛管理类 新建speechManager.hpp #pragma once#include <iostream>using namespace std;// 设计演讲比赛类 clas…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023