AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

Redis客户端操作之Jedis

2021-12-01 202
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
Redis 开源版，标准版 2GB
推荐场景：
搭建游戏排行榜
云数据库 Tair（兼容Redis），内存型 2GB
推荐场景：
通过缓存加速数据库访问
简介： 在前面的文章给大家详细的介绍了Redis各种知识点，本文主要给大家介绍下java程序怎么操作Redis数据。

在前面的文章给大家详细的介绍了Redis各种知识点，本文主要给大家介绍下java程序怎么操作Redis数据。

Redis官网中提供了各种语言的客户端，使用起来很方便，本文主要介绍java中常用的Jedis

20190215212014130.png20190215212107701.png

Jedis


 Jedis Client是Redis官网推荐的一个面向java客户端，库文件实现了对redis各类API进行封装调用,通过这些API我们会非常方便的操作我们的Redis数据库。


redis配置的修改


1.注释掉绑定的信息


 在redis.conf的配置文件中bind配置的信息表示的是redis服务可以接收外部访问的地址，这个主要还是为了提高安全性，我们在学习阶段可以将这个信息直接注释掉，这样的话任意的外部ip地址都可以访问。bind是protected-mode配合使用的

bind 127.0.0.1

2.关闭保护模式


 redis3.2版本后新增protected-mode配置，默认是yes，即开启。设置外部网络连接redis服务，设置方式如下：

1、关闭protected-mode模式，此时外部网络可以直接访问

2、开启protected-mode保护模式，需配置bind ip或者设置访问密码


创建项目


创建maven的java项目，添加如下maven坐标

<dependency>
  <groupId>redis.clients</groupId>
  <artifactId>jedis</artifactId>
  <version>2.9.0</version>
</dependency>
<dependency>
  <groupId>junit</groupId>
  <artifactId>junit</artifactId>
  <version>3.8.1</version>
</dependency>

Redis单机版

案例代码:

  /**
   * 测试是否连接成功
   */
  public void ping(){
    Jedis jedis = new Jedis("192.168.88.124", 6379);
    System.out.println(jedis.ping());
  }
  /**
   * 设置key/value对
   */
  public void set(){
    Jedis jedis = new Jedis("192.168.88.124", 6379);
    jedis.set("name", "張三");
    jedis.set("age", "18");
    jedis.close();
  }
  /**
   * 通过key获取对应的value
   */
  public void get(){
    Jedis jedis = new Jedis("192.168.88.124", 6379);
    String name = jedis.get("name");
    String age = jedis.get("age");
    System.out.println(name+"--"+age);
    jedis.close();
  }
  /**
   * 通过Jedis的连接池Pool
   */
  public void testJedisPool() {
    // 创建Jedis连接池
    JedisPool pool = new JedisPool("192.168.88.124", 6379);
    // 从连接池中获取Jedis对象
    Jedis jedisItem = pool.getResource();
    String name = jedisItem.get("name");
    System.out.println(name);
    jedisItem.close();
    pool.close();
  }
  /**
   * 操作incr方法自增1
   */
  public void incr(){
    Jedis jedis = new Jedis("192.168.88.124", 6379);
    Long age = jedis.incr("age");
    System.out.println(age);
  }

redis中的数据

20190215213719233.png

操作控制台的输出

20190215213801893.png2019021521383677.png20190215213910851.png

Redis集群版

  /**
   * 操作Redis集群的数据
   * @throws IOException 
   */
  public void testRedisCluster() throws IOException{
    JedisPoolConfig pool = new JedisPoolConfig();
    // 设置最大的空闲数
    pool.setMaxIdle(2);
    // 设置最大连接数
    pool.setMaxTotal(30);
    Set<HostAndPort> nodes = new HashSet<>();
    nodes.add(new HostAndPort("192.168.88.121", 7001));
    nodes.add(new HostAndPort("192.168.88.121", 7002));
    nodes.add(new HostAndPort("192.168.88.121", 7003));
    nodes.add(new HostAndPort("192.168.88.121", 7004));
    nodes.add(new HostAndPort("192.168.88.121", 7005));
    nodes.add(new HostAndPort("192.168.88.121", 7006));
    JedisCluster jedis = new JedisCluster(nodes,pool );
    String name = jedis.set("name","lisi");
    System.out.println(name);
    jedis.close();
    pool.clone();
  }

20190215215730352.png

Jedis整合Spring

  Jedis单独使用情况还是比较少的，实际开发中和spring整合使用的场景还是比较多的，所以此处介绍下和spring一块使用的情况

maven坐标

  <dependencies>
    <dependency>
      <groupId>redis.clients</groupId>
      <artifactId>jedis</artifactId>
      <version>2.9.0</version>
    </dependency>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>3.8.1</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-context</artifactId>
      <version>4.3.3.RELEASE</version>
    </dependency>
  </dependencies>

20190215221219994.png

Redis单机环境

spring的配置文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://www.springframework.org/schema/beans 
 http://www.springframework.org/schema/beans/spring-beans.xsd">
  <!-- 连接池配置 -->
  <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
    <!-- 最大连接数 -->
    <property name="maxTotal" value="30" />
    <!-- 最大空闲连接数 -->
    <property name="maxIdle" value="10" />
    <!-- 每次释放连接的最大数目 -->
    <property name="numTestsPerEvictionRun" value="1024" />
    <!-- 释放连接的扫描间隔（毫秒） -->
    <property name="timeBetweenEvictionRunsMillis" value="30000" />
    <!-- 连接最小空闲时间 -->
    <property name="minEvictableIdleTimeMillis" value="1800000" />
    <!-- 连接空闲多久后释放, 当空闲时间>该值 且 空闲连接>最大空闲连接数 时直接释放 -->
    <property name="softMinEvictableIdleTimeMillis" value="10000" />
    <!-- 获取连接时的最大等待毫秒数,小于零:阻塞不确定的时间,默认-1 -->
    <property name="maxWaitMillis" value="1500" />
    <!-- 在获取连接的时候检查有效性, 默认false -->
    <property name="testOnBorrow" value="false" />
    <!-- 在空闲时检查有效性, 默认false -->
    <property name="testWhileIdle" value="false" />
    <!-- 连接耗尽时是否阻塞, false报异常,ture阻塞直到超时, 默认true -->
    <property name="blockWhenExhausted" value="false" />
  </bean>
  <!-- jedis客户端单机版 -->
  <bean id="redisClient" class="redis.clients.jedis.JedisPool">
    <constructor-arg name="host" value="192.168.88.124"></constructor-arg>
    <constructor-arg name="port" value="6379"></constructor-arg>
    <constructor-arg name="poolConfig" ref="jedisPoolConfig"></constructor-arg>
  </bean>
</beans>

测试代码

public void test1(){
  ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml");
  JedisPool pool = ac.getBean("redisClient",JedisPool.class);
  Jedis jedis = pool.getResource();
  String type = jedis.set("address", "sz");
  System.out.println(type);
  jedis.close();
  pool.close();
}

20190215221357444.png20190215221410158.png

Redis集群环境

配置文件

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://www.springframework.org/schema/beans 
 http://www.springframework.org/schema/beans/spring-beans.xsd">
  <!-- 连接池配置 -->
  <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
    <!-- 最大连接数 -->
    <property name="maxTotal" value="30" />
    <!-- 最大空闲连接数 -->
    <property name="maxIdle" value="10" />
    <!-- 每次释放连接的最大数目 -->
    <property name="numTestsPerEvictionRun" value="1024" />
    <!-- 释放连接的扫描间隔（毫秒） -->
    <property name="timeBetweenEvictionRunsMillis" value="30000" />
    <!-- 连接最小空闲时间 -->
    <property name="minEvictableIdleTimeMillis" value="1800000" />
    <!-- 连接空闲多久后释放, 当空闲时间>该值 且 空闲连接>最大空闲连接数 时直接释放 -->
    <property name="softMinEvictableIdleTimeMillis" value="10000" />
    <!-- 获取连接时的最大等待毫秒数,小于零:阻塞不确定的时间,默认-1 -->
    <property name="maxWaitMillis" value="1500" />
    <!-- 在获取连接的时候检查有效性, 默认false -->
    <property name="testOnBorrow" value="false" />
    <!-- 在空闲时检查有效性, 默认false -->
    <property name="testWhileIdle" value="false" />
    <!-- 连接耗尽时是否阻塞, false报异常,ture阻塞直到超时, 默认true -->
    <property name="blockWhenExhausted" value="false" />
  </bean>
  <!-- jedis客户端集群版 -->
  <bean id="redisClient" class="redis.clients.jedis.JedisCluster">
    <constructor-arg name="nodes">
      <set>
        <bean class="redis.clients.jedis.HostAndPort">
          <constructor-arg name="host" value="192.168.88.121"></constructor-arg>
          <constructor-arg name="port" value="7001"></constructor-arg>
        </bean>
        <bean class="redis.clients.jedis.HostAndPort">
          <constructor-arg name="host" value="192.168.88.121"></constructor-arg>
          <constructor-arg name="port" value="7002"></constructor-arg>
        </bean>
        <bean class="redis.clients.jedis.HostAndPort">
          <constructor-arg name="host" value="192.168.88.121"></constructor-arg>
          <constructor-arg name="port" value="7003"></constructor-arg>
        </bean>
        <bean class="redis.clients.jedis.HostAndPort">
          <constructor-arg name="host" value="192.168.88.121"></constructor-arg>
          <constructor-arg name="port" value="7004"></constructor-arg>
        </bean>
        <bean class="redis.clients.jedis.HostAndPort">
          <constructor-arg name="host" value="192.168.88.121"></constructor-arg>
          <constructor-arg name="port" value="7005"></constructor-arg>
        </bean>
        <bean class="redis.clients.jedis.HostAndPort">
          <constructor-arg name="host" value="192.168.88.121"></constructor-arg>
          <constructor-arg name="port" value="7006"></constructor-arg>
        </bean>
      </set>
    </constructor-arg>
    <constructor-arg name="poolConfig" ref="jedisPoolConfig"></constructor-arg>
  </bean>
</beans>

测试代码

public void test1() throws IOException{
  ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml");
  JedisCluster jedis = ac.getBean("redisClient",JedisCluster.class);
  String type = jedis.set("address", "sz-cluster");
  System.out.println(type);
  jedis.close();
}

20190215221929664.png

添加Jedis到Dao

  Redis是一个NOSQL数据库，我们常用来做缓存数据库。所以在实际操作的时候我们经常会把他的操作封装起来作为Dao层

Redis单机环境

创建接口

package com.dpb.dao;
/**
 * Jedis接口
 * @author dengp
 *
 */
public interface IJedisClient {
  String get(String key);
  String set(String key, String value);
  String hget(String hkey, String key);
  long hset(String hkey, String key, String value);
  long incr(String key);
  long expire(String key, int second);
  long ttl(String key);
  long del(String...key);
  long hdel(String hkey, String...fields);
}


创建接口实现类

@Component
public class JedisClientImpl implements IJedisClient{
  @Resource
  private JedisPool jedisPool;
  @Override
  public String get(String key) {
    Jedis jedis = jedisPool.getResource();
    String string = jedis.get(key);
    jedis.close();
    return string;
  }
  @Override
  public String set(String key, String value) {
    Jedis jedis = jedisPool.getResource();
    String string = jedis.set(key, value);
    jedis.close();
    return string;
  }
  @Override
  public String hget(String hkey, String key) {
    Jedis jedis = jedisPool.getResource();
    String string = jedis.hget(hkey, key);
    jedis.close();
    return string;
  }
  @Override
  public long hset(String hkey, String key, String value) {
    Jedis jedis = jedisPool.getResource();
    Long result = jedis.hset(hkey, key, value);
    jedis.close();
    return result;
  }
  @Override
  public long incr(String key) {
    Jedis jedis = jedisPool.getResource();
    Long result = jedis.incr(key);
    jedis.close();
    return result;
  }
  @Override
  public long expire(String key, int second) {
    Jedis jedis = jedisPool.getResource();
    Long result = jedis.expire(key, second);
    jedis.close();
    return result;
  }
  @Override
  public long ttl(String key) {
    Jedis jedis = jedisPool.getResource();
    Long result = jedis.ttl(key);
    jedis.close();
    return result;
  }
  @Override
  public long del(String...keys) {
    Jedis jedis = jedisPool.getResource();
    Long code = jedis.del(keys);
    jedis.close();
    return code;
  }
  @Override
  public long hdel(String hkey, String...fields) {
    Jedis jedis = jedisPool.getResource();
    Long code = jedis.hdel(hkey, fields);
    jedis.close();
    return code;
  }
}

测试

注意添加扫描20190215223002165.png

spring的配置文件和上面的单机Spring的是一样的,测试代码也是一样的

  public void test1(){
    ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml");
    JedisPool pool = ac.getBean("redisClient",JedisPool.class);
    Jedis jedis = pool.getResource();
    String type = jedis.set("address", "sz-dao");
    System.out.println(type);
    jedis.close();
    pool.close();
  }

20190215223105119.png

Redis集群环境

接口的实现

@Component
public class JedisClusterClientImpl implements JedisClient {
  @Autowired
  private JedisCluster jedisCluster;
  @Override
  public String get(String key) {
    return jedisCluster.get(key);
  }
  @Override
  public String set(String key, String value) {
    return jedisCluster.set(key, value);
  }
  @Override
  public String hget(String hkey, String key) {
    return jedisCluster.hget(hkey, key);
  }
  @Override
  public long hset(String hkey, String key, String value) {
    return jedisCluster.hset(hkey, key, value);
  }
  @Override
  public long incr(String key) {
    return jedisCluster.incr(key);
  }
  @Override
  public long expire(String key, int second) {
    return jedisCluster.expire(key, second);
  }
  @Override
  public long ttl(String key) {
    return jedisCluster.ttl(key);
  }
  @Override
  public long del(String... key) {
    return 0;
  }
  @Override
  public long hdel(String hkey, String... fields) {
    // TODO Auto-generated method stub
    return 0;
  }
}

其他的配置操作和spring整合Jedis中都是一样的

好了本文介绍到此。下次再见~~

文章标签：
云数据库 Tair（兼容 Redis）
Java
NoSQL
数据安全/隐私保护
Redis
Spring
Maven
API
数据库
缓存
关键词：
云数据库 Tair（兼容 Redis）Jedis
云数据库 Tair（兼容 Redis）客户端jedis
云数据库 Tair（兼容 Redis）操作
相关实践学习
基于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
游客a74jvhcp7vclg
目录
相关文章
听白
|
4月前
|
NoSQL 网络协议 算法
Redis 客户端连接
10月更文挑战第21天
听白
62 1
何雨晨
|
4月前
|
存储 消息中间件 NoSQL
Redis 入门 - C#.NET Core客户端库六种选择
Redis 入门 - C#.NET Core客户端库六种选择
何雨晨
108 8
dream_ready
|
4月前
|
NoSQL Redis 数据安全/隐私保护
Redis 最流行的图形化界面下载及使用超详细教程（带安装包）！ redis windows客户端下载
文章提供了Redis最流行的图形化界面工具Another Redis Desktop Manager的下载及使用教程，包括如何下载、解压、连接Redis服务器以及使用控制台和查看数据类型详细信息。
dream_ready
417 6
Redis 最流行的图形化界面下载及使用超详细教程（带安装包）！ redis windows客户端下载
dream_ready
|
4月前
|
NoSQL Redis 数据库
Redis 图形化界面下载及使用超详细教程（带安装包）！ redis windows下客户端下载
文章提供了Redis图形化界面工具的下载及使用教程，包括如何连接本地Redis服务器、操作键值对、查看日志和使用命令行等功能。
dream_ready
339 0
Redis 图形化界面下载及使用超详细教程（带安装包）！ redis windows下客户端下载
杀死一只知更鸟debug
|
5月前
|
JSON NoSQL Java
redis的java客户端的使用（Jedis、SpringDataRedis、SpringBoot整合redis、redisTemplate序列化及stringRedisTemplate序列化）
这篇文章介绍了在Java中使用Redis客户端的几种方法，包括Jedis、SpringDataRedis和SpringBoot整合Redis的操作。文章详细解释了Jedis的基本使用步骤，Jedis连接池的创建和使用，以及在SpringBoot项目中如何配置和使用RedisTemplate和StringRedisTemplate。此外，还探讨了RedisTemplate序列化的两种实践方案，包括默认的JDK序列化和自定义的JSON序列化，以及StringRedisTemplate的使用，它要求键和值都必须是String类型。
杀死一只知更鸟debug
618 1
redis的java客户端的使用（Jedis、SpringDataRedis、SpringBoot整合redis、redisTemplate序列化及stringRedisTemplate序列化）
你都不懂
|
5月前
|
NoSQL 网络协议 Java
[Redis] 渐进式遍历+使用jedis操作Redis+使用Spring操作Redis
[Redis] 渐进式遍历+使用jedis操作Redis+使用Spring操作Redis
你都不懂
70 7
游客zi3qmblbcdexu
|
5月前
|
NoSQL Java 网络安全
[Redis] 渐进式遍历+使用jedis操作Redis+使用Spring操作Redis
[Redis] 渐进式遍历+使用jedis操作Redis+使用Spring操作Redis
游客zi3qmblbcdexu
73 5
路边两盏灯
|
6月前
|
NoSQL 网络协议 Linux
【AKS+Redis】AKS中客户端(ioredis)遇见Azure Redis服务Failover后链接中断的可能性
【AKS+Redis】AKS中客户端(ioredis)遇见Azure Redis服务Failover后链接中断的可能性
路边两盏灯
53 0
路边两盏灯
|
6月前
|
NoSQL 网络协议 Linux
【Azure Redis】Lettuce客户端遇见连接Azure Redis长达15分钟的超时
【Azure Redis】Lettuce客户端遇见连接Azure Redis长达15分钟的超时
路边两盏灯
82 0
路边两盏灯
|
6月前
|
NoSQL 网络协议 Linux
【Azure Redis】Redis客户端出现15分钟的超时异常
【Azure Redis】Redis客户端出现15分钟的超时异常
路边两盏灯
42 0

热门文章

最新文章

  • 1
    Redis的两种持久化方式---RDB、AOF
  • 2
    Docker 部署 Redis
  • 3
    Springboot使用Redis实现分布式锁
  • 4
    Redis，分布式缓存演化之路
  • 5
    java连接redis和基础操作命令
  • 6
    Redis与MySQL的数据一致性
  • 7
    Redis Plus 来了，性能炸裂！
  • 8
    Vue.js应用结合Redis数据库：实践与优化
  • 9
    Redis哈希结构在提升数据检索速度中的实践应用
  • 10
    Redis 功能扩展 Lua 脚本 对Redis扩展 eval redis.call redis.pcall
  • 1
    Springboot使用Redis实现分布式锁
    108
  • 2
    尼恩一键开发环境： vagrant+java+springcloud+redis+zookeeper镜像下载(&制作详解)
    40
  • 3
    Docker 部署 Redis
    107
  • 4
    Redis Plus 来了，性能炸裂！
    62
  • 5
    Redis的两种持久化方式---RDB、AOF
    124
  • 6
    Redis，分布式缓存演化之路
    93
  • 7
    Redis哈希结构在提升数据检索速度中的实践应用
    41
  • 8
    Redis 功能扩展 Lua 脚本 对Redis扩展 eval redis.call redis.pcall
    43
  • 9
    Redis的操作以及SpringCache框架
    35
  • 10
    java连接redis和基础操作命令
    83

    • 相关课程

    更多
  • 使用Redis企业版(Tair)构建实时推荐系统
  • Redis入门及实战
  • Redis入门到精通（进阶篇）
  • Redis入门到精通（基础篇）
  • 使用Spring Data Redis+zTree实现授权模型的设计与思考
  • 使用Redis消息队列完成秒杀过期订单处理

    • 相关电子书

    更多
  • 2023云栖大会：阿里云Redis - 更稳更快更好用
  • 阿里开发者手册-Redis专题
  • 国内开发者与Redis开源社区的发展

    • 相关实验场景

    更多
  • 基于Redis实现在线游戏积分排行榜
  • Tair for Redis数据闪回：任意时间点数据恢复
  • 如何开通Redis的专属集群
  • 如何通过数据库Redis内网访问
  • 基于Redis实现在线游戏积分排行榜
    • 下一篇
    阿里云oss简介和如何对接使用