Java：MultiDataSource 解决 CVAuto 下载 Excel 报告时调用 Nodejs 接口来生成渲染图时接收不到完整 request body

Author: TommyLemon

APIJSON-Java-Server/APIJSONBoot-MultiDataSource/pom.xml

@@ -318,11 +318,11 @@
 
 
         <!-- DemoController /delegate 代理转发请求 HTTP PATCH 方法需要，使用 PATCH 可以取消注释 -->
-        <!--        <dependency>-->
-        <!--            <groupId>org.apache.httpcomponents.client5</groupId>-->
-        <!--            <artifactId>httpclient5</artifactId>-->
-        <!--            <version>5.3</version>-->
-        <!--        </dependency>-->
+                <dependency>
+                    <groupId>org.apache.httpcomponents.client5</groupId>
+                    <artifactId>httpclient5</artifactId>
+                    <version>5.3</version>
+                </dependency>
 
 <!--        &lt;!&ndash; 需要用的 HikariCP 数据库连接池库，3.1.0 以上 &ndash;&gt;-->
 <!--        <dependency>-->

APIJSON-Java-Server/APIJSONBoot-MultiDataSource/src/main/java/apijson/boot/DemoController.java

@@ -24,6 +24,7 @@
 
 import jakarta.servlet.AsyncContext;
 import jakarta.servlet.ServletResponse;
+import org.jetbrains.annotations.NotNull;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.*;
 import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
@@ -37,6 +38,7 @@
 import java.lang.reflect.Method;
 import java.net.URLDecoder;
 import java.net.URLEncoder;
+import java.nio.charset.StandardCharsets;
 import java.rmi.ServerException;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
@@ -1875,6 +1877,18 @@ else if (recordType > 0) {
             CLIENT.getMessageConverters().forEach(converter -> {
                 if (converter instanceof StringHttpMessageConverter) {
                     ((StringHttpMessageConverter) converter).setWriteAcceptCharset(false);
+                    // 设置更大的缓冲区来处理大文本
+                    ((StringHttpMessageConverter) converter).setDefaultCharset(StandardCharsets.UTF_8);
+                }
+            });
+
+            // 添加自定义的消息转换器来处理大文本
+            CLIENT.getMessageConverters().add(0, new StringHttpMessageConverter(StandardCharsets.UTF_8) {
+                @NotNull
+                @Override
+                protected Long getContentLength(String s, MediaType contentType) {
+                    // 对于大文本，返回 null 让HTTP客户端自动处理分块传输
+                    return s.length() > 1024 * 1024 ? -1L : super.getContentLength(s, contentType);
                 }
             });
         }
@@ -1886,6 +1900,32 @@ else if (recordType > 0) {
     protected String sendRequest(HttpSession session, HttpMethod method, String url, String body, HttpHeaders headers) {
         String rspBody = null;
         try {
+            // 为JSON请求设置默认的Content-Type
+            if (body != null && method != HttpMethod.GET && !headers.containsKey(HttpHeaders.CONTENT_TYPE)) {
+                // 尝试解析JSON来判断内容类型
+                try {
+                    JSON.parse(body);
+                    headers.setContentType(MediaType.APPLICATION_JSON);
+                } catch (Exception e) {
+                    // 如果不是JSON，设置为普通文本
+                    headers.setContentType(MediaType.TEXT_PLAIN);
+                }
+            }
+            
+            // 设置默认的Accept header
+            if (!headers.containsKey(HttpHeaders.ACCEPT)) {
+                headers.setAccept(Arrays.asList(MediaType.APPLICATION_JSON, MediaType.TEXT_PLAIN));
+            }
+            
+            // 为大文本body，设置适当的Content-Type和分块传输
+            if (body != null && body.length() > 1024 * 1024) { // 超过1MB
+                if (!headers.containsKey(HttpHeaders.CONTENT_TYPE)) {
+                    headers.setContentType(MediaType.TEXT_PLAIN);
+                }
+                // 设置分块传输
+                headers.set(HttpHeaders.TRANSFER_ENCODING, "chunked");
+            }
+            
             HttpEntity<String> requestEntity = new HttpEntity<>(method == HttpMethod.GET ? null : body, headers);
             ResponseEntity<String> entity = CLIENT.exchange(url, method, requestEntity, String.class);
 

APIJSON-Java-Server/APIJSONBoot-MultiDataSource/src/main/java/apijson/boot/FileController.java

@@ -360,9 +360,23 @@ public ResponseEntity<Object> downloadCVReport(@PathVariable(name = "id") String
 							JSONObject renderReq = new JSONObject();
 							renderReq.put("img", img);
 							renderReq.put("data", resObj);
-							renderReq.put("wrongs", testRecord.getJSONArray("wrongs"));
+							renderReq.put("wrongs", testRecord.get("wrongs"));
 							String body = renderReq.toJSONString();
+							
+							// 设置完整的HTTP headers
 							HttpHeaders headers = new HttpHeaders();
+							headers.setContentType(MediaType.APPLICATION_JSON);
+							headers.setAccept(Arrays.asList(MediaType.APPLICATION_JSON));
+							headers.set("User-Agent", "APIJSON-Server/1.0");
+							headers.set("X-Requested-With", "XMLHttpRequest");
+							
+							// 如果body很大，设置适当的headers来支持大文件传输
+							if (body.length() > 1024 * 1024) { // 超过1MB
+								headers.set("Transfer-Encoding", "chunked");
+							} else {
+								headers.setContentLength(body.length());
+							}
+							
 							String renderStr = demoController.sendRequest(session, HttpMethod.POST, "http://localhost:3003/cv/render", body, headers);
 							renderStr = StringUtil.trim(renderStr);
 							if (renderStr.length() > 100) {

APIJSON-Java-Server/APIJSONBoot-MultiDataSource/src/main/resources/application.yml

@@ -1,8 +1,8 @@
 spring:
   servlet:
     multipart:
-      max-file-size: 10MB
-      max-request-size: 10MB
+      max-file-size: 50MB
+      max-request-size: 50MB
       enabled: true
       file-size-threshold: 2KB
 # If using flyway-core dependency, either comment this out or use @FlywayDatasource in DemoDataSourceConfig

APIJSON-Java-Server/APIJSONBoot-MultiDataSource/src/main/resources/static/cv/js/server.js

@@ -199,15 +199,15 @@ app.use(async ctx => {
 //    while (! done[0]) {
 //    }
   }
-    else if (ctx.path == '/cv/render') {
+  else if (ctx.path == '/cv/render') {
 //      done = [false];
 //      var json = '';
 //      ctx.req.addListener('data', (data) => {
 //    		json += data;
 //    	})
 //    	ctx.req.addListener('end', function() {
 //    		console.log(json);
-          var body = ctx.body || ctx.req.body || ctx.request.body|| {}; // || JSON.parse(json) || {};
+          var body = ctx.body || ctx.req.body || ctx.request.body || {}; // || JSON.parse(json) || {};
           if (DEBUG) {
               console.log('\n\n <<<<<<< body = ' + body);
               console.log('\n\n <<<<<<< body = ' + JSON.stringify(body));