标签：redisson

排查redisson中订阅connection无故消失的问题

最近在项目中使用了redis结合spring cache一起作了一个缓存，并使用了订阅功能来达到进程间的数据同步。但在测试使用过程中，发现第二天一来，本来应该工作的订阅同步并不能进行。当时没在意，简单重启了事。但后来发现，每天早上相应的同步都不能进行，并且经测试。每个进程的同步都不进行，感觉是redis的订阅出问题了。

1. 验证问题

表现出来就是A程序修改了数据，B程序并没有识别到这次更新。那么就先尝试手动在redis中进行相应的set操作，因为订阅的是redis的空间事件，即key space event. 在控制台单独连接redis，执行相应的set 命令，在B程序中并没有任何表示。
怀疑是不是redis的发布订阅出问题了，就另开终端，手动地进行订阅，一切正常。
初步确定是程序出问题了。

2. 查看程序

把进程的stack打印一份，查看里面的线程信息，发现并没有redisson的线程信息。一般来说，没收到消息也可能是线程内阻塞了，但是直接就没有相应的线程，这就有问题了。
怀疑是不是相应的连接被断开之后就没有再连，也可能是redis server被重启了。

重新连接redis，使用status查看相应的状态，显示server端并没有重启过，其运行时间长达X天，即没有间断过。

回过来再看相应的redisson程序，里面有一个watch dog，是负责连接断开重连的。即如果连接被断掉了，它会尝试重连，但每一次的重连都会迟后一定时间，如 1 2 4 8 秒这样。这也是为什么要看stack的原因。简单看了下watchdog的实现，表示并没有明显的问题（或者就没问题)。

进一步怀疑是不是出现了某个异常，导致相应的watchdog重连直接被中断了。比如Error级错误。将相应的日志拉下来一份，因为一晚上都没人操作，日志信息本身也很少。直接在里面使用grep Exception查找日志信息，但一切也很正常，甚至没有异常发生。

再重新查看了redisson的源码，里面使用netty的channelInActive来进行重连尝试。在本地测试了一下这个机制，redis重启或者断开连接，它都能检测到。开始怀疑是不是日志信息不全，被吞掉了。重新调整日志级别，将redisson和netty的级别调到TRACE级别，结果中午过去一会，再回来看。相应的连接又不见了，订阅又不能正常工作。查看了日志，里面也没有任何信息，因为这期间无任何操作。

继续阅读“排查redisson中订阅connection无故消失的问题”

redisson中连接对象创建及断线重连

在redisson中，由于使用了netty来封装对redis的协议访问，因此对于连接对象的创建和释放，也借由相应的connection来实现。由篇由masterSlave的角度，描述整个redisson中对于client的封装，以及在网络中断情况下，客户端会得到什么样的反馈，如何实现重连的情况。

本篇主要介绍master slave情况下各个对象的关系图信息，以及在具体创建时的一些处理问题.Redisson版本:2.1.1

1 对象关系图

整个关系如上所示，由下图进行描述

  1. 由MasterSlaveServersConfig负责配置连接的各项参数，比如master地址,slave地址,连接数大小等,这个对象是在redision创建时，由Config对象负责创建的
  2. 在调用Redission.create时，创建起相应的connectionManager对象，其持有相应的master连接信息，以及相应slave的连接信息
  3. 相应的connectionManager负责创建卢相应masterEntry以及slaveEntry信息，并且保存相应的映射信息
  4. connectionManager负责当前客户端对于具体服务器端的各项配置以下，比如转码器，连接池，使用的各项协议等，其根据这些信息，使用netty创建起相应的redisClient对象
  5. entry将已经创建好的redisClient交由connectionEntry负责持有，因此这里的client仅表示一个特有的客户端连接信息。在初始化时并不自动创建相应的连接
  6. entry因此持有相应的client，因此也自然根据当前的需要创建出相应的connection对象，这里entry的创建工作交由client负责，同时将创建好的connection管理起来

继续阅读“redisson中连接对象创建及断线重连”

redisson的理解和使用－调用流程

redisson是一个用于连接redis的java客户端工作，相对于jedis，是一个采用异步模型，大量使用netty promise编程的客户端框架。

0     代码示例

        //创建配置信息
        Config config = new Config();
        config.useSingleServer().setAddress("localhost:6379").setConnectionPoolSize(5);

        Redisson redisson = Redisson.create(config);

        //测试 list
        List<String> strList = redisson.getList("strList");
        strList.clear(); //清除所有数据
        strList.add("测试中文1");
        strList.add("test2");

        redisson.shutdown();

从代码上来看，其基本的使用非常简单，在最后的使用当中。除与redisson打交道之外(获取各种数据结构)，完全感觉不到与redis的信息连接。甚至于返回于上层直接不需要考虑下层的实现，一切均由redisson进行了封装。

继续阅读“redisson的理解和使用－调用流程”