RedisRedis 使用 redisson 做分布式锁 复盘 maven 依赖 netty 冲突

Posted 2021-06-30 九师兄

本文为博主九师兄（QQ:541711153 欢迎来探讨技术）原创文章，未经允许博主不允许转载。

文章目录

• 1.概述

1.概述

今天想要做一个功能，大概是 flink任务中，输出到100条数据的时候，就要停止输出。并且输出一个特殊的信息。这里每次发送一个消息，记录。

难点：

1. flink任务是并行处理的，要求所有并行度，总共输出不能超过100.
2. 最后输出一条特殊的消息，因此每个并行度都要判断哪个是最后的一条消息。

我这里采用redis分布式锁，去做。核心就是。

发送一条数据，我就在redis中某个key增加1，然后每次去读取，然后判断是不是超过限制了。如果超过限制那么输出一条告警信息。

开始我引入了如下

<dependency