• Springboot 结合PDF上传到OSS

    目录

     一、首先注册阿里云OSS（新用户免费使用3个月）

    二、步骤

    2.1 将pdf模板上传到oos

    2.2 这里有pdf地址,将读写权限设置为共工读

    ​编辑 三、代码

    3.1 pom.xml

    3.2 配置文件

     3.3 oss model

    3.4 配置类(不需要修改)

    3.5 将配置类放入ioc容器

    3.6 controller

    四、结果

    ​编辑 五、源代码参考

     一、首先注册阿里云OSS（新用户免费使用3个月）

    阿里云OSS 存储对象的注册与使用-CSDN博客

    二、步骤

    2.1 将pdf模板上传到oos

    2.2 这里有pdf地址,将读写权限设置为共工读

     三、代码

    3.1 pom.xml

    1.    
    2.         <dependency>
    3.             <groupId>com.itextpdfgroupId>
    4.             <artifactId>itext7-coreartifactId>
    5.             <version>7.2.5version>
    6.             <type>pomtype>
    7.         dependency>
    8.  
    9.         <dependency>
    10.             <groupId>com.aliyun.ossgroupId>
    11.             <artifactId>aliyun-sdk-ossartifactId>
    12.             <version>3.10.2version>
    13.         dependency>

    3.2 配置文件

    1. # 配置阿里云OSS（application.properties）
    2. aliyun.oss.bucketName = hyc-8147
    3. aliyun.oss.endpoint = oss-cn-beijing.aliyuncs.com
    4. aliyun.oss.accessKeyId = LTAI5tE2krid8AXzidDUpn9n
    5. aliyun.oss.accessKeySecret = 2A0Vrvj982nfRPWDVt3lp
    6.  
    7. # yml版(application.yml)
    8. #aliyun:
    9. #  oss:
    10. #    bucketName: hyc-8147
    11. #    endpoint: oss-cn-beijing.aliyuncs.com
    12. #    accessKeyId: LTAI5tE2krid8AXzidDUpn9n
    13. #    accessKeySecret: 2A0Vrvj982nfRPWDVt3lp

     3.3 oss model

    1. package com.by.model;
    2.  
    3. import lombok.Data;
    4. import org.springframework.boot.context.properties.ConfigurationProperties;
    5. import org.springframework.context.annotation.Configuration;
    6.  
    7. @Configuration
    8. @ConfigurationProperties(prefix = "aliyun.oss")
    9. @Data
    10. public class AliOssProperties {
    11.  
    12.     private String endpoint;
    13.     private String accessKeyId;
    14.     private String accessKeySecret;
    15.     private String bucketName;
    16.  
    17.  
    18. }

    3.4 配置类(不需要修改)

    1. package com.by.util;
    2.  
    3. import com.aliyun.oss.ClientException;
    4. import com.aliyun.oss.OSS;
    5. import com.aliyun.oss.OSSClientBuilder;
    6. import com.aliyun.oss.OSSException;
    7. import lombok.AllArgsConstructor;
    8. import lombok.Data;
    9. import lombok.extern.slf4j.Slf4j;
    10. import java.io.ByteArrayInputStream;
    11.  
    12. @Data
    13. @AllArgsConstructor
    14. //固定代码，CV直接使用
    15. public class AliOssUtil {
    16.  
    17.     private String endpoint;
    18.     private String accessKeyId;
    19.     private String accessKeySecret;
    20.     private String bucketName;
    21.  
    22.     /**
    23.      * 文件上传
    24.      *
    25.      * @param bytes ：传入的文件要转为byte[]
    26.      * @param objectName ：表示在oss中存储的文件名字。
    27.      * @return
    28.      */
    29.     public String upload(byte[] bytes, String objectName) {
    30.  
    31.         // 创建OSSClient实例。
    32.         OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
    33.  
    34.         try {
    35.             // 创建PutObject请求。
    36.             ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(bytes));
    37.         } catch (OSSException oe) {
    38.             System.out.println("Caught an OSSException, which means your request made it to OSS, "
    39.                     + "but was rejected with an error response for some reason.");
    40.             System.out.println("Error Message:" + oe.getErrorMessage());
    41.             System.out.println("Error Code:" + oe.getErrorCode());
    42.             System.out.println("Request ID:" + oe.getRequestId());
    43.             System.out.println("Host ID:" + oe.getHostId());
    44.         } catch (ClientException ce) {
    45.             System.out.println("Caught an ClientException, which means the client encountered "
    46.                     + "a serious internal problem while trying to communicate with OSS, "
    47.                     + "such as not being able to access the network.");
    48.             System.out.println("Error Message:" + ce.getMessage());
    49.         } finally {
    50.             if (ossClient != null) {
    51.                 ossClient.shutdown();
    52.             }
    53.         }
    54.  
    55.         //文件访问路径规则 https://BucketName.Endpoint/ObjectName
    56.         StringBuilder stringBuilder = new StringBuilder("https://");
    57.         stringBuilder
    58.                 .append(bucketName)
    59.                 .append(".")
    60.                 .append(endpoint)
    61.                 .append("/")
    62.                 .append(objectName);
    63.  
    64.         return stringBuilder.toString();
    65.     }
    66. }

    3.5 将配置类放入ioc容器

    1. package com.by.config;
    2.  
    3.  
    4. import com.by.model.AliOssProperties;
    5. import com.by.util.AliOssUtil;
    6. import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
    7. import org.springframework.context.annotation.Bean;
    8. import org.springframework.context.annotation.Configuration;
    9. @Configuration
    10. public class OssConfiguration {
    11.     @Bean
    12.     @ConditionalOnMissingBean
    13.     public AliOssUtil getAliOssUtil(AliOssProperties aliOssProperties) {
    14. //        log.info("创建OssUtil");
    15.         AliOssUtil aliOssUtil = new AliOssUtil(
    16.                 aliOssProperties.getEndpoint(),
    17.                 aliOssProperties.getAccessKeyId(),
    18.                 aliOssProperties.getAccessKeySecret(),
    19.                 aliOssProperties.getBucketName()
    20.         );
    21.         return aliOssUtil;
    22.     }
    23. }

    3.6 controller

    1. package com.by.controller;
    2.  
    3. import com.by.util.AliOssUtil;
    4. import com.itextpdf.forms.PdfAcroForm;
    5. import com.itextpdf.forms.fields.PdfFormField;
    6. import com.itextpdf.kernel.font.PdfFont;
    7. import com.itextpdf.kernel.font.PdfFontFactory;
    8. import com.itextpdf.kernel.geom.PageSize;
    9. import com.itextpdf.kernel.pdf.PdfDocument;
    10. import com.itextpdf.kernel.pdf.PdfReader;
    11. import com.itextpdf.kernel.pdf.PdfWriter;
    12. import org.slf4j.Logger;
    13. import org.slf4j.LoggerFactory;
    14. import org.springframework.beans.factory.annotation.Autowired;
    15. import org.springframework.http.HttpHeaders;
    16. import org.springframework.http.HttpStatus;
    17. import org.springframework.http.MediaType;
    18. import org.springframework.http.ResponseEntity;
    19. import org.springframework.web.bind.annotation.GetMapping;
    20. import org.springframework.web.bind.annotation.RestController;
    21.  
    22. import javax.servlet.http.HttpServletResponse;
    23. import java.io.*;
    24. import java.net.URL;
    25. import java.nio.file.Files;
    26. import java.nio.file.Path;
    27. import java.nio.file.StandardCopyOption;
    28. import java.util.HashMap;
    29. import java.util.Map;
    30. import java.util.Optional;
    31.  
    32. @RestController
    33. public class PdfController {
    34.     // 初始化日志记录器，用于记录PDF控制器类的操作日志
    35.     private static final Logger logger = LoggerFactory.getLogger(PdfController.class);
    36.  
    37.     @Autowired
    38.     private AliOssUtil aliOssUtil;
    39.  
    40.     /**
    41.      * 生成填充数据的PDF文件并提供下载。
    42.      *
    43.      * @param response 用于设置HTTP响应信息的ServletResponse对象。
    44.      * @return 返回包含填充后PDF文件内容的响应实体。
    45.      * @throws IOException 如果处理PDF文件或下载模板文件时发生IO错误。
    46.      */
    47.     @GetMapping("/download")
    48.     public ResponseEntity<byte[]> generateFilledPdf(HttpServletResponse response) throws IOException {
    49.         // 准备需要填充到PDF的数据
    50.         Map dataMap = new HashMap<>();
    51.         dataMap.put("name", "黄哥");
    52.         dataMap.put("tel", "175");
    53.  
    54.         // 从URL下载PDF模板并临时保存到本地
    55.         String templateUrl = "https://hyc-8147.oss-cn-beijing.aliyuncs.com/3.pdf";
    56.         Path tempTemplateFile = Files.createTempFile("temp_template_", ".pdf");
    57.  
    58.         try (InputStream inputStream = new URL(templateUrl).openStream()) {
    59.             Files.copy(inputStream, tempTemplateFile, StandardCopyOption.REPLACE_EXISTING);
    60.         } catch (IOException e) {
    61.             logger.error("Failed to download and save the PDF template from {}", templateUrl, e);
    62.             // 下载模板失败时，返回500错误并提供错误信息
    63.             return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR)
    64.                     .body("Error downloading PDF template. Please try again later.".getBytes());
    65.         }
    66.         try {
    67.             // 使用填充的数据生成新的PDF文件
    68.             byte[] pdfBytes = fillPdfData(tempTemplateFile, dataMap);
    69.  
    70.             // 将生成的PDF文件上传到OSS，并设置下载文件名
    71.             String downloadFileName = System.currentTimeMillis() + "_filled.pdf";
    72.             aliOssUtil.upload(pdfBytes, downloadFileName);
    73.  
    74.             // 设置响应头，提供PDF文件的下载
    75.             HttpHeaders headers = new HttpHeaders();
    76.             headers.setContentType(MediaType.APPLICATION_PDF);
    77.             headers.setContentDispositionFormData("attachment", downloadFileName);
    78.             return ResponseEntity.ok().headers(headers).body(pdfBytes);
    79.         } finally {
    80.             // 清理临时文件
    81.             Files.deleteIfExists(tempTemplateFile);
    82.         }
    83.     }
    84.  
    85.  
    86.     /**
    87.      * 根据提供的数据映射，填充PDF表单并返回填充后的PDF数据。
    88.      *
    89.      * @param sourcePdf 表单源PDF文件的路径。
    90.      * @param dataMap   需要填充到PDF表单的数据映射，键为表单字段名称，值为填充的文本。
    91.      * @return 填充后的PDF数据的字节数组。
    92.      * @throws IOException 如果读取或处理PDF文件时发生错误。
    93.      */
    94.     private byte[] fillPdfData(Path sourcePdf, Map dataMap) throws IOException {
    95.         // 使用try-with-resources语句确保资源正确关闭
    96.         try (InputStream fileInputStream = Files.newInputStream(sourcePdf);
    97.              PdfReader pdfReader = new PdfReader(fileInputStream);
    98.              ByteArrayOutputStream outputStream = new ByteArrayOutputStream()) {
    99.  
    100.             // 初始化PDF文档并设置页面大小
    101.             PdfDocument pdf = new PdfDocument(pdfReader, new PdfWriter(outputStream));
    102.             pdf.setDefaultPageSize(PageSize.A4);
    103.  
    104.             // 获取PDF表单并填充数据
    105.             PdfAcroForm form = PdfAcroForm.getAcroForm(pdf, true);
    106.             Map fields = form.getFormFields();
    107.  
    108.             // 设置表单字段使用的字体
    109.             PdfFont currentFont = PdfFontFactory.createFont("STSong-Light", "UniGB-UCS2-H", PdfFontFactory.EmbeddingStrategy.PREFER_NOT_EMBEDDED);
    110.  
    111.             // 填充表单字段
    112.             dataMap.forEach((key, value) -> {
    113.                 Optional.ofNullable(fields.get(key))
    114.                         .ifPresent(formField -> formField.setFont(currentFont).setValue(value));
    115.             });
    116.  
    117.             // 将表单字段合并到PDF文档中，防止编辑
    118.             form.flattenFields();
    119.  
    120.             // 关闭PDF文档并返回填充后的PDF数据
    121.             pdf.close();
    122.  
    123.             return outputStream.toByteArray();
    124.         } catch (Exception e) {
    125.             logger.error("Error filling PDF data: {}", e.getMessage());
    126.             // 抛出IOException，封装原始异常
    127.             throw new IOException("Failed to fill PDF data due to an internal error.", e);
    128.         }
    129.     }
    130.  
    131. }

    四、结果

     五、源代码参考

    源代码我已经放入了云效

    https://codeup.aliyun.com/62858d45487c500c27f5aab5/huang-spring-boot-pdf.git

  • 相关阅读:
    箩筐递馒头
    并查集总结
    A星寻路优化方案
    油猴浏览器（安卓）
    记一次相同sql语句，java中执行不成功，数据库中能执行成功的问题
    计算机毕业设计（附源码）python钟点工管理系统
    Domain Admin域名和SSL证书过期监控到期提醒
    基于Zookeeper实现高可用架构
    20天拿下华为OD笔试之【模拟】2023B-阿里巴巴找黄金宝箱(1)【欧弟算法】全网注释最详细分类最全的华为OD真题题解
    mysql 8.0.17 解压版安装教程
  • 原文地址：https://blog.csdn.net/qq_65142821/article/details/137992630