RabbitMQ Common Method

Common Method

1. 常见信道三大步骤

后期可以封装成一个工具类进行调用

 //创建连接工厂
 ConnectionFactory factory = new ConnectionFactory();
 factory.setHost(IP地址);
 factory.setUsername(RabbitMQ用户名);
 factory.setPassword(RabbitMQ密码);
 //创建链接
 Connection connection = factory.newConnection();
 //创建信道
 Channel channel = connection.createChannel();

2. basicConsume接收消息

消费者

//声明接收消息回调函数
DeliverCallback deliverCallback = (consumerTag,message) ->{
    System.out.println("接收到的消息" + new String(message.getBody()));//打印接收到的消息
};
//取消消息回调函数
CancelCallback cancelCallback = consumerTag ->{
    System.out.println("消费被中断00");
};
 /**
    * 消费者接收消息method参数介绍
     * 1.消费哪个队列队列名称
     * 2.消费成功之后是否要自动应答 true 代表的是自动应答 false 手动应答
     * 3.消费者未成功消费的回调
     * 4.消费者取消消费的回调
     * **/
channel.basicConsume(队列名称,是否手或自动应答,deliverCallback,cancelCallback);

3.queueDeclare声明队列

发送消息第一步创建连接工厂第二步创建队列

/**
 * 生成一个队列
 * 1.队列名称
 * 2.队列里面的消息是否持久化(磁盘) 默认情况消息存储在内存中(true表示持久化)
 * 3.该队列是否只提供一个消费者进行消费 是否键消息共享true:可以多个消费者消费 false:只能一个消费者消费
 * 4.是否自动删除最后一个消费者端开连接以后 该队列是否自动删除 true:自动删除 false:不自动删除
 * **/
//channel.queueDeclare(QUEUE_NAME,false,false,false,null);
//语法
channel.queueDeclare(队列名称,是否持久化,是否消息共享,断开连接后是否自动删除,是否有其它设置);

4.basicPublish发送消息

//消息主体
String message = "hello world";//初次使用
 /**
  * 1.发送到哪个交换机
  * 2.路由的key值是哪个 本次是队列名称
  * 3.其它参数信息
  * 4.发送消息的消息体
  * **/
 //channel.basicPublish("",QUEUE_NAME,null,message.getBytes());
 //语法
 channel.basicPublish(交换机名称,队列名称,其它参数,消息主体);
 System.out.println("消息已成功发送");//发送成功后提示

使用HashMap方式发送消息
增强for循环fori

Map<String,String> bindingKeyMap =new HashMap<>();
bindingKeyMap.put("quick.orange.rabbit","被队列Q1Q2接收到");//
bindingKeyMap.put("lazy.orange.elephant","被队列0102接收创");//
bindingKeyMap.put("quick.orange.fox","被队列Q1接收到");//
bindingKeyMap.put("lazy.brown.fox","被队列Q2接收到");//
bindingKeyMap.put("lazy.pink.rabbit","虽然满足两个绑定但只被队列Q2接收一次");//
bindingKeyMap.put("quick.brown.fox","不匹配任何绑定不会被任何队列接收到会被丢弃");//
bindingKeyMap.put("quick.orange.male.rabbit","是四个单词不匹配任何绑定会被丢弃");//
bindingKeyMap.put("lazy.orangc.malc.rabbit","是四个单词但匹配Q2");//
for (Map.Entry<String, String> stringStringEntry : bindingKeyMap.entrySet()) {
   String key = stringStringEntry.getKey();
   String value = stringStringEntry.getValue();
   channel.basicPublish(EXCHANGE_NAME,key,null,value.getBytes(StandardCharsets.UTF_8));
   System.out.println("生产者发出消息"+value);
   }

5.basicQos设置预取值 不公平分发

rabbitMQ当一条消息同时发送到多个队列中默认会采用LB轮询机制默认为0采用轮训机制

channel.basicQos(2);

6.UUID自动生成唯一队列名称

//声明队列
String queueName = UUID.randomUUID().toString();

7.confirmSelect开启发布确认

//开启发布确认
channel.confirmSelect();

8.queueDeclare().getQueue()声明临时队列

//声明一个 临时队列
/*
 * 生成一个临时队列队列名称是随机的
 * 当消费者断开与队列的连接后队列就自动删除
 * */
 String queue = channel.queueDeclare().getQueue();

9.queueBind绑定交换机与队列

//channel.queueBind(queue,EXCHANGE_NAME,"");
//语法
channel.queueBind(队列名称,交换机名称,"");

11.exchangeDeclare声明并设置交换机类型

//channel.exchangeDeclare(NORMAL_EXCHANGE, BuiltinExchangeType.DIRECT);
//语法direct为主体交换机
channel.exchangeDeclare(交换机名称, 交换机类型);