# redisStream

**Repository Path**: kevin323/redis-stream

## Basic Information

- **Project Name**: redisStream
- **Description**: redisStream学习，简单实现自动生成数据，消费组进行消费功能
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 3
- **Created**: 2023-09-01
- **Last Updated**: 2025-05-24

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# REDIS Stream
## 1、校验stream是否存在，不存在需创建stream
## 2、自动ack和不自动ack的需要分开放
## 3、死信处理（消费了几次才处理）
## 4、创建定时任务来进行消费，每秒一次，一次消费5条
## 5、stream中无数据时不消费
## 6、RedisStreamConfig与RedisStreamConfiguration二选一配置，其中RedisStreamConfig更灵活方便
## 7、RedisUserInfoStreamConfig主要是为了直接添加实体类使用，在使用时需单独配置
### 在使用7的时候需要加上以下配置货在StreamMessageListenerContainerOptions中配置，否则容易出问题（乱码）
###   redisTemplate.setKeySerializer(new StringRedisSerializer());
###   redisTemplate.setValueSerializer(new StringRedisSerializer());
###   redisTemplate.setHashKeySerializer(new StringRedisSerializer());

* 1、检测 RedisTemplate的HashValueSerializer的序列化方式，最好不要使用json可以使用RedisSerializer.string()。
* 2、检查redisTemplate.opsForStream()中配置的HashMapper，默认是ObjectHashMapper这个是把对象字段和值序列化成byte[]格式。

# Redisson Delayed Queue
## 1、添加数据 testRedissonDelayQueueOffer
## 2、消费数据 RedisDelayQueueRunner