统一消息系统

在当今的信息时代，消息传递系统在各种应用中扮演着至关重要的角色。为了提高系统的可维护性和扩展性，采用统一的消息处理框架变得尤为重要。Python作为一种高级编程语言，因其简洁的语法和强大的库支持，在实现此类系统时具有明显的优势。

本篇文章将介绍如何使用Python来构建一个简单的统一消息处理系统。该系统能够接收来自不同来源的消息，并根据预设规则进行处理，最终将处理后的消息发送出去。我们将从消息的接收开始，到处理逻辑的设计，再到消息的发送，一步步展示整个流程。

首先，我们定义一个基本的消息类`Message`，用于封装消息内容及其元数据。

        class Message:
            def __init__(self, content, source):
                self.content = content
                self.source = source
        

接下来，创建一个消息处理中心`MessageCenter`，它负责接收消息并调用相应的处理函数。

        class MessageCenter:
            def __init__(self):
                self.handlers = {}

            def register_handler(self, message_type, handler_function):
                if message_type not in self.handlers:
                    self.handlers[message_type] = []
                self.handlers[message_type].append(handler_function)

            def process_message(self, message):
                handlers = self.handlers.get(message.source, [])
                for handler in handlers:
                    handler(message)
        

最后，定义几个简单的处理函数，并注册到`MessageCenter`中。

        def handle_email(message):
            print(f"Handling email from {message.source}: {message.content}")

        def handle_sms(message):
            print(f"Handling SMS from {message.source}: {message.content}")

        # 实例化消息中心
        center = MessageCenter()
        # 注册处理函数
        center.register_handler('email', handle_email)
        center.register_handler('sms', handle_sms)

        # 创建并发送消息
        email_msg = Message("Hello, this is an email.", "email")
        sms_msg = Message("Hello, this is an SMS.", "sms")

        center.process_message(email_msg)
        center.process_message(sms_msg)