我可以使用Celery发布和订阅主题吗？

from celery import Celery

app = Celery('tasks', broker='pyamqp://guest@localhost//')

@app.task(bind=True, type='broadcast')
def broadcast_task(self, message):
    print(f"Received message: {message}")

broadcast_task.apply_async(args=['Hello, world!'], broadcast=True)

pip install redis

import redis

r = redis.Redis(host='localhost', port=6379, db=0)

def publish_message(channel, message):
    r.publish(channel, message)

from celery import Celery
import redis

app = Celery('tasks', broker='pyamqp://guest@localhost//')

r = redis.Redis(host='localhost', port=6379, db=0)

@app.task
def subscribe_task():
    pubsub = r.pubsub()
    pubsub.subscribe('my_channel')

    for message in pubsub.listen():
        if message['type'] == 'message':
            print(f"Received message: {message['data']}")
            # 在这里处理消息

subscribe_task.apply_async()