Camel-Spring Boot应用调用GCP getObject操作返回元数据而非对象内容的问题咨询

嘿，我看到你已经成功用Apache Camel连接上Google Cloud Storage并拿到了Blob对象，但还在纠结怎么提取里面的实际内容对吧？别担心，这其实有两种简单的解决办法，咱们一起来看看：

方法一：从Blob对象中读取内容 #

Camel的google-storage组件执行getObject操作时，默认返回的是GCS的Blob实例——这就是你日志里看到的那个对象。要获取内容，你只需要在路由里添加一个处理器，调用Blob的getContent()方法即可：

from("direct:selectPhoto")
    .process(new Processor() {
        @Override
        public void process(Exchange xchg) throws Exception {
            xchg.getIn().setHeader(GoogleCloudStorageConstants.OBJECT_NAME, "kitten.png");
        }
    })
    .to("google-storage://sagessapp_test?operation=getObject")
    .process(new Processor() {
        @Override
        public void process(Exchange exchange) throws Exception {
            // 从Exchange的body中取出Blob对象
            Blob blob = exchange.getIn().getBody(Blob.class);
            
            // 如果你要处理的是图片/二进制文件，获取字节数组
            byte[] objectContent = blob.getContent();
            
            // 如果是文本文件，可以转成字符串（记得指定编码）
            // String objectContent = new String(blob.getContent(), StandardCharsets.UTF_8);
            
            // 将内容设置回Exchange，方便后续返回给客户端
            exchange.getIn().setBody(objectContent);
            
            // 根据文件类型设置正确的Content-Type头，比如图片设为image/png
            exchange.getIn().setHeader(Exchange.CONTENT_TYPE, "image/png");
        }
    })
    .log("Object content size: ${body.length} bytes");

这种方法的好处是，你可以先获取Blob的元数据（比如大小、原始ContentType等），再决定怎么处理内容。

方法二：让组件直接返回对象内容 #

如果你不需要Blob的元数据，只想直接拿到内容，可以在Camel的端点URI中添加blobDownload=true参数。这样执行getObject操作时，组件会直接返回对象的输入流（InputStream），而不是Blob实例：

from("direct:selectPhoto")
    .process(new Processor() {
        @Override
        public void process(Exchange xchg) throws Exception {
            xchg.getIn().setHeader(GoogleCloudStorageConstants.OBJECT_NAME, "kitten.png");
        }
    })
    // 添加blobDownload=true参数
    .to("google-storage://sagessapp_test?operation=getObject&blobDownload=true")
    .process(new Processor() {
        @Override
        public void process(Exchange exchange) throws Exception {
            InputStream contentStream = exchange.getIn().getBody(InputStream.class);
            // 转成字节数组（可以用Apache Commons IO的IOUtils工具类，或者自己实现）
            byte[] objectContent = IOUtils.toByteArray(contentStream);
            
            exchange.getIn().setBody(objectContent);
            exchange.getIn().setHeader(Exchange.CONTENT_TYPE, "image/png");
        }
    })
    .log("Object content size: ${body.length} bytes");

额外提示 #

注意你的REST接口当前设置的produces("application.json")，如果返回的是图片，建议改成对应的MIME类型（比如produces("image/png")），或者根据返回的内容动态设置Exchange.CONTENT_TYPE头，这样客户端才能正确解析返回的内容。

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