Spring Batch自定义GSWriter写入GCP Bucket遇类型转换异常

出现ClassCastException是因为你使用的ResourceLoader默认不识别gs://协议，它把这个路径当成了Web应用的ServletContext资源路径，返回了ServletContextResource实例，但这个类并没有实现WritableResource接口，所以强转失败。

1. 引入Spring Cloud GCP依赖 #

首先需要添加Spring Cloud GCP存储模块的依赖，让Spring能够识别并处理gs://协议的资源：

<!-- Maven依赖 -->
<dependency>
    <groupId>com.google.cloud</groupId>
    <artifactId>spring-cloud-gcp-storage</artifactId>
    <version>4.8.1</version> <!-- 版本可根据Spring Boot/Spring Batch版本调整 -->
</dependency>

如果用Gradle：

implementation 'com.google.cloud:spring-cloud-gcp-storage:4.8.1'

2. 修改GSWriter实现，使用正确的ResourceLoader #

Spring Cloud GCP会自动配置GcpResourceLoader，它能正确解析gs://路径并返回实现了WritableResource接口的GcsResource实例。直接使用这个Loader替换默认的ResourceLoader：

import com.google.cloud.spring.storage.GcpResourceLoader;
import org.springframework.core.io.WritableResource;
import org.springframework.batch.item.ItemWriter;
import org.springframework.batch.item.Chunk;

import java.io.IOException;
import java.io.OutputStream;

public class GSWriter implements ItemWriter<String> {

    private final WritableResource resource;

    public GSWriter(GcpResourceLoader gcpResourceLoader, String gsResourcePath) {
        Resource resource = gcpResourceLoader.getResource(gsResourcePath);
        if (!(resource instanceof WritableResource)) {
            throw new IllegalArgumentException("指定资源不支持写入操作: " + gsResourcePath);
        }
        this.resource = (WritableResource) resource;
    }

    @Override
    public void write(Chunk<? extends String> items) throws Exception {
        try (OutputStream outputStream = resource.getOutputStream()) {
            for (String item : items) {
                outputStream.write(item.getBytes());
                // 可选：添加换行符，避免内容连续拼接
                outputStream.write(System.lineSeparator().getBytes());
            }
        } catch (IOException e) {
            throw new RuntimeException("写入GCS存储桶失败", e);
        }
    }
}

3. 配置GCP访问凭证 #

确保应用具备GCP存储桶的写入权限：

• 本地开发时，设置环境变量GOOGLE_APPLICATION_CREDENTIALS指向你的服务账号密钥文件路径
• GCP托管环境（如GKE、Cloud Run）中，使用工作负载身份或默认服务账号，确保账号拥有storage.objects.create和storage.objects.update权限

4. 注册GSWriter Bean #

在Spring Batch配置类中，注入GcpResourceLoader并创建GSWriter实例：

import com.google.cloud.spring.storage.GcpResourceLoader;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class BatchConfig {

    @Bean
    public GSWriter gsWriter(GcpResourceLoader gcpResourceLoader) {
        String gsPath = "gs://your-bucket-name/output-file.csv";
        return new GSWriter(gcpResourceLoader, gsPath);
    }

    // 其他Batch配置（Job、Step等）...
}

内容的提问来源于stack exchange，提问作者Safwan Muhammed