入站和出站网关 AMQP 注释

Question

我有一个使用 xml 配置的工作 spring 集成 + rabbitmq 应用程序。现在，我将它们转换为 java config 注释。一些主要的 amqp 对象（如 Queue、TopicExchange 和 Binding）有可用的类和 java 注释。但是，在将 inbound-gateway 和 outbound-gateway 转换为 java 注释或类实现时，我找不到任何参考。

这是我的实现： // 网关.xml

<int-amqp:outbound-gateway request-channel="requestChannel" reply-channel="responseChannel" exchange-name="${exchange}" routing-key-expression="${routing}"/>


<int-amqp:inbound-gateway request-channel="inboundRequest"
    queue-names="${queue}" connection-factory="rabbitConnectionFactory"
    reply-channel="inboundResponse" message-converter="compositeMessageConverter"/>

是否可以将它们转换为java注解或类实现（bean等）？

补充：我目前正在使用spring boot + spring integration。

Answer 1

如果你看看Spring Integration Java DSL，那就太好了。

它为 AMQP 提供了一些流畅性：

@Bean
public IntegrationFlow amqpFlow() {
     return IntegrationFlows.from(Amqp.inboundGateway(this.rabbitConnectionFactory, queue()))
           .transform("hello "::concat)
           .transform(String.class, String::toUpperCase)
           .get();
}

@Bean
public IntegrationFlow amqpOutboundFlow() {
       return IntegrationFlows.from(Amqp.channel("amqpOutboundInput", this.rabbitConnectionFactory))
               .handle(Amqp.outboundAdapter(this.amqpTemplate).routingKeyExpression("headers.routingKey"))
               .get();
}

从注解的角度来看，您应该直接使用 Spring Integration 中的类来配置类似的东西：

@Bean
public AmqpInboundGateway amqpInbound() {
    AmqpInboundGateway gateway = new AmqpInboundGateway(new SimpleMessageListenerContainer(this.rabbitConnectionFactory));
    gateway.setRequestChannel(inboundChanne());
    return gateway;
}

@Bean
@ServiceActivator(inputChannel = "amqpOutboundChannel")
public AmqpOutboundEndpoint amqpOutbound() {
    AmqpOutboundEndpoint handler = new AmqpOutboundEndpoint(this.rabbitTemplate);
    handler.setOutputChannel(amqpReplyChannel());
    return handler;
}