Spring Data Redis 教程

Redis Streams 追加(Appending)

在 Spring Data Redis 中,如果要向 Redis Stream 发送记录。可以与其他操作一样,使用低级 RedisConnection 或高级 StreamOperations 类来实现。

RedisConnection 和 StreamOperations 两个类都提供 add(xAdd)方法,该方法接受记录(record)和目标流(stream)作为参数。虽然 RedisConnection 需要原始数据(字节数组),但 StreamOperations 允许将任意对象作为记录(record)传入。

示例

RedisConnection

添加依赖

由于 Redis Stream 是 Redis 5.0 版本新增加的数据结构。因此,Spring Boot 需要更高的 Spring Data Redis 版本才能使用 Redis Stream,添加如下依赖:

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.5.6</version>
    <relativePath/> <!-- lookup parent from repository -->
</parent>

测试代码

创建一个简单的 @SpringBootTest 测试类,代码如下:

@Test
public void contextLoads() {
    System.out.println("redisTemplate = " + redisTemplate);
    redisTemplate.execute(new RedisCallback<String>() {
        @Override
        public String doInRedis(RedisConnection connection) throws DataAccessException {
            // Redis Stream 的键名
            byte[] stream = "myStream".getBytes();
            
            // Redis Stream 的数据
            Map<byte[],byte[]> map = new HashMap<>();
            map.put("title".getBytes(), "Redis Streams".getBytes());
            map.put("version".getBytes(), "v1.0.0".getBytes());
            map.put("summary".getBytes(),
                    "Redis Streams model a log data structure in an abstract approach.".getBytes());
                    
            // 将 Redis Stream 写入到 Redis
            MapRecord<byte[], byte[], byte[]> mapRecord =
                    StreamRecords.rawBytes(map).withStreamKey(stream);
            connection.xAdd(mapRecord);
            
            return null;
        }
    });
}

运行上面示例,然后利用 redis-cli 命令连接到 Redis 服务器。使用 xrange 命令查询刚刚写入的 Redis Stream 数据,如下:

D:\server\redis-x64-5.0.14.1>redis-cli
127.0.0.1:6379[2]> select 1
OK
127.0.0.1:6379[1]> xrange myStream - +
1) 1) "1666331433947-0"
   2) 1) "version"
      2) "v1.0.0"
      3) "title"
      4) "Redis Streams"
      5) "summary"
      6) "Redis Streams model a log data structure in an abstract approach."
127.0.0.1:6379[1]>

注意,上面的“select 1”语句用来选择下标为1的数据库,“xrange myStream - +”命令用来获取 Key 为 myStream 的 Redis Stream 中的数据。

RedisTemplate

下面演示使用 RedisTemplate 高级类向 Redis Stream 中添加数据,代码如下:

@Test
public void contextLoads() {
    System.out.println("redisTemplate = " + redisTemplate);
    StreamOperations<String,byte[], byte[]> ops = redisTemplate.opsForStream();
    // Redis Steam 键
    String key = "myStream";

    // Redis Stream 内容
    Map<byte[],byte[]> map = new HashMap<>();
    map.put("title".getBytes(), "Redis Streams".getBytes());
    map.put("version".getBytes(), "v1.0.0".getBytes());
    map.put("summary".getBytes(),
            "Redis Streams model a log data structure in an abstract approach.".getBytes());

    // 添加到 Redis Stream
    ops.add(key, map);
}

运行示例,然后利用 redis-cli 命令连接到 Redis 服务器。使用 xrange 命令查询刚刚写入的 Redis Stream 数据,如下:

D:\server\redis-x64-5.0.14.1>redis-cli
127.0.0.1:6379> select 1
OK
127.0.0.1:6379[1]> xrange myStream - +
1) 1) "1666366851342-0"
   2) 1) "title"
      2) "Redis Streams"
      3) "version"
      4) "v1.0.0"
      5) "summary"
      6) "Redis Streams model a log data structure in an abstract approach."
127.0.0.1:6379[1]>

说说我的看法
全部评论(
没有评论
关于
本网站属于个人的非赢利性网站,转载的文章遵循原作者的版权声明,如果原文没有版权声明,请来信告知:hxstrive@outlook.com
公众号