消息推送系统

小明：最近我在研究一个统一消息系统，想看看有没有开源的项目可以参考。

小李：你是不是在找类似RabbitMQ或者Kafka这样的消息中间件？它们都是开源的，而且社区活跃。

统一登录认证

小明：对，但我想自己实现一个轻量级的。你能给我看个例子吗？

小李：当然可以，我给你写一段Python代码，用简单的队列来模拟消息传递。

小明：那太好了，我可以在这个基础上继续扩展。

小李：

    import threading
    import queue

    class MessageQueue:
        def __init__(self):
            self.queue = queue.Queue()

        def send(self, message):
            self.queue.put(message)
            print(f"发送消息: {message}")

        def receive(self):
            message = self.queue.get()
            print(f"接收消息: {message}")
            return message

    def producer(queue):
        for i in range(5):
            queue.send(f"消息{i}")

    def consumer(queue):
        for _ in range(5):
            queue.receive()

    if __name__ == "__main__":
        mq = MessageQueue()
        t1 = threading.Thread(target=producer, args=(mq,))
        t2 = threading.Thread(target=consumer, args=(mq,))
        t1.start()
        t2.start()
        t1.join()
        t2.join()
    

小明：这段代码看起来不错，但我还想让它支持多种消息类型。

小李：你可以考虑使用JSON格式来封装消息内容，这样更灵活。

小明：明白了，我打算把这个项目申请软著证书，确保我的知识产权。

小李：没错，开源并不意味着放弃版权，申请软著证书能更好地保护你的成果。

小明：谢谢你的帮助，我现在更有信心了。