RabbitMQ 설치(Windows) 예제 튜토리얼

관리 백엔드

rabbitmq에는 자체 관리 백엔드가 함께 제공되며 설치 후에 구성하고 켜야 합니다.
rabbitmq 설치 디렉터리에 sbin 디렉터리를 입력하고
rabbitmq-plugins 활성화 Rabbitmq_management
rabbitmq 서비스를 다시 시작하면 적용됩니다.
http://localhost:15672/ 열기 관리 배경 보기
사용자 이름과 비밀번호는 모두 손님입니다

구성 지침

명령줄을 사용하여 대기열 목록을 봅니다

sbin>rabbitmqctl list_queues  
sbin>rabbitmqctl list_queues name messages_ready messages_unacknowledged

명령줄을 사용하여 대기열 목록을 봅니다. exchange list

sbin>rabbitmqctl list_exchanges

큐 정의

RabbitMQ에서는 다른 매개변수 사용을 허용하지 않습니다. 기존 큐를 재정의하세요.

RabbitMQ에서는 다른 매개변수를 사용하여 기존 대기열을 재정의하는 것을 허용하지 않으며 이를 시도하는 모든 프로그램에 오류를 반환합니다.

신뢰성

메시지가 손실되지 않도록 하려면 메시지 지속성을 설정해야 합니다. 동시에 큐는 내구성도 있어야 합니다.
하지만 메시지를 받은 후 지속성을 완료하기 전에 RabbitMQ가 충돌하면 메시지가 손실되므로 여전히 100% 신뢰할 수는 없습니다.

반복 처리

다음 시나리오를 고려하세요(전제: 대기열과 메시지는 내구성이 있습니다).

1. 소비자가 msgA 메시지를 받았는데, 이 메시지는 절반만 처리되었고 완료되지 않았으며 ack 확인이 시작되지 않았습니다.

   이때 RabbitMQ가 충돌했습니다.

2. 소비자가 메시지 msgA 처리를 완료했습니다.

3. RabbitMQ를 다시 시작했을 때 msgA가 처리되지 않은 것으로 확인되어 msgA가 다시 소비자에게 전송되었습니다.
이 시나리오에서는 메시지 msgA가 두 번 처리되므로 소비자 측에서는 반복 처리를 방지하는 메커니즘이 있어야 합니다.

ACK

ACK 확인은 RabbitMQ에게 소비자가 메시지 처리를 완료했음을 알려주는 것이지, 비즈니스 처리가 실패하더라도 ACK 확인은 필요합니다. 일반적으로 비즈니스상의 이유로 실패가 발생한 경우 재시도만으로는 문제가 해결되지 않기 때문입니다. 네트워크 중단, 시스템 정전 등으로 인해 발생한 오류에만 재시도가 필요합니다.

비즈니스 부하가 특정 소비자에게 집중되는 것을 방지

channel.basicQos(prefetchCount);

prefetchCount=1

을 설정하고 해당 소비자에게 마지막 메시지가 할당될 때까지 한 번에 하나의 메시지만 한 소비자에게 할당하도록 RabbitMQ에 지시합니다. 메시지가 승인되고 처리됩니다. 이러한 방식으로 메시지는 실제 처리 조건에 따라 매번 유휴 소비자에게 할당됩니다.

기본 Exchange 정보prefetchCount=1
，告诉RabbitMQ 每次只给一个消费者分配一个消息，直到上一个分配给该消费者的消息被确认处理完成。这样一来，消息就会根据实际处理情况，每次都分配给空闲的消费者。

关于默认Exchange

默认Exchange隐式地绑定到每一个队列，路由key为队列名。不能对其进行显式绑定或解绑。并且它是不可删除的。

The default exchange is implicitly bound to every queue, with a routing key equal to the queue name. It is not possible to explicitly bind to, or unbind from the default exchange. It also cannot be deleted.

消息传递的基本过程

发布者发布一个消息
-->exchange接收消息（如果发布者没有指定特定的Exchange则使用默认Exchange），并根据exchange的类型，按照一定的路由规则，把消息路由给每一个符合路由规则的队列（如果没有匹配的队列，则消息被丢弃）
-->队列将消息发送给订阅该队列的某一个消费者（如果没有消费者则消息保留在队列中，知道有消费者消费该消息）

Topic Exchange的通配符

星号匹配一个单词（注意，不是一个字母）

* (star) can substitute for exactly one word.
井号匹配任意个单词
#

기본 Exchange는 암시적으로 각 대기열에 바인딩되며 라우팅 키는 대기열 이름입니다. 명시적으로 바인드되거나 바인드 해제될 수 없습니다. 그리고 삭제할 수 없습니다.

기본 교환은 대기열 이름과 동일한 라우팅 키를 사용하여 암시적으로 바인딩되거나 기본 교환에서 바인딩을 해제할 수 없습니다.

메시지 전달도 불가능합니다. 기본 프로세스

게시자가 메시지를 게시합니다

--> Exchange가 메시지를 수신하고(게시자가 특정 Exchange를 지정하지 않은 경우 기본 Exchange가 사용됨) 교환 유형 및 특정 라우팅 규칙에 따라 메시지는 라우팅 규칙을 준수하는 각 A 큐로 라우팅됩니다. (일치하는 큐가 없으면 메시지는 폐기됩니다.)

--> 큐는 큐를 구독하는 소비자에게 메시지를 보냅니다. 소비자가 메시지를 소비할 때까지 메시지는 대기열에 남아 있습니다.)

Topic Exchange 와일드카드

🎜별표는 단어와 일치합니다(문자가 아닌 참고). 🎜🎜🎜*(별표)는 정확히 대체할 수 있습니다. 한 단어.🎜파운드 기호 원하는 수의 단어와 일치🎜#(해시)는 0개 이상의 단어를 대체할 수 있습니다.🎜🎜🎜AMQP 프로토콜 필수 및 즉시 플래그의 역할🎜🎜필수 및 즉시 플래그는 다음과 같습니다. AMQP 프로토콜의 basic.plish 메서드에서 두 개의 플래그 비트는 메시지 전달 중 대상에 도달할 수 없을 때 생산자에게 메시지를 반환하는 기능을 가지고 있습니다. 구체적인 차이점은 다음과 같습니다. 🎜🎜1 필수 플래그 🎜🎜 필수 플래그가 true로 설정된 경우 교환기가 자체 유형 및 메시지 RouteKey를 기반으로 자격을 갖춘 대기열을 찾을 수 없는 경우 basic.return 메서드가 호출되어 또는 필수를 false로 설정하면 위 상황에서 브로커가 메시지를 직접 버립니다. 🎜🎜2. 즉시 플래그 비트 🎜🎜즉시 플래그 비트가 true로 설정된 경우 Exchange에서 메시지를 대기열로 라우팅할 때 해당 대기열에 소비자가 없는 것으로 확인되면 메시지는 대기줄. 메시지 RouteKey와 연결된 모든 대기열(하나 이상)에 소비자가 없으면 메시지는 basic.return 메서드를 통해 생산자에게 반환됩니다. 🎜

위 내용은 RabbitMQ 설치(Windows) 예제 튜토리얼의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!