国际化

src/main/java/com/txz/project/filter/AccessGlobalFilter.java

@@ -7,6 +7,7 @@ import com.txz.operating.dto.InterfacesDTO;
 import com.txz.operating.result.Result;
 import com.txz.project.dubbo.client.OperatingInterfacesDubboServiceClient;
 import com.txz.project.dubbo.client.UserDubboServiceClient;
+import com.txz.project.util.I18nUtil;
 import io.jsonwebtoken.Claims;
 import io.jsonwebtoken.ExpiredJwtException;
 import io.jsonwebtoken.Jwts;
@@ -89,7 +90,7 @@ public class AccessGlobalFilter implements GlobalFilter, Ordered {
         // 从请求头获取token和请求路径
         String token = request.getHeaders().getFirst("token");
         String servicePath = request.getURI().getPath();
-        
+
         try {
             // 如果是Swagger文档请求，直接放行
             if (StrUtil.endWith(servicePath,"/v3/api-docs")){

src/main/java/com/txz/project/filter/LanguageWebFilter.java

@@ -0,0 +1,45 @@
+package com.txz.project.filter;
+
+
+import com.txz.project.util.LanguageContextHolder;
+import org.springframework.core.Ordered;
+import org.springframework.stereotype.Component;
+import org.springframework.web.server.ServerWebExchange;
+import org.springframework.web.server.WebFilter;
+import org.springframework.web.server.WebFilterChain;
+import reactor.core.publisher.Mono;
+import reactor.util.context.Context;
+
+@Component
+
+public class LanguageWebFilter implements WebFilter,Ordered{
+
+
+    @Override
+    public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
+        // 1. 从请求头获取Accept-Language，默认en
+        String acceptLanguage = exchange.getRequest().getHeaders().getFirst("accept-language");
+
+        if (acceptLanguage == null || acceptLanguage.trim().isEmpty()) {
+            acceptLanguage = "en";
+        }
+
+        //        // 1. 设置到ThreadLocal
+        LanguageContextHolder.setLanguage(acceptLanguage);
+
+        // 2. 将语言参数写入Reactor上下文（关键：上下文随异步流传递）
+        return chain.filter(exchange)
+                .contextWrite(Context.of("ACCEPT_LANGUAGE", acceptLanguage))
+                .doFinally(signalType -> {
+                    // 请求结束后清除ThreadLocal
+                    LanguageContextHolder.clear();
+                });
+    }
+
+    @Override
+    public int getOrder() {
+        return Ordered.HIGHEST_PRECEDENCE;
+    }
+}
+
+

src/main/java/com/txz/project/filter/ThrowExceptionFilter.java

@@ -1,5 +1,6 @@
 package com.txz.project.filter;
 
+import com.txz.project.util.I18nUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.cloud.gateway.filter.GatewayFilterChain;
@@ -30,7 +31,7 @@ public class ThrowExceptionFilter implements GlobalFilter, Ordered {
             // 将异常信息放入 exchange attributes 中，供后续处理使用
             exchange.getAttributes().put("error.status_code", HttpStatus.INTERNAL_SERVER_ERROR.value());
             exchange.getAttributes().put("error.exception", e);
-            exchange.getAttributes().put("error.message", "有一些错误发生");
+            exchange.getAttributes().put("error.message", I18nUtil.get("error.message"));
             
             // 继续传递给下一个过滤器处理
             return chain.filter(exchange);

src/main/java/com/txz/project/util/I18nUtil.java

@@ -0,0 +1,70 @@
+package com.txz.project.util;
+
+import org.springframework.context.MessageSource;
+import org.springframework.context.i18n.LocaleContextHolder;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+import java.util.Locale;
+
+/**
+ * 描述: 3、国际化工具类
+ * 版权: Copyright (c) 2020
+ * 公司: XXXX
+ * 作者: yanghj
+ * 版本: 4.0
+ * 创建日期: 2020/9/18 10:31
+ */
+
+@Component
+public class I18nUtil
+{
+
+    @Resource
+    private MessageSource messageSource;
+
+    private static MessageSource staticMessageSource;
+
+    public static String acceptLanguage;
+
+    // 用 @PostConstruct 替代 InitializingBean 接口
+    @PostConstruct
+    public void init() {
+        if (staticMessageSource == null) {
+            I18nUtil.staticMessageSource = this.messageSource;
+        }
+    }
+
+    // 静态 get 方法（同上）
+    public static String get(String msgKey) {
+        try {
+//            ServletRequestAttributes sra = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
+//            String header = sra.getRequest().getHeader("accept-language");
+            String header = LanguageContextHolder.getLanguage();
+          //  String header = acceptLanguage;
+            LocaleContextHolder.setLocale(Locale.US);
+            if(!ObjectUtils.isEmpty(header)) {
+                if ("en".equals(header)) {
+                    LocaleContextHolder.setLocale(Locale.US);
+                } else if ("zh".equals(header)) {
+                    LocaleContextHolder.setLocale(Locale.SIMPLIFIED_CHINESE);
+                } else if ("bd".equals(header)) {
+                    Locale bengaliLocale = new Locale("bn", "BD"); //孟加拉文
+                    LocaleContextHolder.setLocale(bengaliLocale);
+                }
+            }
+
+            return staticMessageSource.getMessage(msgKey, null, LocaleContextHolder.getLocale());
+        } catch (Exception e) {
+            return msgKey;
+        }
+    }
+
+
+
+
+
+
+}

src/main/java/com/txz/project/util/LanguageContextHolder.java

@@ -0,0 +1,22 @@
+package com.txz.project.util;
+
+public class LanguageContextHolder {
+    // ThreadLocal存储当前请求的语言
+    // 存储当前线程的语言参数
+    private static final ThreadLocal<String> LANGUAGE_HOLDER = new ThreadLocal<>();
+
+    // 设置语言（从Reactor上下文同步时调用）
+    public static void setLanguage(String language) {
+        LANGUAGE_HOLDER.set(language);
+    }
+
+    // 获取当前线程的语言
+    public static String getLanguage() {
+        return LANGUAGE_HOLDER.get();
+    }
+
+    // 清除ThreadLocal（必须调用）
+    public static void clear() {
+        LANGUAGE_HOLDER.remove();
+    }
+}

src/main/resources/bootstrap.properties

@@ -102,3 +102,8 @@ spring.cloud.gateway.globalcors.cors-configurations.[/**].allowedMethods[1]=POST
 spring.cloud.gateway.globalcors.cors-configurations.[/**].allowedMethods[2]=PUT
 spring.cloud.gateway.globalcors.cors-configurations.[/**].allowedMethods[3]=OPTIONS
 spring.cloud.gateway.globalcors.cors-configurations.[/**].allowedMethods[4]=DELETE
+
+
+spring.messages.basename=i18n/messages,i18n/messages_zh_CN
+spring.messages.encoding=UTF-8
+spring.messages.cache-duration=0

src/main/resources/i18n/error.properties

@@ -0,0 +1,16 @@
+BUSINESS_ERROR_001=\u8BF7\u68C0\u67E5\u624B\u673A\u53F7\u662F\u5426\u6B63\u786E
+BUSINESS_ERROR_002=\u624B\u673A\u53F7\u548C\u5BC6\u7801\u4E0D\u5339\u914D
+BUSINESS_ERROR_003=APP\u767B\u5F55\u6388\u6743\u5931\u8D25
+BUSINESS_ERROR_004=AccountKit \u767B\u5F55\u5931\u8D25\uFF0C\u8BF7\u91CD\u65B0\u9A8C\u8BC1
+BUSINESS_ERROR_005=\u624B\u673A\u53F7\u5DF2\u6CE8\u518C
+BUSINESS_ERROR_006=\u9A8C\u8BC1\u5DF2\u8FC7\u671F
+BUSINESS_ERROR_007=\u9A8C\u8BC1\u7801\u9519\u8BEF
+BUSINESS_ERROR_008=\u8BBE\u7F6E\u5BC6\u7801\u5931\u8D25
+BUSINESS_ERROR_009=\u8BF7\u91CD\u65B0\u9A8C\u8BC1code
+BUSINESS_ERROR_010=Facebook \u767B\u5F55\u5931\u8D25
+BUSINESS_ERROR_011=\u6B64 Facebook \u5DF2\u88AB\u5176\u4ED6\u8D26\u53F7\u4F7F\u7528
+BUSINESS_ERROR_012=\u8BF7\u60A8\u5148\u767B\u9646
+BUSINESS_ERROR_013=\u7CFB\u7EDF\u5185\u90E8\u5F02\u5E38\uFF0Csource \u8BF7\u6C42\u53C2\u6570\u4E0D\u5408\u6CD5
+BUSINESS_ERROR_014=\u624B\u673A\u53F7\u5DF2\u5173\u8054\u8FC7\u5176\u4ED6 Facebook \u8D26\u53F7\uFF0C\u8BF7\u6362\u4E00\u4E2A\u53F7\u7801\u8BD5\u8BD5
+
+PARAMETER_ERROR_001=\u65E0\u6548\u7684\u53C2\u6570

src/main/resources/i18n/error_in_ID.properties

@@ -0,0 +1,16 @@
+BUSINESS_ERROR_001=Silakan periksa apakah nomor telepon sudah benar
+BUSINESS_ERROR_002=Nomor telepon dan kata sandi tidak cocok
+BUSINESS_ERROR_003=Otorisasi login APP gagal
+BUSINESS_ERROR_004=Login Akun gagal, harap verifikasi ulang
+BUSINESS_ERROR_005=Nomor anda telah diregistrasi
+BUSINESS_ERROR_006=Verifikasi telah kedaluwarsa
+BUSINESS_ERROR_007=Kode verifikasi salah
+BUSINESS_ERROR_008=Gagal mengatur kata sandi
+BUSINESS_ERROR_009=Harap verifikasi ulang kodenya
+BUSINESS_ERROR_010=Verifikasi Facebook gagal
+BUSINESS_ERROR_011=Akun Facebook ini telah digunakan oleh akun lain
+BUSINESS_ERROR_012=Silahkan login
+BUSINESS_ERROR_013=Kesalahan internal sistem
+BUSINESS_ERROR_014=Nomor telepon ini telah terhubung dengan akun Facebook, silahkan ganti nomor untuk mencoba
+
+PARAMETER_ERROR_001=Parameter tidak valid

src/main/resources/i18n/messages_en_US.properties

@@ -0,0 +1,14 @@
+
+ResultCode.SUCCESS=success
+ResultCode.FAIL=failure
+ResultCode.UNAUTHORIZED=unauthenticated signature error
+ResultCode.NOT_FOUND=interface does not exist
+ResultCode.INTERNAL_SERVER_ERROR=internal server error
+
+success=success
+failure=failure
+unauthenticated.signature.error=unauthenticated signature error
+interface.does.not.exist=interface does not exist
+internal.server.error=internal server error
+
+error.message=some errors have occurred

src/main/resources/i18n/messages_zh_CN.properties

@@ -0,0 +1,16 @@
+
+ResultCode.SUCCESS=\u6210\u529F
+ResultCode.FAIL=\u5931\u8D25
+ResultCode.UNAUTHORIZED=\u672A\u8BA4\u8BC1\uFF08\u7B7E\u540D\u9519\u8BEF\uFF09
+ResultCode.NOT_FOUND=\u63A5\u53E3\u4E0D\u5B58\u5728
+ResultCode.INTERNAL_SERVER_ERROR=\u670D\u52A1\u5668\u5185\u90E8\u9519\u8BEF
+
+
+success=\u6210\u529F
+failure=\u5931\u8D25
+unauthenticated.signature.error=\u672A\u8BA4\u8BC1\uFF08\u7B7E\u540D\u9519\u8BEF\uFF09
+interface.does.not.exist=\u63A5\u53E3\u4E0D\u5B58\u5728
+internal.server.error=\u670D\u52A1\u5668\u5185\u90E8\u9519\u8BEF
+
+error.message=\u6709\u4E00\u4E9B\u9519\u8BEF\u53D1\u751F
+