介绍

• 支持自定义topic实现发布订阅
• 支持发布订阅, 通过自动化的线程渠道去分配线程处理业务
• 支持高并发的处理

订阅

import sys_bus
def cb_callback(topic, msg):
    print(topic, msg)
# 支持一个topic 可以注册多个订阅函数
sys_bus.subscribe("topic1", cb_callback)

发布

import sys_bus
"发布后订阅者会收到消息"
sys_bus.publish("topic1", "this is a msg")

解绑

import sys_bus
# 解绑topic 下的cb_callback函数
sys_bus.unsubscribe("topic1", cb_callback)
# 解绑topic
sys_bus.unsubscribe("topic1"

查看注册表

import sys_bus
sys_bus.sub_table()
# 返回 {"topic1": set(cb_callback...)}
sys_bus.sub_table("topic1")
# 返回 set(cb_callback...)