欢迎来到尧图网

客户服务 关于我们

您的位置:首页 > 财经 > 创投人物 > 11.redis的客户端-Jedis

11.redis的客户端-Jedis

2024/10/24 22:27:54 来源:https://blog.csdn.net/qq_36352889/article/details/140902348  浏览:    关键词:11.redis的客户端-Jedis

1.Jedis

以redis命令作为方法名称,学习成本低,简单使用。但是jedis实例是不安全的,多线程环境下需要基于连接池来使用。

2.Lettuce

lettuce是基于Netty实现的,支持同步,异步和响应式编程方式,并且是线程安全的。支持redis的哨兵模式、集群模式和管道模式。

3.Redisson

redisson是一个基于redis实现分布式、可伸缩的java数据结构集合,包含了诸如Map,Queue,Lock,Semphore,AtomicLong等强大功能。

Spring Data Redis 可以兼容 Jedis和Lettuce两个客户端。

Jedis官方网站:https://github.com/redis/jedis

1.引入依赖

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

单元测试依赖

<dependency><groupId>org.junit.jupiter</groupId><artifactId>junit-jupiter</artifactId><version>5.7.0</version><scope>test</scope>
</dependency>

2.建立连接

3.操作redis

4.释放资源

package com.xkj.org;import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import redis.clients.jedis.Jedis;public class JedisTest {private Jedis jedis;@BeforeEachvoid setUp() {//建立连接jedis = new Jedis("192.168.171.130", 6379);//设置密码jedis.auth("123456");//选择库jedis.select(0);}@Testvoid testString() {String result = jedis.set("name", "虎子");System.out.println("result="+result);String name = jedis.get("name");System.out.println("name="+name);}@AfterEachvoid tearDown() {if(jedis!= null) {jedis.close();}}}

Hash类型的操作

@Testvoid testHash() {//插入hash数据Long res = jedis.hset("person", "name", "张三");jedis.hset("person", "age", "22");System.out.println("res="+res);//取出hash数据String name = jedis.hget("person", "name");System.out.println("name="+name);//全部取出hash数据Map<String, String> person = jedis.hgetAll("person");System.out.println("person="+person);}

jedis本身是线程不安全的,并且频繁的创建和销毁连接会有性能损耗,因此推荐使用jedis连接池代替jedis直连方式。

Jedis连接池

package com.xkj.org.utils;import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;public class JedisConnectionFactory {public static final JedisPool jedisPool;static {//配置连接池JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();jedisPoolConfig.setMaxTotal(8);jedisPoolConfig.setMaxIdle(8);jedisPoolConfig.setMaxWaitMillis(1000);//创建连接池对象jedisPool = new JedisPool(jedisPoolConfig, "192.168.171.130", 6379, 1000, "123456");}public static Jedis getJedis() {return jedisPool.getResource();}}
package com.xkj.org;import com.xkj.org.utils.JedisConnectionFactory;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisFactory;import java.util.Map;public class JedisTest {private Jedis jedis;@BeforeEachvoid setUp() {//建立连接
//        jedis = new Jedis("192.168.171.130", 6379);jedis = JedisConnectionFactory.getJedis();//设置密码jedis.auth("123456");//选择库jedis.select(0);}@Testvoid testString() {String result = jedis.set("name", "虎子");System.out.println("result="+result);String name = jedis.get("name");System.out.println("name="+name);}@Testvoid testHash() {//插入hash数据Long res = jedis.hset("person", "name", "张三");jedis.hset("person", "age", "22");System.out.println("res="+res);//取出hash数据String name = jedis.hget("person", "name");System.out.println("name="+name);//全部取出hash数据Map<String, String> person = jedis.hgetAll("person");System.out.println("person="+person);}@AfterEachvoid tearDown() {if(jedis!= null) {//如果是连接池,会将连接还回池子jedis.close();}}}

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com