`
fantaxy025025
  • 浏览: 1311822 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类

Jedis客户端的调用流程-

 
阅读更多

=

=

=

Jedis客户端的调用流程 (https://www.jianshu.com/p/7913f9984765 

 

Redis的各种语言客户端列表,请参见Redis Client。其中Java客户端在github上start最高的是Jedis和Redisson。Jedis提供了完整Redis命令,而Redisson有更多分布式的容器实现。

使用Jedis客户端

首先通过maven引入Jedis的依赖:

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

创建Jedis对象,调用set方法,并通过get方法获取到值并打印:

    Jedis jedis = new Jedis("localhost", 6379);
    jedis.set("singleJedis", "hello jedis!");
    System.out.println(jedis.get("singleJedis"));
    jedis.close();

注意Jedis对象并不是线程安全的,在多线程下使用同一个Jedis对象会出现并发问题。为了避免每次使用Jedis对象时都需要重新构建,Jedis提供了JedisPoolJedisPool是基于Commons Pool 2实现的一个线程安全的连接池。

    JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
    jedisPoolConfig.setMaxTotal(10);
    JedisPool pool = new JedisPool(jedisPoolConfig, "localhost", 6379);

    Jedis jedis = null;
    try{
        jedis = pool.getResource();
        jedis.set("pooledJedis", "hello jedis pool!");
        System.out.println(jedis.get("pooledJedis"));
    }catch(Exception e){
        e.printStackTrace();
    }finally {
        //还回pool中
        if(jedis != null){
            jedis.close();
        }
    }

    pool.close();

使用完后记得主动调一下close方法,将Jedis对象归还到连接池中。Jedis的close方法:

  public void close() {
    //如果使用了连接池,检查客户端状态,归还到池中
    if (dataSource != null) {
      if (client.isBroken()) {
        this.dataSource.returnBrokenResource(this);
      } else {
        this.dataSource.returnResource(this);
      }
    } else {
      //未使用连接池,直接关闭
      client.close();
    }
  } 

Jedis代码分析

从类结构、启动、执行命令三个方面分析一下Jedis客户端。

Jedis类结构

Jedis类是整个客户端的入口,通过Jedis可以建立与Redis Server的连接并发送命令。Jedis继承自BinaryJedis,同时Jedis和BinaryJedis都实现了很多接口,通过一张类图来描述:

每一个接口都代表了一类Redis命令,例如JedisCommands中包含了SET GET等命令,MultiKeyCommands中包含了针对多个Key的MSET MGET等命令。一部分命令有两个版本的接口,如JedisCommands和BinaryJedisCommands。JedisCommands是字符串参数版本命令,会在Jedis内部将参数转换成UTF-8编码的字节数组。BinaryJedisCommands提供的是字节参数版本,允许用户自己决定编码等细节。ClusterCommands和SentinelCommands与集群、高可用等相关的命令只有一个版本。

Jedis的初始化

JedisPool的构造函数:

  public JedisPool(/** Commons Pool的参数 **/ final GenericObjectPoolConfig poolConfig,
                   /** Redis Server地址 **/ final URI uri,
                   /** 连接Redis Server超时时间**/ final int connectionTimeout,
                   /** 等待Response超时时间 **/ final int soTimeout) {
    super(poolConfig, new JedisFactory(uri, connectionTimeout, soTimeout, null));
  }

JedisFactory实现了PooledObjectFactory的makeObject方法,当调用pool.getResource()方法获取Jedis对象时,会通过makeObject方法创建了Jedis对象:

    final Jedis jedis = new Jedis(hostAndPort.getHost(), hostAndPort.getPort(), connectionTimeout, soTimeout);  

在Jedis的构造函数中,会创建真正与Redis Server通信的Client对象:

    client = new Client(host, port);
    client.setConnectionTimeout(timeout);
    client.setSoTimeout(timeout);

初始化Jedis对象并不会与Redis Server建立连接,连接发生在第一次执行命令时。

Jedis执行命令

SET命令为例,在Jedis中执行SET命令:

jedis.set("singleJedis", "hello jedis!");

调用Jedis的set方法,会委托给内部的client对象的set方法,在client的字符串版本set方法中,会进行String到byte[]的转换:

set(SafeEncoder.encode(key), SafeEncoder.encode(value));

SafeEncoder.encode将字符串转换为UTF-8编码的字节数组,然后调用sendCommand方法:

sendCommand(Command.SET, key, value);

protected Connection sendCommand(final Command cmd, final byte[]... args) {
    try {
      connect();
      Protocol.sendCommand(outputStream, cmd, args);
      ...
    } catch (JedisConnectionException ex) {
      ...
    }
}

省略了一部分异常处理的代码,在sendCommand方法中,建立了与Server的连接,并发送命令。connect方法会按照JedisPool构造函数中的参数,初始化Socket:

    socket = new Socket();
    //TIME_WAIT状态下可以复用端口
    socket.setReuseAddress(true);
    //空闲时发送数据包,确认服务端状态
    socket.setKeepAlive(true);
    //关闭Nagle算法,尽快发送
    socket.setTcpNoDelay(true);
    //调用close方法立即关闭socket,丢弃所有未发送的数据包
    socket.setSoLinger(true, 0);
    //连接server
    socket.connect(new InetSocketAddress(host, port), connectionTimeout);
    //设置读取时超时时间
    socket.setSoTimeout(soTimeout);

sendCommand方法,按照Redis协议,发送命令:

  private static void sendCommand(final RedisOutputStream os, final byte[] command,
      final byte[]... args) {
    try {
      os.write(ASTERISK_BYTE);
      os.writeIntCrLf(args.length + 1);
      os.write(DOLLAR_BYTE);
      os.writeIntCrLf(command.length);
      os.write(command);
      os.writeCrLf();

      for (final byte[] arg : args) {
        os.write(DOLLAR_BYTE);
        os.writeIntCrLf(arg.length);
        os.write(arg);
        os.writeCrLf();
      }
    } catch (IOException e) {
      throw new JedisConnectionException(e);
    }
  }
作者:yingzong
链接:https://www.jianshu.com/p/7913f9984765
來源:简书
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。


=

=

=

 

分享到:
评论

相关推荐

    Redis中使用Java代码的方式实现发布订阅流程-订阅者示例代码.zip

    3. **订阅操作**: 实现`JedisPubSub`接口后,可以创建一个订阅器类实例,并使用Jedis客户端调用`subscribe`或`psubscribe`方法来订阅频道或模式。例如: ```java Jedis jedis = new Jedis("localhost"); ...

    Redis中使用Java代码的方式实现发布订阅流程-发布者示例代码.zip

    首先,我们需要引入Jedis库,这是一个Java客户端,用于与Redis服务器进行交互。确保在项目中已经添加了Jedis的依赖,如Maven项目可以在pom.xml中添加以下依赖: ```xml &lt;groupId&gt;redis.clients &lt;artifactId&gt;...

    有赞多级缓存解决方案怎么做的,你知道吗.docx

    TMC 的基本流程是:Java 应用调用 Jedis-Client 接口获取 key 的缓存值时,Jedis-Client 会询问 Hermes-SDK 该 key 当前是否是热点 key,对于热点 key,直接从 Hermes-SDK 的热点模块获取热点 key 在本地缓存的 ...

    redis 所用到的jar包

    在Java开发中,为了与Redis进行交互,我们需要引入相应的客户端库,其中Jedis是广泛使用的Java Redis客户端。本篇文章将详细介绍Jedis-2.9.0以及与其配合使用的Apache Commons Pool 2库,这两个jar包在Java中与Redis...

    jedis操作源码

    Jedis是Java语言中广泛使用的Redis客户端库,它提供了丰富的API来操作Redis数据存储。本文将深入探讨Jedis的操作源码,帮助读者理解其内部工作原理,提升对Redis操作的理解。 首先,Jedis的连接管理是其核心部分之...

    redis相关知识,安装流程,Java调用

    本文将深入探讨Redis的相关知识,包括其安装流程以及如何使用Java进行调用。 一、Redis简介 Redis是一个开源(BSD许可)的,内存中的数据结构存储系统,可以作为数据库、缓存和消息代理使用。它支持多种数据结构,...

    jedis-annotation

    在Java世界中,Jedis是一个非常流行的Redis客户端库,它为开发者提供了丰富的API来操作Redis数据库。然而,随着编程模式的演进,注解(Annotation)逐渐成为提升代码可读性和简化配置的重要工具。"jedis-annotation...

    java源码剖析-jedis-sr:JedisforRedisJavaclient源码剖析笔记

    当调用Jedis的API执行Redis命令时,Jedis会通过网络发送命令到Redis服务器,接收响应并解析结果。这个过程中涉及的关键类有`CommandExecutor`,它封装了网络通信逻辑,以及`Command`,表示Redis命令的元数据。 3. ...

    dubbo,redis_pool,springMVC(可用在wind上运行)

    同时,Jedis 是一个 Java 的 Redis 客户端,项目中使用 Jedis 进行具体的 Redis 操作,如读写数据、设置键值对等。 3. **Spring MVC**: Spring MVC 是 Spring 框架的一部分,是用于构建 Web 应用程序的模型-视图-...

    SpringMVC+Nutz框架介绍.pdf

    - Jedis是Java实现的Redis客户端,支持Redis集群模式和单机模式切换。 - Dubbo和RSF用于服务间的分布式调用。 - RabbitMQ用于消息队列,支持异步处理和解耦。 - Quartz用于定时任务调度。 - Elasticsearch用于...

    集群redis哨兵模式连接方式,解决database不生效问题(附源码)

    在这个例子中,我们创建了一个`JedisSentinelPool`实例,然后从池中获取一个`Jedis`对象,调用`select`方法指定数据库,接着执行Redis操作。在操作完成后,记得关闭资源以避免资源泄露。 总的来说,解决Redis哨兵...

    我的SpringBoot2.X+Mybatis-plus+Mysql+redis学习项目.zip

    4. **Redis配置及客户端**:使用Jedis或Lettuce等库进行Redis操作,设置缓存策略。 5. **Controller层**:SpringBoot的控制器,处理HTTP请求并调用Service层方法。 6. **Service层**:业务逻辑处理,通常会调用...

    ssm黑马旅游整合最终版2018

    - **其他工具类库**:Jackson(JSON处理)、Jedis(Redis客户端)、JavaMail(邮件发送)、JSTL(标签库)、Servlet API等。 ```xml &lt;!-- 单元测试 --&gt; &lt;groupId&gt;junit &lt;artifactId&gt;junit &lt;groupId&gt;...

    Redis初级案例(推荐)

    3. 使用Jedis操作Redis:调用Jedis的方法进行数据的增删改查,例如`set`、`get`、`lpush`、`rpop`等。 4. 连接池管理:为了提高性能,通常会使用连接池管理多个Jedis实例,例如使用`JedisPool`。 5. 键的过期策略:...

    java链接Redis实例

    如果你选择使用Lettuce,其API设计更面向对象和异步,基本流程如下: 1. **创建Client**: Lettuce提供`RedisClient`类来创建客户端实例。 ```java import io.lettuce.core.RedisClient; import io.lettuce.core....

    t淘淘商城项目 商城项目 视频和源码教程 详细

    Maven定义了软件开发的整套流程体系,并进行了封装,开发人员只需要指定项目的构建流程,无需针对每个流程编写自己的构建脚本。 2、依赖管理。除了项目构建,Maven最核心的功能是软件包的依赖管理,能够自动分析...

    verifi_code.rar

    Jedis是Java语言中广泛使用的Redis客户端库。Redis是一款开源的内存数据结构存储系统,可作为数据库、缓存和消息中间件使用。在验证码场景中,Redis通常用来暂存生成的验证码,以便在用户输入时进行比对验证。 首先...

    12Spring以及框架相关面试问题汇总1

    在Spring中,可以使用Jedis或Lettuce客户端库来操作Redis,通过Spring的Data Redis模块实现集成。 6. Maven插件: Maven是Java项目管理工具,它的插件如maven-compiler-plugin用于编译源代码,maven-surefire-...

Global site tag (gtag.js) - Google Analytics