分类：Springboot整合RabbitMq

2022
10-08

SpringBoot整合RabbitMQ实现消息确认机制

前面几篇案例已经将常用的交换器（DirectExchange、TopicExchange、FanoutExchange）的用法介绍完了，现在我们来看一下消息的回调，也就是消息确认。在rabbitmq-provider项目的application.yml文件上加上一些配置server:port:8021spring:#给项目来个名字application:name:rabbitmq-provider#配置rabbitMq服务器rabbitmq:host:127.0.0.1port:5672username:guestpassword:guest#connection... 继续阅读 >

2021
05-19

springBoot整合rabbitMQ的方法详解

引入pom<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId... 继续阅读 >

2021
03-14

SpringBoot整合RabbitMQ, 实现生产者与消费者的功能

自然，依赖是少不了的。除了spring-boot-starter-web依赖外。就这个是最主要的依赖了，其他的看着办就是了。我用的是gradle,用maven的看着弄也一样的。无非就是包+包名+版本//AMQPcompile('org.springframework.boot:spring-boot-starter-amqp:2.0.4.RELEASE')这里有一个坑。导致我后来发送消息时一直连不上去。报错:java.net.SocketException:socketclosed。我去网上寻找了许多方案。大致都是一个意思。没有设置远程连接权限。... 继续阅读 >

2021
01-09

SpringBoot整合RabbitMQ 手动应答(简单demo)

版本说明JDK1.8RabbitMQ3.7.15Erlang22.0SpringBoot2.3.3.RELEASE//TODO2021年1月8日整理CentOS安装RabbitMQ流程1.在RabbitMQ的Web管理界面，创建test队列参数的含义durability：是否持久化（重启或宕机后消息依然保存）durable持久transient暂时新建maven项目。2.pom.xml<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w... 继续阅读 >

2020
12-22

Springboot 整合RabbitMq(用心看完这一篇就够了)

该篇文章内容较多，包括有rabbitMq相关的一些简单理论介绍，provider消息推送实例，consumer消息消费实例，Direct、Topic、Fanout的使用，消息回调、手动确认等。（但是关于rabbitMq的安装，就不介绍了）在安装完rabbitMq后，输入http://ip:15672/，是可以看到一个简单后台管理界面的。在这个界面里面我们可以做些什么？可以手动创建虚拟host，创建用户，分配权限，创建交换机，创建队列等等，还有查看队列消息，消费效率，推送... 继续阅读 >