日韩av黄I国产麻豆传媒I国产91av视频在线观看I日韩一区二区三区在线看I美女国产在线I麻豆视频国产在线观看I成人黄色短片

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 >

Redis管道 发布订阅

發布時間:2025/3/14 23 豆豆
生活随笔 收集整理的這篇文章主要介紹了 Redis管道 发布订阅 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

管道(pipe):
redis-py默認在執行每次請求都會創建(連接池申請連接)和斷開(歸還連接池)一次連接操作,如果想要在一次請求中指定多個命令,則可以使用pipline實現一次請求指定多個命令。
代碼范例:

import redis
pool
= redis.ConnectionPool(host='192.168.33.6', port=6379) r = redis.Redis(connection_pool=pool) pipe = r.pipeline(transaction=True)
print(r.get('name'), r.get('role')) pipe.set('name', 'alex') pipe.set('role', 'sb') pipe.execute() print(r.get('name'), r.get('role'))
# 輸出:
None None
alex sb

訂閱發布:只要有主播說話,所有收聽者都能聽到。

代碼范例:

import redisclass RedisHelper:def __init__(self):self.__conn = redis.Redis(host='192.168.33.6')self.chan_sub = 'fm104.5'self.chan_pub = 'fm104.5'def public(self, msg):self.__conn.publish(self.chan_pub, msg)return Truedef subscribe(self):pub = self.__conn.pubsub() # 打開收音機pub.subscribe(self.chan_sub) # 調頻道pub.parse_response() # 準備接收return pub

訂閱者:

# -*- coding: utf-8 -*-
from Redis_helper import RedisHelperobj = RedisHelper() redis_sub = obj.subscribe()while True:msg = redis_sub.parse_response()print(msg)

發送者:

# -*- coding: utf-8 -*-from Redis_helper import RedisHelperobj = RedisHelper() obj.public('hello')

?

轉載于:https://www.cnblogs.com/fone933/p/8306457.html

與50位技術專家面對面20年技術見證,附贈技術全景圖

總結

以上是生活随笔為你收集整理的Redis管道 发布订阅的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。