云交易系统开发手册

1. 依赖和中间件

• open-jdk 17.0.7
• graalvm 22.3.2
• Maven 3.6.3
• nacos 2.2.3
• Redis 6.0
• Mysql 8.0
• Springboot 3.0.6
• SpringCloud Alibaba 2022.0.0.0
• mybatis-plus 3.5.3
• Seata 1.7.0
• Netty 4.1.99
• Disruptor 4.0.0

2. 模块总览

2.1 模块简介

todo…

3. 部署事项

3.1 部署命令：

• 建议每个模块都在idea中添加两个启动配置项

  • Native-cloud-xxx-debug：用于本地idea调试功能使用
  • Native-cloud-xxx-preCompile：用于Native打包镜像，需要添加VM参数命令：
    • -agentlib:native-image-agent=config-output-dir=/你的idea workspace目录/native-cloud-system/native-cloud-xxx-system/src/main/resources/META-INF/native-image/native-cloud-xxx-system
    • 添加VM参数启动后，随机通过调试请求工具（如postman）访问该模块子系统几个功能（也可以不做这一步，只是为了确保native-image打包时所有代码组件均能够被链接），然后停止该模块，会在该模块的src/main/resources/META-INF/native-image/native-cloud-xxx-system目录下生成打包所需的json配置文件，这些文件中指定了源代码中通过反射、代理等途径创建的对象，只有成功生成这些配置文件，native-image打包成本地镜像才不会报错。
  • native-image执行打包命令：
    • mvn -e -Pnative -DskipTests=true native:compile

• 建议在部署模块之前，先通过mvn clean install将本地所有模块的改动都打入本地maven repo中去。

• nacos本地启动命令：

  • sudo sh ./startup.sh -m standalone
    

• seata本地启动命令：

  • sh ./seata-server.sh
    

  • 同时注意，seata的端口配置默认为7091，如果要更改默认启动端口，要在seata/conf/application.yml中打开如下配置：

    • server:
        port: 8091
      

4. 部署常见问题

• 镜像打包成功，但Mybatis相关类报错：ClassNotFound

  • 检查该模块启动类上是否有注解@EnableNativeHints，只有引入了该注解，才能让mybatis-plus在打包成本地镜像后正常工作。

• 镜像打包成功，但Jwt相关类报错：DefaultJwtParser：ClassNotFound

  • 检查该模块对应打包配置目录下的proxy-config.json文件中有没有指定DefaultJwtParser，若没有指定则说明该类和其相关的模块均未被链接，需要使用对应模块的preCompile启动项启动该类，调用一次流程中使用了DefaultJwtParser的功能，再停止该模块，能够使proxy-config文件写入该类，再重新执行打包命令即可。

• 执行native-image打包命令过程中报错：nosuchmethoderror

  • 如果是在一个之前能够正常工作的class中添加了新方法，那么需要让maven重新生成该类的安装包，执行mvn clean install即可。
  • 如果是javabean中不存在getXXX或setXXX方法，检查是否使用lombok的@data、@AllArgsConstructor等注解，另外，不建议在项目中使用lombok。

• gateway无法转发请求到正确的子模块：

  • 检查gateway下的配置文件routes节点中是否已添加子模块的路由。
  • 如果是新加的模块，由于AOT提前编译的局限性，需要在gateway目录下增加一个对应模块的OpenFeignClient，这样才能确保OpenFeign相关的配置类提前被链接。

• mybatis-plus使用lambda查询方式报错：

• 目前mybatis官方暂未出补丁修复AOT模式下lambda查询失效的问题，虽然github上issue已经存在，建议避开wrapper查询，自行在mapper中增加查询方法进行业务上的适配。

• 打包成native-image执行时，插入到mysql的中文字段乱码：

  • show full columns from .，确保数据库表字段的字符集是UTF8编码。
  • 检查配置文件中jdbc-url配置，由于使用了hikariCP作为数据源，characterEncoding=uft8才能起到使用UTF8中文字符集的作用。

• native镜像RPC报错： java.lang.IllegalArgumentException: Object of class [org.springframework.context.support.GenericApplicationContext] must be an instance of interface org.springframework.context.annotation.AnnotationConfigRegistry] with root cause

  • 在对应的调用方模块配置文件中加入openfeign相关AOT配置，以qms-system调用user-system为例，需在qms-system模块的配置文件中加入如下内容：

    • spring:
        cloud:
          refresh:
            enabled: false
          openfeign:
            # 支持AOT编译openfeign调用配置项 begin
            client:
              refresh-enabled: false
              config:
                user-system:
                  urls: http://127.0.0.1:8880
            lazy-attributes-resolution: false
          loadbalancer:
            ribbon:
              enabled: false
            nacos:
              enabled: true
            eager-load:
              clients:
                - user-system
            cache:
              enabled: true
            # 支持AOT编译openfeign调用配置项 end
      

    • 如果下游服务（上述例子user-system）为集群部署，由于AOT需要提前加载指定订阅服务的列表，所以user-system.urls中需要配置集群中所有节点的ip:port。

• 全局错误处理失败，报错：No acceptable representation

  • 检查返回的result实现类是否有成员变量的get\set方法。

• 集成seata之后，使用nacos作为配置中心，控制台报错，nacos-server端登录错误，完整错误如下：

  2023-12-09T13:14:38.423+08:00 ERROR 2971 --- [s.client.Worker] c.a.n.c.a.i.process.HttpLoginProcessor   : login failed: {"code":500,"message":"caused: Cannot invoke \"com.alibaba.nacos.plugin.auth.impl.jwt.NacosJwtParser.getExpireTimeInSeconds(String)\" because \"this.jwtParser\" is null;","header":{"header":{"Accept-Charset":"UTF-8","Authorization":"Bearer","Connection":"close","Content-Length":"142","Content-Security-Policy":"script-src 'self'","Content-Type":"text/html;charset=UTF-8","Date":"Sat, 09 Dec 2023 05:14:38 GMT","Vary":"Access-Control-Request-Headers"},"originalResponseHeader":{"Authorization":["Bearer"],"Connection":["close"],"Content-Length":["142"],"Content-Security-Policy":["script-src 'self'"],"Content-Type":["text/html;charset=UTF-8"],"Date":["Sat, 09 Dec 2023 05:14:38 GMT"],"Vary":["Access-Control-Request-Headers","Access-Control-Request-Method","Origin"]},"charset":"UTF-8"}}
  
  

  • 原因是nacos使用的2.2.3版本默认取消了登录验证，所以注释掉工程对应的配置文件中的username和password配置项，需要注意的是seata.config.nacos和seata.config.registry均需要注释用户名和密码。

• 集成seata，使用nacos做配置中心，控制台报错：service.vgroupMapping.native-cloud-system-group配置为空：

  io.seata.config.exception.ConfigNotFoundException: service.vgroupMapping.native-cloud-system-group configuration item is required
  

  • 先检查工程模块下seata.config.nacos.group的值，发现配置项中定义去group为SEATA_GROUP的组中去获取配置：

    seata:
      tx-service-group: native-cloud-system-group
      service:
        tx-service-group: native-cloud-system-group
        vgroup-mapping:
          native-cloud-system-group: native
      config:
        type: nacos
        nacos:
          server-addr: 127.0.0.1:8848
          group: SEATA_GROUP
    

  • 再检查nacos dashboard中，namespace为public下(因为seata.config.nacos.namespace未配置，所以采用默认命名空间)是否添加了DataId为service.vgroupMapping.native-cloud-system-group且group为SEATA_GROUP的配置，如果没有，按照上述的条件添加一条配置，配置的值为：SEATA_GROUP。

• 集成seata，集群订阅报错：

  [timeoutChecker_1_1] ERROR i.s.c.r.n.NettyClientChannelManager:188 --> no available service found in cluster 'default', please make sure registry config correct and keep your seata server running
  

  • 确认seata-server端配置文件中seata.registry.nacos.cluster的值，和客户端从nacos拉取的配置文件中dataID为service.vgroupMapping.native-cloud-system-group中的值相等。

• @GlobalTransactional，TCC模式只执行一阶段try的逻辑，不执行二阶段提交：

  • 断点打入GlobalTransactionalInterceptor中invoke方法，重点调试GlobalTransactional注解获取的过程：

    final GlobalTransactional globalTransactionalAnnotation = getAnnotation(method, targetClass, GlobalTransactional.class);
    

    查看method变量的方法名是否和业务代码中GlobalTransactional注解标记的方法名一致。

• 集成seata，客户端启动后报错：RM can not reconnect server

  • 用下面的命令指定ip和端口重启seata-server:

    ./seata-server.sh -h 127.0.0.1 -p 8091
    

• 集成seata后，分布式事务执行过程中报错：

  java.sql.SQLSyntaxErrorException: Table 'credit.undo_log' doesn't exist
  

  • 发生在向数据库表进行insert记录的动作中，检查执行sql insert操作的方法是否已实现本地TccService，由于使用了seata代理了Datasource，不实现TccService情况下则会在插入时使用mysql默认的undolog表记录日志，而代理后的数据源无法获取mysql自带undolog，将执行insert语句的方法实现TccService即可，可参考下面委托表对应的TccService：

    @LocalTCC
    public interface CreditEntrustTccService {
    
        @TwoPhaseBusinessAction(name = "generateCreditEntrust", commitMethod = "generateCreditEntrustCommit", rollbackMethod = "generateCreditEntrustRollback")
        Long generateCreditEntrust(@BusinessActionContextParameter(paramName = "creditEntrust") CreditEntrust creditEntrust,
                                 @BusinessActionContextParameter(paramName = "entrustProperty") EntrustProperty entrustProperty);
    
        Boolean generateCreditEntrustCommit(BusinessActionContext businessActionContext);
    
        Boolean generateCreditEntrustRollback(BusinessActionContext businessActionContext);
    }
    

• OpenFeign报错feign.RetryableException: too many bytes written executing

  • RPC传对象的时候造成请求体序列化后的字节数过多，需要取消openFeign拦截器中从前端请求带来的content-length限制，在项目下找到FeignBasicAuthRequestInterceptor并在遍历请求header循环中加入如下代码：

    if (name.equals("content-length")){
      	continue;
    }
    

• jdk17 使用annotation processor处理编译期注解，mvn install 注解处理器模块报错：

  服务配置文件不正确, 或构造处理程序对象javax.annotation.processing.Processor: Provider com.huang.ast.processor.LemonCompileProcessor not found时抛出异常错误
  
  

  • 确保处理器模块maven的配置文件中加入如下配置项

    		<build>
            <plugins>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-compiler-plugin</artifactId>
                    <configuration>
                      	<!-- 此项必须 -->
                        <proc>none</proc>
                        <compilerArgs>
                          	<!-- 下面四项arg也建议加上，这样执行mvn compile命令会加上下面的参数，确保字节码增强所依赖的javac模块不会无法访问-->
                            <arg>--add-exports=jdk.compiler/com.sun.tools.javac.processing=ALL-UNNAMED</arg>
                            <arg>--add-exports=jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED</arg>
                            <arg>--add-exports=jdk.compiler/com.sun.tools.javac.tree=ALL-UNNAMED</arg>
                            <arg>--add-exports=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED</arg>
                        </compilerArgs>
                    </configuration>
                </plugin>
            </plugins>
        </build>
    

• jdk17 使用annotation processor处理编译期注解，mvn install 注解处理器模块时代码构建不通过，报如下错误：

  com.sun.tools.javac.api不可见
  com.sun.tools.javac.processing不可见
  com.sun.tools.javac.tree不可见
  com.sun.tools.javac.util不可见
  

  • 由于jdk9 引入了jigsaw特性，原本javac所在的tools.jar被模块化，需要在idea设置中找到 Build,Execution,Deployment –> Compiler –> Java Complier –> override complier parameters per module，确保处理器模块export如下jdk自带模块：

    -parameters
    --add-exports=jdk.compiler/com.sun.tools.javac.processing=ALL-UNNAMED
    --add-exports=jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED
    --add-exports=jdk.compiler/com.sun.tools.javac.tree=ALL-UNNAMED
    --add-exports=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED
    

• 使用注解处理器的业务模块 执行mvn compile/install 报错：

  class com.huang.ast.processor.LemonCompileProcessor (in unnamed module @0x3ac3f6f) cannot access class com.sun.tools.javac.processing.JavacProcessingEnvironment (in module jdk.compiler) because module jdk.compiler does not export com.sun.tools.javac.processing to unnamed module @0x3ac3f6f
  
  

  • 使用了idea自带的maven进行打包，所以不会读取配置在pom文件中的compilerArgs，需要手动为idea自带的maven指定解析时可访问的模块，打开settings –> Build,Execution,Deployment –> build tools–> maven –> runner，设置maven运行时的vm option：

    --add-exports=jdk.compiler/com.sun.tools.javac.tree=ALL-UNNAMED
    --add-exports=jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED
    --add-exports=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED
    --add-exports=jdk.compiler/com.sun.tools.javac.processing=ALL-UNNAMED
    

  • 同时，建议在业务模块pom文件中加上如下配置，使得命令行打包时能够读取配置项，使得编译期注解处理器能够正常被依赖：

    		<build>
            <plugins>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-compiler-plugin</artifactId>
                    <configuration>
                        <target>17</target>
                        <source>17</source>
                        <annotationProcessors>
                            <annotationProcessor>com.huang.ast.processor.LemonCompileProcessor</annotationProcessor>
                        </annotationProcessors>
                    </configuration>
                </plugin>
            </plugins>
        </build>
    

• build modules或者执行mvn clean compile报如下错误：

  java.lang.AssertionError
  	at jdk.compiler/com.sun.tools.javac.util.Assert.error(Assert.java:155)
  	at jdk.compiler/com.sun.tools.javac.util.Assert.check(Assert.java:46)
  	at jdk.compiler/com.sun.tools.javac.util.Bits.incl(Bits.java:186)
  	at jdk.compiler/com.sun.tools.javac.comp.Flow$AssignAnalyzer.initParam(Flow.java:2232)
  	at jdk.compiler/com.sun.tools.javac.comp.Flow$AssignAnalyzer.visitMethodDef(Flow.java:2156)
  	at jdk.compiler/com.sun.tools.javac.tree.JCTree$JCMethodDecl.accept(JCTree.java:921)
  	at jdk.compiler/com.sun.tools.javac.tree.TreeScanner.scan(TreeScanner.java:49)
  	at jdk.compiler/com.sun.tools.javac.comp.Flow$BaseAnalyzer.scan(Flow.java:444)
  	at jdk.compiler/com.sun.tools.javac.comp.Flow$AssignAnalyzer.scan(Flow.java:1724)
  	at jdk.compiler/com.sun.tools.javac.comp.Flow$AssignAnalyzer.visitClassDef(Flow.java:2098)
  	at jdk.compiler/com.sun.tools.javac.tree.JCTree$JCClassDecl.accept(JCTree.java:819)
  	at jdk.compiler/com.sun.tools.javac.tree.TreeScanner.scan(TreeScanner.java:49)
  

  • 需要将treeMaker的节点指针定位至当前元素对应语法树的节点指针，在获取当前元素的语法树之后加入如下代码：

    JCTree jcTree = this.trees.getTree(element);
    treeMaker.pos = jcTree.pos;
    

• 调用inner接口时报错：403 Forbidden

  feign.FeignException$Forbidden: [403] during [GET] to [http://user-system/inner/user/getUserDetail/] [UserClient#getUserDetail(String)]: []
  

  • 原因是feign client发起RPC的时候，如果方法是在path后紧跟入参，比如/inner/user/getUserDetail/{userId}，需要入参和对应的innerController完全保持一致，检查InnerController被@PathVariable注解标记的方法入参，在对应的feign client中也存在@PathVariable：

    InnerController:
    @OpenApi
    @GetMapping("/user/getUserDetail/{userId}")
    public T getUserDetail(@PathVariable String userId){
      return  userDetailsService.loadUserByUsername(userId);
    }
    
    Feign Client:
    @FeignClient(name = "user-system",value = "user-system",contextId = "userSystem")
    public interface UserClient {
    
    		... // 其他方法
    
        @GetMapping("/inner/user/getUserDetail/{userId}")
        T getUserDetail(@PathVariable String userId);
    }
    

• 集成native-cloud-common-auth，通过@EnableSecurityAuthorization开启全局用户鉴权后，在进入controller方法之前，模块应该实现spring-security要求的userServiceImpl，否则请求该子系统任意接口（标记了openApi的白名单接口除外）都会返回403Forbidden错误，可参考交易模块已实现的UserServiceImpl：

  /**
   * @description: 信用交易系统用户权限认证实现
   * @author: huang.zh
   * @create: 2024-09-15 08:09
   **/
  @Service
  @Slf4j
  public class UserDetailServiceImpl implements UserDetailsService {
  
  
      private UserClient userClient;
  
      public UserDetailServiceImpl(@Autowired UserClient userClient) {
          this.userClient = userClient;
      }
  
      @Override
      public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
          // 注意此时传入的username为jwtAuthUtil解析的userId
        	// 发起RPC至账户子系统，请求用户的权限等运行时数据
          UserMetadata userMetadata = userClient.getUserDetail(username);
          String userId = userMetadata.getUserId();
        	// 当前系统需要鉴权，将UserMetadata转换为符合Spring-security权限校验体系的实体类User
          List<SimpleGrantedAuthority> authorities = userMetadata.getPermissions().stream().map(SimpleGrantedAuthority::new).collect(Collectors.toList());
          return new User(userId,userId,authorities);
      }
  }
  

  • 注意，通过OpenFeign发起RPC请求，至账户子系统请求用户元数据，要求下游账户系统不能直接返回spring security的UserDetails接口及其任意一个实现类，是因为这些实现类没有默认无参构造函数，而OpenFeign解析response时使用jackson进行反序列化，要求响应类实体要有无参构造函数，这里可以使用native-cloud-common-auth模块下的UserMetadata，各上游系统获取到用户元数据后如果需要鉴权，可参考信用交易子系统将UserMetadata转换为符合Spring-security权限校验体系的实体类User：

    /**
     * @description: 用户元数据运行时包装类，维护从账户系统获取的用户数据（userId，permissions...）
     * @author: huang.zh
     * @create: 2024-09-15 20:47
     **/
    public class UserMetadata {
    
        private String userId;
    
        private List<String> permissions;
    
        public UserMetadata() {
        }
    
        public UserMetadata(String userId, List<String> permissions) {
            this.userId = userId;
            this.permissions = permissions;
        }
    
        public String getUserId() {
            return userId;
        }
    
        public void setUserId(String userId) {
            this.userId = userId;
        }
    
        public List<String> getPermissions() {
            return permissions;
        }
    
        public void setPermissions(List<String> permissions) {
            this.permissions = permissions;
        }
    }
    

• 单元测试中，将 类通过 @component 注解标记，尝试托管给 spring 容器，但单元测试方法报错：

  No qualifying bean of type 'com.huang.buffer.handler.GenerateMessageDataHandler' available
  

  • 这是因为测试类继承自 TestApplication，在 TestApplication 中 通过注解配置了指定单元测试时允许容器托管的类：

    @SpringBootTest(classes = {TestApplication.class, NettyStartListener.class, ServerProperty.class, SocketServer.class})
    

    在 SpringBootTest注解 的 classes 属性中补齐单元测试中需要 Spring容器托管的类即可正常托管对应的 bean：

    @SpringBootTest(classes = {TestApplication.class, NettyStartListener.class, ServerProperty.class, SocketServer.class, GenerateMessageDataHandler.class, MessageMetaDataHandler.class})
    

• 使用SocketChannel 连接服务端进行测试，并发写入需要控制写入速率，通过 Thread.sleep(20l)可实现安全写入。

• 引入 ringbuffer 模块后，报错显示无法强制类型转换为指定的 springContext 容器：

  Caused by: java.lang.ClassCastException: class org.springframework.boot.web.servlet.context.AnnotationConfigServletWebServerApplicationContext cannot be cast to class org.springframework.context.annotation.AnnotationConfigApplicationContext (org.springframework.boot.web.servlet.context.AnnotationConfigServletWebServerApplicationContext and org.springframework.context.annotation.AnnotationConfigApplicationContext are in unnamed module of loader 'app')
  	at com.huang.buffer.handler.MessageMetaDataHandler.setApplicationContext(MessageMetaDataHandler.java:62) ~[classes/:na]
  	at org.springframework.context.support.ApplicationContextAwareProcessor.invokeAwareInterfaces(ApplicationContextAwareProcessor.java:112) ~[spring-context-6.0.8.jar:6.0.8]
  	at org.springframework.context.support.ApplicationContextAwareProcessor.postProcessBeforeInitialization(ApplicationContextAwareProcessor.java:87) ~[spring-context-6.0.8.jar:6.0.8]
  	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyBeanPostProcessorsBeforeInitialization(AbstractAutowireCapableBeanFactory.java:419) ~[spring-beans-6.0.8.jar:6.0.8]
  	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1762) ~[spring-beans-6.0.8.jar:6.0.8]
  	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:598) ~[spring-beans-6.0.8.jar:6.0.8]
  	... 15 common frames omitted
  

  • 这是因为业务子系统使用的AnnotationConfigServletWebServerApplicationContext进行托管，将 ringbuffer 中实现了 ApplicationContextAware 接口的 bean 所包含的成员变量全部改为对应的上层抽象接口ConfigurableApplicationContext即可进行强转，可参考：

    @Component
    public class MessageMetaDataHandler extends ChannelInboundHandlerAdapter implements InitializingBean, ApplicationContextAware {
    
        private static final Logger log = LoggerFactory.getLogger(MessageMetaDataHandler.class);
    
        private static final String BUSINESS_FLAG_KEY = "businessFlag";
    
        private ConfigurableApplicationContext applicationContext;
    
        private static Map<Integer,BusinessHandler> handlers;
    
    
        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            ...
        }
    
        @Override
        public void afterPropertiesSet() throws Exception {
            // 从容器中获取 BusinessHandler 接口的所有实现类
            Map<String, BusinessHandler> candidateBeans = this.applicationContext.getBeansOfType(BusinessHandler.class);
            handlers = candidateBeans.values().stream().collect(Collectors.toMap(BusinessHandler::businessFlag, Function.identity()));
        }
    
        @Override
        public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
            this.applicationContext = (ConfigurableApplicationContext) applicationContext;
        }
    }
    

• 如果业务子系统引入 Ringbuffer 模块后，无法找到 ringbuffer 模块下要求运行时托管给 Spring 容器管理的 bean，是因为默认 Spring 只扫描启动类所在目录下的所有 component、service、controller，需要手动通过注解引入 ringbuffer 模块下的 bean，可参考信用交易子系统启动类上的注解：

  /**
   * @description: 信用竞价交易子系统启动类
   * @author: huang.zh
   * @create: 2023-11-16 21:12
   **/
  @EnableApiDoc
  @EnableSecurityAuthorization
  @EnableGlobalExceptionHandler
  @SpringBootApplication
  @EnableNativeHints
  @EnableDiscoveryClient
  @EnableFeignClients
  @MapperScan(basePackages = "com.huang.credit.mapper",sqlSessionTemplateRef = "sqlSessionTemplate")
  // 引入 ringbuffer 模块下的 bean
  @Import(value = {NettyStartListener.class, ServerProperty.class, SocketServer.class,
          GenerateMessageDataHandler.class, MessageMetaDataHandler.class})
  public class CreditTradeApplication {
  
      public static void main(String[] args) {
          SpringApplication.run(CreditTradeApplication.class,args);
      }
  }
  

  • 也可以直接使用 ringbuffer 模块下的@EnableRingBuffer 注解，它会帮业务系统自动引入启用环形队列处理消息时所有需要托管的 bean：

  /**
   * @description: 信用竞价交易子系统启动类
   * @author: huang.zh
   * @create: 2023-11-16 21:12
   **/
  @EnableApiDoc
  @EnableSecurityAuthorization
  @EnableGlobalExceptionHandler
  @SpringBootApplication
  @EnableNativeHints
  @EnableDiscoveryClient
  @EnableFeignClients
  @MapperScan(basePackages = "com.huang.credit.mapper",sqlSessionTemplateRef = "sqlSessionTemplate")
  @EnableRingBuffer
  public class CreditTradeApplication {
  
      public static void main(String[] args) {
          SpringApplication.run(CreditTradeApplication.class,args);
      }
  }
  

• 如果在 gateway 模块下的 globalfilter 相关实现类中，直接通过 autowired 注入OpenFeign 的请求借口 FeignClient，会引起循环依赖报错：

  Description:
  
  The dependencies of some of the beans in the application context form a cycle:
  
  ┌─────┐
  |  partitionNoCheckFilter (field private com.huang.UserSystemFeignClient com.huang.PartitionNoCheckFilter.userSystemFeignClient)
  ↑     ↓
  |  com.huang.UserSystemFeignClient
  ↑     ↓
  |  corsGatewayFilterApplicationListener defined in class path resource [org/springframework/cloud/gateway/config/GatewayAutoConfiguration.class]
  ↑     ↓
  |  routePredicateHandlerMapping defined in class path resource [org/springframework/cloud/gateway/config/GatewayAutoConfiguration.class]
  ↑     ↓
  |  filteringWebHandler defined in class path resource [org/springframework/cloud/gateway/config/GatewayAutoConfiguration.class]
  └─────┘
  
  Action:
  
  Relying upon circular references is discouraged and they are prohibited by default. Update your application to remove the dependency cycle between beans. As a last resort, it may be possible to break the cycle automatically by setting spring.main.allow-circular-references to true.
  
  

  • 需要考虑引入 lazy 注解，在第一次实际使用该FeignClient 时才进行初始化：

    
    @Lazy
    @Autowired
    private UserSystemFeignClient userSystemFeignClient;
    
    

  • 同时，需要注意 Spring Cloud Gateway中，不支持动态路由，需要将配置项中对应 serviceId 的 url 改成具体地址：

     openfeign:
      client:
        refresh-enabled: false
        config:
          user-system:
            url: http://127.0.0.1:8880
          quota-manager-system:
            url: http://127.0.0.1:8881
          credit-trade-system:
            url: http://127.0.0.1:8883
    

5.开发日志

6.初始化脚本

系统初始化脚本，打入后，交易回到最初数据状态：

truncate table compact.compact;

truncate table compact.compact_jour;

truncate table compact.compact_summary;

truncate table compact.compact_summary_jour;

truncate table credit.credit_entrust;

truncate table credit.credit_trade_time;

truncate table credit.credit_serial_counter_record;

truncate table credit.credit_stock_real_jour;

truncate table credit.special_cash_group_fund_jour;

truncate table quota.cash_group_fund_jour;

-- 初始化普通业务头寸资金表
update quota.cash_group_fund set financing_total_balance = 10000000000.00,enable_balance = 10000000000.00,frozen_balance = 0.00,financing_used_balance = 0.00 where 1=1;

-- 初始化专项业务头寸资金表
update credit.special_cash_group_fund set fin_total_balance = 10000000000.00,enable_balance = 10000000000.00,fin_used_balance = 0.0,ref_due_balance = 0.0,frozen_balance = 0.0,cash_interest = 0.0 where 1=1;

-- 重置流水号额度表各业务种类的计数器为初始值
update quota.serial_no_counter set serial_counter_value = 1000000 where 1=1 ;

-- 重置普通头寸业务资金流水表的计数器号段长度
update quota.serial_no_counter set step = 1 where serial_counter_no = 0;

-- 重置信用交易委托表的计数器号段长度
update quota.serial_no_counter set step = 100 where serial_counter_no = 1;

-- 重置专项头寸业务资金流水表的计数器号段长度
update quota.serial_no_counter set step = 100 where serial_counter_no = 2;

-- 重置专项头寸业务资金流水表回滚的计数器号段长度
update quota.serial_no_counter set step = 1 where serial_counter_no = 3;

-- 重置信用客户持仓流水表的计数器号段长度
update quota.serial_no_counter set step = 1 where serial_counter_no = 4;


-- 插入信用交易时间表
INSERT INTO credit.credit_trade_time (id, time_kind, init_date, begin_time, end_time, remark, withdraw_flag) VALUES (1, '0', 0, 0, 0, '0-交易系统是否初始化', '0');
INSERT INTO credit.credit_trade_time (id, time_kind, init_date, begin_time, end_time, remark, withdraw_flag) VALUES (2, '3', 20231130, 0, 99999999, '信用交易时间', '1');
INSERT INTO credit.credit_trade_time (id, time_kind, init_date, begin_time, end_time, remark, withdraw_flag) VALUES (3, '4', 20241028, 0, 99999999, '信用委托撤单时间', '1');

存储过程

-- 检查资产账号表是否存在分片号的存储过程
-- 信用交易账号，默认 52 分片
drop procedure if exists checkPartitionNo;
delimiter //
create procedure checkPartitionNo()
begin
  select count(1) into @row_num from information_schema.COLUMNS
         where TABLE_SCHEMA = 'user'
           and TABLE_NAME = 'fund_account' and COLUMN_NAME = 'partition_no';
  if @row_num = 0 then alter table user.fund_account add column partition_no int default 52 comment '分片号';

end if;
end; //
delimiter ;
call checkPartitionNo();

7.字段释义

8. todo list

• ✅流水计数器中的缓存功能，需要维护每一种计数器种类的号段起始值，否则存在多种计数器种类缓存无法击中的风险。
• ✅专项头寸资金发生变化，流水序列号使用带缓存的统一流水计数器工具类。
• ✅流水计数器缓存，需要判断新申请号段的情况下才更新缓存中号段的起始值。
• ✅构造成交回报报文，并解析报文。
• ✅统一报文反序列化处理器和消息元数据处理器托管给 Spring 容器管理生命周期，支持嵌入各业务系统。
• ✅ringbuffer 模块需要自定义一个注解来实现业务子系统集成该模块后能扫描到该模块下的 bean。
• ✅搭建回报模块，执行回报流程。
• ✅实现委托撤单。
• ✅融资买入回报业务处理器，需要实现 doRevert，并在 doHandle 中触发。
• 🔴融资买入回报业务处理器，需要集成 RingBuffer ，实现高性能异步队列处理回报请求。
• 🔴统一流水计数器考虑抽象成公共组件，供各业务子系统使用。
• 🔴普通业务头寸资金流水表，需要通过统一流水计数器获取序列号，同时考虑性能，序列号递增的写库操作考虑引入异步队列触发。

9. 流水计数器种类