写一段基于redis进行消息收发的代码
以下是一个基于redis进行消息收发的代码示例:
发送消息
import redis
# 连接redis服务器
redis_client = redis.Redis(host='localhost', port=6379)
# 发送消息到名为message_queue的频道
redis_client.publish('message_queue', 'Hello, world!')
该代码使用了redis的publish方法,将消息发送到名为message_queue的频道。
接收消息
import redis
# 连接redis服务器
redis_client = redis.Redis(host='localhost', port=6379)
# 订阅名为message_queue的频道
pubsub = redis_client.pubsub()
pubsub.subscribe('message_queue')
# 循环接收消息
for message in pubsub.listen():
print(message['data'])
该代码使用了redis的pubsub方法,订阅名为message_queue的频道,并循环接收消息。每当有新的消息到达时,会打印出消息内容。
需要注意的是,该代码是阻塞式的。如果需要在程序中处理其他任务,可以将接收消息的代码放在单独的线程中运行。
原文地址: https://www.cveoy.top/t/topic/qAr 著作权归作者所有。请勿转载和采集!