2022-1-28 Redis Java客户端-Jedis/Lettuse
2022/1/29 2:04:38
本文主要是介绍2022-1-28 Redis Java客户端-Jedis/Lettuse,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
文章目录
- 1. 开启远程连接
- 2. Jedis
- 连接池
- 3. Lettuce
1. 开启远程连接
Redis默认不支持远程连接,需要手动开启。
进入redis.conf
-
注释掉以下绑定 bind
-
取消注释并设置密码 (开启密码校验)
requirepass 123456 -
然后启动redis
2. Jedis
- 创建一个普通Maven项目
- 添加Jedis依赖
<dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>4.0.1</version> </dependency>
- 创建测试方法
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的比较:
- Jedis在实现的过程中是直接连接Redis的,在多个线程之间共享一个Jedis实例,这是线程不安全的。如果想在多线程场景下使用Jedis,就得使用连接池,这样,每个线程都有自己的Jedis实例,需要许多物理资源
- 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");
这篇关于2022-1-28 Redis Java客户端-Jedis/Lettuse的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-09-21订单系统资料入门教程:轻松管理你的订单
- 2024-09-21Java部署资料:新手入门教程
- 2024-09-21Java部署资料:新手入门教程
- 2024-09-21Java订单系统资料:新手入门教程与实战指南
- 2024-09-21Java管理系统资料入门教程
- 2024-09-21从零开始学习Java监控系统资料
- 2024-09-21Java就业项目资料:新手入门的必备教程
- 2024-09-21Java全端资料:初学者指南
- 2024-09-21Java全栈资料入门教程及资源汇总
- 2024-09-21Java日志系统资料入门教程