位置：首页-资讯-后端开发

浅试仿 mapstruct实现微服务编排框架详解

2024-04-02 19:55

短信预约 -IT技能 免费直播动态提醒

微服务编排框架

起始原因是我们公司分布式事务使用的是 seate 分布式事务框架，现在只在一些小部分使用，因为考虑到seate 对性能 TCP的影响，对事务这块没有更多的选择。我就在想是不是做一个微服务编排框架来解决这个问题。这里就

开发背景

因为我们是saas 可能A企业要这个功能，B企业不要，通过服务编排就可以解决这种情况（还是要受制于业务的）
解决分布式事务问题，我们涉及到钱的用seate ，其他的用这个框架，能提升性能和TPS

接口的方式

@Component
public class AProcessorDemo extends RollbackProcessor {
    @Override
    protected void processInternal(ProcessContext context) {
        System.out.println("a RollBackProcessor " + context.get("id"));
    }
    @Override
    protected void rollback(ProcessContext context) {
        System.out.println("a rollback RollBackProcessor " + context.get("id"));
    }
}

通过注解的方式

@Component
public class AProcessorDemo  {
    @Processor(name="a")
    protected void processInternal(ProcessContext context) {
        System.out.println("a RollBackProcessor " + context.get("id"));
    }
    @ProcessoRrollback(name="a")
    protected void rollback(ProcessContext context) {
        System.out.println("a rollback RollBackProcessor " + context.get("id"));
    }
}

书写代码方式的选择

代码实现上都可以实现，

选择接口方式缺点

代码改动会很大
node的拆分会根据开发人员的水平得到不同体现

选择注解方式

代码可读性会降低因为各种情况都会放在同一个类中
和之前代码的兼容性比较好，对代码和抽象的能力要求降低

我感觉还是先按照接口方式写，之前代码不动，只是新的业务才这么写，让结构清晰，增强抽象的能力。之后可以用mapStruct 方式优化

张小龙说的为客户/用户考虑，到我们这就是为了开发人员考虑。这样能节省业务开发的改动量

方案选择

feign

有@FeignClient(name = "provider"),其实不就是根据注解添加代理么？和我们一样的功能，是不是可以借鉴下,其实还是反射拿值做响应的对应

上生产，通过阿里云监控平台看，8g内存的机器 tps 到200 就会显示卡在这个BeanUtils 方法上

MapStruct

替换 BeanUtils 复制属性的新组件，用生成代理类，set方法赋值来替换了反射的方式提升性能，减小内存的使用。这种也是可以的

方案总结

我们平时学习学一个技术，其实了解其原理是为了自己写组件的时候，能用上他们的思路和技术来达到我们的目的。我个人不是很排斥学习八股文，可以学到很多的思路是我们能用上的。但是面试官别光考八股文

feign 可能是前面第一版会用，等后面的mapStruct demo写完了我就升级下版本，让测试同学帮忙测试下，然后换jar 版本呗

说实话其实我对这种换jar包的方式还是比较方案的，之前我都是这么干，但是涉及到改动的地方太多，我现在会从K8s 下手，直接挂 agent，不影响业务系统

两个都分析下吧

Feign @FeignClient

主要看 FeignClientsRegistrar registerFeignClients 方法中

BeanDefinition candidateComponent = (BeanDefinition)var21.next();
if (candidateComponent instanceof AnnotatedBeanDefinition) {
    AnnotatedBeanDefinition beanDefinition = (AnnotatedBeanDefinition)candidateComponent;
    AnnotationMetadata annotationMetadata = beanDefinition.getMetadata();
    Assert.isTrue(annotationMetadata.isInterface(), "@FeignClient can only be specified on an interface");
    Map&lt;String, Object&gt; attributes = annotationMetadata.getAnnotationAttributes(FeignClient.class.getCanonicalName());
    String name = this.getClientName(attributes);
    //注册client 配置到spring 容器
    this.registerClientConfiguration(registry, name, attributes.get("configuration"));
    //注册动态代理类到 spring 容器
    this.registerFeignClient(registry, annotationMetadata, attributes);
}