這篇文章主要講解了“Python怎么實(shí)現(xiàn)發(fā)布和訂閱”,文中的講解內(nèi)容簡單清晰,易于學(xué)習(xí)與理解,下面請大家跟著小編的思路慢慢深入,一起來研究和學(xué)習(xí)“Python怎么實(shí)現(xiàn)發(fā)布和訂閱”吧!
10年積累的成都網(wǎng)站設(shè)計(jì)、成都做網(wǎng)站經(jīng)驗(yàn),可以快速應(yīng)對客戶對網(wǎng)站的新想法和需求。提供各種問題對應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認(rèn)識你,你也不認(rèn)識我。但先網(wǎng)站設(shè)計(jì)后付款的網(wǎng)站建設(shè)流程,更有扎賚諾爾免費(fèi)網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。
`import redis
class RedisHelper:
def __init__(self): self.__conn = redis.Redis(host='192.168.5.124',password='V6jZVVhNBfSiJ7Ib') self.chan_pub = 'TaskManager.Redis.Channel' self.chan_sub = 'TaskManager.Redis.Channel' def public(self,msg): self.__conn.publish(self.chan_pub, msg) return True def subscribe(self): pub = self.__conn.pubsub() pub.subscribe(self.chan_pub) pub.parse_response() return pub
rhl = RedisHelper() msg = { "name":'Tim' } redis_sub = rhl.subscribe() rhl.public(json.dumps(msg)) while True: msg = redis_sub.parse_response() print(msg)
`
chan_pub是redis通信頻道,連接同一個(gè)頻道的發(fā)布者和訂閱者能通信
如果redis庫設(shè)置的密碼,一定要加上password,不然會報(bào)錯(cuò)
感謝各位的閱讀,以上就是“Python怎么實(shí)現(xiàn)發(fā)布和訂閱”的內(nèi)容了,經(jīng)過本文的學(xué)習(xí)后,相信大家對Python怎么實(shí)現(xiàn)發(fā)布和訂閱這一問題有了更深刻的體會,具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是創(chuàng)新互聯(lián),小編將為大家推送更多相關(guān)知識點(diǎn)的文章,歡迎關(guān)注!