淺試仿?mapstruct實現微服務編排框架詳解

更新時間：2022年08月29日 14:05:06 作者：雨夜之寂

這篇文章主要為大家介紹了淺試仿?mapstruct實現微服務編排框架詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪

微服務編排框架

起始原因是我們公司分布式事務使用的是 seate 分布式事務框架，現在只在一些小部分使用，因為考慮到seate 對性能 TCP的影響，對事務這塊沒有更多的選擇。我就在想是不是做一個微服務編排框架來解決這個問題。這里就

開發(fā)背景

因為我們是saas 可能A企業(yè)要這個功能，B企業(yè)不要，通過服務編排就可以解決這種情況（還是要受制于業(yè)務的）
解決分布式事務問題，我們涉及到錢的用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的拆分會根據開發(fā)人員的水平得到不同體現

選擇注解方式

代碼可讀性會降低因為各種情況都會放在同一個類中
和之前代碼的兼容性比較好，對代碼和抽象的能力要求降低

我感覺還是先按照接口方式寫，之前代碼不動，只是新的業(yè)務才這么寫，讓結構清晰，增強抽象的能力。之后可以用mapStruct 方式優(yōu)化

張小龍說的為客戶/用戶考慮，到我們這就是為了開發(fā)人員考慮。這樣能節(jié)省業(yè)務開發(fā)的改動量

方案選擇

feign

有@FeignClient(name = "provider"),其實不就是根據注解添加代理么？和我們一樣的功能，是不是可以借鑒下,其實還是反射拿值做響應的對應

上生產，通過阿里云監(jiān)控平臺看，8g內存的機器 tps 到200 就會顯示卡在這個BeanUtils 方法上

MapStruct

替換 BeanUtils 復制屬性的新組件，用生成代理類，set方法賦值來替換了反射的方式提升性能，減小內存的使用。這種也是可以的

方案總結

我們平時學習學一個技術，其實了解其原理是為了自己寫組件的時候，能用上他們的思路和技術來達到我們的目的。我個人不是很排斥學習八股文，可以學到很多的思路是我們能用上的。但是面試官別光考八股文

feign 可能是前面第一版會用，等后面的mapStruct demo寫完了我就升級下版本，讓測試同學幫忙測試下，然后換jar 版本唄

說實話其實我對這種換jar包的方式還是比較方案的，之前我都是這么干，但是涉及到改動的地方太多，我現在會從K8s 下手，直接掛 agent，不影響業(yè)務系統

兩個都分析下吧

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"));
    //注冊動態(tài)代理類到 spring 容器
    this.registerFeignClient(registry, annotationMetadata, attributes);
}