SpringMQ的使用

文章目录

• SpringMQ的使用
• • 1、windows安装
  • 2、添加依赖：
  • 3、增加rabbit的配置：
  • 4、最简单的测试：publisher—>MQ–>consumer
  • • 4.1、建立连接配置：
    • 4.2、发送端：建立连接，获取通道，创建队列，准备消息，发送消息到队列：
    • 4.3 、接收端：建立连接，获取通道，声明队列，申请队列的一个消费者（内含监听消息的方法），在通道线路上接收消息。
  • 4.4 消息接收的手动确认：
  • 5、work消息模型
  • • 5.1 消息发送：
    • 5.2 消息接收：
  • 6、订阅模型分类：
  • • • 6.1 fanout：也就是交换机广播消息
      • • 6.1.1 发送消息：建立连接，获取通道，声明交换机，发送消息到交换机
        • 6.1.2 接受消息：建立连接，获取通道，声明队列，绑定到交换机，定义消费者（包含监听），监听通道。
      • 6.2 direct：相当于定向投放
      • • 6.2.1 发送消息: 交换机类型指定为direct，发送消息时指定routing key
        • 6.2.2 接收消息: 获取通道，声明队列，绑定交换机，指定routing key
      • 6.3 Topic：交换机采用通配符的方式和队列匹配
      • • 6.3.1 发送消息: 指定交换机类型，发送消息携带route key
        • 6.3.2 接收消息: 声明队列，绑定交换机携带带通配符的route key
    • 7、持久化
    • • 7.1 交换机持久化
      • 7.2 队列持久化
      • 7.3 消息持久化
    • 8、spring和MQ整合
    • • 8.1 设置接收消息的监听器: 通过注解@RabbitListener实现，绑定队列，交换机，和route-key
      • 8.2接收消息：通过AmqpTemplate实现

SpringMQ的使用

1、windows安装

安装erlang，配置环境变量，安装rabbitmq-server

访问：http://localhost:15672/

2、添加依赖：

3、增加rabbit的配置：

4、最简单的测试：publisher—>MQ–>consumer

4.1、建立连接配置：

4.2、发送端：建立连接，获取通道，创建队列，准备消息，发送消息到队列：

4.3 、接收端：建立连接，获取通道，声明队列，申请队列的一个消费者（内含监听消息的方法），在通道线路上接收消息。

4.4 消息接收的手动确认：

5、work消息模型

5.1 消息发送：

public class Send {    private final static String QUEUE_NAME = "test_work_queue";    public static void main(String[] argv) throws Exception {// 获取到连接Connection connection = ConnectionUtil.getConnection();// 获取通道Channel channel = connection.createChannel();// 声明队列channel.queueDeclare(QUEUE_NAME, false, false, false, null);
声明：本站部分文章及图片源自用户投稿，如本站任何资料有侵权请您尽早请联系jinwei@zod.com.cn进行处理,非常感谢！