RabbitMQ学习笔记 一、MQ简介 1.、什么是 MQ MQ(message queue),从字面意思上看,本质是个队列,FIFO 先入先出,只不过队列中存放的内容是 message 而已,...
目录 1、生产者+消费者工程搭建 2、订阅/发布模式 2.1、消费者代码 2.2、生产者代码 2.3、测试 3、LPUSH+BRPOP模式 3.1、消费者代码 3.2、生产者代...
目录 1、消息分发机制 2、不公平分发 3、预值分发 1、消息分发机制 RabbitMQ 分发消息默认采用的轮训分发,但是在某种场景下这种策略并不是很好,当有两...
目录 1、概述 2、队列持久化 3、消息持久化 1、概述 如何保障当 RabbitMQ 服务停掉以后消息生产者发送过来的消息不丢失,默认情况下 RabbitMQ 退出或由于...
目录 消息应答 1、概念 2、自动应答 3、手动应答 4、手动批量应答(Multiple) 5、消息自动重新入队 6、手动应答代码实现 7、源码地址 消息应答 参考代...
目录 1、概述 2、工具类封装 3、简单列队模式 4、工作列队模式 5、发布/订阅模式 6、路由模式 7、主题模式 8、交换机说明 9、发布确认模式(消息确认机制) ...
创建channel (信道) ConnectionFactory factory = new ConnectionFactory();factory.setHost("192.168.1.104");factory.setUsername("root");factory.setP...
目录 1、环境搭建 2、队列模式 3、发布订阅模式 4、路由模式 5、主题模式 6、消息手动应答机制 7、回调函数-确认机制(发布确认模式) 1、环境搭建 引入pom...
目录 1、DelayExchange插件配置 1.1、下载DelayExchange插件 1.2、安装DelayExchange插件 1.3、启动DelayExchange插件 2、使用原理 3、使用说明 4、完...
目录 前言: 1、pom文件 2、静态工具类 3、实现HandshakeInterceptor 4、配置消息发送类 5、配置实体类 6、实现WebSocketHandler 7、WebSocketConfig配置 ...