Spring Boot集成Camel读取GCS图片Blob对象返回null问题求解

根因说明 #

• ContentType返回null：Google Cloud Storage不会自动推断存储对象的MIME类型，只有上传对象时主动设置了contentType元数据才会返回对应值，未设置时默认返回null，和文件内容是否读取成功无关。
• 图片内容无法正常返回：原代码直接将图片二进制字节数组放入Camel消息体，若后续路由未适配二进制流序列化规则，会导致内容丢失。你需要返回Base64格式，直接将编码后的字符串放入消息体即可。

修复代码 #

修改你处理器中匹配到目标文件后的逻辑：

package processors;

import java.io.FileInputStream;
import java.nio.file.Paths;
import java.util.Base64;

import org.apache.camel.Exchange;
import org.apache.camel.Processor;

import com.google.auth.Credentials;
import com.google.auth.oauth2.GoogleCredentials;
import com.google.cloud.storage.Blob;
import com.google.cloud.storage.BlobId;
import com.google.cloud.storage.Storage;
import com.google.cloud.storage.StorageOptions;

public class ListObjFromGCPProcessor implements Processor{
    public void process(Exchange xchg) throws Exception {
        Credentials credentials = GoogleCredentials.fromStream(new FileInputStream("D:/Users/User/MyFiles/Apache Camel github/SagesseMobileAppAPIs/camel-SagesseMobApp/src/main/resources/gcp-credentials.json"));
        Storage storage = StorageOptions.newBuilder().setCredentials(credentials).build().getService();
        String targetFileName = "kitten.png";
        // 优化：直接查询指定对象，不需要遍历全桶，避免文件量大时超时
        Blob blob = storage.get(BlobId.of("sagessapp_test", targetFileName));
        if (blob != null && blob.exists()) {
            byte[] content = blob.getContent();
            // 编码为Base64字符串
            String base64Img = Base64.getEncoder().encodeToString(content);
            // 设置响应体为Base64字符串
            xchg.getIn().setBody(base64Img);
            // 手动设置响应ContentType，需要直接返回图片流就改为image/png
            xchg.getIn().setHeader(Exchange.CONTENT_TYPE, "text/plain");
            // 校验内容是否读取成功
            System.out.println("文件大小：" + blob.getSize() + "字节，Base64长度：" + base64Img.length());
        }
    }
}

可选优化：修复ContentType为null的问题 #

如果需要GCS返回正确的ContentType，上传文件时主动指定元数据即可，示例上传代码：

BlobId blobId = BlobId.of("sagessapp_test", "kitten.png");
BlobInfo blobInfo = BlobInfo.newBuilder(blobId)
    .setContentType("image/png")
    .build();
storage.create(blobInfo, Files.readAllBytes(Paths.get("本地图片路径")));

排查校验 #

如果还是无法正常返回，按以下步骤排查：

1. 检查服务账号权限，确认拥有桶对象的读取权限
2. 打印处理器中生成的base64Img值，和本地同一张图片生成的Base64对比，确认内容一致
3. 检查Camel全局路由配置，确认没有拦截修改二进制内容的转换器

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