AMQP에서 RabbitMQ로 RPC-Model을 읽었습니다. 이 자습서에서는 임시 대기열을 만들고 correlationId도 만듭니다. 임시 대기열은 고유하므로 왜 correlationId가 필요합니까? 각 요청/응답 하나의 응답 큐를 만들고 correlationId 및 메시지 선택기를 사용하는 임시 큐를 생성 : 나는 우리가 두 가지 방법으로 요청/응답
RabbitMQ가 아니라 ActiveMQ를 사용하여 빠른 메시징 처리량 (게시 및 소비 모두)을 달성하는 것이 일반적이지 않은지 궁금합니다. 나는 RabbitMQ가 더 빠르다고 자랑하는 다른 온라인 참고 자료가 있기 때문에 묻고있다. 저는 합법적 인 벤치마킹 도구로 테스트하지 않습니다. 오히려 나는 기본 게시자/소비자 예제를 수정하여 3 킬로바이트 메시지
RabbitMQ 서버에서 node.js amqp-node 클라이언트를 실행 중입니다. 두 가지 방법으로 간단한 게시/소비 테스트를 설정했습니다. 각각 다른 지연 시간이 생겨서 왜 작동하지 못합니다. 대기 시간은 메시지가 전송 된 시간부터 배달 된 시간까지 측정됩니다. 첫 번째 방법은 퍼블리싱 앱과 소모 앱의 두 가지 프로세스를 사용합니다. 약 4ms의 레이
나는 RabbitMQ/Haskell 바인딩을 해결하기 위해 tutorialish 스크립트를 만들었고 이상한 메시지 손실이 발생했습니다. 버스트 길이와는 독립적으로, 수신 측은 대기중인 메시지를 소량 삭제합니다. 나는 소비자가 데이터 버스트의 끝을 "감지"하고 포기하는 것이 매우 믿을만하지 않다는 것을 알지만, 그것이 나에게 어떻게 보이는지를 알 수있다. 그
지난 2 일 동안 미쳐 버렸습니다. 교환 가능한 내구성 큐가있는 NodeJS 클라이언트에서 연결할 수 없습니다. 그래서 PHP 코드를 생성하고 메시지를 보낼 : 화면에서 <?php
$connection = new AMQPConnection(array(
'host' => 'localhost',
'vhost' => 'bvh',
'port' => 5672,
특정 서버의 메모리 부담을 줄이기 위해 클러스터의 두 서버에있는 두 개의 대기열에 메시지를 배포하려는 주제 교환기가 있습니다. 내 소비자는 주기적으로 느려지고 때로는 높은 메모리 워터 마크가 발생합니다. 나는이 교환에 바인딩이 큐와, 중간 직접 교환을 사용하여 메시지를 라우팅하는 것입니다 해결하기 위해 시도하는 방법 : a (topic) -> a1 (dir
내 RabbitMQ 서버에 연결하기 위해 데비안 Squeeze 서버에 컴파일되고 설치된 AMQP를 사용하고 있습니다. $this->_amqpConnection = new AMQPConnection($arrRmqConfig);
$this->_amqpConnection->connect();
// creating the amqp channel is suff
(Java) 메시징에 대한 무역 연구를 수행 중입니다. & 주요 웹 응용 프로그램의 백엔드 프레임 워크를 곧 다시 설계하기위한 대기열 시스템 (Amazon EC2 Cloud에서 , x-large 인스턴스). 나는 현재 ActiveMQ와 RabbitMQ를 평가 중이다. 계획에는 5 개의 다른 대기열이 있으며 하나는 데드 - 레터 대기열입니다. 하루에 보내는
우리는 이벤트 일정을 잡는 데 사용할 수있는 서비스가 필요합니다. 예를 들어, 우리는 3시 (1 회) 또는 2 시간 (여러 번)마다 실행해야하는 작업을 가질 수 있습니다. 각 작업은 게시 할 AMQP 대기열로 구성하는 것이 바람직합니다. OS 타이머 이벤트를 만들어 쉽게 구현할 수 있습니다. 내 관심사는이 서비스가 중단 된 경우 복구하는 방법입니다. CRO