RabbitMQ的SpringAMQP的各种模式的案例-Toy模板网

这篇具有很好参考价值的文章主要介绍了RabbitMQ的SpringAMQP的各种模式的案例。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

Basic Queue 简单队列模型

任务模型（Work queues，也被称为（Task queues））

发布/订阅的广播（Fanout）模式

发布/订阅的定向（Direct）模式

发布订阅的通配（Topic）模式

导入依赖

RabbitMQ的SpringAMQP的各种模式的案例

配置yml

Basic Queue 简单队列模型

RabbitMQ的SpringAMQP的各种模式的案例

消息发送

RabbitMQ的SpringAMQP的各种模式的案例

消息接收

RabbitMQ的SpringAMQP的各种模式的案例

任务模型（Work queues，也被称为（Task queues））

RabbitMQ的SpringAMQP的各种模式的案例

消息发送

RabbitMQ的SpringAMQP的各种模式的案例

消息接收

RabbitMQ的SpringAMQP的各种模式的案例

发布/订阅的广播（Fanout）模式

RabbitMQ的SpringAMQP的各种模式的案例

交换机


@Configuration
public class FanoutConfig {
    /**
     * 声明交换机
     * @return Fanout类型交换机
     */
    @Bean
    public FanoutExchange fanoutExchange(){
        return new FanoutExchange("itcast.fanout");
    }
    /**
     * 第1个队列
     */
    @Bean
    public Queue fanoutQueue1(){
        return new Queue("fanout.queue1");
    }
    /**
     * 绑定队列和交换机
     */
    @Bean
    public Binding bindingQueue1(Queue fanoutQueue1, FanoutExchange fanoutExchange){
        return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);
    }
    /**
     * 第2个队列
     */
    @Bean
    public Queue fanoutQueue2(){
        return new Queue("fanout.queue2");
    }
    /**
     * 绑定队列和交换机
     */
    @Bean
    public Binding bindingQueue2(Queue fanoutQueue2, FanoutExchange fanoutExchange){
        return BindingBuilder.bind(fanoutQueue2).to(fanoutExchange);
    }
}

消息发送

RabbitMQ的SpringAMQP的各种模式的案例