13.1 消息补偿机制介绍

RabbitMQ默认的补偿机制就是重试机制，当消费者程序报错时就会默认的去实现补偿机制，因为@RabbitListener底层使用的是AOP的异常通知进行拦截，自动实现补偿机制该消息会缓存到rabbitmq服务器端进行存放，一直重试到不报错。这样一直重试是有问题的，我们可以设置重试的间隔时间，当重试次数全部用完之后，消息就会被放弃掉。

在使用消息队列时防止消息重复消费是一个常见且关键的问题，尤其是在分布式系统中。以下是几种典型的解决方案，涵盖生产者、消费者和系统设计层面：

1. 生产者端：避免消息重复发送

（1）消息唯一标识（Message ID）

• 原理：为每条消息生成全局唯一ID（如UUID、雪花算法ID），并在发送前记录该ID。

1. 自动补偿机制

大家好，今天一起聊聊在软件性能测试过程中，可能会出现的RabbitMQ消息队列阻塞等问题影响到性能。

一、污点（Taint）

节点亲和性，是Pod的一种属性（偏好或硬性要求），它使Pod被吸引到一类特定的节点
Taint 则相反，它使节点能够排斥一类特定的 Pod

1 前言

SCDF指的是Spring Cloud Data Flow。

基于各种原因，团队的Kubernetes被加了限制，必须在特定的Node才可以部署。而之前没有指定，所以Spring Cloud Data Flow在跑Task时失败了，无法创建Pod。按照Spring官方文档配置也一直没用，后面查看源码、修改源码增加日志后终于解决了。

本地数据卷（Local Volume）代表一个本地存储设备，比如磁盘、分区或者目录等。主要的应用场景包括分布式存储和数据库等需要高性能和高可靠性的环境里。本地数据卷同时支持块设备和文件系统，通过 spec.local.path 指定；但对于文件系统来说，kubernetes 并不会限制该目录可以使用的存储空间大小。本地数据卷只能以静态创建的PV使用。相对于HostPath，本地数据卷可以直接以持久化的方式使用（它总是通过NodeAffinity调度在某个指定的节点上）。