Java Structs 中动态创建 CSV 文件并上传至 FTP 服务器-java教程-PHP中文网

Java Structs 中动态创建 CSV 文件并上传至 FTP 服务器

霞舞

发布： 2025-07-15 16:44:01

原创

435人浏览过

java structs 中动态创建 csv 文件并上传至 ftp 服务器

本文介绍了如何在 Java Structs 框架中，基于 ArrayList 的值动态生成 CSV 文件，并将其上传到 FTP 服务器。核心思路是使用 ByteArrayOutputStream 和 ByteArrayInputStream 在内存中创建 CSV 数据流，避免了实际文件的创建，从而提高了效率。最后，通过 FTP 客户端将数据流上传到指定服务器。

在传统的 Java Structs 应用中，生成 CSV 文件并上传到 FTP 服务器通常涉及以下步骤：先将数据写入磁盘文件，然后读取该文件并上传。然而，这种方法效率较低，因为涉及磁盘 I/O 操作。更高效的方法是在内存中生成 CSV 数据，然后直接将其作为 InputStream 上传到 FTP 服务器，从而避免了磁盘 I/O。

以下是如何在 Java 中实现这一目标的详细步骤：

1. 准备数据

立即学习“Java免费学习笔记（深入）”；

首先，假设我们有一个包含业务数据和位置数据的 ArrayList，需要将其写入 CSV 文件。

String[] business = {"Business1", "Business2", "Business3"};
String[] position = {"Position1", "Position2", "Position3"};

登录后复制

2. 使用 ByteArrayOutputStream 和 ByteArrayInputStream 生成 InputStream

使用 ByteArrayOutputStream 将数据写入内存，然后使用 ByteArrayInputStream 从内存中读取数据。

维普科创助手

AI驱动的一站式科研资源服务平台

117

查看详情

import java.io.*;

ByteArrayOutputStream bos = new ByteArrayOutputStream();
try (Writer writer = new OutputStreamWriter(bos)) {
    // 写入 CSV 文件的头部（可选）
    writer.write("Business,Position\n");

    // 写入数据
    for (int i = 0; i < business.length; i++) {
        writer.write(business[i] + "," + position[i] + "\n");
    }

    writer.flush(); // 确保所有数据都写入到 ByteArrayOutputStream
} catch (IOException e) {
    e.printStackTrace();
    // 处理IO异常
}

InputStream inputStream = new ByteArrayInputStream(bos.toByteArray());

登录后复制

代码解释：

ByteArrayOutputStream: 一个字节数组输出流，可以用来在内存中构建数据。
OutputStreamWriter: 一个字符流到字节流的桥梁，使用指定的字符集将写入的字符编码成字节。
writer.write(): 将数据写入到 OutputStreamWriter，最终写入到 ByteArrayOutputStream。
writer.flush(): 刷新缓冲区，确保所有数据都写入到输出流。
ByteArrayInputStream: 一个字节数组输入流，可以用来从字节数组中读取数据。
bos.toByteArray(): 将 ByteArrayOutputStream 中的数据转换为字节数组。

3. 上传到 FTP 服务器

现在我们有了 InputStream，可以使用 fileUpload 方法将其上传到 FTP 服务器。

private boolean fileUpload(InputStream isUploadFile, String dirName, String loggedInUser,  String fileName){
     boolean storeRetVal = false;
  String fileType = fileName.substring(fileName.lastIndexOf(".") + 1, fileName.length());
     storeRetVal = SISSFTPManager.getInstance().put(isUploadFile, dirName, fileName);
     if (storeRetVal)
     {
         try {
        if (fileType.trim().equalsIgnoreCase("csv")){
           ICSAPI.getInstance().getSIMSOrderManager().createFileAudit(loggedInUser, fileName);
        } else {

        }
   } catch (RemoteException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
   } catch (SystemException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
   } catch (ApplicationException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
   }
     logger.info("BulkUploadAction:fileUpload SFTP Transfer file successfully!");
     } else {
         logger.error("BulkUploadAction:fileUpload SFTP Transfer file FAILED!");          
     }       

  return storeRetVal;
 }

登录后复制

4. 调用示例

String dirName = "/ftp/upload/directory";
String loggedInUser = "user123";
String fileName = "PAYROLL_PRM.csv";

// 获取 InputStream (使用上面代码)
ByteArrayOutputStream bos = new ByteArrayOutputStream();
try (Writer writer = new OutputStreamWriter(bos)) {
    writer.write("Business,Position\n");
    for (int i = 0; i < business.length; i++) {
        writer.write(business[i] + "," + position[i] + "\n");
    }
    writer.flush();
} catch (IOException e) {
    e.printStackTrace();
}
InputStream inputStream = new ByteArrayInputStream(bos.toByteArray());

boolean uploadSuccess = fileUpload(inputStream, dirName, loggedInUser, fileName);

if (uploadSuccess) {
    System.out.println("File uploaded successfully!");
} else {
    System.out.println("File upload failed!");
}

登录后复制

注意事项：

确保正确处理 IOException，例如使用 try-catch 块。
在上传之前，可能需要设置 FTP 连接参数，例如服务器地址、端口号、用户名和密码。
SISSFTPManager.getInstance().put() 的具体实现取决于所使用的 FTP 客户端库。常见的 Java FTP 客户端库包括 Apache Commons Net 和 JSch。需要根据实际使用的库进行调整。
在关闭 writer 之前，务必调用 writer.flush()，以确保所有数据都写入到 ByteArrayOutputStream。
异常处理部分需要根据实际情况进行完善，添加更详细的错误信息和日志记录。

总结：

通过使用 ByteArrayOutputStream 和 ByteArrayInputStream，我们可以在内存中动态生成 CSV 数据流，并将其直接上传到 FTP 服务器，避免了不必要的磁盘 I/O 操作，从而提高了效率。这种方法特别适用于需要快速生成和上传小文件的场景。记住，要根据实际使用的 FTP 客户端库调整 fileUpload 方法的实现。

以上就是Java Structs 中动态创建 CSV 文件并上传至 FTP 服务器的详细内容，更多请关注php中文网其它相关文章！