public class ReceiveLogs01 {
    private static final String EXCHANGE_NAME = "logs";
    public static void main(String[] argv) throws Exception {
        Channel channel = RabbitUtils.getChannel();
        channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
        /**
        * 生成一个临时的队列 队列的名称是随机的
        * 当消费者断开和该队列的连接时 队列自动删除
        */
        String queueName = channel.queueDeclare().getQueue();
        //把该临时队列绑定我们的 exchange 其中 routingkey(也称之为 binding key)为空字符串
        channel.queueBind(queueName, EXCHANGE_NAME, "");
        System.out.println("等待接收消息,把接收到的消息打印在屏幕.....");
        DeliverCallback deliverCallback = (consumerTag, delivery) -> {
            String message = new String(delivery.getBody(), "UTF-8");
            System.out.println("控制台打印接收到的消息"+message);
        };
        channel.basicConsume(queueName, true, deliverCallback, consumerTag -> { });
    }
}

public class ReceiveLogs02 {
    private static final String EXCHANGE_NAME = "logs";
    public static void main(String[] argv) throws Exception {
        Channel channel = RabbitUtils.getChannel();
        channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
        /**
        * 生成一个临时的队列 队列的名称是随机的
        * 当消费者断开和该队列的连接时 队列自动删除
        */
        String queueName = channel.queueDeclare().getQueue();
        //把该临时队列绑定我们的 exchange 其中 routingkey(也称之为 binding key)为空字符串
        channel.queueBind(queueName, EXCHANGE_NAME, "");
        System.out.println("等待接收消息,把接收到的消息写到文件.....");
        DeliverCallback deliverCallback = (consumerTag, delivery) -> {
            String message = new String(delivery.getBody(), "UTF-8");
            File file = new File("C:\\work\\rabbitmq_info.txt");
            FileUtils.writeStringToFile(file,message,"UTF-8");
            System.out.println("数据写入文件成功");
        };
        channel.basicConsume(queueName, true, deliverCallback, consumerTag -> { });
    }
}

public class EmitLog {
 private static final String EXCHANGE_NAME = "logs";
 public static void main(String[] argv) throws Exception {
 try (Channel channel = RabbitUtils.getChannel()) {
 /**
 * 声明一个 exchange
 * 1.exchange 的名称
 * 2.exchange 的类型
 */
 channel.exchangeDeclare(EXCHANGE_NAME, "fanout");
 Scanner sc = new Scanner(System.in);
 System.out.println("请输入信息");
 while (sc.hasNext()) {
 String message = sc.nextLine();
 channel.basicPublish(EXCHANGE_NAME, "", null, message.getBytes("UTF-8"));
 System.out.println("生产者发出消息" + message);
 }
 }
 }
}

public class ReceiveLogsDirect01 {
 private static final String EXCHANGE_NAME = "direct_logs";
 public static void main(String[] argv) throws Exception {
 Channel channel = RabbitUtils.getChannel();
 channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.DIRECT);
 String queueName = "disk";
 channel.queueDeclare(queueName, false, false, false, null);//队列
 channel.queueBind(queueName, EXCHANGE_NAME, "error");//绑定
 System.out.println("等待接收消息.....");
 DeliverCallback deliverCallback = (consumerTag, delivery) -> {
 String message = new String(delivery.getBody(), "UTF-8");
 message="接收绑定键:"+delivery.getEnvelope().getRoutingKey()+",消息:"+message;
 File file = new File("d:\\work\\rabbitmq_info.txt");
 FileUtils.writeStringToFile(file,message,"UTF-8");
 System.out.println("错误日志已经接收");
 };
 channel.basicConsume(queueName, true, deliverCallback, consumerTag -> {
 });
 }
} 

public class EmitLogTopic {
 private static final String EXCHANGE_NAME = "topic_logs";
 public static void main(String[] argv) throws Exception {
 try (Channel channel = RabbitUtils.getChannel()) {
 channel.exchangeDeclare(EXCHANGE_NAME, "topic");
 /**
 * Q1-->绑定的是
 * 中间带 orange 带 3 个单词的字符串(*.orange.*)
 * Q2-->绑定的是
 * 最后一个单词是 rabbit 的 3 个单词(*.*.rabbit)
 * 第一个单词是 lazy 的多个单词(lazy.#)
 */
 Map<String, String> bindingKeyMap = new HashMap<>();
 bindingKeyMap.put("quick.orange.rabbit","被队列 Q1Q2 接收到");
 bindingKeyMap.put("lazy.orange.elephant","被队列 Q1Q2 接收到");
 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.orange.male.rabbit","是四个单词但匹配 Q2");
 for (Map.Entry<String, String> bindingKeyEntry: bindingKeyMap.entrySet()){
     String bindingKey = bindingKeyEntry.getKey();
     String message = bindingKeyEntry.getValue();
     channel.basicPublish(EXCHANGE_NAME,bindingKey, null, 
     message.getBytes("UTF-8"));
     System.out.println("生产者发出消息" + message);
 }
 }
 }
}