shiwei901020 2022-09-26 16:53
浏览 77
已结题

JedisConnectionFactory was destroyed

问题遇到的现象和发生背景

JedisConnectionFactory was destroyed and cannot be used anymore

用代码块功能插入代码,请勿粘贴截图

@PostConstruct
public void cusumerAlarm() {
// 创建一个单线程的执行器
ExecutorService executorService = Executors.newSingleThreadExecutor();
// 放入循环消费消息的任务
executorService.execute(() -> {
// 循环出队
while (true) {
try {
// 读取备份list,存在则先消费备份list
AlarmNoticeVO alarmNoticeVO = gson.fromJson( (String)redisTemplate.opsForList().rightPop(RedisConfig.CLIENT_ALARM_TOPIC),AlarmNoticeVO.class);

                if (alarmNoticeVO == null) {
                    alarmNoticeVO = gson.fromJson((String)redisTemplate.opsForList()
                            .rightPop(RedisConfig.CLIENT_ALARM_TOPIC, 10, TimeUnit.SECONDS),AlarmNoticeVO.class);
                }

                // 无消息时,开始下一轮
                if (alarmNoticeVO == null) {
                    continue;
                }
                // 进行业务处理
                cdaAlarmDetailsService.dealAlarm(alarmNoticeVO);

            } catch (Exception e) {
                // 异常捕获,防止循环因异常停止
                log.error(e.getMessage());
            }
        }
    });
}
运行结果及报错内容

img

我想要达到的结果

启动可以正常消费redis

  • 写回答

0条回答

      报告相同问题?

      相关推荐 更多相似问题

      问题事件

      • 系统已结题 10月4日
      • 创建了问题 9月26日

      悬赏问题

      • ¥15 有关时间计算器的问题
      • ¥200 Chrome浏览器自动保存密码需要解密!来人
      • ¥18 关于#c语言#的问题:如何把下面几个代码放在一起编序号,然后输入对应数字运行对应代码,还可以返回重输1.成绩求平均数#include <stdio.h>
      • ¥30 windows下无法运行go test的问题
      • ¥15 多个Rigify骨骼 导入一起 后 没有 控制器面板
      • ¥15 想问一下sprak ada语言的pre和post怎么设
      • ¥15 使用python将分子模拟输出.gro文件
      • ¥15 港诡实录的背包系统拆解
      • ¥15 宽带IP网络路由器的初始路由表和最终路由表
      • ¥15 c语言基础这几个该怎么搞