Redis流详解及Java实践

import redis.clients.jedis.Jedis;
import redis.clients.jedis.StreamEntryID;
 
public class RedisStreamExample {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("localhost", 6379);
        
        // 使用XADD添加消息到流中
        String streamKey = "mystream";
        String field1 = "field1";
        String value1 = "value1";
        String field2 = "field2";
        String value2 = "value2";
        String addedMessageId = jedis.xadd(streamKey, field1, value1, field2, value2);
        System.out.println("添加的消息ID: " + addedMessageId);
        
        // 使用XREAD读取消息，阻塞模式
        StreamEntryID streamEntryID = StreamEntryID.UNRECEIVED_ENTRY; // 从开始读取
        jedis.xread(StreamReadOptions.block(0), streamKey, streamEntryID);
        
        // 使用XDEL删除消息
        String messageIdToDelete = "1526572994611-0";
        long numberOfDeletedMessages = jedis.xdel(streamKey, messageIdToDelete);
        System.out.println("删除的消息数量: " + numberOfDeletedMessages);
        
        // 使用XTRIM修剪流，只保留最新的N个消息
        long count = 5;
        jedis.xtrim(streamKey, count);
        
        jedis.close();
    }
}

这段代码展示了如何在Java中使用Jedis客户端库来操作Redis的流数据类型。代码中包含了添加消息、读取消息（阻塞模式）、删除消息和修剪流等操作。这些操作是Redis流功能的基本用法，对开发者有很好的示范作用。