Operation009-Prefetch
老大夫 发布于 2024-09-01 18:01
操作009：Prefetch
一、思路
生产者发送100个消息
对照两种情况：
消费端没有设置prefetch参数：100个消息被全部取回
消费端设置prefetch参数为1：100个消息慢慢取回
二、生产者端代码
@Test
public void testSendMessage() {
for (int i = 0; i < 1...
Operation008-Confirm03-Consumer
老大夫 发布于 2024-09-01 18:01
操作008-03：消费端消息确认
一、ACK
ACK是acknowledge的缩写，表示已确认
二、默认情况
默认情况下，消费端取回消息后，默认会自动返回ACK确认消息，所以在前面的测试中消息被消费端消费之后，RabbitMQ得到ACK确认信息就会删除消息
但实际开发中，消费端根据消息队列投递的消息执行对应的业务，未必都能执行成功，如果希望能够多次重试，那么...
Operation008-Confirm02-Duration
老大夫 发布于 2024-09-01 18:00
操作008-02：交换机和队列持久化
一、测试非持久化交换机和队列
1、创建非持久化交换机
创建之后，可以在列表中看到：
2、创建非持久化队列
创建之后，可以在列表中看到：
3、绑定
4、发送消息
public static final String EXCHANGE_TRANSIENT = "exchange.transient.user...
Operation008-Confirm01-B-BackupEx
老大夫 发布于 2024-09-01 17:59
操作008-01-B：备份交换机
一、创建备份交换机
1、创建备份交换机
注意：备份交换机一定要选择fanout类型，因为原交换机转入备份交换机时并不会指定路由键
2、创建备份交换机要绑定的队列
①创建队列
②绑定交换机
注意：这里是要和备份交换机绑定
3、针对备份队列创建消费端监听器
public static final String ...
Operation008-Confirm01-A-Producer生产者端消息确认机制
老大夫 发布于 2024-09-01 17:58
操作008-01-A：生产者端消息确认机制
一、创建module
二、搭建环境
1、配置POM
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</art...
Operation007-SpringBoot
老大夫 发布于 2024-09-01 16:27
操作007：整合SpringBoot
1、消费者工程
①创建module
②配置POM
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifac...
Operation006-Topics
老大夫 发布于 2024-09-01 16:27
操作006：主题模式
一、生产者代码
package com.atguigu.rabbitmq.topic;
import com.atguigu.rabbitmq.util.ConnectionUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.c...
Operation005-Routing
老大夫 发布于 2024-09-01 16:26
操作006-路由模式
一、生产者代码
package com.atguigu.rabbitmq.routing;
import com.atguigu.rabbitmq.util.ConnectionUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq...
Operation004-PubSub
老大夫 发布于 2024-09-01 16:26
操作004：发布订阅模式
一、生产者代码
package com.atguigu.rabbitmq.fanout;
import com.atguigu.rabbitmq.util.ConnectionUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitm...
java: 不再支持源选项 5。请使用 7 或更高版本
老大夫 发布于 2024-09-01 14:28
POM中没有指定java版本
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
...
Operation003-WorkQueue
老大夫 发布于 2024-09-01 14:04
操作003：工作队列模式
一、生产者代码
1、封装工具类
package com.atguigu.rabbitmq.util;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
public class Connection...
Operation002-HelloWorld
老大夫 发布于 2024-09-01 13:02
操作002：HelloWorld
一、目标
生产者发送消息，消费者接收消息，用最简单的方式实现
官网说明参见下面超链接：
RabbitMQ tutorial - "Hello World!" — RabbitMQ
二、具体操作
1、创建Java工程
①消息发送端（生产者）
②消息接收端（消费者）
③添加依赖
<depend...
Operation001-Install
老大夫 发布于 2024-09-01 10:29
操作001：RabbitMQ安装
一、安装
# 拉取镜像
docker pull rabbitmq:3.13-management
# -d 参数：后台运行 Docker 容器
# --name 参数：设置容器名称
# -p 参数：映射端口号，格式是“宿主机端口号:容器内端口号”。5672供客户端程序访问，15672供后台管理界面访问
# -v 参数：卷映...
乐尚代驾P178集的RequestUtils类
老大夫 发布于 2024-09-01 09:18
先吐槽一下，大部分学这个的都是个人学员吧，没有企业微信支付接口也不先给个解决方法。
个人不要花钱去搞，没必要，不耽误跟着听完整个项目，只不过最后不能测试，或者自己想办法屏蔽掉微信支付。
import jakarta.servlet.http.HttpServletRequest;
import java.io.BufferedReader;
import j...
