心跳超时（heartbeat timeout） 定义了经过多长时间没有心跳，我们就认为RabbitMQ和客户端之间的连接不可达。这个值是在客户端和RabbitMQ服务端建立连接的时候通过商讨得出的。客户端必须配置有心跳。 协商过程为： 服务端提供一个配置好的值（默认60s） 客户端就收到服务端的值后，与客户端自己配置的值对比，并得出结果。 客户端将结果发送回服务端。 客户端默认协商对比机制为： 任何一方为0，则取另一方不为0的值。 双方都不为0，取最小值。 双方都为0，禁止心跳。

前言 最近公司内网部署RabbitMQ服务器，部署上测试后安全部门扫描到MQ服务器有一个漏洞【禁用AMQP配置中的明文身份验证机制】。本文记录解决该漏洞的过程和方法，以及遇到的问题 配置流程 主要步骤为： 在服务器生成所需的两对密钥和CA证书，然后将CA、服务器公私钥放到Rabbit目录下并添加配置文件 将服务器公钥转换为Java专用JKS格式，然后将客户端私钥和JKS一起拷贝到本地，通过Java或者Springboot-amqp连接 生成CA证书、客户端密钥、服务器密钥

实现本案例之前先 来手动的安装一遍rabbitMQ吧，非Docker安装 实验环境：阿里云centos7.2（也可以安装在本地） 物理设备 ：一台笔记本 安装步骤如下： 一 安装软件 1. 安装依赖环境 在线安装依赖环境： yum install build-essential openssl openssl-devel unixODBC unixODBC-devel make gcc gcc-c++ kernel-devel m4 ncurses-devel tk tc xz

如果没有安装rabbitmq》》》》linux安装rabbitmq 一、导入依赖 <!--AMQP依赖--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> 二、编写配置 下面配置都是spring:

目录 1、什么是死信队列 2、产生死信队列的原因 3、代码实现---直连交换机 3.1、导入依赖 3.2、配置rabbitmq连接信息 3.3、编写配置类 3.4、编写生产者 3.5、编写消费者 3.6、测试 4、死信队列的架构原理 5、死信队列应用场景 1、什么是死信队列         RabbitMQ死信队列俗称，备胎队列；消息中间件因为某种原因拒收该消息后，可以转移到死信队列中存放，死信 队列也可以有交换机和路由key等。消费者在消费生产者生产的消息时发生了某

下载延迟插件 在 RabbitMQ 的 3.5.7 版本之后，提供了一个插件（rabbitmq-delayed-message-exchange）来实现延迟队列 ，同时需保证 Erlang/OPT 版本为 18.0 之后。 我这里 MQ 的版本是 3.10.5，现在去 GitHub 上下载最新版插件（插件具有兼容性） 下载地址：https://github.com/rabbitmq/rabbitmq-delayed-message-exchange/releases 下载.ez后缀的版本安装插件

  目录 前言 1.bbitMQ环境搭建 2.RabbitMQ测试 2.1.添加账号 2.2.编码实测 前言 大家好，我是月夜枫，我又来了！！！！ 最近写的消息队列系列文章，当时只讲解了消息队列的选型，以及RabbitMQ、Kafka、RocketMQ的基本原理，现在选择RabbitMQ进行实战方面的讲解，其实主要是为了将之前的“债”给还上。 1.bbitMQ环境搭建 因为我用的是Mac，所以直接可以参考官网： https://www.rabbitmq.c

[版权申明] 非商业目的注明出处可自由转载 出自：shusheng007 概述 好久没有写博客了，终日忙于生计，真是人过30不如狗啊，但写点什么好呢？想想当年自己入门时候那痛苦的经历，还是写点优质实用的入门文章吧，既满足了自己好为人师的本性，也能给后辈提供一些帮助。今天咱们就来聊聊springboot 整合rabbitmq的那些事吧。 SpringBoot的风头之盛不多说了，我是在2016年首次接触springboot的，当时自己要写个APP，后台采用了springbo

RabbitMQ通过Exchange(交换机)将消息根据不同规则路由到对应的Queue(队列)中，本文主要简述交换机的四种类型，仅供学习分享使用，如有不足之处，还请指正。 RabbitMQ交换机类型 RabbitMQ一共四种交换机，如下所示： Direct Exchange：直连交换机，根据Routing Key(路由键)进行投递到不同队列。 Fanout Exchange：扇形交换机，采用广播模式，根据绑定的交换机，路由到与之对应的所有队列。 Topic Exchange：主题交换机，

1. RPC Remote Procedure Call：远程过程调用，一次远程过程调用的流程即客户端发送一个请求到服务端，服务端根据请求信息进行处理后返回响应信息，客户端收到响应信息后结束 2. Client interface客户端接口 为了说明如何使用RPC服务，我们将把“发送方”和“接收方”更改为“客户端”和“服务器”。当我们调用服务时，我们将得到我们对应的斐波那契值 Integer response = (Integer) template.convertSendAndRe

聊聊 RabbitMQ 消息可靠性的保证 消息可能会出现的不可靠问题： 消息丢失 消息重复 消息积压 1、消息丢失 产生的原因及相应的解决方案 原因一： ​  消息发送出去，但由于网络问题没有成功抵达服务器，造成消息丢失。 解决方案： ​  做好相应的日志记录（将消息信息写入数据库）和容错方法（try-catch 尝试重发、定期扫描数据库将发送失败的消息进行重发） try{ // 业务代码... // 将消息信息写入数据库（如：消息id、消息内容、目的地、

什么是RabbitMQ? RabbitMQ是一个消息代理 - 一个消息系统的媒介。 RabbitMQ服务器是用Erlang语言编写的，而集群和故障转移是构建在开放电信平台框架上的。 它可以为你的应用提供一个通用的消息发送和接收平台，并且保证消息在传输过程中的安全。 为什么要选择RabbitMQ,不选其他MQ? kafka是以吞吐量高而闻名，不过其数据稳定性一般，而且无法保证消息有序性。如果公司的项目中使用了MQ作为日志收集，建议选择使用RabbitMQ。 阿里巴巴的Rock