RabbitMQ. 2부. 교환 이해하기

Exchange - 교환기 또는 교환 지점. 메시지가 전송됩니다. Exchange 메시지를 배포합니다 하나 이상의 대기열에 있습니다. 그 메시지를 큐로 라우팅 생성된 연결을 기반으로(bindings) 그와 대기열 사이.

Exchange ~이 아니다. 얼랭 프로세스. 확장성 이유로 exchange - 내장 데이터베이스에 있는 라인(라우팅 로직이 있는 코드가 있는 모듈에 대한 링크)입니다. 기억상실증. 1개의 교환기는 1MB의 메모리만 소비합니다.

차례

• RabbitMQ. 파트 1. 소개. Erlang, AMQP 및 RPC
• RabbitMQ. 2부. 교환 이해하기
• RabbitMQ. 3부. 대기열 및 바인딩 이해
• RabbitMQ. 파트 4. 메시지 및 프레임 처리
• RabbitMQ. 5부: 메시지 게시 및 사용 성능
• RabbitMQ. 파트 6. Federation 및 Shovel 모듈 개요
• RabbitMQ. Part 7. 연결 및 샤넬에 대한 세부 정보
• RabbitMQ. 파트 8. .NET의 RabbitMQ
• RabbitMQ. 파트 9. 모니터링

직접 교환

Direct exchange - 필요할 때 사용 특정 대기열에 메시지 전달. 메시지는 특정 정보를 사용하여 교환기에 게시됩니다. 라우팅 키 유사한 라우팅 키를 사용하여 이 교환기에 연결된 모든 대기열에 들어갑니다. 라우팅 키는 문자열입니다.. 다음을 사용하여 일치하는 항목을 찾습니다. 문자열이 동일한지 확인.

메시지 흐름의 그래픽 표현:

В rabbitmq 개념이 있다 기본 교환기. 그것 direct exchange 이름이 없습니다. 기본 교환기가 사용되는 경우 메시지는 다음과 같은 이름을 가진 큐로 라우팅됩니다. 메시지 라우팅 키.

주제 교환

Topic exchange - 비슷한 direct exchange 라우팅 키를 비교하여 선택적 라우팅이 가능합니다. 하지만 이 경우에는 키가 제공됩니다. 템플릿으로. 템플릿을 만들 때 다음을 사용하세요. 0 또는 더 많은 단어(문자 AZ и az 그리고 숫자 0-9), 점으로 구분 및 기호 * и #.

• * - 정확하게 대체될 수 있음 1 слово
• # - 다음으로 대체 가능 0 또는 더 많은 단어

메시지 흐름의 그래픽 표현:

버전 이후 RabbitMQ 2.4.0 라우팅 알고리즘 topic exchange 까지 일을 시작했다 145 배 더 빨라요. 그들은 접근 방식을 도입하여 이를 달성했습니다. 트라이 구현, 이는 패턴을 트리 구조로 표현하는 것을 포함합니다. 예를 들어 템플릿 a.b.c, a.*.b.c, a.#.c и b.b.c 다음 구조로 표현됩니다.

패턴 일치 검색은 루트부터 시작하여 위에서 아래로 진행됩니다.

특징 :

• 이 교환기의 사용은 될 수 있습니다 향후 애플리케이션 개발을 위한 좋은 선택, 왜냐하면 메시지가 동일한 방식으로 게시되도록 템플릿을 항상 사용자 정의할 수 있습니다. direct exchange 또는 fanout exchange
• 사용하는 템플릿 * 훨씬 더 빨리사용하는 템플릿보다 #.
• topic exchange 느린 direct exchange

팬아웃 교환

Fanout exchange - 모든 메시지가 모든 대기열로 전달됩니다. 메시지에 라우팅 키가 지정된 경우에도 마찬가지입니다.

특징 :

• RabbitMQ 라우팅 키 및 템플릿에서는 작동하지 않습니다. 이는 생산성에 긍정적인 영향을 미칩니다. 이것이 가장 빠르다 exchange;
• 모든 소비자는 모든 메시지를 처리할 수 있어야 합니다.

메시지 흐름의 그래픽 표현:

헤더 교환

Headers exchange - (키, 값) 속성 쌍의 비교를 기반으로 메시지를 연결된 대기열로 라우팅합니다. headers 바인딩 및 유사한 메시지 속성. headers ~이다. Dictionary<ключ, значение>.

사전에 특수 키를 추가하는 경우 x-match 의미를 가지고 any, (키, 값) 쌍이 부분적으로 일치하는 경우 메시지가 라우팅됩니다. 이 동작은 연산자와 유사합니다. or.

var bindingArguments = new Dictinary<String, Object>();
bindingArguments.add("x-match", "any");

기본 키 x-match 값을 포함합니다 all. 이는 (키, 값) 쌍이 정확히 일치하면 메시지가 라우팅된다는 의미입니다. 이 동작은 연산자와 유사합니다. and.

메시지 흐름의 그래픽 표현:

특징 :

• 추가적인 유연성
• 추가 계산 오버헤드. 속성의 모든(키, 값) 쌍 headers 메시지 라우팅 값을 계산하기 전에 키 이름별로 정렬해야 합니다. 다른 교환 유형보다 느림.

일관된 해싱 교환

이 교환기는 플러그인 и 내장되어 있지 않음 в RabbitMQ.

Consistent-hashing exchange (일관된 해싱으로 교환) - 잠재적인 메시지 수신자가 될 대기열이 여러 개 있을 때와 이들 사이의 로드 균형을 조정해야 할 때 사용됩니다. 큐와 메시지의 연결은 가중치(조건부 문자열 값)에 따라 발생합니다. 0 - n).

대기열의 등가 가중치 - 각 대기열이 수신함을 나타냅니다. 거의 같은 금액 메시지(각 메시지는 하나의 대기열에만 배치됩니다) 메시지의 균일한 배포가 완벽하게 보장되지는 않습니다..

메시지 흐름의 그래픽 표현:

Hash 라우팅 키 또는 속성을 기반으로 계산됨 headers 메시지. 게시된 모든 메시지에 서로 다른 라우팅 키가 있는 경우 또는 headers, 그러면 분포는 무게별로 발생합니다. 그렇지 않으면 라우팅 키가 사용됩니다. headers.

단일 대기열을 사용하는 여러 소비자가 있는 솔루션보다 소비자 처리량을 높여야 할 때 도움이 됩니다.

교환기 결합(E2E)

통신을 사용하여 모든 교환기의 동작을 결합할 수 있습니다. 교환 대 교환 (교환기 결합은 사양에 포함되지 않습니다. AMQP. 이것은 측면에서 프로토콜을 확장한 것입니다. RabbitMQ).

메시지 흐름의 그래픽 표현:

작성자 E2E 현재 요구 사항과 증가하는 요구 사항을 모두 충족할 수 있는 올바른 확장 가능한 구성을 찾을 수 있습니다.

교환 생성

교환기 생성은 동기식을 사용하여 발생합니다. RPC 서버에 요청합니다. 방법을 사용하여 요청이 이루어집니다. Exchange.Declare, 다음 매개변수와 함께 호출됨:

• 교환기 이름
• 교환기 유형
• 다른 옵션

작성예 exchange ...에 의하여 토끼MQ.클라이언트:

//...
channel.ExchangeDeclare(
    exchange: "my_exchange",
    type: "direct",
    durable: "false",
    autoDelete: "false",
    arguments: null
);
//...

• exchange — 생성하려는 교환기의 이름입니다. 이름은 고유해야 합니다.
• type — 교환기 유형
• durable - 설치된 경우 true, 그런 다음 exchange 영구적이 될 것입니다. 이는 디스크에 저장되며 서버/브로커를 다시 시작해도 유지될 수 있습니다. 값이 false, 그런 다음 exchange 임시적이며 서버/브로커가 재부팅되면 삭제됩니다.
• autoDelete - 자동 제거. Exchange 관련된 모든 대기열이 삭제되면 삭제됩니다.
• arguments - 선택적 인수. 대부분 인수를 통해 지정합니다. alternative exchange (대체 교환기). 메시지가 원래 경로를 따라 이동할 수 없는 경우 대체 교환기로 전송되어 다른 경로를 따라 라우팅될 수 있습니다.

생성하는 경우 exchange 어쩌면그런 다음 서버는 클라이언트에 동기식을 보냅니다. RPC 답변 Exchange.DeclareOk. 생성하는 경우 불가능한 (요청에 대한 거부가 있었습니다. Exchange.Declare), 저것 채널이 닫힙니다 비동기 명령을 사용하는 서버 Channel.Close 그리고 클라이언트는 예외를 얻을 것입니다 OperationInterruptedException, 오류 코드 및 설명이 포함됩니다.

메시지를 게시하기 전에 교환기를 만들어야 합니다. 존재하지 않는 교환기에 메시지를 게시하는 경우 - RabbitMQ 조용히 제거하겠습니다.

GUI를 통해 Exchange 생성

관리자 패널로 이동 RabbitMQ 사용자 아래 guest (사용자 이름: guest 및 암호: guest). 사용자는 guest localhost에서만 연결할 수 있습니다. 이제 탭으로 이동합니다. Exchanges 그리고 클릭 Add a new exchange. 속성을 입력합니다.

대부분의 속성은 위에 설명되어 있습니다. 여기서 우리가 설정하면 Internal, 교환은 다음 용도로만 사용할 수 있습니다. E2E. Producer 그러한 교환으로 메시지를 보낼 수 없습니다.

결론

시스템을 개발할 때 토폴로지를 설명하는 것이 편리합니다. 라우팅 그래프를 사용합니다. 하지만 그래프 작성을 시작하기 전에 트래픽이 많은 경로를 강조하는 것이 좋습니다. 그들은 요구하는 사람들이다 더 높은 처리량 (성능). 다음으로 트래픽을 분류할 수 있습니다. 그리고 나서야 건물을 짓기 시작합니다.

구성된 그래프에 유한 집합 라우팅 키를 찾으려면 여러 가지를 살펴보는 것이 좋습니다. fanout exchange, 라우팅 키와 1:1로 관련되어 있습니다. 우리는 그것을 기억합니다 fanout exchange 가장 빠른.

노선 수의 경우 무한대로 가는 경향이 있다, 그렇다면 주의를 기울여야 합니다. topic exchange 또는 템플릿이 필요하지 않은 경우 선택할 수 있습니다. direct exchnge, 왜냐하면 그 사람이 더 빠르다 topic exchange.

다양한 조합 exchange 당신이 올바른 것을 찾는 데 도움이 될 것입니다 확장 가능한 구성, 이는 현재 및 증가하는 시스템 요구 사항을 모두 충족합니다.

수 exchange 그리고 경로 수에 비해 대기열이 최소화되어야 합니다.

다음 글에서는 큐와 바인딩에 대해 더 자세히 알아보겠습니다.

참조

• RabbitMQ 프로젝트 웹사이트

출처 : habr.com