RabbitMQ使用SpringAMQP

简介

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

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

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

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

配置

 消息发送配置

logging:pattern:dateformat: MM-dd HH:mm:ss:SSS
spring:rabbitmq:host: 8.137.59.245port: 5672username: itcastpassword: 123321# 设置虚拟主机路径virtual-host: /

消息接收配置

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

Basic Queue简单队列

简单介绍

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

消息发送者

//    Basic Queue简单队列@Testpublic 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队列@Testpublic 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交换机@Testpublic void testSendFanoutExchange(){//交换机名称String exchangeName = "itcast.fanout";//消息String message = "hello,every one!";//发送消息，参数分别是：交换机名称，RoutingKey(暂时为空)，消息rabbitTemplate.convertAndSend(exchangeName, "", message);
//        这里我们不给队列名，而给交换机名称，通过交换机来发送消息给不同的队列}

消息接收者

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

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

交换机

    //itcast.fanout(交换机)@Beanpublic FanoutExchange fanoutExchange(){return new FanoutExchange("itcast.fanout");}//itcast.queue1（队列一）@Beanpublic Queue fanoutQueue1(){return new Queue("fanout.queue1");}//绑定队列1到交换机@Beanpublic Binding fanoutBinding1(Queue fanoutQueue1, FanoutExchange fanoutExchange){return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);}//itcast.queue2（队列二）@Beanpublic Queue fanoutQueue2(){return new Queue("fanout.queue2");}//绑定队列2到交换机@Beanpublic 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交换机@Testpublic 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交换机@Testpublic 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发送对象队列@Testpublic 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.rhkb.cn/news/270646.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Android使用Sensor.TYPE_STEP_COUNTER计步器传感器进行步数统计

Android使用Sensor.TYPE_STEP_COUNTER计步器传感器进行步数统计

1、首先&#xff0c;申请权限 必须声明 ACTIVITY_RECOGNITION 权限&#xff0c;以便您的应用在运行 Android 10 (API 级别 29) 或更高版本的设备上使用此传感器。 Manifest.xml也记得声明 if (Build.VERSION.SDK_INT > Build.VERSION_CODES.P) {Log.d(TAG, "[权限]&quo…
阅读更多...
虚拟化之CPU

虚拟化之CPU

一 cpu 1 如何查看内核版本&#xff1a;uname -r 2 如何查看操作系统的发行版本&#xff1a;cat /etc/redhat-release 3 计算机系统子的系统 cpu处理器memory内存storage存储network 网络Display显示 4 进程模式 用户模式&#xff08;user mode&#xff09;主要处理I/O的模…
阅读更多...
CTP-API开发系列之四：接口对接准备

CTP-API开发系列之四：接口对接准备

CTP-API开发系列之四&#xff1a;接口对接准备 CTP-API开发系列之四&#xff1a;接口对接准备CTP-API文件清单CTP-API通用规则命名规则Spi与Api CTP-API通讯模式开发语言选择 CTP-API开发系列之四&#xff1a;接口对接准备 CTP-API文件清单 文件名说明ThostFtdcTraderApi.h交…
阅读更多...
微前端之什么是微前端

微前端之什么是微前端

什么是微前端 微前端分类 基于路由的微前端&#xff1a;组件化微前端&#xff1a;iframe嵌入式微前端&#xff1a; 优点缺点 动态加载/懒加载微前端&#xff1a;微应用容器化方案&#xff1a; 微前端解决方案 single-spa阿里巴巴 Cloud Alfaiframe 方案Web ComponentsModule Fe…
阅读更多...
kafka消费端消息去重方案

kafka消费端消息去重方案

背景 我们在日常工作中&#xff0c;消费kafka消息是一个最常见的操作&#xff0c;不过由于kafka队列中经常包含重复的消息&#xff0c;并且消息量巨大&#xff0c;所以我们消费端总是需要先把消息进行去重后在消费&#xff0c;以减少消费端的压力&#xff0c;那么日常中我们一…
阅读更多...
Android视角看鸿蒙第一课（工程目录）

Android视角看鸿蒙第一课（工程目录）

Android视角看鸿蒙第一课&#xff08;工程目录&#xff09; 导读 鸿蒙马上就来了&#xff0c;这个工作很有可能落到Android开发的头上&#xff0c;既是机遇也是挑战&#xff0c;希望能跟上时代的浪潮&#xff0c;迫不得已开始学习鸿蒙开发&#xff0c;顺带分享记录下 我的学…
阅读更多...
四、神经网络语言模型（NNLM）

四、神经网络语言模型（NNLM）

神经网络&#xff08;Neural Network&#xff0c;NN&#xff09;主要由输入层、隐藏层、输出层构成&#xff0c;输入层的的节点数等于待处理数据中输入变量的个数&#xff08;每一个变量代表了一个特征&#xff09;&#xff0c;输出层的节点数等于与每个输入变量关联的输出的数…
阅读更多...
docker mysql主从复制

docker mysql主从复制

新建主服务器容器实例3301 mysql 主 3301 docker run -p 3301:3306 --name mysql-master \ -v /mydata/mysql-master/log:/var/log/mysql \ -v /mydata/mysql-master/data:/var/lib/mysql \ -v /mydata/mysql-master/conf:/etc/mysql \ -v /home/mysql/mysql-files:/var/lib/…
阅读更多...
微信小程序开发学习笔记《18》uni-app框架-网络请求与轮播图

微信小程序开发学习笔记《18》uni-app框架-网络请求与轮播图

微信小程序开发学习笔记《18》uni-app框架-网络请求 博主正在学习微信小程序开发&#xff0c;希望记录自己学习过程同时与广大网友共同学习讨论。建议仔细阅读uni-app对应官方文档 一、下载网络请求包 这个包是以前黑马程序员老师写的一个包&#xff0c;跟着课程学习&#x…
阅读更多...
【仿真总结】基于matlab的传递函数计算与绘图

【仿真总结】基于matlab的传递函数计算与绘图

前言 在DC-DC电路控制算法中&#xff0c;PID控制是最常见且实用的&#xff0c;但实现前提有二&#xff0c;一是需要手算电路传递函数&#xff0c;二是需要将实际电路元件数值代入计算&#xff0c;第一步无法避免&#xff0c;但是在进行第二步时&#xff0c;存在大量基础、细致的…
阅读更多...
Qt入门(一)Qt概述

Qt入门(一)Qt概述

Qt是什么&#xff1f; Qt是一个跨平台应用开发框架。 Qt既包括了一系列的Qt库&#xff0c;还包括诸多配套的开发工具如QtCreater&#xff0c;GUI Designer。Qt本身是由C开发的&#xff0c;但是也提供了其他编程语言的接口。 Qt的定位以及同类 学一种技术&#xff0c;最重要的是…
阅读更多...
蓝桥杯-Set

蓝桥杯-Set

目录 HashSet类常用方法 1 add(Object obj)方法 2 size() 方法 3 remove(Object obj)方法 4 contains()方法 5 clear() 方法 例题实战 set 一个不允许出现重复的元素&#xff0c;并且无序的集合&#xff0c;主要有HashSet实现类。 在判断重复元素的时候&#xff0c;Set集…
阅读更多...
基于Python实现银行卡识别

基于Python实现银行卡识别

在本文中将介绍如何使用Python和深度学习技术来实现银行卡识别功能。银行卡识别是一个在金融、安全等领域具有重要应用的问题&#xff0c;将使用深度学习模型来实现银行卡图像的识别和分类。 目录 引言数据集准备预处理和特征提取模型选择与训练模型评估与性能优化部署与应用 引…
阅读更多...
第三百八十六回

第三百八十六回

文章目录 概念介绍使用方法示例代码 我们在上一章回中介绍了Snackbar Widget相关的内容,本章回中将介绍TimePickerDialog Widget.闲话休提&#xff0c;让我们一起Talk Flutter吧。 概念介绍 我们在这里说的TimePickerDialog是一种弹出窗口&#xff0c;只不过窗口的内容固定显示…
阅读更多...
[Redis]——数据一致性，先操作数据库，还是先更新缓存？

[Redis]——数据一致性，先操作数据库，还是先更新缓存？

目录 一、操作缓存和数据库时有三个问题需要考虑&#xff1a; 1.删除缓存还是更新缓存&#xff1f; 2.如何保证缓存与数据库的操作同时成功或失效 3.先操作缓存还是先操作数据库&#xff08;多线程并发问题&#xff09; 二、 缓存更新的最佳策略 一、操作缓存和数据库时有…
阅读更多...
heic怎么转换成jpg？3个方法帮你一键批量转换

heic怎么转换成jpg？3个方法帮你一键批量转换

heic怎么转换成jpg&#xff1f;在日常生活中&#xff0c;将HEIC转换为JPG可以为我们带来诸多便利。JPG格式作为一种广泛被接受的图片格式&#xff0c;不仅兼容性更强&#xff0c;还能在各种设备和平台上顺畅显示。这意味着&#xff0c;无论是上传到社交媒体&#xff0c;还是发送…
阅读更多...
观其大略之HybridCLR学习笔记

观其大略之HybridCLR学习笔记

问题背景 1 现有热更方案的开发效率、性能没有到达极限&#xff0c;还有提升的空间 2 ios多平台政策导致热更新受限问题&#xff0c;ios禁止jit。根据我查找的资料&#xff0c;ios的代码段启动的时候就确定了&#xff0c;不能增加新的代码段。IOS封了内存&#xff08;或者堆&…
阅读更多...
MySQL基础-----SQL语句之DDL数据定义语句

MySQL基础-----SQL语句之DDL数据定义语句

目录 前言 开启登录数据库 一、数据库操作 1.查询所有数据库 2.切换使用数据库 3.查询当前使用的数据库 4.创建数据库 创建一个hello数据库, 使用数据库默认的字符集。 创建一个itheima数据库&#xff0c;并且指定字符集 5.删除数据库 二、表操作 1.查询当前数据库所有…
阅读更多...
html样式排版

html样式排版

<template><div class"box"><div class"header">头部</div><div class"main"><div class"left">菜单</div><div class"right"><div class"right-contentr"&g…
阅读更多...
可调恒定电流稳压器NSI50150ADT4G车规级LED驱动器 提供专业的汽车级照明解决方案

可调恒定电流稳压器NSI50150ADT4G车规级LED驱动器 提供专业的汽车级照明解决方案

NSI50150ADT4G产品概述&#xff1a; NSI50150ADT4G可调恒定电流稳压器 (CCR) &#xff0c;是一款简单、经济和耐用的器件&#xff0c;适用于为 LED 中的调节电流提供成本高效的方案&#xff08;与恒定电流二极管 CCD 类似&#xff09;。该 (CCR) 基于自偏置晶体管 (SBT) 技术&…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发