消息推送系统

import threading

import queue

class MessageCenter:

走班排课系统源码

def __init__(self):

self.queue = queue.Queue()

def publish(self, message):

self.queue.put(message)

def start(self):

while True:

msg = self.queue.get()

print(f"消息中台接收到: {msg}")

if __name__ == "__main__":

center = MessageCenter()

thread = threading.Thread(target=center.start)

thread.start()

center.publish("用户注册请求")

class UserModule:

def handle_message(self, message):

if "注册" in message:

print("用户管理模块处理注册请求")

if __name__ == "__main__":

user_module = UserModule()

# 假设这里有一个机制来接收消息中台的输出

user_module.handle_message("用户注册请求")