feat: ✨ 增加dubbo模块

bubble-spring-boot-starters/bubble-spring-boot-starter-dubbo/.gitignore

@@ -0,0 +1,38 @@
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### IntelliJ IDEA ###
+.idea/modules.xml
+.idea/jarRepositories.xml
+.idea/compiler.xml
+.idea/libraries/
+*.iws
+*.iml
+*.ipr
+
+### Eclipse ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/
+
+### Mac OS ###
+.DS_Store

bubble-spring-boot-starters/bubble-spring-boot-starter-dubbo/pom.xml

@@ -0,0 +1,48 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>bubble-spring-boot-starters</artifactId>
+        <groupId>cn.fxbin.bubble</groupId>
+        <version>2.0.0.BUILD-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>bubble-spring-boot-starter-dubbo</artifactId>
+
+    <properties>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>cn.fxbin.bubble</groupId>
+            <artifactId>bubble-spring-boot-starter</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.dubbo</groupId>
+            <artifactId>dubbo-spring-boot-starter</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.dubbo</groupId>
+            <artifactId>dubbo-spring-boot-observability-starter</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.google.protobuf</groupId>
+            <artifactId>protobuf-java</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.dubbo</groupId>
+            <artifactId>dubbo-native</artifactId>
+        </dependency>
+
+    </dependencies>
+
+</project>

bubble-spring-boot-starters/bubble-spring-boot-starter-dubbo/src/main/java/cn/fxbin/bubble/dubbo/constant/DubboConst.java

@@ -0,0 +1,22 @@
+package cn.fxbin.bubble.dubbo.constant;
+
+/**
+ * DubboConst
+ *
+ * @author fxbin
+ * @version v1.0
+ * @since 2023/11/8 11:27
+ */
+public interface DubboConst {
+
+    /**
+     * code
+     */
+    String CODE = "code";
+
+    /**
+     * 信息
+     */
+    String MSG = "msg";
+
+}

bubble-spring-boot-starters/bubble-spring-boot-starter-dubbo/src/main/java/cn/fxbin/bubble/dubbo/filter/DubboConsumerExceptionFilter.java

@@ -0,0 +1,43 @@
+package cn.fxbin.bubble.dubbo.filter;
+
+import cn.fxbin.bubble.core.exception.ServiceException;
+import cn.fxbin.bubble.core.util.StringUtils;
+import cn.fxbin.bubble.dubbo.constant.DubboConst;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.dubbo.common.constants.CommonConstants;
+import org.apache.dubbo.common.extension.Activate;
+import org.apache.dubbo.rpc.*;
+
+import java.util.Map;
+
+/**
+ * DubboConsumerExceptionFilter
+ *
+ * @author fxbin
+ * @version v1.0
+ * @since 2023/11/8 11:27
+ */
+@Slf4j
+@Activate(group = {CommonConstants.CONSUMER})
+public class DubboConsumerExceptionFilter implements Filter, Filter.Listener {
+
+    @Override
+    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
+        return invoker.invoke(invocation);
+    }
+
+    @Override
+    public void onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation) {
+        Map<String, String> attach = appResponse.getAttachments();
+        String code = attach.get(DubboConst.CODE);
+        String msg = attach.get(DubboConst.MSG);
+        if (StringUtils.isNotEmpty(code)) {
+            appResponse.setException(new ServiceException(Integer.parseInt(code), msg));
+        }
+    }
+
+    @Override
+    public void onError(Throwable t, Invoker<?> invoker, Invocation invocation) {
+        log.error("Got unchecked and undeclared exception which called by " + RpcContext.getServiceContext().getRemoteHost() + ". service: " + invoker.getInterface().getName() + ", method: " + invocation.getMethodName() + ", exception: " + t.getClass().getName() + ": " + t.getMessage(), t);
+    }
+}

bubble-spring-boot-starters/bubble-spring-boot-starter-dubbo/src/main/java/cn/fxbin/bubble/dubbo/filter/DubboProviderExceptionFilter.java

@@ -0,0 +1,118 @@
+package cn.fxbin.bubble.dubbo.filter;
+
+import cn.fxbin.bubble.core.dataobject.GlobalErrorCode;
+import cn.fxbin.bubble.core.exception.ServiceException;
+import cn.fxbin.bubble.core.util.ExceptionUtils;
+import cn.fxbin.bubble.dubbo.constant.DubboConst;
+import jakarta.validation.ConstraintViolation;
+import jakarta.validation.ConstraintViolationException;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.dubbo.common.constants.CommonConstants;
+import org.apache.dubbo.common.extension.Activate;
+import org.apache.dubbo.rpc.*;
+import org.apache.dubbo.rpc.service.GenericService;
+
+import java.lang.reflect.Type;
+import java.util.Map;
+
+/**
+ * DubboProviderExceptionFilter
+ *
+ * @author fxbin
+ * @version v1.0
+ * @since 2023/11/9 15:09
+ */
+@Slf4j
+@Activate(group = CommonConstants.PROVIDER)
+public class DubboProviderExceptionFilter implements Filter, BaseFilter.Listener {
+
+    @Override
+    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
+        return invoker.invoke(invocation);
+    }
+
+    @Override
+    public void onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation) {
+        if (appResponse.hasException() && GenericService.class != invoker.getInterface()) {
+            try {
+                // 1. 转换异常
+                Throwable exception = appResponse.getException();
+                // 1.1 参数校验异常
+                if (exception instanceof ConstraintViolationException) {
+                    exception = this.constraintViolationExceptionHandler((ConstraintViolationException) exception);
+                    // 1. ServiceException 业务异常，因为不会有序列化问题，所以无需处理
+                } else {
+                    exception = this.defaultExceptionHandler(exception, invocation);
+                    Map<String, String> attachments = appResponse.getAttachments();
+                    attachments.put(DubboConst.CODE, String.valueOf(((ServiceException) exception).getErrcode()));
+                    attachments.put(DubboConst.MSG, ((ServiceException) exception).getErrmsg());
+                }
+
+                // 2. 根据不同的方法 schema 返回结果
+                // 2.1 如果是 ServiceException 异常，并且返回参数类型是 Result 的情况，则将转换成 Result 返回
+                if (isReturnCommonResult(invocation) && exception instanceof ServiceException) {
+                    // 一定要清空异常
+                    appResponse.setException(null);
+                    appResponse.setValue(cn.fxbin.bubble.core.dataobject.Result.failure((ServiceException) exception));
+                    // 2.2 如果是 GlobalException 全局异常，则直接抛出
+                } else {
+                    appResponse.setException(exception);
+                    appResponse.getAttachments();
+                }
+            } catch (Throwable e) {
+                log.warn("Fail to ExceptionFilter when called by " + RpcContext.getServiceContext().getRemoteHost() + ". service: " + invoker.getInterface().getName() + ", method: " + invocation.getMethodName() + ", exception: " + e.getClass().getName() + ": " + e.getMessage(), e);
+            }
+        }
+    }
+
+    @Override
+    public void onError(Throwable t, Invoker<?> invoker, Invocation invocation) {
+        log.error("Got unchecked and undeclared exception which called by " + RpcContext.getServiceContext().getRemoteHost() + ". service: " + invoker.getInterface().getName() + ", method: " + invocation.getMethodName() + ", exception: " + t.getClass().getName() + ": " + t.getMessage(), t);
+    }
+
+    private boolean isReturnCommonResult(Invocation invocation) {
+        if (!(invocation instanceof RpcInvocation)) {
+            return false;
+        }
+        RpcInvocation rpcInvocation = (RpcInvocation) invocation;
+        Type[] returnTypes = rpcInvocation.getReturnTypes();
+        if (returnTypes.length == 0) {
+            return false;
+        }
+        Type returnType = returnTypes[0];
+        if (!(returnType instanceof Class)) {
+            return false;
+        }
+        Class returnClass = (Class) returnType;
+        return returnClass == Result.class;
+    }
+
+    /**
+     * 处理 Validator 校验不通过产生的异常
+     */
+    private ServiceException constraintViolationExceptionHandler(ConstraintViolationException ex) {
+        log.warn("[constraintViolationExceptionHandler]", ex);
+        ConstraintViolation<?> constraintViolation = ex.getConstraintViolations().iterator().next();
+        return new ServiceException(GlobalErrorCode.BAD_REQUEST.value(),
+                String.format("请求参数不正确:%s", constraintViolation.getMessage()));
+    }
+
+    /**
+     * 处理系统异常，兜底处理所有的一切
+     */
+    private ServiceException defaultExceptionHandler(Throwable exception, Invocation invocation) {
+        log.error("[defaultExceptionHandler][service({}) method({}) params({}) 执行异常] ===> {}",
+                invocation.getTargetServiceUniqueName(), invocation.getMethodName(), invocation.getArguments(), ExceptionUtils.getStackTrace(exception));
+        // 如果已经是 ServiceException 全局异常，直接返回即可
+        if (exception instanceof ServiceException) {
+            return (ServiceException) exception;
+        }
+        return new ServiceException(GlobalErrorCode.INTERNAL_SERVER_ERROR);
+    }
+
+    private String buildDetailMessage(Throwable exception, Invocation invocation) {
+        return String.format("Service(%s) Method(%s) 发生异常(%s)",
+                invocation.getTargetServiceUniqueName(), invocation.getMethodName(), ExceptionUtils.getStackTrace(exception));
+    }
+
+}

bubble-spring-boot-starters/bubble-spring-boot-starter-dubbo/src/main/java/cn/fxbin/bubble/dubbo/package-info.java

@@ -0,0 +1 @@
+package cn.fxbin.bubble.dubbo;

bubble-spring-boot-starters/pom.xml

@@ -38,6 +38,7 @@
         <module>bubble-spring-boot-starter-dynamic-threadpool</module>
         <module>bubble-spring-boot-starter-i18n</module>
         <module>bubble-spring-boot-starter-mail</module>
+        <module>bubble-spring-boot-starter-dubbo</module>
     </modules>