java-rabbitmq

刚学习RabbitMQ的同学可能对prefetchCount预取值这个参数有一些困惑，本文对其作用进行详细讲解。配合了几张有趣的图片方便同学们理解。 一、从轮询分发说起   首先要…

RabbitMQ—-生产者可靠性 生产者可靠性主要分为两个方面： 生产者重连 生产者确认 一、生产者重连         有的时候由于网络波动，可能会出现客户端连接MO…

应用场景： 异步处理。把消息放入消息中间件中，等到需要的时候再去处理。 流量削峰 例如秒杀活动，在短时间内访问量急剧增加，使用消息队列，当消息队列满了就拒绝响应，跳转到错误页面，这…

Kafka集群安装部署（超详细操作演示）—— Linux 简介 安装 测试Kafka能否正常使用 简介 Kafka是一款分布式的、去中心化的、高吞吐低延迟、订阅模式的消息队列系统。…

文章目录 1. 引言 2. 环境搭建 2.1 RabbitMQ概述 2.2 RabbitMQ安装环境 2.3 RabbitMQ安装 2.4 配置RabbitMq的环境变量 2.5 …

1. docker-compose配置内容： 2. 映射文件夹一定要赋予权限 不然程序启动无法写入数据：     chmod 777 /docker/rabbitmq/log ch…

一、背景 传统处理：如果不涉及到redis的话，最初的用户请求进来的流程大概是先去数据库判断下当前用户是否已经秒杀过当前商品，如果秒杀过的话则返回秒杀失败不能重复秒杀，否则的话则执…

RabbitMQ-Java 入门案例 参考非常详细的博主教程：https://www.cnblogs.com/dtdx/p/14362760.html SpringBoot+Jav…

RabbitMQ实现延时消息的两种方法 1、死信队列 1.1消息什么时候变为死信(dead-letter) 消息被否定接收，消费者使用basic.reject 或者 basic.n…

文章目录 项目背景 一、部署RabbiqMQ 二、设备连接鉴权 1.开启插件 2.修改配置 3.连接鉴权 4.消息鉴权 总结 项目背景 最近公司启动了一个新的物联网项目，使用MQT…

一、安装 前言 RabbitMQ服务端代码是使用并发式语言Erlang编写的，安装Rabbit MQ的前提是安装Erlang （ https://www.erlang.org/do…

一、访问控制台页面 如果在本机上装了RabbitMQ则在浏览器访问127.0.0.1:15672,如果在服务器装了RabbitMQ则通过在浏览器输入urlip:15762来访问 登…

文章目录 1.RabbitMQ消息丢失的三种情况 2.RabbitMQ消息丢失解决方案 2.1 针对生产者 2.1.1 方案1 ：开启RabbitMQ事务 2.1.2 方案2：使用…

总括执行流程：生产根据routingkey发送给交换机，而交换机通过routingkey来寻找对应的bindingkey从而把消息发送到队列里面去。 如果只有队列没有交换机的话，r…

当我们消息消费失败的时候，可以进行重试， 什么情况下会重发消息 1、网络抖动 2、程序抛出异常没有try-catch RabbitMQ自动补偿机制触发:(多用于调用第三方接口) 1…