从不知道到了解—RabbitMQ 基础概念及 Spring 的配置和使用

原理同上

  • 请求地址:http://localhost:8080/home?type=3&routing_key=myO.pay.phbj&message=65
    打印:

    原理同上

  • 请求地址:http://localhost:8080/home?type=3&routing_key=myO.pay.phbj&message=65
    打印:

    这里 routing_key 匹配到了*.pay.phbj,所以发送到 queue 中并由 queue 的 Consumer 接收

  • 请求地址:http://localhost:8080/home?type=3&routing_key=myO.log.phbj&message=65
    打印:

    这里 routing_key 匹配到了*.log.phbj,所以发送到 queue2 中并由 queue2 的 Consumer 接收

  • confirmCallback 和 returnCallback

    接下来我们来看一组请求:
    请求地址:http://localhost:8080/home?type=3&touting_key=myO.l2og.phbj&message=65
    看这组请求,我们知道是调用 amqpTemplate3 来发送的,但是并没有 binding-key 与之对应,所以这个 Message 发送到 Exchange 之后 Exchange 不知道该交给哪个 Queue。但是由于我们设置了

    接收到了。然后再去看 RabbitMQ 的网页控制端:http://192.168.1.198:15672

    queue 中累计了三条消息,而这三条消息已经是处理过的,如果有消息不停的进入,结果就是堆满内存

    这是最需要注意的一点

    都是自己在实际了解学习过程中遇到的一些问题以及感悟,看了很多博客,感谢各位大牛。
    有错误请指出,望不吝赐教。

    RabbitMQ-Dem

    05-11 13:29