报错信息 Connection refused: no further information: localhost/127.0.0.1:6379

redis版本5.07

yml配置的是远程端口,发生问题时,redis是启动的,也可以远程访问;

以下是报错类的代码麻烦各位帮忙看下是什么原因比较急

package com.hem.xhlapi.redis.client;

import com.alibaba.fastjson.JSON;
import com.hem.xhlapi.enums.RedisPrefixEnum;
import com.hem.xhlapi.model.vo.BroadUserVO;
import com.hem.xhlapi.netease.model.BroadCastNoticeRequest;
import com.hem.xhlapi.service.facade.NeteaseFacade;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.stereotype.Component;


/**
 * @ClassName RedisKeyExpirationListener
 * @Deacription redis键失效处置
 * @Author Leslie.Guo
 * @Date 2021/3/5 13:29
 * @Version 1.0
 **/
@Component
public class RedisKeyExpirationListener extends KeyExpirationEventMessageListener {

    @Autowired
    private NeteaseFacade neteaseFacade;

    public RedisKeyExpirationListener(RedisMessageListenerContainer listenerContainer) {
        super(listenerContainer);
    }
    /**
     * 针对 redis 数据失效事件，进行数据处理
     * @param message
     * @param pattern
     */
    @Override
    public void onMessage(Message message, byte[] pattern) {

        // 获取到失效的 key，进行取消订单业务处理
        String expiredKey = message.toString();
        System.out.println(expiredKey);
        String headlineKey = RedisPrefixEnum.ISSUE_HEADLINE.getKey();
        String issueBroadcastKey = RedisPrefixEnum.ISSUE_BROADCAST.getKey();
        BroadUserVO vo =new BroadUserVO();
        if(expiredKey.equals(headlineKey)){
            //封装头条信息
            vo.setBroadcastType("1");
            String s = JSON.toJSONString(vo);
            //推送云信数据
            BroadCastNoticeRequest sendRequest = new BroadCastNoticeRequest.Builder()
                    .withBody(s)
                    .build();
            // 发送广播消息
            neteaseFacade.asyncBroadcastMsg(sendRequest);
        }else if(expiredKey.equals(issueBroadcastKey)){
          vo.setBroadcastType("2");
            String s = JSON.toJSONString(vo);
            //推送云信数据
            BroadCastNoticeRequest sendRequest = new BroadCastNoticeRequest.Builder()
                    .withBody(s)
                    .build();
            // 发送广播消息
            neteaseFacade.asyncBroadcastMsg(sendRequest);
        }else{
            System.out.println(expiredKey);
        }
    }

}

lswjkl

eclipse使用Debug调试和正常运行输出结果不一致

3条回答

为你推荐