AI 助理
备案控制台
开发者社区 数据库 文章 正文

Redis极简入门-Java操作Redis

2023-07-29 439
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 Tair（兼容Redis），内存型 2GB
推荐场景：
通过缓存加速数据库访问
Redis 开源版，标准版 2GB
推荐场景：
搭建游戏排行榜
简介： 1.Java集成Jedis开始在 Java 中使用 Redis 前， 我们需要确保已经安装并启动 redis 服务及 Java redis 驱动，且你的机器上能正常使用 Java。可以取Maven仓库下载驱动包 下载 jedis.jar，。

1.Java集成Jedis

开始在 Java 中使用 Redis 前， 我们需要确保已经安装并启动 redis 服务及 Java redis 驱动，且你的机器上能正常使用 Java。可以取Maven仓库下载驱动包 下载 jedis.jar，。

1.1.搭建工程

  • 搭建普通java项目，项目名：jedis-demo

1.2.导入Jedis依赖

  • 把Jedis和连接池包一起导入进来
commons-pool2-2.2.jar   #连接池
jedis-2.5.2.jar         #Jedis核心包
• 1
• 2

1.3.编写测试类

  • 通过Jedis客户端对象连接Redis，调用API进行Redis
@Test
public void testJedis()throws Exception{
    //创建连接
    String host ="127.0.0.1";
    //端口
    int port = 6379;
  //超时时间,1秒超时
    int timeout = 1000;
    //jedis客户端
    Jedis jedis = new Jedis(host,port,timeout);
    //认证
    jedis.auth("123456");
    //执行操作,保存值
    jedis.set("username","wang da cui");
    //获取值
    String result = jedis.get("username");
    System.out.print(result);
    //关闭连接
    jedis.close();
}

1.4.连接池的使用

如果直接使用 Jedis链接Redis会造成频繁的Jedis对象创建和销毁，对性能会有很大的影响，所以我们会选择使用连接池来链接性能。原理同Mysql连接池

  • 编写测试方法，使用JedisPool连接池对象
@Test
public void test()throws Exception{
    //1 创建jedispool配置对象
    JedisPoolConfig config = new JedisPoolConfig();
    //2 做配置
    //最大空闲连接数
    config.setMaxIdle(2);
    //最大链接对象数
    config.setMaxTotal(10);
    //链接超时时间
    config.setMaxWaitMillis(1*1000);
    //获取连接是测试连接是否畅通
    config.setTestOnBorrow(true);
    //3 创建jedispool连接池对戏
    //参数：配置对象，redis主机地址 ，超时时间，密码
    JedisPool pool = new JedisPool(config,"127.0.0.1",6379,1*1000,"123456");
    //4 通过jedispool获取连接
    Jedis jedis = pool.getResource();
    //5 执行操作
    jedis.set("age",10);
    String result = jedis.get("age");
    System.out.println(result);
    // 6 释放连接 , 底层做了兼容,如果是连接池操作就是释放,如果是连接操作就是关闭
    jedis.close(); 
    // 7 摧毁连接池-如果是真正项目中它应该是一个受spring管理的单例
    pool.destroy();
}
  • 工具类封装：JedisPool应该是单例的(想想你的Mybatis的DataSource也只是创建了一个)，为了方便使用，将JedisPool封装成工具。

redis.properties

redis.host=127.0.0.1
redis.port=6379
redis.password=123456
redis.timeout=5000
• 1
• 2
• 3
• 4

RedisUtils

package org.example;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import java.util.Properties;
import java.util.Set;
/**
 * 获取连接池对象
 */
public enum RedisUtils {
    INSTANCE;
    //连接池
    static JedisPool jedisPool = null;
    static {
        //1 创建连接池配置对象
        JedisPoolConfig config = new JedisPoolConfig();
        //2 进行配置-四个配置
        config.setMaxIdle(1);//最小连接数
        config.setMaxTotal(11);//最大连接数
        config.setMaxWaitMillis(10 * 1000L);//最长等待时间
        config.setTestOnBorrow(true);//测试连接时是否畅通
        //3 通过配置对象创建连接池对象
        Properties properties = null;
        try {
            properties = new Properties();
            properties.load(RedisUtils.class.getClassLoader().getResourceAsStream("redis.properties"));
        } catch (IOException e) {
            e.printStackTrace();
        }
        String host = properties.getProperty("redis.host");
        String port = properties.getProperty("redis.port");
        String password = properties.getProperty("redis.password");
        String timeout = properties.getProperty("redis.timeout");
        jedisPool = new JedisPool(config, host, Integer.valueOf(port),Integer.valueOf(timeout), password);
    }
    //获取连接
    public Jedis getSource() {
        return jedisPool.getResource();
    }
    //关闭资源
    public void closeSource(Jedis jedis) {
        if (jedis != null) {
            jedis.close();
        }
    }
    /**
     * hash操作字符串==============================================
     */
    public List<String> hvals(String key) {
        Jedis jedis = getSource();
        List<String> hvals = jedis.hvals(key);
        closeSource(jedis);
        return hvals;
    }
    public Set<String> hkeys(String key) {
        Jedis jedis = getSource();
        Set<String> hkeys = jedis.hkeys(key);
        closeSource(jedis);
        return hkeys;
    }
    public Long hset(String key,String field,String value) {
        Jedis jedis = getSource();
        Long result = jedis.hset(key,field,value);
        closeSource(jedis);
        return result;
    }
    public String hmset(String key, Map<String,String> data) {
        Jedis jedis = getSource();
        String result = jedis.hmset(key,data);
        closeSource(jedis);
        return result;
    }
    public String hget(String key,String field) {
        Jedis jedis = getSource();
        String value = jedis.hget(key, field);
        closeSource(jedis);
        return value;
    }
    /**
     * hash操作byte[]==============================================
     */
    public List<byte[]> hvals(byte[] key) {
        Jedis jedis = getSource();
        List<byte[]> hvals = jedis.hvals(key);
        closeSource(jedis);
        return hvals;
    }
    public Set<byte[]> hkeys(byte[] key) {
        Jedis jedis = getSource();
        Set<byte[]> hkeys = jedis.hkeys(key);
        closeSource(jedis);
        return hkeys;
    }
    public Long hset(byte[] key,byte[] field,byte[] value) {
        Jedis jedis = getSource();
        Long result = jedis.hset(key,field,value);
        closeSource(jedis);
        return result;
    }
    public String hmset(byte[] key, Map<byte[],byte[]> data) {
        Jedis jedis = getSource();
        String result = jedis.hmset(key,data);
        closeSource(jedis);
        return result;
    }
    public byte[] hget(byte[] key,byte[] field) {
        Jedis jedis = getSource();
        byte[] value = jedis.hget(key, field);
        closeSource(jedis);
        return value;
    }
    /**
     * 删除key
     */
    public boolean del(String key) {
        Jedis jedis = getSource();
        long result  = jedis.del(key);
        closeSource(jedis);
        return result > 0;
    }
    /**
     * 设置字符值
     *
     * @param key
     * @param value :value是字符串，如果要存储对象，转成JSON字符串在存储
     */
    public void set(String key, String value) {
        Jedis jedis = getSource();
        jedis.set(key, value);
        closeSource(jedis);
    }
    /**
     * 设置
     * @param key
     * @param value
     */
    public void set(byte[] key, byte[] value) {
        Jedis jedis = getSource();
        jedis.set(key, value);
        closeSource(jedis);
    }
    /**
     *
     * @param key
     * @return
     */
    public byte[]  get(byte[] key) {
        Jedis jedis = getSource();
        try {
            return jedis.get(key);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            closeSource(jedis);
        }
        return null;
    }
    /**
     * 设置字符值
     *
     * @param key
     * @return ：返回的是JSON格式的字符串 ，考虑转对象
     */
    public String get(String key) {
        Jedis jedis = getSource();
        try {
            return jedis.get(key);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            closeSource(jedis);
        }
        return null;
    }
}

2.Jedis的API操作

使用jedis来操作redis的key和value，而value有很多种类型，和命令操作一样。

2.1.key的操作

System.out.println(jedis.keys("*"));

2.2.String的操作

System.out.println(jedis.set("name","zhangsan"));//新增
System.out.println(jedis.get("name"));//获取
System.out.println(jedis.set("name","zhangsan1"));//修改
System.out.println(jedis.get("name"));//获取
System.out.println(jedis.del("name"));//删除
System.out.println(jedis.keys("*"));//查看所有的key

2.3.List的操作

jedis.lpush("students1","1","2","3","5","6"); //添加数据
System.out.println(jedis.lrange("students1", 0, 3));  //获取数据
  • 排序操作，对于数字元素排序不需要加SortingParams，对于字符串需要指定SortingParams，并且指定使用assii值排序
//对数字排序
jedis.flushDB();
//添加数据
jedis.lpush("nums","1","2","3","4","8","5","3","1");
//排序
System.out.println(jedis.sort("nums"));
//指定排序方式
SortingParams sortingParams1 = new SortingParams();
sortingParams1.desc();
System.out.println(jedis.sort("nums", sortingParams1));
//对字母排序
jedis.lpush("langues","java","php","c++","test","ui");
SortingParams sortingParams = new SortingParams();
sortingParams.alpha();
sortingParams.desc();
System.out.println(jedis.sort("langues",sortingParams));

2.4.Set的操作

jedis.sadd("students2","a1","b1","c1","b1");    //添加数据
System.out.println(jedis.smembers("students2"));  //获取成员

2.5.Hash操作

jedis.hset("students3","student","zhangsan");     //添加数据
System.out.println(jedis.hget("students3", "student"));  //获取数据

2.6.Hash存储对象

序列化SerializeUtil.java

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
public class SerializeUtil {
    /**
     * 序列化
     * 
     * @param object
     * @return
     */
    public static byte[] serialize(Object object) {
        ObjectOutputStream oos = null;
        ByteArrayOutputStream baos = null;
        try {
            // 序列化
            baos = new ByteArrayOutputStream();
            oos = new ObjectOutputStream(baos);
            oos.writeObject(object);
            byte[] bytes = baos.toByteArray();
            return bytes;
        } catch (Exception e) {
        }
        return null;
    }
    /**
     * 反序列化
     * 
     * @param bytes
     * @return
     */
    public static Object unserialize(byte[] bytes) {
        ByteArrayInputStream bais = null;
        try {
            // 反序列化
            bais = new ByteArrayInputStream(bytes);
            ObjectInputStream ois = new ObjectInputStream(bais);
            return ois.readObject();
        } catch (Exception e) {
        }
        return null;
    }
}

实体类User.java

import java.io.Serializable;
public class User implements Serializable {
    @Override
    public String toString() {
        return "User{" +
                "username='" + username + '\'' +
                ", id=" + id +
                '}';
    }
    private String username;
    private Long id;
    public String getUsername() {
        return username;
    }
    public void setUsername(String username) {
        this.username = username;
    }
    public Long getId() {
        return id;
    }
    public void setId(Long id) {
        this.id = id;
    }
    public User() {
    }
    public User(String username, Long id) {
        this.username = username;
        this.id = id;
    }
}

测试代码

import com.alibaba.fastjson.JSON;
import org.junit.Test;
import java.util.*;
public class RedisTest {
    private User createUser(){
        return new User("zs",1L);
    }
    private List<User> createUsers(){
        return Arrays.asList(
                new User("zs",1L),
                new User("zs",2L),
                new User("zs",3L),
                new User("zs",4L),
                new User("zs",5L),
                new User("zs",6L));
    }
    //查询所有的用户
    //根据id查询某个用户
    @Test
    public void test(){
        //存放====================================================================
        List<User> users = createUsers();
        Map<String,String> data = new HashMap<>(users.size());
        users.forEach(user -> {
            data.put(user.getId().toString(),JSON.toJSONString(user));
        });
        String hmsetResult = RedisUtils.INSTANCE.hmset("users", data);
        System.out.println(hmsetResult);
        RedisUtils.INSTANCE.hset("users","7",JSON.toJSONString(new User("zs",7L)));
        //取所有值==================================================================
        List<String> values = RedisUtils.INSTANCE.hvals("users");
        List<User> result  = new ArrayList<>(values.size());
        values.forEach(value ->{
            result.add(JSON.parseObject(value,User.class));
        });
        System.out.println(values);
        //根据ID取User==============================================================
        String user = RedisUtils.INSTANCE.hget("users","1");
        System.out.println(user);
    }
    //查询所有的用户
    //根据id查询某个用户
    @Test
    public void test2(){
        //存放====================================================================
        List<User> users = createUsers();
        Map<byte[],byte[]> data = new HashMap<>(users.size());
        users.forEach(user -> {
            data.put(user.getId().toString().getBytes(),SerializeUtil.serialize(user));
        });
        String hmsetResult = RedisUtils.INSTANCE.hmset("users".getBytes(), data);
        System.out.println(hmsetResult);
        RedisUtils.INSTANCE.hset("users".getBytes(),"7".getBytes(),SerializeUtil.serialize(new User("zs",7L)));
        //取所有值==================================================================
        List<byte[]> values = RedisUtils.INSTANCE.hvals("users".getBytes());
        List<User> result  = new ArrayList<>(values.size());
        values.forEach(value ->{
            result.add(((User)SerializeUtil.unserialize(value)));
        });
        System.out.println(result);
        //根据ID取User==============================================================
        byte[] user = RedisUtils.INSTANCE.hget("users".getBytes(),"7".getBytes());
        System.out.println(SerializeUtil.unserialize(user));
    }
    //查询所有的用户
    //根据id查询某个用户
    @Test
    public void test3(){
        //存放====================================================================
        RedisUtils.INSTANCE.hset("users".getBytes(),"7".getBytes(),SerializeUtil.serialize(new User("zs",7L)));
        //根据ID取User==============================================================
        byte[] user = RedisUtils.INSTANCE.hget("users".getBytes(),"7".getBytes());
        System.out.println(SerializeUtil.unserialize(user));
    }
}

2.7.事务操作

jedis.set("name","zs");
jedis.set("age",18);
//开启事务
Transaction multi = jedis.multi();
multi.incr("name");
multi.incr("age");
//提交事务
List<Object> result = multi.exec();
System.out.println(result);
//关闭连接
jedis.close();
//关闭连接池
pool.destory();
文章标签：
云数据库 Tair（兼容 Redis）
Java
关系型数据库
NoSQL
MySQL
Redis
Maven
mybatis
API
存储
数据库连接
关键词：
Java Redis
Java入门
云数据库 Tair（兼容 Redis）入门
云数据库 Tair（兼容 Redis）java
Java操作
相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务，基于高可靠双机热备架构及可无缝扩展的集群架构，满足高读写性能场景及容量需弹性变配的业务需求。 产品详情：https://www.aliyun.com/product/kvstore &nbsp; &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验：数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引，您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接，领取免费ECS&amp;RDS资源，30分钟完成数据库上云实战！https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
Heron
目录
相关文章
蓝易云
|
17天前
|
NoSQL Java 关系型数据库
Liunx部署java项目Tomcat、Redis、Mysql教程
本文详细介绍了如何在 Linux 服务器上安装和配置 Tomcat、MySQL 和 Redis，并部署 Java 项目。通过这些步骤，您可以搭建一个高效稳定的 Java 应用运行环境。希望本文能为您在实际操作中提供有价值的参考。
蓝易云
90 26
m1a6
|
25天前
|
Java 开发者 微服务
Spring Boot 入门：简化 Java Web 开发的强大工具
Spring Boot 是一个开源的 Java 基础框架，用于创建独立、生产级别的基于Spring框架的应用程序。它旨在简化Spring应用的初始搭建以及开发过程。
m1a6
46 6
Spring Boot 入门：简化 Java Web 开发的强大工具
游客7ofzsdfcat7ls
|
21天前
|
监控 架构师 Java
Java虚拟机调优的艺术：从入门到精通####
本文作为一篇深入浅出的技术指南，旨在为Java开发者揭示JVM调优的神秘面纱，通过剖析其背后的原理、分享实战经验与最佳实践，引领读者踏上从调优新手到高手的进阶之路。不同于传统的摘要概述，本文将以一场虚拟的对话形式，模拟一位经验丰富的架构师向初学者传授JVM调优的心法，激发学习兴趣，同时概括性地介绍文章将探讨的核心议题——性能监控、垃圾回收优化、内存管理及常见问题解决策略。 ####
游客7ofzsdfcat7ls
41 7
ShaFaChuang-36210
|
1月前
|
监控 安全 Java
Java中的多线程编程：从入门到实践####
本文将深入浅出地探讨Java多线程编程的核心概念、应用场景及实践技巧。不同于传统的摘要形式，本文将以一个简短的代码示例作为开篇，直接展示多线程的魅力，随后再详细解析其背后的原理与实现方式，旨在帮助读者快速理解并掌握Java多线程编程的基本技能。 ```java // 简单的多线程示例：创建两个线程，分别打印不同的消息 public class SimpleMultithreading { public static void main(String[] args) { Thread thread1 = new Thread(() -> System.out.prin
ShaFaChuang-36210
56 1
蓝易云
|
1月前
|
存储 消息中间件 NoSQL
使用Java操作Redis数据类型的详解指南
通过使用Jedis库，可以在Java中方便地操作Redis的各种数据类型。本文详细介绍了字符串、哈希、列表、集合和有序集合的基本操作及其对应的Java实现。这些示例展示了如何使用Java与Redis进行交互，为开发高效的Redis客户端应用程序提供了基础。希望本文的指南能帮助您更好地理解和使用Redis，提升应用程序的性能和可靠性。
蓝易云
42 1
游客gavtnh6pi64i6
|
1月前
|
Java 大数据 API
14天Java基础学习——第1天：Java入门和环境搭建
本文介绍了Java的基础知识，包括Java的简介、历史和应用领域。详细讲解了如何安装JDK并配置环境变量，以及如何使用IntelliJ IDEA创建和运行Java项目。通过示例代码“HelloWorld.java”，展示了从编写到运行的全过程。适合初学者快速入门Java编程。
游客gavtnh6pi64i6
68 2
历年考试不作弊
|
1月前
|
Java 程序员 数据库连接
Java中的异常处理：从入门到精通
在Java编程的海洋中，异常处理是一艘不可或缺的救生艇。它不仅保护你的代码免受错误数据的侵袭，还能确保用户体验的平稳航行。本文将带你领略异常处理的风浪，让你学会如何在Java中捕捉、处理和预防异常，从而成为一名真正的Java航海家。
历年考试不作弊
29 0
涂作权
|
Java Android开发
WSDL2Java操作指南
1. 安装JDK1.5, 配置系统环境变量:     下载安装JDK后, 设置环境变量：     JAVA_HOME=C:\Program Files\Java\jdk1.5.0_02     Path=%Path%;%JAVA_HOME%\bin(这里的%Path%指你系统已经有的一系列配置)     CLASSPATH=%JAVA_HOME%\lib  2. 下载axis,
涂作权
1430 0
大数据文摘
|
1天前
|
Java
Java—多线程实现生产消费者
本文介绍了多线程实现生产消费者模式的三个版本。Version1包含四个类：`Producer`（生产者）、`Consumer`（消费者）、`Resource`（公共资源）和`TestMain`（测试类）。通过`synchronized`和`wait/notify`机制控制线程同步，但存在多个生产者或消费者时可能出现多次生产和消费的问题。 Version2将`if`改为`while`，解决了多次生产和消费的问题，但仍可能因`notify()`随机唤醒线程而导致死锁。因此，引入了`notifyAll()`来唤醒所有等待线程，但这会带来性能问题。
大数据文摘
22 1
Java—多线程实现生产消费者
2G冲浪词条
|
3天前
|
安全 Java Kotlin
Java多线程——synchronized、volatile 保障可见性
Java多线程中，`synchronized` 和 `volatile` 关键字用于保障可见性。`synchronized` 保证原子性、可见性和有序性，通过锁机制确保线程安全；`volatile` 仅保证可见性和有序性，不保证原子性。代码示例展示了如何使用 `synchronized` 和 `volatile` 解决主线程无法感知子线程修改共享变量的问题。总结：`volatile` 确保不同线程对共享变量操作的可见性，使一个线程修改后，其他线程能立即看到最新值。
2G冲浪词条
22 7

热门文章

最新文章

  • 1
    Java volatile关键字：你真的懂了吗？
  • 2
    java小工具util系列2：字符串工具
  • 3
    Java爬虫：数据采集的强大工具
  • 4
    Java多线程并发编程：同步机制与实践应用
  • 5
    Java中的异常处理：从基础到高级
  • 6
    深入理解Java异常处理机制
  • 7
    Java爬虫：深入解析商品详情的利器
  • 8
    java实现从HDFS上下载文件及文件夹的功能，以流形式输出，便于用户自定义保存任何路径下
  • 9
    Java 异常处理：机制、策略与最佳实践
  • 10
    Java 中的正则表达式
  • 1
    Linux安装jdk、mysql、redis
    62
  • 2
    Redis经典问题：数据不一致
    33
  • 3
    Redis经典问题：数据并发竞争
    17
  • 4
    Redis经典问题：缓存穿透
    34
  • 5
    为什么越来越多的企业选择Redis？简述Redis生平
    26
  • 6
    单线程传奇Redis，为何引入多线程？
    15
  • 7
    Redis事务长什么样？一文带你全面了解
    15
  • 8
    Redis性能攻略：Redis-benchmark工具与实用性能优化技巧
    14
  • 9
    Redis在中国火爆，为何MongoDB更受欢迎国外？
    16
  • 10
    Redis集群方案汇总：概念性介绍
    14

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0

    • 相关实验场景

    更多
  • 基于Redis实现在线游戏积分排行榜
  • 阿里云平台上进行Java程序的编译与运行
  • 使用Java面向对象编写网络通信程序应用
  • 手动部署Java Web环境（Alibaba Cloud Linux 2）
  • 搭建Java Web开发环境（Anolis OS）
  • RocketMQ中使用Java客户端发送消息和消费的应用
    • 下一篇
    手把手教你白嫖阿里云服务器(免费领服务器)