标签：Lettuse Java 28 redis JedisPool Jedis jedis ping public

文章目录

• • 1. 开启远程连接
  • 2. Jedis
  • • 连接池
  • 3. Lettuce

1. 开启远程连接

Redis默认不支持远程连接，需要手动开启。
进入redis.conf

• 注释掉以下绑定 bind
  

• 取消注释并设置密码 （开启密码校验）
  
  requirepass 123456

• 然后启动redis

2. Jedis

1. 创建一个普通Maven项目
2. 添加Jedis依赖

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

3. 创建测试方法

public class MyJedis {
    public static void main(String[] args) {
        //1. 构造Jedis对象 因为使用默认端口6379,可以不用配置端口
        Jedis jedis = new Jedis("192.168.xx.xx",6379);
        //2. 密码认证
        jedis.auth("123456");
        //3. 测试是否连接成功(ping)
        String ping=jedis.ping();
        //4. 返回pong表示连接成功
        System.out.println(ping);
    }
}

输出PONG即连接成功：

要是未连接成功——确认配置无误，redis服务已经打开——还是不行——重启或许是最好的方法

在jedis中，由于方法的API和redis的命令高度一致，所以，jedis中的方法可以直接使用。

连接池

在实际应用中，jedis实例一般通过连接池获取，由于jedis对象不是线程安全的，所以，当我们使用jedis对象时，从连接池获取jedis，使用完成后还给连接池。

public class JedisPoolTest {
    public static void main(String[] args) {
        //1. 构造一个Jedis连接池
        JedisPool pool = new JedisPool("192.168.", 6379);
        //2. 从连接池中获取Jedis；连接
        Jedis jedis = pool.getResource();
        //3. Jedis操作
        jedis.auth("123456");
        String ping = jedis.ping();
        System.out.println(ping);
        
        //4. 归还连接
        jedis.close();

    }
}

如果步骤3出现异常，那么连接无法关闭，无法归还连接，连接被持久占用。
因此要进行优化–finally

package org.kk.jedis;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

/**
 * @program: jedis
 * @description:
 * @author: zjx
 * @create: 2022-01-28 21:39
 **/
public class JedisPoolTest {
    public static void main(String[] args) {
        Jedis jedis = null;

            //1. 构造一个Jedis连接池
            JedisPool pool = new JedisPool("192.168.", 6379);
            //2. 从连接池中获取Jedis；连接
            jedis = pool.getResource();
            //3. Jedis操作
        try {
            jedis.auth("123456");
            String ping = jedis.ping();
            System.out.println(ping);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //4. 归还连接
            if(jedis!=null){
                jedis.close();
            }
        }



    }
}

再优化：
利用JDK1.7中的try-with-resource特性，可以对上面的代码进行改造：

package org.kk.jedis;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

/**
 * @program: jedis
 * @description:
 * @author: zjx
 * @create: 2022-01-28 21:39
 **/
public class JedisPoolTest {
    public static void main(String[] args) {
        JedisPool pool = new JedisPool("192.168.", 6379);
        try(Jedis jedis=pool.getResource()) {
            jedis.auth("123456");
            String ping = jedis.ping();
            System.out.println(ping);
        }
        
    }
}

似乎还是不可靠。。。上面这段代码无法实现强约束，我们可以做进一步的改进：

写一个接口，然后真正调用的时候去实现这个接口。

首先定义接口：

package org.kk.jedis;

import redis.clients.jedis.Jedis;

public interface CallWithJedis {
    void call(Jedis jedis);
    //对这个接口做一个实现类，实现类里面传Jedis进来

}

然后实现方法Redis：

package org.kk.jedis;

import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

/**
 * @program: jedis
 * @description:
 * @author: zjx
 * @create: 2022-01-28 22:19
 **/
public class Redis {
    private JedisPool pool;

    public Redis(){ //作初始化
        GenericObjectPoolConfig config=new GenericObjectPoolConfig();
        pool=new JedisPool(config,"192.168.10.14",6379);
        //或者写全参数 timeout，password
    }

    public void execute(CallWithJedis callWithJedis){
        try(Jedis jedis=pool.getResource())
        {
            callWithJedis.call(jedis);
        }
    }
}

测试：

    public static void main(String[] args) {
        Redis redis = new Redis();
        redis.execute(jedis -> {
            jedis.auth("123456");
            System.out.println(jedis.ping());
        });
    }

一些配置：

  public Redis(){ //作初始化
        GenericObjectPoolConfig config=new GenericObjectPoolConfig();
        config.setMaxIdle(300);//连接池最大空闲数
        config.setMaxTotal(1000);//最大连接数
        config.setMaxWaitMillis(10000);//连接最大等待时间 如果是-1 表示没有限制
        config.setTestOnBorrow(true);//在空闲时检查有效性
        pool=new JedisPool(config,"192.168.10.14",6379);
    }

3. Lettuce

github搜索即可。

Lettuce和Jedis的比较：

1. Jedis在实现的过程中是直接连接Redis的，在多个线程之间共享一个Jedis实例，这是线程不安全的。如果想在多线程场景下使用Jedis，就得使用连接池，这样，每个线程都有自己的Jedis实例，需要许多物理资源
2. Lettuse基于目前很火的Netty NIO框架来构建，所以克服了Jedis中线程不安全的问题，支持同步、异步、响应式调用，多个线程可以共享一个连接实例。

使用Lettuse，创建普通的maven项目并添加依赖。
Basic Use
注意：密码写在连接里面

RedisClient client = RedisClient.create("redis://password@192.168.");
StatefulRedisConnection<String, String> connection = client.connect();
RedisStringCommands sync = connection.sync();
sync.set("key","123");
String value = sync.get("key");

标签：Lettuse,Java,28,redis,JedisPool,Jedis,jedis,ping,public
来源： https://blog.csdn.net/qq_39679772/article/details/122735670

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。