小李：老王，最近学校要建设一个融合服务门户，听说还能集成统一消息功能？

老王：没错！融合服务门户可以整合各种信息服务，比如公告通知、课程提醒等。统一消息功能能让师生在一个平台上接收所有信息。

小李：听起来很厉害，那我们从哪里开始呢？

老王：首先得有一个消息队列系统，比如使用RabbitMQ来管理消息传递。我先给你看看配置文件：

      <?xml version="1.0" encoding="UTF-8"?>
      <configuration>
        <rabbitmq>
          <host>localhost</host>
          <port>5672</port>
          <username>guest</username>
          <password>guest</password>
        </rabbitmq>
      </configuration>
    

小李：这是配置文件啊，那怎么发送消息呢？

老王：我们可以用Python编写一个简单的脚本发送消息。例如：

      import pika

      def send_message(message):
          connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
          channel = connection.channel()
          channel.queue_declare(queue='unified_messages')
          channel.basic_publish(exchange='', routing_key='unified_messages', body=message)
          print(f"Sent message: {message}")
          connection.close()

      if __name__ == "__main__":
          send_message("欢迎来到农业大学！")
    

小李：这个脚本看起来挺简单的，那接收消息呢？

老王：同样用Python编写接收端：

      import pika

      def callback(ch, method, properties, body):
          print(f"Received message: {body.decode()}")

      def receive_messages():
          connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
          channel = connection.channel()
          channel.queue_declare(queue='unified_messages')
          channel.basic_consume(queue='unified_messages', on_message_callback=callback, auto_ack=True)
          print('Waiting for messages...')
          channel.start_consuming()

      if __name__ == "__main__":
          receive_messages()
    

小李：太棒了！这样就能实现实时的消息推送了。

老王：是的，接下来可以将这些功能集成到学校的融合服务门户中，让每位师生都能方便地获取信息。

]]>