Redis를 사용하여 대기열 작업을 수행하는 방법 Redis 작업 예제 코드 요약

큐 작업에 Redis를 사용하는 방법

Reids는 ANSI C로 구현된 비교적 고급 오픈 소스 키-값 저장 시스템입니다. memcached와 유사하지만 영구 데이터 저장을 지원하고 값은 string(memcached의 값과 동일), 목록, 집합(Set), 순서 집합(OrderSet) 및 Hash 등 여러 유형을 지원합니다. 모든 값 유형은 목록에 요소 추가 및 팝핑, 컬렉션에서 요소 삽입 및 제거 등과 같은 원자성 작업을 지원합니다. Rdids의 데이터는 대부분 메모리에 위치하며 읽기 및 쓰기 효율성이 매우 높습니다. AOF(작업 기록 파일 추가)와 DUMP(정기 데이터 백업)라는 두 가지 지속성 방법을 제공합니다. Redis는 맞춤형 VM(가상 메모리) 메커니즘을 지원합니다. 데이터 용량이 메모리를 초과하는 경우 값의 일부를 파일에 저장할 수 있습니다. 동시에 Redis는 데이터 복제를 수행할 수 있는 마스터-슬레이브 메커니즘을 지원합니다.
Redis의 목록 구조를 큐로 사용할 수 있습니다.
위의 Redis 시나리오와 기능 중에서 현재 개발 활동에서는 이러한 좋은 것을 "로 진화시키는 대신 Redis를 도입할 수 있는 시나리오가 있습니다." Redis, "Redis"의 비극적인 상황은 어떻습니까? 물론 구체적인 이슈를 자세히 분석하는 것은 정말 중요하다.
캐싱? 분산 캐시? 대기줄? 분산 대기열?
일부 시스템 애플리케이션(예: 통신, 은행, 대규모 인터넷 애플리케이션 등)에서 사용하게 됩니다. 물론 현재 인기 있는 memcache가 좋은 증거이지만 어떤 측면에서는 memcache에 이 두 가지가 포함될 수 있나요? 더 잘할 수 있습니다(실용적인 적용이 없으므로 그냥 버립니다). 하지만 Redis에서는 Redis가 큐와 캐시를 모두 포함할 수 있고 Redis의 작업이 모두 원자적 작업이기 때문에 동시 환경에서 문제를 일으키지 않을 것이라고 느꼈습니다.
어느 쪽이 더 좋고 나쁘다 논할 필요는 없습니다. 존재 이유가 있기 때문에 자신에게 맞는 것을 선택하는 것이 가장 좋습니다.
Redis에서 큐(분산) 디자인 YY를 사용해 보겠습니다. 조언을 부탁드립니다.
상황 시나리오:
현재 프로젝트는 여러 서버 또는 여러 IP에 배포되고, 프런트엔드는 F5를 통해 배포되므로 사용자의 요청이 어떤 서버에 속하는지 파악하는 것이 불가능합니다. 프로젝트에는 플래시 킬 설계가 있는데, 이러한 배포 방식은 처음에는 고려되지 않았지만 (Oracle의 경우) 데이터베이스 테이블의 행 레코드를 직접 잠그는 것이 가장 쉬운 방법이기도 했습니다. . 다양한 애플리케이션 배포와 단 하나의 데이터베이스 서버의 경우 이 동시성 문제는 "쉽게" 해결될 수 있습니다. 그렇다면 이제 데이터베이스 서버가 업무에 관여하지 못하도록 애플리케이션으로 옮겨야 할지 고민해보자.
예를 들어 현재 애플리케이션 서버 2개와 데이터베이스 서버 1개가 있습니다. 두 서버가 동시 캐시나 큐를 운영할 때 먼저 Redis 서버에서 두 애플리케이션 서버의 프록시 객체를 얻은 후 열을 입력하는 작업을 수행한다는 개념입니다.
코드 구현(PHP)을 보세요
Enqueue 작업 파일 list_push.php

코드는 다음과 같습니다.

<?php 
$redis = getRedisInstance();//从Redis服务器拿到redis实例 
$redis->connect(&#39;Redis服务器IP&#39;, 6379); 
while (true) { 
$redis->lPush(&#39;list1&#39;, &#39;A_&#39;.date(&#39;Y-m-d H:i:s&#39;)); 
sleep(rand()%3); 
} 
?>

Execute #php list_push.php &
Output queue 작업 list_pop.php 파일

코드는 다음과 같습니다.

<?php 
$redis = getRedisInstance();//从Redis服务器拿到redis实例 
$redis->pconnect(&#39;Redis服务器IP&#39;, 6379); 
while(true) { 
try { 
var_export( $redis->blPop(&#39;list1&#39;, 10) ); 
} catch(Exception $e) { 
//echo $e; 
} 
}

구현 방법(Python)
1. 큐 입력(write.py)

코드는 다음과 같습니다.

#!/usr/bin/env python 
import time 
from redis import Redis 
redis = Redis(host='127.0.0.1', port=6379) 
while True: 
now = time.
strftime("%Y/%m/%d %H:%M:%S") 
redis.lpush('test_queue', now) 
time.sleep(1)

2. Dequeue(read.py)

코드는 다음과 같습니다.

#!/usr/bin/env python 
import sys 
from redis import Redis 
redis = Redis(host='127.0.0.1', port=6379) 
while True: 
res = redis.rpop('test_queue') 
if res == None: 
pass 
else: 
print str(res)

샘플 코드:

1. 팀 가입

<?php
$redis = new Redis();
$redis->connect(&#39;127.0.0.1&#39;,6379);
while(True){
  try{
    $value = &#39;value_&#39;.date(&#39;Y-m-d H:i:s&#39;);
    $redis->LPUSH(&#39;key1&#39;,$value);
    sleep(rand()%3);
    echo $value."\n";
  }catch(Exception $e){
    echo $e->getMessage()."\n";
  }
}
?>

2. 팀 분리

<?php
$redis = new Redis();
$redis->pconnect(&#39;127.0.0.1&#39;,6379);
while(True){
  try{
    echo $redis->LPOP(&#39;key1&#39;)."\n";
  }catch(Exception $e){
  echo $e->getMessage()."\n";
  }
  sleep(rand()%3);
}
?>

.

위 내용은 Redis를 사용하여 대기열 작업을 수행하는 방법 Redis 작업 예제 코드 요약의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!