RabbitMQ 및 PHP(1) - RabbitMQ 원리 및 작동 예

RabbitMQ는 erlang 언어로 개발된 인기 있는 오픈 소스 메시지 대기열 시스템이며 AMQP(Advanced Message Queuing Protocol)를 완벽하게 구현합니다. 웹사이트는 다음과 같습니다: http://www.rabbitmq.com/ 튜토리얼과 예제 코드(Python 및 Java)가 있습니다.
7af40ad162d9f2d36b6bf89fa8ec8a136327cc4c
AMPQ 프로토콜은 다양한 메시지 대기열 요구 사항을 충족하기 위해 개념적으로 복잡합니다. 우선, RabbitMQ는 기본적으로 아무런 구성 없이 시작됩니다. 작동하려면 클라이언트 연결, 스위치 설정 등이 필요합니다. 이러한 기본 개념이 명확하지 않으면 이후의 프로그래밍 설계에서 문제가 발생하기 쉽습니다.
1.vhosts: 가상 호스트.
RabbitMQ 엔터티는 여러 가상 호스트를 가질 수 있으며 사용자 및 권한 설정은 가상 호스트에 따라 달라집니다. 일반 PHP 애플리케이션의 경우 사용자 권한 설정이 필요하지 않습니다. 기본적으로 존재하는 "/"만 사용하면 됩니다. 사용자는 기본적으로 존재하는 "guest"를 사용할 수 있습니다. 간단한 구성 예:
$conn_args = array(
'host' => '127.0.0.1',
'port' => '5672',
'login' => ; 'guest',
'password' => 'guest',
'vhost'=>'/'
);
연결 및 채널: 연결 및 채널
연결을 의미합니다. 물리적 연결에는 클라이언트와 서버 사이에 여러 채널이 설정될 수 있으며 이는 논리적 연결로 이해될 수 있습니다. 일반적인 응용 프로그램에서는 하나의 채널이면 충분하며 더 이상 채널을 만들 필요가 없습니다. 샘플 코드:
//연결 및 채널 생성
$conn = new AMQPConnection($conn_args);
if (!$conn->connect()) {
die("연결할 수 없습니다. thebroker!n");
}
$channel = new AMQPChannel($conn);
3.교환 및 라우팅 키: 교환 및 라우팅 키
다른 유형의 메시지를 구별하려면 다음을 설정합니다. 스위치와 라우팅의 개념을 이해합니다. 예를 들어 A 유형의 메시지를 'C1'이라는 스위치에 보내고 B 유형의 메시지를 'C2'라는 스위치에 보냅니다. 클라이언트가 큐 메시지를 처리하기 위해 C1에 연결하면 유형 A 메시지만 가져옵니다. 또한, A형 메시지가 많은 경우에는 더욱 세분화된 구분이 필요합니다. 예를 들어 클라이언트가 K 사용자에 대한 A형 메시지만 처리하는 경우 이를 위해 라우팅키가 사용됩니다.
$e_name = 'e_linvo'; //스위치 이름
$k_route = array(0=> 'key_1', 1=> 'key_2') //라우팅 키
//스위치 생성
$ex = new AMQPExchange($channel);
$ex->setName($e_name);
$ex->setType(AMQP_EX_TYPE_DIRECT) //직접 유형
$ex- >setFlags(AMQP_DURABLE); //지속성
echo "교환 상태:".$ex->declare()."n";
for($i=0; $i<5; + + $i){
echo "메시지 보내기:".$ex->publish($message . date('H:i:s'), $k_route[i%2])."n";
}
위 코드에서 볼 수 있듯이 메시지를 보낼 때는 "스위치" 하나만 있으면 충분합니다. 스위치 뒤에 해당 처리 대기열이 있는지 여부에 대해 발신자는 걱정할 필요가 없습니다. Routingkey는 빈 문자열일 수 있습니다. 예제에서는 아래 라우팅 키의 역할을 이해하기 쉽도록 두 개의 키를 사용하여 메시지를 번갈아 보내도록 하겠습니다.
스위치에는 두 가지 중요한 개념이 있습니다.
A, 유형입니다. 세 가지 유형이 있습니다. 팬아웃(Fanout) 유형이 가장 단순하고, 이 모델은 라우팅 키를 무시하며, 특정 라우팅 키를 사용하는 직접 유형이 가장 많이 사용됩니다. 이 모델에서는 메시지를 받을 때 'key_1'을 바인딩하면 마지막 메시지인 Key_1만 받게 됩니다. 이 모드는 Direct와 유사하지만 'key_*'와 같은 와일드카드 일치를 지원합니다. key_1과 key_2를 허용합니다. Topic은 보기에는 좋지만 부정확성이 발생할 수 있으므로 Direct를 사용하는 것이 좋습니다.
B, 끈기. 지속성을 위해 지정된 스위치는 다시 시작할 때만 재구축할 수 있습니다. 그렇지 않으면 클라이언트가 생성을 다시 선언해야 합니다.
특히 명확한 개념이 필요합니다. 스위치의 지속성은 메시지의 지속성과 같지 않습니다. 지속성 대기열에 있는 메시지만 지속될 수 있습니다. 대기열이 없으면 메시지 자체에도 지속성 플래그가 있습니다. PHP에서 지속성 스위치로 전달되는 기본 메시지는 지속적인 메시지, 임시 필요 없음.
4.queue: Queue
너무 많은 얘기를 하다보니 그냥 Queue에 대한 얘기만 나왔어요. 실제로 대기열은 수신자(소비자)만을 위한 것이며 요청에 따라 수신자가 생성합니다. 대기열이 생성될 때만 스위치는 새로 수신한 메시지를 대기열에 보내지 않습니다. 즉, 대기열이 설정되기 전에 전송된 모든 메시지는 삭제됩니다. 아래 그림은 공식 RabbitMQ 그림보다 더 명확합니다. 대기열은 receiveMessage의 일부입니다.
024f78f0f736afc37053e415b219ebc4b7451266
큐를 생성하고 메시지를 받는 예를 살펴보겠습니다.
$e_name = 'e_linvo'; //스위치 이름
$q_name = 'q_linvo'; //큐 이름 > $k_route = ''; //라우팅 키
//연결 및 채널 생성
$conn = new AMQPConnection($conn_args);
if (!$conn->connect()) {
die("브로커에 연결할 수 없습니다!n");
}
$channel = new AMQPChannel($conn);
//스위치 만들기
$ex = new AMQPExchange($channel);
$ex->setName($e_name);
$ex - >setType(AMQP_EX_TYPE_DIRECT); //직접 유형
$ex->setFlags(AMQP_DURABLE); //지속성
echo "교환 상태:".$ex->declare()."n" ;
//큐 생성
$q = new AMQPQueue($channel);
$q->setName($q_name);
$q->setFlags(AMQP_DURABLE) // 지속성
//스위치와 큐를 바인딩하고 라우팅 키를 지정합니다
echo 'Queue Bind: '.$q->bind($e_name, $k_route)."n";
// 차단 모드에서 메시지 수신
echo "Message:n";
$q->consume('processMessage', AMQP_AUTOACK) //자동 ACK 응답
$conn->disconnect();
/**
* 소비 콜백 기능
* 메시지 처리
*/
function processMessage($envelope, $queue) {
var_dump($envelope->getRoutingKey);
$msg = $envelope->getBody() ;
echo $msg."n"; //메시지 처리
}
위의 예에서 볼 수 있듯이 스위치는 메시지 발신자 또는 메시지 소비자에 의해 생성될 수 있습니다.
큐(라인:20)를 생성한 후 큐가 작동하려면 먼저 큐를 스위치(라인:25)에 바인딩해야 합니다. 라우팅 키도 여기에 지정됩니다. 일부 정보에서는 바인딩키라고 하는데 실제로는 두 개의 명사를 사용하는 것은 혼동하기 쉽습니다.
메시지를 처리하는 방법에는 두 가지가 있습니다.
A, 일회성. $q->get([...])을 사용하면 메시지 획득 여부에 관계없이 즉시 반환됩니다. 일반적으로 이 방법은 폴링을 사용하여 메시지 큐를 처리하는 데 사용됩니다. $q->consum( callback, [...] )을 사용하면 프로그램은 메시지가 수신될 때마다 콜백에 지정된 함수가 한 번 호출됩니다. 콜백 함수는 FALSE를 반환합니다.
콜백과 관련해 몇 가지 단어를 더 소개합니다. PHP의 call_back은 배열 사용을 지원합니다. 예: $c = new MyClass() $c->counter = 100; $ c,'myfunc') ) 이런 식으로 작성한 처리 클래스를 호출할 수 있습니다. MyClass의 myfunc 매개변수 정의는 위 예제의 processMessage 매개변수 정의와 동일합니다.
위 예에서 $routingkey = ''를 사용하면 모든 메시지를 수신한다는 의미입니다. 이를 $routingkey = 'key_1'로 변경할 수 있으며, 결과의 유일한 내용은 Routingkey를 key_1로 설정한 것임을 알 수 있습니다.
참고: 라우팅키 = 'key_1'과 라우팅키 = 'key_2'는 서로 다른 두 개의 대기열입니다. 가정: client1과 client2는 모두 key_1의 대기열에 연결되어 있습니다. 메시지가 client1에 의해 처리된 후에는 client2에 의해 처리되지 않습니다. Routingkey = ''는 또 다른 대안입니다. client_all은 모든 메시지가 처리된 후에는 client1과 client2에 메시지가 없습니다.
프로그램 설계 측면에서는 교환 이름, 다양한 유형의 태그를 구별하기 위해 키를 사용하는 방법, 메시지가 생성되는 위치에 메시지 전송 코드를 삽입할 계획이 필요합니다. 백엔드 처리에서는 각 키에 대해 하나 이상의 클라이언트를 시작하여 메시지 처리의 실시간 특성을 향상시킬 수 있습니다. 다중 스레드 메시지 처리에 PHP를 사용하는 방법은 다음 섹션에서 설명됩니다.
더 많은 메시지 모델을 보려면 http://www.rabbitmq.com/tutorials/tutorial-two-python.html
b03533fa828ba61e15fc0e5f4034970a304e59b4
http://nonfu.me/p/8833을 참조하세요. HTML
위 내용은 RabbitMQ와 PHP(1)를 소개한 내용입니다. RabbitMQ의 원리와 동작 예시와 관련 내용이 포함되어 있어 PHP 튜토리얼에 관심이 있는 친구들에게 도움이 되었으면 좋겠습니다.