统一消息系统

小明：最近学校的信息系统总是出问题，学生们的通知经常收不到。

小李：是啊，我觉得应该引入一个统一的消息系统，把所有通知都集中管理。

小明：那是什么？我好像没听说过。

小李：统一消息系统是一种集中的消息处理平台，可以接收、存储和分发各种类型的消息。比如考试通知、成绩发布、课程提醒等等。

小明：听起来不错，那怎么实现呢？

小李：我们可以用消息队列技术，比如RabbitMQ或者Kafka。它们可以保证消息的可靠传递。

小明：那具体的代码是怎么写的？

学生管理系统

小李：举个例子，我们用Java来写一个发送消息的类：

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

    public class MessageSender {
        private final static String QUEUE_NAME = "student_notifications";

        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 = "你的成绩已发布，请登录系统查看！";
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
            System.out.println(" [x] Sent '" + message + "'");
            channel.close();
            connection.close();
        }
    }
    

小明：那接收端呢？

小李：同样用Java编写，监听队列并处理消息：

    import com.rabbitmq.client.*;

    public class MessageReceiver {
        private final static String QUEUE_NAME = "student_notifications";

        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 -> {});
        }
    }
    

小明：这样就能确保学生及时收到通知了！

小李：没错，统一消息系统不仅提升了效率，也提高了系统的可维护性和扩展性。