使用amq处理cxf请求

Posted 2021-04-14

我想做出这样的解决方案：

1. cxf https soap服务获取请求并将其发送到activemq队列1
2. 服务实现从队列1获取消息，处理它并放入队列2
3. 端点从队列2获取响应并将响应发送到客户端

现在，我提出了一种解决方案，但我不确定如何处理来自activemq的响应并将其作为SOAP响应发回。我的骆驼蓝图如下。端点蓝图：

    <?xml version="1.0" encoding="UTF-8"?>
    <blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0"
           xmlns:cxf="http://camel.apache.org/schema/blueprint/cxf"
           xmlns:soap="http://cxf.apache.org/blueprint/bindings/soap"
           xsi:schemaLocation="
             http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
             http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0 http://aries.apache.org/schemas/blueprint-cm/blueprint-cm-1.0.0.xsd
             http://camel.apache.org/schema/blueprint/cxf http://camel.apache.org/schema/blueprint/cxf/camel-cxf.xsd
             http://camel.apache.org/schema/blueprint http://camel.apache.org/schema/blueprint/camel-blueprint.xsd
             http://cxf.apache.org/blueprint/bindings/soap http://cxf.apache.org/schemas/configuration/blueprint/soap.xsd">
    <bean id="cardServiceEndpoint" class="com.endpoint.card.CardEndpoint">
        <argument>
            <reference interface="com.card.CardService" />
        </argument>
    </bean>
    <cxf:cxfEndpoint
        id="cardEndpoint" 
        address="https://host:port/soa/card"
        serviceClass="com.card.CardService">
        <cxf:properties>
            <entry key="schema-validation-enabled" value="true" />
        </cxf:properties>
    </cxf:cxfEndpoint>
    <bean id="jaxB" class="org.apache.camel.model.dataformat.JaxbDataFormat">
        <property name="prettyPrint" value="true" />
        <property name="contextPath" value="com.type.card" />
    </bean>
    <camelContext id="endpoint-card-cxf" xmlns="http://camel.apache.org/schema/blueprint">
        <route id="endpoint-soap-in">
            <from uri="cxf:bean:cardEndpoint"/>
            <transform>
                <simple>${body[0]}</simple>
            </transform>
            <marshal ref="jaxB"/>
            <setHeader headerName="JMSType">
                <simple>${headers.operationName}</simple>
            </setHeader>
            <to uri="amq:q.in"/>
        </route>
        <route id="endpoint-soap-out">
            <from uri="amq:q.out" />
            <unmarshal ref="jaxB" />
            <!-- STUCK HERE :( -->
        </route>
    </camelContext>
</blueprint>

服务处理器蓝图：

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0"
           xsi:schemaLocation="
             http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
             http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0 http://aries.apache.org/schemas/blueprint-cm/blueprint-cm-1.0.0.xsd
             http://camel.apache.org/schema/blueprint http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">
    <bean id="cardService" class="com.card.impl.DefaultCardService">
        <argument>
            <reference interface="com.base.StashService"/>
        </argument>
    </bean>
    <service interface="com.card.CardService" ref="cardService" />
    <bean id="amqCardServiceEndpoint" class="com.card.endpoint.AmqCardEndpoint">
        <argument ref="cardService" />
    </bean>
    <bean id="jaxB" class="org.apache.camel.model.dataformat.JaxbDataFormat">
        <property name="prettyPrint" value="true" />
        <property name="contextPath" value="com.type.base:com.type.card" />
    </bean>
    <camelContext id="service-card-cx" xmlns="http://camel.apache.org/schema/blueprint">
        <route id="card-rq-broker">
            <from uri="amq:queue:q.in?asyncConsumer=true" />
            <unmarshal ref="jaxB" />
            <doTry>
                <bean ref="amqCardServiceEndpoint" method="invoke" />
                <doCatch>
                    <exception>com.type.base.BaseException</exception>
                    <setBody>
                        <simple>${exception.getFaultInfo()}</simple>
                    </setBody>
                </doCatch>
            </doTry>
            <marshal ref="jaxB" />
            <to uri="amq:q.out" />
        </route>
    </camelContext>
</blueprint>

任何帮助或建议？

答案

使用jmsReplyTo指定回复队列的名称（如果需要固定队列名称），Camel应该使用它来监听响应。在Camel JMS文档中查看有关请求/回复的更多信息。

<to uri="amq:q.in?jmsReplyTo=q.out"/>
// continue here when reply is back

• http://camel.apache.org/jms