springboot2.0整合redis_灰度发布的方式

springboot2.0整合redis_灰度发布的方式一、简介1、发布订阅SUBSCRIBE,UNSUBSCRIBE和PUBLISH实现了发布/订阅消息范例,发送者(publishers)不用编程就可以向特定的接受者发送消息(subscribers).Rather,发布的消息进入通道,不需要知道有没有订阅者.订阅者发表感兴趣的一个或多个通道,并且只接受他们感兴趣的消息,不管发布者是不是存在.发布者和订阅者的解耦可以允许更大的伸缩性和更多动态的网络拓扑。2、说明本篇文章是继:【SpringBoot】三十四、SpringBoot

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

一、简介

二、注入消息发布/订阅

  • 1、添加消息监听器
/** * 消息监听 * <p> * 可以传入多个 MessageListenerAdapter */
@Bean
RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory, MessageListenerAdapter messageListenerAdapter) { 
   
    RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    // 监听所有库的key过期事件
    container.setConnectionFactory(connectionFactory);
    // 可以添加多个 messageListener,配置不同的通道
    container.addMessageListener(messageListenerAdapter, new PatternTopic("user"));
    return container;
}

所有的订阅消息,都需要在这里进行注册绑定,new PatternTopic(“user”),表示发布的主题信息

  • 小插曲
    前面我们学习了监听 key 过期事件,如果我们只需要监听当前库的 key 过期事件,可以这样写:
@Value("${spring.redis.database}")
public String redisDatabaseIndex;

先拿到我们项目中使用的 Redis 的库索引

// 监听当前库的key过期
container.addMessageListener(messageListenerAdapter, new PatternTopic("__keyevent@" + redisDatabaseIndex + "__:expired"));

然后使用发布/订阅模式,订阅主题为:keyevent@0:expired 的消息,则表示订阅数据库索引为 0 的 key 过期事件,监听所有的库则为:keyevent@*:expired

  • 2、绑定消息处理器
/** * 消息监听器适配器,绑定消息处理器 * <p> * 可以配置多个 listenerAdapter,监听不同的通道 */
@Bean
MessageListenerAdapter listenerAdapter(RedisMessageListener receiver) { 
   
    return new MessageListenerAdapter(receiver, "onMessage");
}

也就是说,当我们订阅的频道,当有消息进来时,指定它的处理类以及处理方法

三、注入消息处理器

上面我们已经注入了 RedisMessageListener 消息处理器,并指定了处理方法 onMessage(),代码如下:

package com.zyxx.common.redis;

import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.stereotype.Component;

/** * Redis 消息接收 * * @Author Lizhou **/
@Slf4j
@Component
public class RedisMessageListener implements MessageListener { 
   

    @Override
    public void onMessage(Message message, byte[] pattern) { 
   
        // 接收的topic
        log.info("channel:" + new String(pattern));
        // 消息的POJO
        log.info("message:" + message.toString());
    }
}

需要实现 MessageListener 接口,重写 onMessage() 方法,然后就可以获取到通道以及消息了,从而进行我们的一些业务逻辑处理

四、操作API

在 RedisUtils 中,我们增加一个操作方法

/** * 向通道发布消息 */
public boolean convertAndSend(String channel, Object message) { 
   
    if (StringUtils.isBlank(channel)) { 
   
        return false;
    }
    try { 
   
        template.convertAndSend(channel, message);
        log.info("发送消息成功,channel:{},message:{}", channel, message);
        return true;
    } catch (Exception e) { 
   
        log.info("发送消息失败,channel:{},message:{}", channel, message);
        e.printStackTrace();
    }
    return false;
}

这里的 channel 相当于 我们存入数据的时候的 key,如果该通道不存在,则会新建一个通道

五、测试

  • 1、测试用例
package com.zyxx.redistest;

import com.zyxx.redistest.common.RedisUtils;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
class RedisTestApplicationTests { 
   

    @Autowired
    private RedisUtils redisUtil;

    @Test
    void contextLoads() { 
   
        String message = "Hello World!";
        // 发送消息
        redisUtil.convertAndSend("user", message);
    }
}

我们向通道 user 发送了一条 “Hello World!” 的消息

  • 2、测试结果
    发送消息
    可以看出,我们的消息发送成功,再看控制台
    接收消息
    我们接收到通道 user 发送了一条 “Hello World!” 的消息

如您在阅读中发现不足,欢迎留言!!!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/190640.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • 防火墙-interface GigabitEthernet0/0/0-ensp

    防火墙-interface GigabitEthernet0/0/0-ensp#interfaceGigabitEthernet0/0/0 undoshutdown ipbindingvpn-instancedefault ipaddress192.168.0.1255.255.255.0 service-managehttppermit service-managehttpspermit service-managepingper…

    2022年10月28日
  • 泰国80亿互联网记录数据库泄漏,疑遭黑客攻击[通俗易懂]

    泰国80亿互联网记录数据库泄漏,疑遭黑客攻击[通俗易懂]泰国最大的蜂窝网络AIS已使数据库脱机,疑遭黑客攻击,这使达80亿实时互联网记录泄漏到数百万泰国互联网用户上,该事件震惊整个泰国。全球著名白帽黑客、东方联盟创始人郭盛华博客文章中说,他在互联网上没有密码就找到了包含DNS查询和Netflow数据的数据库。通过访问该数据库,任何人都可以“快速描绘”互联网用户(或其家庭)的实时行为。他表示:“在数据库中找到的记录只能来自能够监视Internet流量在网络上流动的人。但是,没有一种简单的方法可以区分数据库是属于Internet提供商还…

  • 回归分析中自变量取舍、检验及多重共线性处理(VIF)「建议收藏」

    回归分析中自变量取舍、检验及多重共线性处理(VIF)「建议收藏」A1正交假定:误差项矩阵与X中每一个x向量都不相关高斯-马尔科夫定理:若满足A1和A2假定,则采用最小二乘法得到回归参数估计是最佳线性无偏估计方程估计值b1和b2可以看做偏回归系数,也是相应自变量对y的一种偏效应偏效应:在控制变量下,各自变量X对因变量Y的净效应残差项:针对具体模型而言,被定义为样本回归模型中观测值与预测值之差误差项:针对总体真实回归模型而言,它由一些不可观测因素或测量…

  • 【Java】idea @NotNull @Nullable 注解

    【Java】idea @NotNull @Nullable 注解这两个注解在idea里面可以帮助我们检测方法的返回值,方法参数以及局部变量是否为空,从而帮助我们减少一些NPE的发生。1.原始注解@NotNull@Nullable最开始只能使用idea提供的一个jetBrainsjavaannotation的jar包下的注解。maven坐标:https://mvnrepository.com/artifact/org.jetbrains…

  • python转置矩阵画流程图_python 矩阵转置transpose

    python转置矩阵画流程图_python 矩阵转置transposearr=np.arange(16).reshape((2,2,4))arr的array是这样的array([[[0,1,2,3],[4,5,6,7]],[[8,9,10,11],[12,13,14,15]]])我们对arr进行transpose转置,arr2=arr.transpose((1,0,2)),结果是这样:array([[[0,1,2,3…

  • 数据库三范式

    数据库三范式

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号