javajedis,javajedis一个线程订阅多个channel

发布时间：2023-01-09

本文目录一览：

1、Jedis集成与踩坑经历
2、redis java 有什么用
3、关于java redis的操作jedis的疑问

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 java 有什么用

Java连接redis的使用示例
Redis是开源的key-value存储工具，redis通常用来存储结构化的数据，因为redis的key可以包含String、hash、list、set和sorted list。
Redis client支持多种语言，包括：c、C++、C#、php、java、python、go等语言，根据自己的开发语言，选择合适的redis client版本类型即可。我是使用java语言开发的，针对java语言，redis client也提供了多种客户端支持，按照推荐类型依次是：Jedis、Redisson、JRedis、JDBC-Redis、RJC、redis-protocol、aredis、lettuce。前两种类型是比较推荐的，我们采用了Redisson类型版本作为redis client的使用。

Redisson版的redis开发工程搭建

  1. 新建maven工程
  2. 在pom.xml文件的dependencies节点下增加如下内容：
<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson</artifactId>
    <version>1.0.2</version>
</dependency>
<dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-log4j12</artifactId>
    <version>1.7.7</version>
</dependency>
  1. 保存pom.xml后，等eclipse工程构建完成后即可进行开发了

开发示例

下面是演示连接redis服务器、保存读取concurrentMap对象、保存读取set对象和保存读取Queue对象的示例代码，代码比较简单，这里就不再详细讲解了，代码如下：

package com.my.test.redis;
import java.util.Queue;
import java.util.Set;
import java.util.concurrent.ConcurrentMap;
import org.redisson.Config;
import org.redisson.Redisson;
public class RedisExample {
    /**
     * @param args
     */
    public static void main(String[] args) {
        // 1.初始化
        Config config = new Config();
        config.setConnectionPoolSize(10);
        config.addAddress("127.0.0.1:6379");
        Redisson redisson = Redisson.create(config);
        System.out.println("reids连接成功...");
        // 2.测试concurrentMap,put方法的时候就会同步到redis中
        ConcurrentMap<String, Object> map = redisson.getMap("FirstMap");
        map.put("wuguowei", "男");
        map.put("zhangsan", "nan");
        map.put("lisi", "女");
        ConcurrentMap resultMap = redisson.getMap("FirstMap");
        System.out.println("resultMap==" + resultMap.keySet());
        // 2.测试Set集合
        Set mySet = redisson.getSet("MySet");
        mySet.add("wuguowei");
        mySet.add("lisi");
        Set resultSet = redisson.getSet("MySet");
        System.out.println("resultSet===" + resultSet.size());
        // 3.测试Queue队列
        Queue myQueue = redisson.getQueue("FirstQueue");
        myQueue.add("wuguowei");
        myQueue.add("lili");
        myQueue.add("zhangsan");
        myQueue.peek();
        myQueue.poll();
        Queue resultQueue = redisson.getQueue("FirstQueue");
        System.out.println("resultQueue===" + resultQueue);
        // 关闭连接
        redisson.shutdown();
    }
}

关于java redis的操作jedis的疑问

Java操作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 中的程序会被编译成中间语言字节码。它支持函数式，命令式以及面向对象编程。

推荐文章