Java操作Redis：从入门到实战- 惊觉

🌺The Begin🌺点点关注，收藏不迷路🌺

1. Redis Java开发环境搭建

1.1 环境准备

JDK 1.8+
Maven/Gradle构建工具
Redis服务器（本地或远程）

1.2 添加Jedis依赖

Maven配置：

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>4.3.1</version>
</dependency>

Gradle配置：

implementation 'redis.clients:jedis:4.3.1'

2. 基础连接与操作

2.1 建立连接

import redis.clients.jedis.Jedis;

public class RedisConnection {
    public static void main(String[] args) {
        // 创建连接
        Jedis jedis = new Jedis("localhost", 6379);
        
        // 认证（如有密码）
        // jedis.auth("yourpassword");
        
        // 测试连接
        System.out.println("连接状态: " + jedis.ping());
        
        // 关闭连接
        jedis.close();
    }
}

2.2 连接池配置

import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class RedisPool {
    private static JedisPool pool;
    
    static {
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(100);  // 最大连接数
        config.setMaxIdle(20);    // 最大空闲连接
        pool = new JedisPool(config, "localhost", 6379);
    }
    
    public static Jedis getResource() {
        return pool.getResource();
    }
}

3. 数据类型操作详解

3.1 String操作

public class StringOperations {
    public static void main(String[] args) {
        try (Jedis jedis = RedisPool.getResource()) {
            // 设置值
            jedis.set("username", "redis_user");
            
            // 获取值
            String value = jedis.get("username");
            System.out.println("用户名: " + value);
            
            // 自增操作
            jedis.incr("counter");
        }
    }
}

3.2 List操作

public class ListOperations {
    public static void main(String[] args) {
        try (Jedis jedis = RedisPool.getResource()) {
            // 左侧插入
            jedis.lpush("messages", "msg1", "msg2");
            
            // 右侧插入
            jedis.rpush("messages", "msg3");
            
            // 获取范围
            List<String> messages = jedis.lrange("messages", 0, -1);
            messages.forEach(System.out::println);
        }
    }
}

3.3 Hash操作

public class HashOperations {
    public static void main(String[] args) {
        try (Jedis jedis = RedisPool.getResource()) {
            // 设置字段
            jedis.hset("user:1001", "name", "张三");
            jedis.hset("user:1001", "age", "30");
            
            // 获取所有字段
            Map<String, String> user = jedis.hgetAll("user:1001");
            System.out.println("用户信息: " + user);
        }
    }
}

3.4 Set操作

public class SetOperations {
    public static void main(String[] args) {
        try (Jedis jedis = RedisPool.getResource()) {
            // 添加元素
            jedis.sadd("tags", "Java", "Redis", "Database");
            
            // 获取所有元素
            Set<String> tags = jedis.smembers("tags");
            System.out.println("标签集合: " + tags);
        }
    }
}

3.5 Sorted Set操作

public class ZSetOperations {
    public static void main(String[] args) {
        try (Jedis jedis = RedisPool.getResource()) {
            // 添加带分数元素
            jedis.zadd("ranking", 100, "Player1");
            jedis.zadd("ranking", 90, "Player2");
            
            // 获取排名
            Set<String> topPlayers = jedis.zrevrange("ranking", 0, 1);
            System.out.println("Top玩家: " + topPlayers);
        }
    }
}

4. 高级特性应用

4.1 事务处理

public class TransactionExample {
    public static void main(String[] args) {
        try (Jedis jedis = RedisPool.getResource()) {
            Transaction tx = jedis.multi();
            try {
                tx.set("tx_key1", "value1");
                tx.set("tx_key2", "value2");
                tx.exec();
            } catch (Exception e) {
                tx.discard();
                throw e;
            }
        }
    }
}

4.2 发布订阅

public class PubSubExample {
    public static void main(String[] args) {
        new Thread(() -> {
            try (Jedis jedis = RedisPool.getResource()) {
                jedis.subscribe(new JedisPubSub() {
                    @Override
                    public void onMessage(String channel, String message) {
                        System.out.println("收到消息: " + message);
                    }
                }, "channel1");
            }
        }).start();

        try (Jedis jedis = RedisPool.getResource()) {
            jedis.publish("channel1", "Hello Redis!");
        }
    }
}

4.3 管道技术

public class PipelineExample {
    public static void main(String[] args) {
        try (Jedis jedis = RedisPool.getResource()) {
            Pipeline pipeline = jedis.pipelined();
            for (int i = 0; i < 1000; i++) {
                pipeline.set("pkey:" + i, "value" + i);
            }
            pipeline.sync();
        }
    }
}

5. 性能优化与最佳实践

5.1 连接管理

5.2 批量操作建议

使用管道(Pipeline)处理批量命令
避免在循环中执行单个Redis命令
合理设置批处理大小（建议500-1000条/批）

5.3 异常处理模板

public class RedisTemplate {
    public <T> T execute(RedisOperation<T> operation) {
        try (Jedis jedis = RedisPool.getResource()) {
            return operation.execute(jedis);
        } catch (Exception e) {
            // 重试逻辑或降级处理
            throw new RedisException("操作失败", e);
        }
    }
    
    public interface RedisOperation<T> {
        T execute(Jedis jedis);
    }
}

6. 实战案例：缓存用户会话

public class SessionManager {
    private static final int SESSION_EXPIRE = 3600;
    
    public void saveSession(String sessionId, User user) {
        try (Jedis jedis = RedisPool.getResource()) {
            Pipeline p = jedis.pipelined();
            p.hset("session:" + sessionId, "userId", user.getId());
            p.hset("session:" + sessionId, "username", user.getUsername());
            p.expire("session:" + sessionId, SESSION_EXPIRE);
            p.sync();
        }
    }
    
    public User getSession(String sessionId) {
        try (Jedis jedis = RedisPool.getResource()) {
            Map<String, String> data = jedis.hgetAll("session:" + sessionId);
            if (data.isEmpty()) return null;
            
            User user = new User();
            user.setId(data.get("userId"));
            user.setUsername(data.get("username"));
            return user;
        }
    }
}

7. 常见问题解决方案

Q: 连接泄漏怎么办？
A: 确保使用try-with-resources或finally块关闭连接

Q: 如何提高吞吐量？
A:

使用连接池
启用管道
优化命令组合

Q: 集群模式如何配置？

Set<HostAndPort> nodes = new HashSet<>();
nodes.add(new HostAndPort("127.0.0.1", 7001));
nodes.add(new HostAndPort("127.0.0.1", 7002));
try (JedisCluster cluster = new JedisCluster(nodes)) {
    cluster.set("cluster_key", "value");
}

8. 总结

本文全面介绍了Java操作Redis的各项技术，包括：

环境搭建与连接配置
各种数据类型的操作示例
高级特性应用
性能优化策略
实战案例与最佳实践

通过合理使用Redis，可以显著提升Java应用的性能。建议根据实际业务场景选择合适的数据结构和操作方式，并注意资源管理和异常处理。

在这里插入图片描述

🌺The End🌺点点关注，收藏不迷路🌺

转载自 CSDN-专业IT技术社区

原文链接：https://blog.csdn.net/qq_41840843/article/details/148644544

Java操作Redis：从入门到实战