RabbitMQ 消息中间件
Kafka是LinkedIn开源的分布式发布-订阅消息系统，目前归属于Apache顶级项目。Kafka主要特点是基于Pull的模式来处理消息消费，追求高吞吐量，一开始的目的就是用于日志收集和传输。0.8版本开始支持复制，不支持事务，对消息的重复、丢失、错误没有严格要求，适合产生大量数据的互联网服务的
基于RabbitMQ的模拟消息队列之五——虚拟主机设计
基于RabbitMQ的模拟消息队列之五——虚拟主机设计
spring-boot对rabbitMQ的操作
1、简单的来理解，就是在上面简单模式下增加几个消费者，如同搬砖一样的，一个搬运工搬不过来，多叫几个人来干活的性质，避免消息堆积。2、生产者代码,运行下面的代码,查看可视化界面,并不存在消息,原因是因为需要手动创建。5、查看可视化界面，进入死信队列的是时间最早的(也就是最先发送的)1、使用配置文件的方
rabbitmq异常处理问题集
rabbitmq权限问题
Rabbitmq 的管理配置
每一个RabbitMQ 服务器都能创建虚拟的消息服务器，我们称之为虚拟主机(virtual host) ,简称为vhost 。每一个vhost 本质上是一个独立的小型RabbitMQ 服务器，拥有自己独立的队列、交换器及绑定关系等，井且它拥有自己独立的权限。vhost 就像是虚拟机与物理服务器一样，
RabbitMQ重复消费
解决 RabbitMQ 重复消费问题是消息队列应用中非常重要的一部分。在实际应用中，可能会出现消费者因某种原因（例如网络问题、应用崩溃等）在处理消息时失败，然后重新开始处理相同的消息，导致消息的重复消费。为了解决这个问题，我们可以采用一些方法和策略来确保消息不会被重复消费。
Docker中的RabbitMQ已经启动运行，但是管理界面打不开
肯定有好多小伙伴在学习RabbitMQ的过程中，发现镜像运行，但是我的管理界面怎么进不去，或者说我第一天可以进去，怎么第二天进不去了，为什么每次重新打开虚拟机都进不去了。下面我总结了解决这两种问题的方法，都是个人经历过的血泪。以上就是本人的血泪记录。
rabbitmq和rocketmq区别
开发语言和生态： RabbitMQ基于Erlang开发，采用AMQP协议，支持多种编程语言，比如Java、Python、Ruby等；高可用性： RabbitMQ具有较高的可用性和可靠性，支持主从模式、镜像队列等多种高可用部署方式。RocketMQ也支持主从模式和多副本同步复制，但是在某些情况下可能会
springboot对接rabbitmq并且实现动态创建队列和消费
/ 死信： 队列 交换机 绑定consumer 绑定队列。//设置延迟队列的 TTL 消息存活时间。// 延迟: 队列 交换机 绑定队列。// 绑定consumer 绑定队列。//设置延迟队列绑定的死信交换机。//设置延迟队列绑定的死信路由键。
RabbitMQ避免消息积压和消费者阻塞
通过生产者限流、消费者多线程、异步处理消息和超时处理等方法，我们可以避免RabbitMQ中消息的积压和消费者的阻塞。生产者限流可以控制消息的发送速度；消费者多线程可以提高消息处理的并发性能；异步处理消息可以避免消费者在处理消息时发生阻塞；超时处理可以避免消费者因为某个消息的处理时间过长而导致阻塞。本
RabbitMQ的LazyQueue
rabbitMQ中的lazyQueue
rabbitMq(路由模式)
idea实现路由模式//发布消息@Test//mq 建立连接// 创建管道// 管道/*** 发布订阅的时候* 交换机->direct* routingkey是一个具体的值* 队列*/// 创建交换机// 创建交换机// 交换机绑定队列//// 发布消息。
RabbitMQ之动态创建队列与绑定交换机和监听器
为什么需要动态创建队列与绑定交换机？我在写项目的时候遇到这么个问题，我数据库中存在一个字段messageType指定为消息类型，消息类型存在三种，一种是通知类，一种是验证码类，一种是活动类。并且对应的，要将消息进行不同渠道的分发，还存在一个channelType，而他又存在QQ邮箱，手机短信、服务号
RabbitMQ之发送者（生产者）可靠性
生产者重试机制、生产者确认机制。每个RabbitTemplate只能配置一个ReturnCallback，因此我们可以在配置类中统一设置。// 获取RabbitTemplate RabbitTemplate rabbitTemplate = applicationContext . getBean(
RabbitMQ - 修改日志和数据存放路径
默认情况下，RabbitMQ会将日志和数据存储在预定义的路径下。然而，有时候我们希望修改这些路径，以满足特定的需求。本文将详细介绍如何修改RabbitMQ的日志和数据存放路径，并提供相应的源代码示例。通过修改RabbitMQ的配置文件，我们可以轻松地修改日志和数据存放路径。在修改配置文件后，记得重启
RabbitMQ 安装和使用
AMQP，即 Advanced Message Queuing Protocol（英[ˈprəʊtəkɒl]）（高级消息队列协议），是一个网络协议，是应用层协议的一个开放标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。
SpringBoot 整合RabbitMQ 之延迟队列实验
实际业务中，例如秒杀系统，秒杀商品成功会有截止时间，这时需要用到RabbitMQ延迟服务。
rabbitMq (2)
本文主要内容：消息应答 , rabbitmq 持久化 ， 发布确认 , 几种分发模式
rabbitMQ rascal/amqplib报错 Error: Unexpected close 排查
这意味着客户端的 TCP 连接在 AMQP 0-9-1（该客户端的）连接之前关闭。TCP协议通过KeepAlive机制判断是应用程序掉线了还是确实没有数据传输，当超过一段时间之后，TCP自动发送一个数据为空的报文给对方，如果对方回应了这个报文，说明对方还在线，连接可以继续保持，如果对方没有报文返回，
