qw-12

news/2025/10/31 2:30:38/文章来源:https://www.cnblogs.com/lihuadaiyu/p/19178486

import org.springframework.core.io.ByteArrayResource;
import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.http.MediaType;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.client.WebClient;
import org.springframework.web.reactive.function.client.WebClientResponseException;
import reactor.core.publisher.Mono;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.util.Base64;

public class ExcelUploadService {

private final WebClient webClient;

public ExcelUploadService(WebClient.Builder webClientBuilder) {
this.webClient = webClientBuilder.build();
}

/**
* 上传Excel文件到第三方接口 - 使用Multipart方式
* @param workbook Excel工作簿对象
* @param fileName 文件名
* @param uploadUrl 上传接口URL
* @return 上传结果
*/
public Mono<String> uploadExcelFile(org.apache.poi.ss.usermodel.Workbook workbook,
String fileName, String uploadUrl) {
return Mono.fromCallable(() -> {
// 将Workbook转换为字节数组
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
workbook.write(outputStream);
byte[] fileBytes = outputStream.toByteArray();
outputStream.close();
return fileBytes;
})
.flatMap(fileBytes -> {
// 创建Multipart表单数据
MultiValueMap<String, Object> formData = new LinkedMultiValueMap<>();
ByteArrayResource fileResource = new ByteArrayResource(fileBytes) {
@Override
public String getFilename() {
return fileName;
}
};

formData.add("file", fileResource);
formData.add("filename", fileName);

return webClient.post()
.uri(uploadUrl)
.contentType(MediaType.MULTIPART_FORM_DATA)
.bodyValue(formData) // 这里是正确的用法
.retrieve()
.bodyToMono(String.class)
.onErrorMap(WebClientResponseException.class, ex ->
new RuntimeException("上传失败: " + ex.getResponseBodyAsString(), ex));
});
}

/**
* 使用BodyInserters.multipartData的方式上传
*/
public Mono<String> uploadExcelWithBodyInserters(org.apache.poi.ss.usermodel.Workbook workbook,
String fileName, String uploadUrl) {
return Mono.fromCallable(() -> {
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
workbook.write(outputStream);
return outputStream.toByteArray();
})
.flatMap(fileBytes -> {
ByteArrayResource fileResource = new ByteArrayResource(fileBytes) {
@Override
public String getFilename() {
return fileName;
}
};

var multipartBuilder = BodyInserters
.fromMultipartData("file", fileResource)
.with("filename", fileName);

return webClient.post()
.uri(uploadUrl)
.body(multipartBuilder)
.retrieve()
.bodyToMono(String.class);
});
}

/**
* 使用Base64编码的方式上传
*/
public Mono<String> uploadExcelAsBase64(org.apache.poi.ss.usermodel.Workbook workbook,
String fileName, String uploadUrl) {
return Mono.fromCallable(() -> {
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
workbook.write(outputStream);
byte[] fileBytes = outputStream.toByteArray();
String base64Content = Base64.getEncoder().encodeToString(fileBytes);
return base64Content;
})
.flatMap(base64Content -> {
var requestObject = new UploadRequest();
requestObject.setFileName(fileName);
requestObject.setFileContent(base64Content);
requestObject.setFileType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");

return webClient.post()
.uri(uploadUrl)
.contentType(MediaType.APPLICATION_JSON)
.bodyValue(requestObject) // JSON请求体
.retrieve()
.bodyToMono(String.class);
});
}

// 上传请求对象
static class UploadRequest {
private String fileName;
private String fileContent;
private String fileType;

// Getters and Setters
public String getFileName() { return fileName; }
public void setFileName(String fileName) { this.fileName = fileName; }

public String getFileContent() { return fileContent; }
public void setFileContent(String fileContent) { this.fileContent = fileContent; }

public String getFileType() { return fileType; }
public void setFileType(String fileType) { this.fileType = fileType; }
}
}

 

 

======================================

 

 

// 使用示例
public class Example {
public static void main(String[] args) {
// 假设你已经有了Workbook对象和文件名
Workbook workbook = ...; // 你的POI Workbook对象
String fileName = "example.xlsx";
String uploadUrl = "https://api.example.com/upload";

ExcelUploadService uploadService = new ExcelUploadService("https://api.example.com");

// 上传文件
uploadService.uploadExcelFile(workbook, fileName, uploadUrl)
.subscribe(
response -> System.out.println("上传成功: " + response),
error -> System.err.println("上传失败: " + error.getMessage())
);
}
}

 

 

=====================================

import org.apache.poi.ss.usermodel.Workbook;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.client.WebClient;
import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.core.io.buffer.DataBufferFactory;
import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.http.MediaType;
import org.springframework.http.codec.multipart.FilePart;
import org.springframework.mock.web.reactive.function.multipart.DefaultFilePart;
import reactor.core.publisher.Mono;
import reactor.netty.http.client.HttpClient;
import io.netty.handler.codec.http.multipart.HttpData;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.nio.charset.StandardCharsets;

public class ExcelUploadService {

private final WebClient webClient;

public ExcelUploadService(String baseUrl) {
this.webClient = WebClient.builder()
.clientConnector(new ReactorClientHttpConnector(
HttpClient.create().responseTimeout(Duration.ofMinutes(5))
))
.build();
}

/**
* 上传Excel文件到第三方接口
* @param workbook POI Workbook对象
* @param fileName 文件名
* @param uploadUrl 上传接口URL
* @return 响应结果
*/
public Mono<String> uploadExcelFile(Workbook workbook, String fileName, String uploadUrl) {
return Mono.fromCallable(() -> {
// 将Workbook转换为字节数组
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
workbook.write(outputStream);
byte[] fileBytes = outputStream.toByteArray();
outputStream.close();
return fileBytes;
})
.flatMap(fileBytes -> {
// 创建WebClient请求
return webClient.post()
.uri(uploadUrl)
.contentType(MediaType.MULTIPART_FORM_DATA)
.body(BodyInserters.fromMultipartData()
.part("file",
org.springframework.core.io.ByteArrayResource(fileBytes, fileName))
.part("filename", fileName))
.retrieve()
.bodyToMono(String.class);
});
}

/**
* 使用ReactiveHttpClient的另一种实现方式
*/
public Mono<String> uploadExcelWithReactiveClient(Workbook workbook, String fileName, String uploadUrl) {
try {
// 将Workbook转换为字节数组
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
workbook.write(outputStream);
byte[] fileBytes = outputStream.toByteArray();

// 使用WebClient构建multipart请求
return webClient.post()
.uri(uploadUrl)
.contentType(MediaType.MULTIPART_FORM_DATA)
.body(BodyInserters.fromValue(
MultipartBodyBuilder()
.part("file", new org.springframework.core.io.ByteArrayResource(fileBytes) {
@Override
public String getFilename() {
return fileName;
}
})
.part("fileName", fileName)
.build()
))
.retrieve()
.bodyToMono(String.class);

} catch (IOException e) {
return Mono.error(e);
}
}

/**
* 更完整的上传实现，包含错误处理和进度监控
*/
public Mono<UploadResponse> uploadExcelWithProgress(Workbook workbook, String fileName, String uploadUrl) {
return Mono.fromCallable(() -> {
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
workbook.write(outputStream);
return outputStream.toByteArray();
})
.flatMap(fileBytes -> {
return webClient.post()
.uri(uploadUrl)
.contentType(MediaType.MULTIPART_FORM_DATA)
.body(BodyInserters.fromMultipartData(builder -> {
builder.part("file",
new org.springframework.core.io.ByteArrayResource(fileBytes) {
@Override
public String getFilename() {
return fileName;
}
})
.part("originalFileName", fileName)
.part("size", String.valueOf(fileBytes.length));
}))
.retrieve()
.onStatus(HttpStatus::isError, clientResponse -> {
return clientResponse.bodyToMono(String.class)
.flatMap(errorBody -> Mono.error(
new UploadException("Upload failed: " + errorBody)
));
})
.bodyToMono(String.class)
.map(responseBody -> UploadResponse.success(responseBody))
.onErrorMap(UploadException.class, ex -> ex)
.onErrorMap(Exception.class, ex -> new UploadException("Upload error", ex));
});
}

// 响应包装类
public static class UploadResponse {
private boolean success;
private String message;
private Object data;

public static UploadResponse success(String message) {
UploadResponse response = new UploadResponse();
response.success = true;
response.message = message;
return response;
}

public static UploadResponse error(String message) {
UploadResponse response = new UploadResponse();
response.success = false;
response.message = message;
return response;
}

// getter和setter方法
public boolean isSuccess() { return success; }
public void setSuccess(boolean success) { this.success = success; }
public String getMessage() { return message; }
public void setMessage(String message) { this.message = message; }
public Object getData() { return data; }
public void setData(Object data) { this.data = data; }
}

// 自定义异常类
public static class UploadException extends Exception {
public UploadException(String message) {
super(message);
}

public UploadException(String message, Throwable cause) {
super(message, cause);
}
}
}

 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/951253.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

vscode cursor中在终端里使用claude code，经常会闪烁，并且粘贴进长文本会有问题。

vscode cursor中在终端里使用claude code，经常会闪烁，并且粘贴进长文本会有问题。

so can use that extension, click that button to show an extra window
阅读更多...
reactive -03

reactive -03

import org.springframework.core.io.buffer.DataBuffer;import org.springframework.core.io.buffer.DataBufferUtils;import org.springframework.http.codec.multipart.FilePart;import org.springframework.web.re…
阅读更多...
reactive - 02

reactive - 02

import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.web.reactive.function.BodyInserters;import org.springfra…
阅读更多...
reactive-01

reactive-01

package com.hyman.service; import org.springframework.core.io.ByteArrayResource;import org.springframework.core.io.buffer.DataBufferUtils;import org.springframework.http.HttpHeaders;import org.springfr…
阅读更多...
revit api获取excursion 拉伸体的轮廓和平面sketchplane GeometryCreationUtilities

revit api获取excursion 拉伸体的轮廓和平面sketchplane GeometryCreationUtilities

revit api获取excursion 拉伸体的轮廓和平面sketchplane GeometryCreationUtilitiespublic void GetSketchFromExtrusion() {Document doc = this.ActiveUIDocument.Document;Extrusion extrusion = doc.GetEleme…
阅读更多...
revit api创建模型线

revit api创建模型线

revit api创建模型线public void CreateModelCurve() {Document doc = this.ActiveUIDocument.Document; // 在族文档中找到名字为"Ref. Level"的标高FilteredElementCollector collector = new Filtered…
阅读更多...
revit 创建sketchplane

revit 创建sketchplane

revit 创建sketchplanesketchplane在创建某些图元时候可以用到 public void CreateSketchPlaneByPlane() {Document doc = this.ActiveUIDocument.Document; using(Transaction trans = new Transaction(doc, "…
阅读更多...
revit api创建参考线

revit api创建参考线

revit api创建参考线参考线可以用modelcurve转化而来 public void ChangeModelCurveToReferenceLine() { Document doc = this.ActiveUIDocument.Document; ModelCurve modelCurve = doc.GetElement(new…
阅读更多...
【AI说HTML 04】掌握核心文档结构标签的方法

【AI说HTML 04】掌握核心文档结构标签的方法

要真正掌握HTML的核心文档结构标签，关键在于理解它们如何像搭积木一样，共同构建起一个清晰、语义明确的网页骨架。下面这个流程图概括了一个网页的典型结构，帮你先建立整体印象： flowchart TDA[<!DOCTYPE html&…
阅读更多...
revit api创建参考平面

revit api创建参考平面

revit api创建参考平面public void CreatReferencePlane() {Document doc = this.ActiveUIDocument.Document; if(!doc.IsFamilyDocument)return;using(Transaction transaction = new Transaction(doc, "Edit…
阅读更多...
【AI说HTML 02】如何深刻建立对HTML的正确认知

【AI说HTML 02】如何深刻建立对HTML的正确认知

要深刻建立对HTML的正确认知，关键在于理解它不仅仅是用来“画”出网页样子的工具，更是一套用于描述内容结构和含义的语言。下面这个表格梳理了理解HTML时需要建立的核心认知维度。认知维度 错误认知（新手常见） 正确…
阅读更多...
【AI说HTML 03】手把手教你搭建极简HTML开发环境

【AI说HTML 03】手把手教你搭建极简HTML开发环境

为你打造一个极简且高效的HTML开发环境，其实只需要几个核心步骤。下面这张流程图概括了全过程，你可以先有一个整体的了解，再跟着后续的详细步骤操作。 flowchart TDA[下载并安装VS Code] --> B[安装必备插件<…
阅读更多...
图元编辑 移动 旋转 镜像等

图元编辑 移动 旋转 镜像等

图元编辑 移动 旋转 镜像等编辑1 Document projectDoc = ActiveUIDocument.Document;using(Transaction moveColumnTran = new Transaction(projectDoc, "Move a new column to the new place")) {moveCol…
阅读更多...
【AI说】如何深刻建立对HTML的正确认知

【AI说】如何深刻建立对HTML的正确认知

要深刻建立对HTML的正确认知，关键在于理解它不仅仅是用来“画”出网页样子的工具，更是一套用于描述内容结构和含义的语言。下面这个表格梳理了理解HTML时需要建立的核心认知维度。认知维度 错误认知（新手常见） 正确…
阅读更多...
计算机组成原理核心知识点梳理

计算机组成原理核心知识点梳理

SQLAlchemy是Python中最流行的ORM（对象关系映射）框架之一，它提供了高效且灵活的数据库操作方式。本文将介绍如何使用SQLAlchemy ORM进行数据库操作。 目录 安装SQLAlchemy 核心概念 连接数据库 定义数据模型 创建数…
阅读更多...
revit api 内置族类型 walltype

revit api 内置族类型 walltype

revit api 内置族类型 walltype复制墙类型 Wall wall = RevitDoc.GetElement(new ElementId(185521)) as Wall; WallType wallType = wall.WallType; ElementType duplicatedWallType = wallType.Duplicate(wallType.…
阅读更多...
国产的编程语言

国产的编程语言

​1、非修改序列算法 这些算法不会改变它们所操作的容器中的元素。 1.1 find 和 find_if find(begin, end, value)：查找第一个等于 value 的元素，返回迭代器（未找到返回 end）。 find_if(begin, end, predicate)：查…
阅读更多...
revit api族文件图元编辑 familyitem factory

revit api族文件图元编辑 familyitem factory

revit api族文件图元编辑 familyitem factory创建拉伸实体 //创建族文档 Document familyDoc = RevitApp.NewFamilyDocument(@"C:\ProgramData\Autodesk\RVT 2014\Family Templates\Chinese\公制常规模型.rft&qu…
阅读更多...
【AI说】HTML从零基础到精通路径

【AI说】HTML从零基础到精通路径

学习HTML从零基础到精通，是一个循序渐进的过程，关键在于建立正确的认知、通过实践巩固知识，并逐步关注更宏观的网页质量维度。下面我为你梳理一条清晰的路径，并附上每个阶段的学习重点和建议。 为了让你对整体学习…
阅读更多...
revit api 加载族文件+放置族实例 创建门图元

revit api 加载族文件+放置族实例 创建门图元

revit api 加载族文件+放置族实例 创建门图元string doorTypeName = "0762 x 2032 mm"; FamilySymbol doorType = null;// 在文档中找到名字为"0762 x 2032 mm"的门类型 ElementFilter doorCateg…
阅读更多...
最新文章

Copyright @ 2022~2023