小明：嘿，小李，我们公司现在消息推送太分散了，每个模块都自己发消息，管理起来很麻烦。

小李：是啊，我最近也在考虑这个问题。有没有想过用统一的消息推送系统？

小明：统一消息推送？听起来不错，怎么实现呢？

小李：我们可以用消息队列，比如RabbitMQ或者Kafka。这样所有模块都往同一个地方发消息，再由统一的服务来处理和发送。

小明：那具体怎么做呢？有没有示例代码？

小李：我可以给你一个简单的例子。比如使用RabbitMQ，先安装好服务，然后写一个生产者和消费者。

小明：好的，那我先看看代码。

小李：这是生产者的代码：

    import com.rabbitmq.client.ConnectionFactory;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.Channel;

    public class Producer {
        private final static String QUEUE_NAME = "notification_queue";

        public static void main(String[] argv) throws Exception {
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel();

            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            String message = "Hello, this is a notification!";
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
            System.out.println(" [x] Sent '" + message + "'");
            channel.close();
            connection.close();
        }
    }
    

小明：这个是消费者的代码：

    import com.rabbitmq.client.*;

    public class Consumer {
        private final static String QUEUE_NAME = "notification_queue";

        public static void main(String[] argv) throws Exception {
            ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel();

            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            DeliverCallback deliverCallback = (consumerTag, delivery) -> {
                String message = new String(delivery.getBody(), "UTF-8");
                System.out.println(" [x] Received '" + message + "'");
            };

            channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> {});
        }
    }
    

小明：明白了，这样以后所有模块都可以通过这个统一的队列发送消息，方便管理。

小李：没错，这就是统一消息推送的优势。而且可以扩展，比如支持多种消息类型、优先级等。

小明：看来我们公司真的需要这样一个系统了。

小李：是的，接下来我们可以设计一个统一的消息服务模块，集成到现有的系统中。