如何拦截Spring Cloud Stream消息？

Question

Spring允许拦截许多产品的消息,比如RestTemplate和SpringMVC.是否可以拦截Spring Cloud Stream消息？对于传入和传出消息.

Answer 1

能够使用GlobalChannelInterceptor注释和ChannelInterceptor界面拦截入站和出站的Spring Cloud Stream消息.见下面的示例.

import org.springframework.integration.config.GlobalChannelInterceptor;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.support.ChannelInterceptor;
import org.springframework.stereotype.Component;

@Component
@GlobalChannelInterceptor
public class Interceptor implements ChannelInterceptor {

    private final Logger log = LoggerFactory.getLogger(Interceptor.class);

    @Override
    public Message<?> preSend(Message<?> msg, MessageChannel mc) {
        log.info("In preSend");
        return msg;
    }

    @Override
    public void postSend(Message<?> msg, MessageChannel mc, boolean bln) {
        log.info("In postSend");
    }

    @Override
    public void afterSendCompletion(Message<?> msg, MessageChannel mc, boolean bln, Exception excptn) {
        log.info("In afterSendCompletion");
    }

    @Override
    public boolean preReceive(MessageChannel mc) {
        log.info("In preReceive");
        return true;
    }

    @Override
    public Message<?> postReceive(Message<?> msg, MessageChannel mc) {
        log.info("In postReceive");
        return msg;
    }

    @Override
    public void afterReceiveCompletion(Message<?> msg, MessageChannel mc, Exception excptn) {
        log.info("In afterReceiveCompletion");
    }

}

Answer 2

不确定这里的拦截是什么意思 - 你给出的两个例子都不是基于消息的:)。

但是您想要访问完整的消息，您可以将其用作@StreamListeneror@ServiceActivator注释方法的参数。此外，Spring Cloud Stream 允许您设置完整的 Spring Integration 管道，因此您可以添加建议和所需的一切 - 请参阅此处： https: //github.com/spring-projects/spring-integration-java-dsl/wiki /Spring-Integration-Java-DSL-Reference。

我鼓励您也看看 Spring Integration 参考http://docs.spring.io/autorepo/docs/spring-integration/4.2.6.RELEASE/reference/html/。Spring Cloud Stream 自动注入通道，从那里您可以完全自由地构建管道。

希望这有帮助，马吕斯