java - Camel CXF : compressing response with CXFOutInterceptor throws classcast exception

Question

我有一个服务包，我想使用 CXF GZIPFeature 来压缩响应。该 bundle 部署在 JBoss Fuse(jboss-fuse-6.1.0.redhat-379) 上。 Camel 路线配置是:

<cxf:bus id="cxf" name ="cxf">
    <cxf:features>
        <bean class="org.apache.cxf.transport.common.gzip.GZIPFeature">
            <property name="threshold">
                <value>1</value>
            </property>
        </bean>
    </cxf:features>
</cxf:bus>

<camel:camelContext ...>
    <camel:route id="test-server">
        <camel:to uri="cxfbean:servicebeans?bus=#cxf&amp;providers=#providers" />
    </camel:route>
</camel:camelContext>

但这会引发类转换异常:

java.lang.ClassCastException: org.apache.cxf.transport.common.gzip.GZIPOutInterceptor$GZipThresholdOutputStream cannot be cast to org.apache.cxf.io.CachedOutputStream
at org.apache.camel.component.cxf.transport.CamelDestination$CamelOutputStream.commitOutputMessage(CamelDestination.java:284)[204:org.apache.camel.camel-cxf-transport:2.12.0.redhat-610379]
at org.apache.camel.component.cxf.transport.CamelDestination$CamelOutputStream.doClose(CamelDestination.java:296)[204:org.apache.camel.camel-cxf-transport:2.12.0.redhat-610379]
at org.apache.cxf.io.CachedOutputStream.close(CachedOutputStream.java:220)[164:org.apache.cxf.cxf-api:2.7.0.redhat-610379]
at java.util.zip.DeflaterOutputStream.close(DeflaterOutputStream.java:241)[:1.7.0_67]
at org.apache.cxf.io.AbstractWrappedOutputStream.close(AbstractWrappedOutputStream.java:77)[164:org.apache.cxf.cxf-api:2.7.0.redhat-610379]
at org.apache.cxf.io.AbstractThresholdOutputStream.close(AbstractThresholdOutputStream.java:102)[164:org.apache.cxf.cxf-api:2.7.0.redhat-610379]
at org.apache.cxf.transport.AbstractConduit.close(AbstractConduit.java:56)[164:org.apache.cxf.cxf-api:2.7.0.redhat-610379]
at org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndingInterceptor.handleMessage(MessageSenderInterceptor.java:62)[164:org.apache.cxf.cxf-api:2.7.0.redhat-610379]
at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:272)[164:org.apache.cxf.cxf-api:2.7.0.redhat-610379]

有没有合法的方法在路由中使用CXF GZIPFeature？我不想使用 Camel 的 DataFormat 进行 gzip。

Answer 1

我正在使用 servicemix-camel-cxf 并且遇到了几乎相同的问题。最后我决定简单地将其添加到 route :

<marshal> <gzip/> </marshal>

看看 - 也许它也会对你有帮助。 但在这种情况下你必须设置 Content-Type: gzip header 。

尝试添加

<setHeader headerName="Content-Type">
    <constant>gzip</constant></setHeader>

但是对我来说这没有帮助，所以我在java代码中添加了 header 。 =)