dophon框架中的消息隊列模塊,包括本地消息中心,遠程消息中心,以及生產消費相關裝飾器以及內部操作模塊等 dophon-mq 項目介紹 dophon框架中的消息隊列模塊,包括本地消息中心,遠程消息中心,以及生產消費相關裝飾器以及內部操作模塊等

有問題可發送郵件聯系作者:athspiring_admin@athspiring.com

一個輕量級消息隊列,承載能力中等,高頻巨量消息請選擇成熟的消息隊列(rocket-mq,kafuka等) 即使使用線程池處理消息,極為消耗cpu資源 該隊列基于io作為消息持久化(消息延遲主要為消息中心的讀寫延遲) 可通過配置選擇本地消息中心以及遠程消息中心 軟件架構 軟件架構說明

安裝教程 <<<<<<< HEAD

pip install dophon_mq ======= pip install dophon-mq e822369e3d8eac4b4bdbcaa2f1613c902a8c4815

使用說明 1 配置 自定義配置:

<application.py>

msg_queue_max_num = 30 # 消息隊列線程池承載話題上限

mq={ 'remote_center':True, # 使用遠程消息中心 # 若為false或不配置,則字典內下面的配置無效 'remote_address':'127.0.0.1', # 消息中心地址 'remote_port':58800 # 消息中心端口 } 2 生產者配置 推薦使用json格式傳遞數據(便于消費者轉義數據)

from dophon_mq import *

@producer( tag='DEMO_TAG', # 消息發送的話題 delay = 3 # 消息發送的延遲時間(秒) ) def producer(): return 'aaa' 3 消費者配置 方式一:

from dophon_mq import *

@consumer( tag='DEMO_TAG', # 消息消費的話題 delay = 1, # 消息消費的延遲 arg_name = 'args' # 承載消息的參數名(默認使用名為args的參數承載) ) def consumer(args): print(args) consumer() 4 統一管理消費者 from dophon_mq import *

class TestConsumer(ConsumerCenter):

@consumer(tag='test_msg_tag|test_msg_tag2', delay=1, arg_name = 'msg')

def consume_msg(

msg # 統一配置的消費入口方法以承載參數取代實例參數(self)

):

print(msg)

print(timestamp)

print(tag)

實例化衍生類啟動消費者

TestConsumer() 參與貢獻 Fork 本項目 新建 Feat_xxx 分支 提交代碼 新建 Pull Request

項目獲取地址：https://github.com/AthspiringSpftware/dophonMq.git

總結

以上是生活随笔為你收集整理的posix自定义消息队列_消息队列开源框架，基于Io，节约服务器资源的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。