RabbitMQ消息监听（多种模式-fanout/topic）

134 阅读 0 评论 89 点赞

我是靠谱客的博主冷静蜜粉，最近开发中收集的这篇文章主要介绍RabbitMQ消息监听（多种模式-fanout/topic），觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

1.rabbitmq消息监听，兼容多种模式的消息，fanout/topic等模式

MQ消息配置监听：

package com.test.ddyin.conf;

import java.util.HashMap;
import java.util.List;
import java.util.function.Predicate;
import java.util.stream.Collectors;

import org.apache.poi.ss.formula.functions.T;
import org.springframework.amqp.core.AbstractExchange;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.Binding.DestinationType;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Exchange;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
import org.springframework.amqp.rabbit.listener.adapter.MessageListenerAd