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

#### Участие в проекте

1. Fork этого проекта.
2. Создайте ветку Feat_xxx.
3. Отправьте код.
4. Создайте запрос на слияние.