Redis를 메시지 대기열로 사용할 수 있나요?

Redis는 캐시 서버뿐만 아니라 메시지 큐로도 사용할 수 있습니다. 목록 유형은 본질적으로 메시지 대기열로의 사용을 지원합니다.

Redis 리스트는 이중 연결 리스트로 구현되기 때문에 헤드 노드와 테일 노드는 저장되므로 에 목록의 머리와 꼬리 양쪽에 요소를 삽입하는 것은 매우 빠릅니다. (권장 학습: Redis 비디오 튜토리얼)

따라서 Redis의 목록을 직접 사용하여 lpush와 rpop이라는 두 가지 간단한 지침만으로 메시지 대기열을 구현할 수 있습니다. 또는 rpush 및 lpop.

하지만 메시지 소비자에게는 문제가 있습니다. 즉, 목록에 대기 중인 메시지가 있는지 확인하려면 rpop 메서드를 지속적으로 호출해야 한다는 것입니다. 각 호출은 연결을 시작하므로 불필요한 낭비가 발생합니다. Thread.sleep()과 같은 메서드를 사용하여 일정 시간 후에 소비자 스레드가 다시 소비되도록 할 수도 있지만 여기에는 두 가지 문제가 있습니다.

1), 생산자 속도가 소비자 소비 속도보다 빠르면 메시지 대기열의 길이가 계속 증가하고 시간이 지남에 따라 많은 메모리 공간을 차지하게 됩니다.

2) Sleep 시간이 너무 길면 시간에 민감한 일부 메시지를 처리할 수 없습니다. Sleep 시간이 너무 짧으면 연결에 상대적으로 큰 오버헤드가 발생합니다.

따라서 brpop 명령을 사용할 수 있습니다. 이 명령은 요소가 있는 경우에만 반환되며 시간 초과될 때까지 차단되고 null을 반환합니다. 콘솔에서 프로그램에 출력이 없는 것을 볼 수 있습니다. 여기 brpop에서는 차단되어 있습니다. 그런 다음 Redis 클라이언트를 열고 client list 명령을 입력하여 현재 두 개의 연결이 있는지 확인합니다.

Redis는 메시지 대기열 지원 외에도 게시/구독 모드를 지원하는 명령 세트도 제공합니다.

1) 게시

PUBLISH 명령을 사용하여 메시지를 게시할 수 있습니다. PUBLISH 채널 메시지 형식은

#🎜🎜 #반환 값은 이 메시지의 구독자 수를 나타냅니다.

2) Subscription

SUBSCRIBE 명령은 메시지를 수신하는 데 사용됩니다. 형식은 SUBSCRIBE 채널

SUBSCRIBE 명령을 사용한 후에 확인할 수 있습니다. , 구독 모드로 진입했지만 게시로 보낸 메시지를 수신하지 못했습니다. 이는 메시지가 전송되기 전에 구독을 통해서만 수신할 수 있기 때문입니다. 이 모드의 다른 명령에 대해서는 응답만 볼 수 있습니다.

답글은 세 가지 유형으로 구분됩니다.

1인 경우 두 번째 값은 구독한 채널을 나타내고 세 번째 값은 구독 채널을 나타냅니다. 어떤 채널에 가입되어 있나요?(일련번호로 이해되나요?)

2. 메시지(메시지)인 경우 두 번째 값은 메시지를 생성한 채널이고, 세 번째 값은 message# 🎜🎜#

3. 구독 취소인 경우 두 번째 값은 구독 취소된 채널을 나타내고 세 번째 값은 현재 클라이언트의 구독 수를 나타냅니다.

UNSUBSCRIBE 명령을 사용하여 구독을 취소할 수 있습니다. 매개변수를 추가하지 않으면 SUBSCRIBE 명령으로 구독한 모든 채널이 구독 취소됩니다.

Redis는 PSUBSCRIBE(패턴 구독) 명령을 사용하여 와일드카드 기반 메시지 구독도 지원합니다.

Publish 명령이 2를 반환하고 구독자가 메시지를 두 번 받은 것을 볼 수 있습니다. 이는 PSUBSCRIBE 명령이 채널을 반복적으로 구독할 수 있기 때문입니다. PSUBSCRIBE 명령을 사용하여 구독한 채널은 PUNSUBSCRIBE 명령을 사용하여 구독을 취소해야 합니다. 마찬가지로 UNSUBSCRIBE는 PSUBSCRIBE 명령으로 구독한 채널에서 구독을 취소할 수 없습니다. 동시에 PUNSUBSCRIBE 명령어 와일드카드는 확장되지 않습니다.

요약:

Redis의 List 데이터 구조와 제공되는 BRPOP 및 BLPOP 명령어를 사용하여 쉽고 빠르게 메시지 큐를 생성할 수 있습니다. by Redis Jedis의 rpop 및 lpop 메소드에 대한 빈번한 호출로 인해 발생하는 리소스 낭비 문제를 해결했습니다. 또한 Redis는 메시지 전달 및 프로세스 간 통신을 실현할 수 있는 게시/구독 모드에 대한 지침을 제공합니다.

Redis 관련 기술 기사를 더 보려면

Redis 데이터베이스 사용 튜토리얼

열을 방문하여 알아보세요!

위 내용은 Redis를 메시지 대기열로 사용할 수 있나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!