큐 작업에 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('Redis服务器IP', 6379); while (true) { $redis->lPush('list1', 'A_'.date('Y-m-d H:i:s')); sleep(rand()%3); } ?>
Execute #php list_push.php &
Output queue 작업 list_pop.php 파일
코드는 다음과 같습니다.
<?php $redis = getRedisInstance();//从Redis服务器拿到redis实例 $redis->pconnect('Redis服务器IP', 6379); while(true) { try { var_export( $redis->blPop('list1', 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('127.0.0.1',6379); while(True){ try{ $value = 'value_'.date('Y-m-d H:i:s'); $redis->LPUSH('key1',$value); sleep(rand()%3); echo $value."\n"; }catch(Exception $e){ echo $e->getMessage()."\n"; } } ?>
2. 팀 분리
<?php $redis = new Redis(); $redis->pconnect('127.0.0.1',6379); while(True){ try{ echo $redis->LPOP('key1')."\n"; }catch(Exception $e){ echo $e->getMessage()."\n"; } sleep(rand()%3); } ?>.
위 내용은 Redis를 사용하여 대기열 작업을 수행하는 방법 Redis 작업 예제 코드 요약의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!