RabbitMQ_x-queue-type:classic

1.
@Configuration
public class RabbitConfig {
    /**
     * 定义一个交换器 exchange ：DirectExchange  直连交换机 ， 精确匹配
     *
     * @return
     */
    @Bean
    public DirectExchange dExchange() {
        //创建一个直连的交换器
        return new DirectExchange("dExchange");
    }
    /**
     * **创建一个队列**，合规队列是用来存放exchange路由过来的消息
     *
     * @return
     */
    @Bean
    public Queue cart() {
        Map args = new HashMap();
        args.put("x-queue-type", "classic");
        return new Queue("cart", true,false,false,args); // true表示持久化该队列
    }

    /**
     * 建立起关系，  交换机 + 队列  绑定起来
     *
     * @param cart
     * @param dExchange
     * @return
     */
    @Bean
    public Binding bindingDirctExchangeCart(Queue cart, DirectExchange dExchange) {
        return BindingBuilder.bind(cart).to(dExchange).with("cart");
    }

    /**
     * **创建一个队列**，合规队列是用来存放exchange路由过来的消息
     *
     * @return
     */
    @Bean
    public Queue order() {
        Map args = new HashMap();
        args.put("x-queue-type", "classic");
        return new Queue("order", true,false,false,args); // true表示持久化该队列
    }

    /**
     * 建立起关系，  交换机 + 队列  绑定起来
     *
     * @param order
     * @param dExchange
     * @return
     */
    @Bean
    public Binding bindingDirctExchangeOrder(Queue order, DirectExchange dExchange) {
        return BindingBuilder.bind(order).to(dExchange).with("order");
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

1.创建好队列后
2.进入队列
3.出队列

例如:支付宝支付完订单后 需要回调