「javajedis使用」jedis jar
今天给各位分享javajedis使用的知识,其中也会对jedis jar进行解释,如果能碰巧解决你现在面临的问题,别忘了关注本站,现在开始吧!
本文目录一览:
- 1、Jedis干什么用的
- 2、(二)连接Redis,Lettuce与Jedis客户端
- 3、Jedis集成与踩坑经历
- 4、怎么连接redis集群 使用jedis连接单机和集群redis的两种方式
- 5、关于java redis的操作jedis的疑问
- 6、如何在java中使用redis
Jedis干什么用的
redis是key-value存储系统。
key-value分布式存储系统查询速度快、存放数据量大、支持高并发,非常适合通过主键进行查询,但不能进行复杂的条件查询。
如果辅以Real-Time Search Engine(实时搜索引擎)进行复杂条件检索、全文检索,就可以替代并发性能较低的MySQL等关系型数据库,达到高并发、高性能,节省几十倍服务器数 量的目的。
以MemcacheDB、Tokyo Tyrant为代表的key-value分布式存储,在上万并发连接下,轻松地完成高速查询。而MySQL,在几百个并发连接下,就基本上崩溃了。
在此基础上,redis支持各种不同方式的排序。与memcached一样,为了保证效率,数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件,并且在此基础上实现了master-slave(主从)同步。
扩展资料:
Jedis主存保护是存储保护的重要环节。主存保护一般有存储区域保护和访问方式保护。存储区域保护可采用界限寄存器方式,由系统软件经特权指令给定上、下界寄存器内容,从而划定每个用户程序的区域,禁止越界访问。
Jedis当两键符合时才允许执行存取操作,从而保护别的程序区域不被侵犯,环状保护是把系统程序和用户程序按重要性分层,称为环,对每个环都规定访问它的级别,违反规定的存取操作是非法的,以此实现对正在执行的程序的保护。
参考资料来源:百度百科-Key-Value
(二)连接Redis,Lettuce与Jedis客户端
Redis优势
从 Spring Boot 2.x 开始 Lettuce 已取代 Jedis 成为首选 Redis 的客户端。当然 Spring Boot 2.x 仍然支持 Jedis,并且你可以任意切换客户端。
使用Lecttuce需要再引用一个包
配置
org.springframework.boot.autoconfigure.data.redis.RedisProperties中集成了Jedis与Lettuce。
概念:
Jedis:是Redis的Java实现客户端,提供了比较全面的Redis命令的支持,
Redisson:实现了分布式和可扩展的Java数据结构。
Lettuce:高级Redis客户端,用于线程安全同步,异步和响应使用,支持集群,Sentinel,管道和编码器。
优点:
Jedis:比较全面的提供了Redis的操作特性
Redisson:促使使用者对Redis的关注分离,提供很多分布式相关操作服务,例如,分布式锁,分布式集合,可通过Redis支持延迟队列
Lettuce:主要在一些分布式缓存框架上使用比较多
可伸缩:
Jedis:使用阻塞的I/O,且其方法调用都是同步的,程序流需要等到sockets处理完I/O才能执行,不支持异步。Jedis客户端实例不是线程安全的,所以需要通过连接池来使用Jedis。
Redisson:基于Netty框架的事件驱动的通信层,其方法调用是异步的。Redisson的API是线程安全的,所以可以操作单个Redisson连接来完成各种操作
Lettuce:基于Netty框架的事件驱动的通信层,其方法调用是异步的。Lettuce的API是线程安全的,所以可以操作单个Lettuce连接来完成各种操作
Jedis集成与踩坑经历
Jedis是Redis的Java客户端实现,封装了对Redis的通信和命令处理等。
Jedis提供了资源池,可以很方便地实现对Redis的API调用。
之前是通过组内对Jedis封装的Spring Bean来获取和使用Jedis的,现在希望自行实现类似功能,设计目标如下:
具体思路就是针对设计目标而定的:
由于需求比较基础,还没有太多应用场景,实现也没考虑太复杂。整体逻辑不到50行,可以在 我的GitHub 上大致看一下。
后续使用可以直接使用Spring将Bean注入。
由于不按常规方法使用JedisPool可能背离了JedisPool设计的使用场景,因此在其中踩了不少坑。
其次,虽然平常常用组内的Jedis组件,但实际上对Jedis的API不了解,本次根据平常使用过程中的一些感受进行“黑盒临摹”,在爬坑过程中其实也学习了其他一些方面的经验,比如Guava Reflections等。
背景
最开始通过FactoryBean提供的连接并未使用动态代理,也就是说仅提供了一个Jedis,所有线程使用同一个Jedis连接。
现象
业务中较频繁地报异常,异常信息为 java.lang.ClassCastException: java.util.ArrayList cannot be cast to [B 等,基本是 ClassCastException ,异常抛出位置为调用Jedis的位置。
原因
最终在另一篇资料指引下来到jedis/issues,在 参考资料 中发现了最可信最合理的原因:Jedis并非线程安全,不应当并发操作。
正确使用
正如参考资料中回答提到的,每个线程(每次调用)都从JedisPool中获取一个连接,并在使用后归还。
也正是因为这一点跟最初的FactoryBean封装方式冲突了,后来才改用提供动态代理类的方式封装FactoryBean。
背景
我使用的Jedis版本为3.0.1,网上的不少资料指出在使用连接后归还可以使用JedisPool的 void returnResource(Jedis resource) 方法,但在3.0.1版本中这个方法是protected可见的,没有间接调用方法。
另外Jedis源码中找不到注释,这有点奇怪,我想当然地认为版本升级后可以自动归还资源了,于是仅在设置最大连接数之后就部署到业务中了。
现象
业务线程启动后每访问一定次数(调用Jedis达到一定次数)后就完全不响应请求了:
还是在 参考资料 的指引下查看Tomcat监听的端口,的确很多连接处于 CLOSE_WAIT 状态,表明客户端已断开连接(我自己测试的时候刷新页面太多,很多就中途断开了)。
原因
结合TCP四次挥手过程,应该是中间有资源释放不了导致没有进入 LAST_ACK 状态,推测是Jedis连接资源未归还而总连接数有限制,导致很多线程在等待获取Jedis资源。
正确使用
在Jedis连接使用完毕后,需要调用Jedis的 close() 方法将资源归还JedisPool, close 方法是用于替代 returnResource 方法的。
这个方法语义比较奇怪,真实作用是“ 归还或 关闭连接”,最开始其实就是考虑到资源复用的问题才没有考虑使用这个 close 方法的。
对比了一下组内的组件,思路差不多,还有以下的点能够扩展:
ClassCastException - B cannot be cast to java.lang.Long · Issue #186 · xetorthio/jedis
nginx 499状态码 - 微信-大数据从业者 - 博客园
深入分析Tomcat无响应问题及解决方法 - 月下狼的个人页面 - OSCHINA
jedis:连接池(JedisPool)使用示例 - 10km的专栏 - CSDN博客
Jedis使用|returnBrokenResource|returnResource废弃替代 - 诗人不写诗 - CSDN博客
本文搬自 我的博客 ,欢迎参观!
怎么连接redis集群 使用jedis连接单机和集群redis的两种方式
第一:非集群状态下
非集群状态下用Jedis获取Redis连接,得到Jedis对象即可,一共有两种:
1.利用Jedis构造器,仅限用于测试,在实际项目中肯定是用JedisPool。
Jedis(String host);
Jedis(String host , int port);
2.利用JedisPool
主要是利用Jedis jedis=jedisPool.getResource();
JedisPool有N多个构造器,常用的构造器参数有GenericObjectPoolConfig poolConfig,String host,int port,int timeout,String password,创建GenericObjectPoolConfig对象时我们一般用其子类JedisPoolConfig (redis.clients.jedis.JedisPoolConfig),timeout是连接redis服务器的超时时间,以毫秒为单位,一般设置为0,如果不设为0,则不可设置太小,如果设成1、2,那么可能因为网络原因在1毫秒、2毫秒之内没有连上服务器而报错。见下例:
[java] view plain copy
public static void main(String[] args) {
JedisPoolConfig poolConfig = new JedisPoolConfig();
// 最大连接数
poolConfig.setMaxTotal(2);
// 最大空闲数
poolConfig.setMaxIdle(2);
// 最大允许等待时间,如果超过这个时间还未获取到连接,则会报JedisException异常:
// Could not get a resource from the pool
poolConfig.setMaxWaitMillis(1000);
JedisPool pool = new JedisPool(poolConfig, "192.168.83.128", 6379, 0, "123");
Jedis jedis = null;
try {
for (int i = 0; i 5; i++) {
jedis = pool.getResource();
jedis.set("foo" + i, "bar" + i);
System.out.println("第" + (i + 1) + "个连接, 得到的值为" + jedis.get("foo" + i));
// 用完一定要释放连接
jedis.close();
}
} finally {
pool.close();
}
}
如上,创建出一个JedisPool对象,然后调用其getResource()方法获取redis连接即可,之后就可以调用Jedis API操作redis了。jedis连接用完要释放即close,如果不close,则产生的连接会越来越多,当达到了最大连接数,再想获得连接,就会等待,当超过了最大等待时间后就会报异常。
第二:集群状态下
集群状态下用Jedis获取redis连接,是得到JedisCluster对象,之后对redis进行操作都是用此对象的方法进行的:
[java] view plain copy
public static void main(String[] args) {
JedisPoolConfig poolConfig = new JedisPoolConfig();
// 最大连接数
poolConfig.setMaxTotal(1);
// 最大空闲数
poolConfig.setMaxIdle(1);
// 最大允许等待时间,如果超过这个时间还未获取到连接,则会报JedisException异常:
// Could not get a resource from the pool
poolConfig.setMaxWaitMillis(1000);
SetHostAndPort nodes = new LinkedHashSetHostAndPort();
nodes.add(new HostAndPort("192.168.83.128", 6379));
nodes.add(new HostAndPort("192.168.83.128", 6380));
nodes.add(new HostAndPort("192.168.83.128", 6381));
nodes.add(new HostAndPort("192.168.83.128", 6382));
nodes.add(new HostAndPort("192.168.83.128", 6383));
nodes.add(new HostAndPort("192.168.83.128", 6384));
JedisCluster cluster = new JedisCluster(nodes, poolConfig);
String name = cluster.get("name");
System.out.println(name);
cluster.set("age", "18");
System.out.println(cluster.get("age"));
try {
cluster.close();
} catch (IOException e) {
e.printStackTrace();
}
}
用集群时,好像没有办法设置集群的参数,比如最大连接数,虽然在创建JedisCluster 对象时传了JedisPoolConfig对象进去,但是JedisPoolConfig对象中的设置是不生效的。
关于java redis的操作jedis的疑问
ava操作redis的jedis的范围查询是怎么写的? 我要从一个范围到另一个范围的区间
我试过了,
List userList = jedis.lrange("userList", 0, -1);
Set user = jedis.zrange("user", 0, -1);
这两个范围查询的得到结果,为何都是 0
但是我用 Set str =jedis.keys("tes2:*");
发现是用完整的数据的,我一次性读取这么多数据,redis直接socket失败了
它是专为 .NET 平台设计的一种静态类型编程语言。 Nemerle 中的程序会被编译成中间语言字节码。它支持函数式,命令式以及面向对象编程。
如何在java中使用redis
public class RedisListJava {
public static void main(String[] args) {
//连接本地的 Redis 服务
Jedis jedis = new Jedis("localhost");
System.out.println("Connection to server sucessfully");
//存储数据到列表中
jedis.lpush("tutorial-list", "Redis");
jedis.lpush("tutorial-list", "Mongodb");
jedis.lpush("tutorial-list", "Mysql");
// 获取存储的数据并输出
ListString list = jedis.lrange("tutorial-list", 0 ,5);
for(int i=0; ilist.size(); i++) {
System.out.println("Stored string in redis:: "+list.get(i));
}
}
}
javajedis使用的介绍就聊到这里吧,感谢你花时间阅读本站内容,更多关于jedis jar、javajedis使用的信息别忘了在本站进行查找喔。