node-amqp

2열

1답변

node-amqp에 문제가 생길 때 "닫기"이벤트가 발생하는 이유는 무엇입니까?

(node-amqp 및 rabbitmq 서버를 사용 중입니다.) 뭔가 잘못되면 close 이벤트가 발생하는 이유를 추측하려고합니다. 예를 들어, 잘못된 매개 변수와 함께 큐에 대한 연결을 열려고하면 오류 이벤트가 발생합니다. 완벽하다는 걸 알았어. 그러나 오류가 발생하면 닫기 연결도 받게됩니다 (이 경우 대기열에 실패한 소켓을 닫았 기 때문일 수 있습니다)

0열

1답변

RabbitMQ & node-amqp - 기본 교환이 확인되지 않습니다.

기본 교환기에 게시 할 때 확인 메시지가 나타나지 않는 것 같습니다. 현재 this post에 의해 제안 된 node-amqp의 master 브랜치를 사용하고 있습니다. 코드 : var amqp = require('amqp'); var conn = amqp.createConnection({ host: 'localhost' }); conn.once('r

4열

1답변

RabbitMQ 및 Node.js 장애 조치 시나리오를 처리하는 방법은 무엇입니까?

RabbitMQ (클러스터)를 사용하고 Node.js 클라이언트 (node-amqp-https://github.com/postwait/node-amqp)를 사용하여 연결하고 있습니다. RabbitMQ 문서에서는 장애 조치 시나리오 처리 (클러스터의 노드 실패)는 클라이언트가 처리해야하며 클라이언트가 장애를 감지하고 클러스터의 다른 노드에 연결해야 함을 의미

2열

1답변

node-amqp가 메시지를 보낼 때까지 기다리시겠습니까?

나는 RabbitMQ에 메시지를 보내려면 다음 코드를 사용하는 경우 : var amqp = require('amqp'); var connection = amqp.createConnection(); connection.on('ready', function() { connection.publish('foo', 'Hello'); proces

9열

2답변

node.js amqp 모듈을 사용할 때 AQMP 메시지 버퍼를 JSON 객체로 변환하는 방법은 무엇입니까?

대기열에서 메시지를 읽는 데 node.js amqp 모듈을 사용하고 있습니다. 다음은 대기열에서 사용 가능한 메시지가있을 때 호출되는 콜백입니다. function onMessage(message, headers, deliveryInfo) { console.log(message); //This prints buffer //how to co

2열

1답변

Node.JS 용 amqplib을 사용하는 RabbitMQ 소비자의 제어 소비율

내 응용 프로그램은 RabbitMQ 대기열을 사용하여 메시지를 저장 한 다음 해당 메시지를 소비하고 데이터베이스에 삽입합니다. 워크로드 최고점에서 데이터베이스를 강조하지 않습니다. 내가 가진 문제는 그 최고점에서 대기열의 게시 속도가 정말로 높다는 것이고 작업자는 충돌 할 때까지 처리 할 수있는 것보다 초당 더 많은 메시지를 수신하기 시작합니다. 소비량을

9열

2답변

Node-amqp - X 시도 후 메시지 거부

구성 가능한 몇 가지 재구성 시도 후에 메시지를 거부하는 메커니즘은 어떻게 구현합니까? 즉, 큐에 가입하면 동일한 메시지가 X 번 이상 재전송되지 않도록하고 싶습니다. 내 코드 샘플 : q.subscribe({ack: true}, function(data,headers,deliveryInfo,message) { try{ doSomethin

0열

1답변

node-amqp, 다중 바인드 콜백

나는 최선의 방안을 알고 싶다. 바인딩을 통해 데이터를 폴링하기 전에 바인딩이 완료 될 때까지 기다려야하며, 대부분이 병렬로 진행되어 클라이언트로 돌아갑니다. 그러나 이미 바인딩 작업이 진행중인 경우 다른 작업을 실행하면 콜백이 교체됩니다. 각 바인딩 작업에 대해 별도의 콜백을 지원하도록 node-amqp를 패치하려면 어떻게해야합니까?

2열

1답변

node.js에서 RabbitMQ에 교환이 있는지 확인하는 방법은 무엇입니까?

node.js에서 특정 RabbitMQ 교환이 존재하는지 여부를 확인하고 싶습니다. 저는 모카를 테스트 프레임 워크로 사용하고 있습니다. 나는 같은 코드를 작성했지만 내 기대가 잘못된 것 같다. Exchange가 없으면 교환 변수가 정의되지 않은 값을 가지기를 기대하지만 그렇지 않습니다. RabbitMQ와 상호 작용하기 위해 amqp 모듈을 사용하고 있습니

19열

1답변

RabbitMQ에서 메시지를 다시 큐하는 방법

소비자가 메시지를 받으면 소비자/근로자가 몇 가지 유효성 검사를 수행 한 다음 웹 서비스를 호출합니다. 이 단계에서 오류가 발생하거나 유효성 검사가 실패하면 원래 소비 된 큐로 메시지를 되돌리려합니다. 나는 RabbitMQ 문서를 읽었습니다. 그러나 거부, 중지 및 취소 방법의 차이점에 대해서는 혼란 스럽습니다.