基于WSO2与RabbitMQ，发送消息至队列后如何返回客户端同步响应？

结论：可以实现发送消息到RabbitMQ队列后向客户端返回同步响应，以下是具体实现方案和配置调整：

问题分析 #

你当前的代理配置中设置了OUT_ONLY=true和FORCE_SC_ACCEPTED=true，这是典型的单向消息传递模式：WSO2会直接返回202 Accepted给客户端，不会等待RabbitMQ端的响应。要实现同步响应，需要切换为请求-响应模式。

实现步骤 #

1. 修改代理配置 #

移除OUT_ONLY和FORCE_SC_ACCEPTED属性，同时完善outSequence用于接收并返回响应给客户端：

<proxy name="VssService" startOnLoad="true" transports="http https" xmlns="http://ws.apache.org/ns/synapse">
    <target>
        <inSequence>
            <log description="LOG REQUEST" level="full"/>
            <!-- 移除单向模式相关属性，启用请求-响应模式 -->
            <send>
               <endpoint key="VssEP"/>
            </send>   
        </inSequence>
        <outSequence>
            <log description="LOG RESPONSE" level="full"/>
            <!-- 将RabbitMQ返回的响应转发给客户端 -->
            <send/>
        </outSequence>
        <faultSequence>
            <log description="LOG FAULT" level="full"/>
            <send/>
        </faultSequence>
    </target>
</proxy>

2. 配置RabbitMQ请求-响应端点 #

在端点配置中启用请求-响应模式，指定回复队列（可使用固定队列或WSO2自动创建的临时队列），示例配置如下：

<endpoint name="VssEP">
    <address uri="rabbitmq:/VssEP?rabbitmq.server.host.name=localhost&amp;rabbitmq.server.port=5672&amp;rabbitmq.server.user.name=guest&amp;rabbitmq.server.password=guest&amp;rabbitmq.queue.name=request_queue&amp;rabbitmq.exchange.name=amq.direct&amp;rabbitmq.queue.routing.key=request_key&amp;rabbitmq.replyToQueueName=response_queue&amp;rabbitmq.request.response.mode=true"/>
</endpoint>

关键参数说明：

• rabbitmq.request.response.mode=true：开启请求-响应模式
• rabbitmq.replyToQueueName=response_queue：指定后端服务回复消息的目标队列（若不指定，WSO2会自动创建临时队列并通过消息头传递replyTo信息）
• 若使用临时队列，无需手动创建，WSO2会自动管理队列的生命周期

3. 后端服务配合 #

消费RabbitMQ消息的后端服务需要：

• 从request_queue接收请求消息
• 处理完成后，将响应消息发送到replyTo字段指定的队列（固定队列直接发送到配置的队列；临时队列则读取消息头中的replyTo值）

注意事项 #

• 确保RabbitMQ服务器与WSO2网络连通，所需队列、交换器已正确创建
• 可通过rabbitmq.request.response.timeout参数设置超时时间，避免客户端无限等待
• 若后端服务处理耗时较长，需合理调整WSO2的超时配置，防止请求提前中断

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