amqp

1열

1답변

postwait로 node-amqp 모듈을 사용하고 있습니다. 일부 메시지를 큐에 게시/구독 할 수 있지만 수동으로 메시지를 확인하고 싶습니다. 예를 들어 메시지를 읽은 다음 확인하지 않고이 메시지에 대한 계산을 실행하려면 q.shift()을 보내고 메시지를 확인하고 두 번째 메시지를 확인하십시오. 나는 인정을 수동으로 사용하고 싶다. 실제로 나는 플래그로

1열

2답변

인도 기간 유지

납품 주문이 가장 중요한 곳에서 AMQP를 사용하는 것이 좋습니다. 그래서 배달되지 않은 메시지는 순서가 맞지 않게 다시 대기하므로 정상적인 재 배달 기능을 사용할 수 없습니다. 마치 내가 처리해야 할 메시지가 처리 될 때까지 대기열에 남겨두고 메시지를 삭제해야합니다. 그런 다음 동일한 메시지가 순서대로 두 번 처리 될 수는 있지만 쉽게 트래핑하고 처리 할

2열

2답변

RabbitMQ + Node.JS 연결 문제, 프레임 크기가 너무 큽니까?

나는 RachebitMQ를 가지고 apache + php로 놀아 왔고 Node.JS와 성능면에서 비교해보기를 원했다. 최신 node.js (0.4.12) 및 amqp 모듈 (npm install amqp)을 사용하면 오류를 일으키는 프레임 크기 (amqp.js의 181 행) 인 것 같은 미지의 예외 연결이 발생합니다. 코드에서 오류를 제거하면 배열 크기가

3열

3답변

삽입 가능한 대기열?

조치를 수집하여 원격 서버로 전송하는 애플리케이션이 있습니다. 이러한 작업은 시간상 중요한 작업이 아니기 때문에 (로그 라인으로 생각할 수 있습니다.)이를 큐에 넣고 일괄 적으로 보내고 싶습니다. 그런 식으로 하드 드라이브가 손상되지 않는 한 메시지가 손실되지 않도록하고 싶습니다. MSMQ는 오히려 중량급, 비속하고 이상한 것 같습니다. 또한 시스템 구성

3열

1답변

Node.js를 + socket.io + 노드 AMQP와 큐 binginds 때 socket.io

를 통해 연결 "다시"나는이이 샘플 매우 가까운 하나의 시나리오 : 하나 개의 메인 화면 : 이 화면 (클라이언트 쪽)은 server : 9090/scope (io.connect ("http : // server : 9090/scope))를 통해 socket.io 서버에 연결하고 하나의 이벤트"userBindOk " .emit ("userBindOk", m

0열

1답변

많은 수의 메시지를 AMQP 대기열에 게시

Ruby amqp 라이브러리의 v0.7.1과 Ruby 1.8.7을 사용하여 RabbitMQ 서버에 짧은 (~ 40 바이트) 메시지를 대량으로 게시하려고합니다. 내 프로그램의 메인 루프는 (물론, 정말 루프,하지만 여전히) 다음과 같습니다 AMQP.start(:host => '1.2.3.4', :username => 'foo', :pas

2열

2답변

puka는 gevent 또는 eventlet과 잘 작동합니까?

필자는 최신 파이썬 AMQP 라이브러리 인 Puka (Pika와 혼동하지 말아야 함)에 대해 읽었으며 이벤트 루프를 처리하는 방식이 gevent 또는 eventlet과 호환되는지 궁금해하고있었습니다. 내 제한된 지식을 바탕으로 gevent/eventlet을 사용하여 자동으로 패치 할 수있는 것 같습니다. 감사합니다. 출처 : http://github.com

2열

2답변

Node.js를 사용하는 AMQP, 어떻게 게시/구독 할 수 있습니까?

내가 여기 사용할 수있는 노드 AMQP 모듈을 조작하는 클래스를 만드는 중이라서 : https://github.com/postwait/node-amqp 을하지만 게시 할 수 없습니다입니다 /이를 사용하여 구독 : 여기 var Queue = require('./Queue.js'); var queue = new Queue(); queue.ad

11열

1답변

플라스크가있는 클래스에 REST 동작 추가, 청사진의 경우?

RabbitMQ & Kombu을 사용하여 통신하는 여러 개의 분산 된 경량 구성 요소로 구성된 python 응용 프로그램을 다루고 있습니다. 구성 요소는 두 개의 대기열에서 수신 대기하고 각 대기열에서 여러 메시지 유형을 수신 할 수 있습니다. 서브 클래스는 사용자 정의 핸들러를 등록하여 각 메시지 유형 처리 방법을 겹쳐 쓸 수 있습니다. 이 모든 것이 정

1열

2답변

RabbitMQ (및 node.js)의 비동기 확인

RabbitMQ의 특정 유스 케이스를 염두에두고 있습니다. 특정 사항을 명확히하고 권장 사항을 요청하고 싶습니다. 1- 나는 두 가지 작업이 실행되어야하는 메시지를 게시 : 이 시나리오 고려 messageA 및 다음 messageB 2 내 소비자, messageA를 얻을이 메시지에 포함 된 작업을 실행하지만, 작업이 실행되는 동안 서버가 충돌합니다. 내 질