Java 使用Reactive Redis

文章目录

前言
代码
自定义业务

前言

目前项目中，有使用到 Redis 的需求。场景如下：
在使用消息队列时，难免会遇到重复消费的事情，因为队列本身不处理这个。
那么就可以使用 Redis 来做一个避免重复消费的操作。

假如你的消息队列是 rocket mq，在消息消费端，获取到的 MessageExt对象，可以拿到消息的 ID。
我们在刚拿到这个ID时，就立刻对其进行存储（可以拼接你自己的业务前缀）。
可以使用 redis 的 setIfAbsent ，也就是 setNx 命令。

每次能够用存储成功 MessageID时，再去执行消费。如果Redis中有了当前的 MessageId，就证明它是之前消费过的，就直接舍弃。从而达到了避免重复消费的效果。

代码

核心代码其实并不多，这里只提供一下公共的配置，以及方法。
代码仓库如下：
https://gitee.com/fengsoshuai/mine-reactive-redis

自定义业务

https://gitee.com/fengsoshuai/customer-redis-feng

对以上代码做了调整，主要是自定义了业务前缀，可以定制化自己的业务需求。
对应在Nacos中的配置如下：

Java 使用Reactive Redis相关推荐

c#获取对象的唯一标识_在 Java 中利用 redis 实现分布式全局唯一标识服务
作者: 杨高超 juejin.im/post/5a4984265188252b145b643e 获取全局唯一标识的方法介绍在一个IT系统中,获取一个对象的唯一标识符是一个普遍的需求.在以前的单体应用 ...
Caused by: java.lang.NoClassDefFoundError: redis/clients/util/Pool
严重: Exception sending context initialized event to listener instance of class org.springframework.we ...
在java中使用redis
在java中使用redis很简单,只需要添加jedist.jar,通过它的api就可以了.而且,api和redis的语法几乎完全相同.以下简单的测试: 参考:http://www.runoob.com ...
在 Java 中利用 redis 实现 LBS 服务
前言 LBS(基于位置的服务) 服务是现在移动互联网中比较常用的功能.例如外卖服务中常用的我附近的店铺的功能,通常是以用户当前的位置坐标为基础,查询一定距离范围类的店铺,按照距离远近进行倒序排序. 自 ...
Redis介绍 Java客户端操作Redis
Redis介绍 && Java客户端操作Redis 本文内容 redis介绍 redis的 shell 客户端简介 redis的 java 客户端简介环境配置 redis 2.8.1 ...
Redis介绍 Java客户端操作Redis
分享一下我老师大神的人工智能教程.零基础!通俗易懂!风趣幽默!还带黄段子!希望你也加入到我们人工智能的队伍中来!https://blog.csdn.net/jiangjunshow Redis介绍 & ...
Redis笔记（六）：Java中使用Redis
Java程序使用Redis 添加依赖包 Maven依赖方式 <dependency><groupId>redis.clients</groupId><arti ...
(2) java项目中用redis
Java 使用 Redis 安装开始在 Java 中使用 Redis 前, 我们需要确保已经安装了 redis 服务及 Java redis 驱动,且你的机器上能正常使用 Java. Java的安装 ...
java怎么弄redis,java怎么使用redis
开始在 Java 中使用 Redis 前, 我们需要确保已经安装了 redis 服务及 Java redis 驱动,且你的机器上能正常使用 Java. Java的安装配置可以参考我们的 Java开发环 ...

Java 使用Reactive Redis

文章目录

前言

代码

自定义业务

Java 使用Reactive Redis相关推荐

最新文章

热门文章