【quarkus系列】实战自定义注解实现策略模式分发

目录

  • 序言
  • 自定义注解
  • 业务接口
  • 渠道消息实现
  • 策略分发
  • 测试
  • 知识扩展
    • @Any
    • AnnotationLiteral 应用场景和语法

序言

策略模式大家都应该了解或者使用过,此篇文章中就不再阐述,之前springboot项目中小编也真正的实战应用过。现在换Quarkus框架开发项目,为了后期的项目业务的可扩展以及高可用,就构思并了解如何在Quarkus中使用,软件设计思想最重要,换组件无非换种语法而已,但是也需要摸索,排坑之类,下面给出一个简单的示例demo:模拟向不同的平台类型发送消息

自定义注解

基于Quarkus自定义注解的语法格式,与java语法基本一致,毕竟遵循 MicroProfile 和 Jakarta EE 的规范。

  • 核心代码
@Qualifier
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.TYPE, ElementType.FIELD, ElementType.PARAMETER, ElementType.METHOD})
public @interface Platform {
    PlatformTypeEnum type();
}
  • 平台类型枚举
@AllArgsConstructor
@Getter
public enum PlatformTypeEnum {
    //企微
    WEWORK(1, "企微"),
    //小红书
    RED_BOOK(2, "小红书"),
    ;
    private final Integer type;
    private final String desc;
}

业务接口

抽象消息业务接口,应用于多平台渠道实现

public interface MessageService {

    String sendMsg(String msg);


}

渠道消息实现

  • 企业微信渠道实现
@Platform(type = PlatformTypeEnum.WEWORK)
@Dependent
public class WeWorkMessage implements MessageService {

    @Inject
    MessageRepo messageRepo;
    @Override
    public String sendMsg(String msg) {
        //TODO
        return messageRepo.getMessage() + ", weWork";
    }
}

  • 小红书渠道消息实现
@Platform(type = PlatformTypeEnum.RED_BOOK)
@Dependent
public class RedBookMessage implements MessageService {
    @Override
    public String sendMsg(String msg) {
        //TODO
        return "redBook";
    }
}

策略分发

  • 方式一:switch-case
  public MessageService getStrategy(PlatformTypeEnum platform) {
        switch (platform) {
            case WEWORK:
                return messageServices.select(WeWorkMessage.class).get();
            case RED_BOOK:
                return messageServices.select(RedBookMessage.class).get();
            default:
                return null;
        }
    }

这种方式违反了开闭原则,每次增加子类都需要修改此处的代码;

  • 方式二:动态分发
@ApplicationScoped
public class MessageStrategy {
    @Inject
    @Any
    Instance<MessageService> messageServices;
    public MessageService getStrategy(PlatformTypeEnum platform) {
        return messageServices.select(new PlatformLiteral(platform)).get();
    }
    private static class PlatformLiteral extends AnnotationLiteral<Platform> implements Platform {
        private final PlatformTypeEnum platform;

        public PlatformLiteral(PlatformTypeEnum platform) {
            this.platform = platform;
        }

        @Override
        public PlatformTypeEnum type() {
            return platform;
        }
    }
}

getStrategy 方法使用 messageServices.select 方法来动态选择符合条件的 MessageService 实例。
PlatformLiteral 用于在运行时创建一个带有具体值的 @Platform 注解。
PlatformLiteral 类扩展了 AnnotationLiteral 并实现了 Platform 接口。它接受一个 PlatformTypeEnum 值并重写 type 方法返回该值。通过这种方式,PlatformLiteral 在运行时创建了一个带有特定 PlatformTypeEnum 值的 @Platform 注解实例。

  • 优点
    这个机制允许在运行时动态选择不同的 MessageService 实现,而无需在编译时确定具体的实现类。

测试

@Path("/message")
@Tag(name = "消息")
public class MessageController {

    @Inject
    MessageStrategy messageStrategy;

    @Path("/get-msg")
    @GET
    public Response<String> getMsg(@QueryParam("platform") PlatformTypeEnum platform) {
        String test = messageStrategy.getStrategy(platform).sendMsg("test");
        return Response.ok(test);
    }
}

可以看到messageService中存在两个实现类
在这里插入图片描述
使用swagger测试,分布使用企微、小红书入参得到的结果如图:
在这里插入图片描述

  • 小红书,消息渠道分发
    在这里插入图片描述

知识扩展

基于方式二实现扩展使用的注解语法以及相关原理

@Any

  • 应用场景
    @Any 注解在 CDI(Context and Dependency Injection)中用于注入所有符合特定类型的 Bean 实例,而不考虑其他限定符。它通常用于动态选择或处理多个实现。

  • 语法

@Inject
@Any
Instance<SomeType> someInstances;
  • 原理
    @Any 告诉 CDI 容器注入所有符合类型 SomeType 的 Bean 实例,即使这些实例有其他限定符。

  • @Any注解的源码,是不是很熟悉呀

@Qualifier
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.TYPE, ElementType.METHOD, ElementType.FIELD, ElementType.PARAMETER})
@Documented
public @interface Any {
    public static final class Literal extends AnnotationLiteral<Any> implements Any {
        public static final Literal INSTANCE = new Literal();
        private static final long serialVersionUID = 1L;

        public Literal() {
        }
    }
}

AnnotationLiteral 应用场景和语法

  • 应用场景
    AnnotationLiteral 用于在运行时动态创建注解实例。它通常用于 CDI 的动态选择,特别是当需要根据条件在运行时选择特定 Bean 实例时。

  • 语法

public class SomeAnnotationLiteral extends AnnotationLiteral<SomeAnnotation> implements SomeAnnotation {
    private final SomeType value;

    public SomeAnnotationLiteral(SomeType value) {
        this.value = value;
    }

    @Override
    public SomeType value() {
        return value;
    }
}

  • 原理
    AnnotationLiteral 是一个抽象类,用于表示注解的具体实例,提供了注解的具体实现,使得可以在运行时生成注解实例,用于 CDI 的选择操作。原理是利用泛型和反射机制,它通过创建一个匿名内部类来实现对注解实例的动态创建,通过扩展 AnnotationLiteral 类并实现注解接口的方法,可以动态创建带有具体值的注解实例,而不是依赖于编译时注解处理器生成的实例。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/683068.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Java面试题:Redis双写一致性问题

Redis双写一致性 缓存和数据库数据同步 正常流程: 读操作: 查询缓存,查询命中直接返回,没命中查询数据库将查询到的数据写入缓存,并设定超时时间 写操作: 删除缓存,修改数据库,在延时一段时间后再删除缓存 (延迟双删)延迟:等待数据库的主节点同步到从节点 因为如果先删…

C++实现,简单的命令行交互框架

目录 背景背景 在实际开发中,经常需要有对端测试程序,配合自己的程序,验证功能、逻辑等。面对繁杂、多变的需求,如果对端程序设计得不够灵活,则无法提升工作效率,如果能够与对端程序交互,通过命令行输入命令的方式完成测试验证,将大大提升工作效率,下面的示例程序是一…

【C语言】一节课拿捏---动态内存分配

谢谢观看&#xff01;希望以下内容帮助到了你&#xff0c;对你起到作用的话&#xff0c;可以一键三连加关注&#xff01;你们的支持是我更新地动力。 因作者水平有限&#xff0c;有错误还请指出&#xff0c;多多包涵&#xff0c;谢谢&#xff01; 目录 一、 为什么要有动态内存…

winscp无法上传,删除,修改文件并提示权限不够的分析

使用winscp删除文件,报了个错如下 根据这个错就去百度,网上大部分都是通过下面这种方法解决: 在winscp端进行设置 输入主机名(即IP地址)、用户名和密码,然后点击高级 在箭头所指位置输入sudo + sftp应用程序的路径 先查询 sudo find / -name sftp-server -print点击Sh…

springboot项目中第三方jar包打包进jar包

springboot项目中&#xff0c;如果手动引入了jar包&#xff0c;打包时不会将手动引入的第三方jar包打包进价包里&#xff0c;如何处理&#xff1f; 若第三方的jar包的lib和src同级&#xff0c;则maven打包时默认不会将lib下的jar包打包进jar包&#xff0c;处理方式有两种&#…

neo4j入门并使用案例说明

1、neo4j是什么 Neo4j是一个高性能的NoSQL图形数据库&#xff0c;它将结构化数据存储在网络&#xff08;在数学角度称为图&#xff09;上&#xff0c;而不是传统的表中。Neo4j是一个嵌入式的、基于磁盘的、具备完全的事务特性的Java持久化引擎。它因其高性能、轻量级、易嵌入和…

c++(内存分配,构造,析构)

#include <iostream>using namespace std; class Per { private:string name;int age;double *height;double *weigh; public://无参构造Per(){cout << "Per::无参构造" << endl;}//有参构造Per(string name,int age,double height,double weigh):…

私募状告基金经理,七千月薪被索赔上百万

一个私募机构的基金经理&#xff0c;月薪七千元&#xff0c;但是却被公司诉讼追索100多万元赔偿。 这样“奇葩”的事情&#xff0c;不仅发生在视频网剧里&#xff0c;也发生在现实生活中。 根据日前相披露的一则案件文书&#xff0c;一家江浙一带的私募机构日前把自己的“基金…

docker create rm export exec命令详解

容器生命周期管理命令教程-3 1. 创建容器 docker create&#xff1a;创建一个新的容器但不启动它。 docker create -it --name mycontainer ubuntu bash通常使用 docker run(详细可看上一篇关于run命令的详细介绍) 2. 删除容器 docker rm&#xff1a;删除一个或多个容器。 d…

计算机网络9——无线网络和移动网络1 无线局域网 WLAN2

文章目录 一、802.11局域网的 MAC 层协议1、CSMA/CA协议2、时间间隔 DIFS 的重要性3、争用信道的过程4、对信道进行预约 二、802.11局域网的 MAC 帧1&#xff09;关于 802.11 数据帧的地址2&#xff09;序号控制字段、持续期字段和帧控制字段 一、802.11局域网的 MAC 层协议 1…

Spring boot+vue前后端分离

目录 1、前端vue的搭建 2、后端项目的构建 pom文件中引入的jar包 yml文件用来配置连接数据库和端口的设置 application.property进行一些整合 service层 imp层 mapper 实体类 额外写一个类、解决跨域问题 3、测试 1、前端vue的搭建 建立项目的过程略 开启一个建立好…

探索营销系统业务架构的设计与应用

随着市场竞争的日益激烈和消费者需求的不断变化&#xff0c;营销系统作为企业营销管理的重要组成部分&#xff0c;扮演着至关重要的角色。本文将深入探讨营销系统业务架构的设计与应用&#xff0c;从客户关系管理、营销活动管理、数据分析和智能化服务等方面进行全面解析&#…

Leetcode3168. 候诊室中的最少椅子数

Every day a Leetcode 题目来源&#xff1a;3168. 候诊室中的最少椅子数 解法1&#xff1a;模拟 代码&#xff1a; /** lc appleetcode.cn id3168 langcpp** [3168] 候诊室中的最少椅子数*/// lc codestart class Solution { public:int minimumChairs(string s){int chair…

学习笔记——路由网络基础——浮动静态路由(路由备份和冗余)

2、浮动静态路由(路由备份和冗余) (1)基本概念 浮动静态路由是两条或多条链路组成浮动路由。当到达某一网络有多条路径&#xff0c;通过为静态路由设置不同的优先级&#xff0c;你可以指定主用路径和备用路径。当主用路径不可用时&#xff0c;走备用路径的静态路由进入路由表…

LeakSearch:针对网络公开凭证的安全扫描与检测工具

关于LeakSearch 在红队演戏过程中&#xff0c;往往需要获取到针对目标域的访问权限。在这个过程中&#xff0c;很多红队人员会选择使用暴露在互联网上的代理服务器来实现目标域的访问&#xff0c;那么此时就需要在互联网上收集公开暴露的凭证信息。 对于蓝队来说&#xff0c;…

使用HTML、CSS和Javascript编写一个注册界面(二)

倘若代码中有任何问题或疑惑&#xff0c;欢迎提出交流哦~ 在上一篇文章我们实现了页面的建设&#xff0c;接下来我们实现JavaScript交互逻辑。 交互功能&#xff1a; 密码显示当用户输入的内容不符合规范时报错在提交注册界面是若有报错则提交失败 密码显示 要实现密码显示的…

【kubernetes】k8s集群中的ingress(对外服务)规则详解

目录 一、Ingress 简介 1.1service的作用 1.2外部访问方案 (四种&#xff09;&#x1f339;&#x1f339;&#x1f339; 部署externalIPs 1.3Ingress 是什么 二、Ingress 组成&#x1f339;&#x1f339;&#x1f339; 三、Ingress 工作原理&#x1f431;&#x1f…

TSR,FSR,DLSS超级分辨率的原理分析

先了解一些时域抗锯齿的方法&#xff1a; TAA&#xff1a; 抖动 TAA 的主要原理是跨帧计算多个子像素样本&#xff0c;然后将它们组合成一个最终像素。最简单的方案是在像素内生成随机样本&#xff0c;但有更好的方法来生成固定序列的样本。选择一个好的序列以避免聚集非常重…

LeetCode-数学基础开篇

概念 1.实数 2.指数函数 f(x) &#xff08;a&#xff1e;0且a≠1&#xff09;【a: 底数&#xff08;常量&#xff09;&#xff0c;x: 指数&#xff08;变量&#xff09;】 特征&#xff1a;指数函数在x轴没有交点&#xff0c;是光滑的曲线 3.幂函数 f(x) 【x&#xff…

Nginx的https功能

一.HTTPS功能简介 Web网站的登录页面都是使用https加密传输的&#xff0c;加密数据以保障数据的安全&#xff0c;HTTPS能够加密信息&#xff0c;以免敏感信息被第三方获取&#xff0c;所以很多银行网站或电子邮箱等等安全级别较高的服务都会采用HTTPS协议&#xff0c;HTTPS其实…