redisを使って非同期キューを作る方法は何ですか？

1年 ago
芽依, 雨夜
1 minute

Redisで、非同期キューを実装するためにListデータ構造を使用することができます。以下は一般的な方法です：

  1. LPUSHは、リストの先頭に要素を追加するコマンドです。
  2. ブロックリスト中の最後の要素を削除して返します。
  3. BRPOPをネイティブで日本語で言い換えると、「最初にキーが空になるまで待機し、その後要素をポップする」です。
  4. 非同期プログラム内で、タスクデータを受信した後に、適切な処理ロジックを実行し、計算を行ったりメッセージを送信したりします。
  5. 処理が完了したら、処理結果をRedisに保存して、他のプログラムやユーザーが検索できるようにします。

以下是一个简单的示例代码，使用Python的Redis模块实现异步队列：
下記は、PythonのRedisモジュールを使用して非同期キューを実装した簡単なサンプルコードです。

import redis
import time
import threading

def worker():
    r = redis.Redis()
    while True:
        # 从队列中获取任务数据，如果队列为空则阻塞等待
        queue, data = r.brpop('task_queue')
        # 执行任务逻辑
        print('Processing task:', data)
        time.sleep(1)  # 模拟任务处理时间
        # 将处理结果存储到Redis中
        r.set('result_' + data, 'done')

# 启动异步处理程序
worker_thread = threading.Thread(target=worker)
worker_thread.start()

# 添加任务到队列
r = redis.Redis()
for i in range(10):
    r.lpush('task_queue', str(i))

# 等待所有任务处理完成
worker_thread.join()

# 查询处理结果
for i in range(10):
    result = r.get('result_' + str(i))
    print('Result of task', i, ':', result)

上記のコードでは、まずバックグラウンドスレッドを非同期処理プログラムとして起動し、その後メインスレッドでタスクキューにタスクデータを追加します。非同期処理プログラムは継続的にキューからタスクデータを取得し、処理を行います。処理結果はRedisに保存され、最終的には結果を取得することで各タスクの処理結果を取得できます。

bannerAds