Camel RabbitMQ 请求响应模式示例

Question

我正在寻找使用 Camel RabbitMQ 请求响应模式的示例代码。

我的用例： - 请求消息存放在 RabbitMQ 队列中 - Camel 路由使用消息，调用外部 Web 服务，并根据消息的回复属性回复响应

我也使用 Spring AMQP 实现这个用例，但我也想用 Camel RabbitMQ 来实现。

骆驼文档：http://camel.apache.org/rabbitmq.html

感谢您的帮助。

阿尔诺

Answer 1

我找到了解决方案：

Camel RabbitMQ Reply-To 功能将出现在下一个 Camel Release 2.15 中。

比照。 https://issues.apache.org/jira/browse/CAMEL-7860

阿尔诺

Answer 2

这是一个HTTP代理的简单例子。 HTTP 请求通过 Rabbit MQ，HTTP 响应返回给 Rabbit MQ。

在 camel 2.17.1 上编写的示例（camel-core、camel-netty4-http、camel-rabbitmq）

示例调用：

curl -H "proxy_url:http://remotehost:port/uri" 127.0.0.1

    context.addRoutes(new RouteBuilder() {

        @Override
        public void configure() throws Exception {

            from("netty4-http:localhost:80").
                    to("rabbitmq://localhost:5672/async");

            from("rabbitmq://localhost:5672/async").
                    process(exchange -> {

                        // for return not only 200 HTTP STATUS
                        String techParams = "throwExceptionOnFailure=false";
                        String proxyUrl = (String) exchange.getIn().getHeader("proxy_url");

                        proxyUrl = proxyUrl.contains("?") && proxyUrl.contains("=") 
                                ? proxyUrl + "&" + techParams : proxyUrl + "?" + techParams;
                        exchange.getIn().setHeader("proxy_url", proxyUrl);

                        exchange.setProperty(RabbitMQConstants.CORRELATIONID, 
                                exchange.getIn().getHeader(RabbitMQConstants.CORRELATIONID));

                    }).
                    toD("netty4-http:${header.proxy_url}").
                    process(exchange -> {
                        exchange.getIn().setHeader(RabbitMQConstants.CORRELATIONID, exchange.getProperty(RabbitMQConstants.CORRELATIONID));
                    });
        }

    });

Camel RabbitMQ 请求响应模式示例

Camel RabbitMQ Request Response Pattern Example

design-patterns

response

request

apache-camel

rabbitmq