dophon-mq

pip install dophon-mq

msg_queue_max_num = 30   # 消息队列线程池承载话题上限

mq={
    'remote_center':True,   # 使用远程消息中心
    # 若为false或不配置,则字典内下面的配置无效
    'remote_address':'127.0.0.1',  # 消息中心地址
    'remote_port':58800  # 消息中心端口
}

from dophon_mq import *

@producer(
    tag='DEMO_TAG', # 消息发送的话题
    delay = 3 # 消息发送的延迟时间(秒)
)
def producer():
    return 'aaa'

from dophon_mq import *

@consumer(
    tag='DEMO_TAG', # 消息消费的话题
    delay = 1, # 消息消费的延迟
    arg_name = 'args' # 承载消息的参数名(默认使用名为args的参数承载) 
)
def consumer(args):
    print(args)
consumer()

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()