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(交换机名称, 交换机类型);
