关于文章 zbus

linux python queue zbus

记录一次zbus在Python上推送报Exception in thread Thread-2异常

记录一次zbus在Python上推送报Exception in thread Thread-2异常的解决办法,实际上是python的包管理确实坑了我

昨天还好好的 今天zbus 推送的时候一直报Exception in thread Thread-2

用git 回退到昨天

依旧报

神奇的。。。

修改zbus存放index目录

无效

重新创建一个venv环境

= = 成功

重新的去检查pip freeze

挑出我用的包

重新干掉venv 生成

安装

== 解决了 抓狂、、、

经过考虑应该是卸载不干净依赖的包的锅

= = 继续填坑

java linux mq python rpc zbus 队列

python使用zbus队列尝试

zbus小巧而极速的MQ, RPC实现, 支持HTTP/TCP代理,开放易扩展,多语言支撑微服务,系统总线架构

小巧而极速的MQ, RPC实现, 支持HTTP/TCP代理,开放易扩展,多语言支撑微服务,系统总线架构

最近再想做对外api服务,再纠结数据库异步驱动后

突然想起了zbus = =

这似乎是一个代价更小的方案

先试试官方demo

发布者

broker = Broker('localhost:15555') 

p = Producer(broker) 
p.declare('MyTopic') 

msg = Message()
msg.topic = 'MyTopic'
msg.body = 'hello world'

res = p.publish(msg)

消费者

broker = Broker('localhost:15555')  

def message_handler(msg, client):
    print(msg)

c = Consumer(broker, 'MyTopic')
c.message_handler = message_handler 
c.start()

消费者会一直阻塞 只要有资源 就会取到 然后调用回调

经过测试 body可以随意写 都可以序列化

那么数据入库的结构就可以这样

tornado -> httpapi -> 队列塞进去

队列 <---> 消费者 --> 数据库