AMQP를 사용하는 백그라운드 작업 처리 시스템이 있습니다. 여러 서버가 동일한 대기열에서 작업을 소비하고 있습니다. 각 서버는 4 개의 작업자 프로세스를 실행 중입니다. 여태까지는 그런대로 잘됐다. 이제 처리 할 작업 자체가 일관성을 유지하기 위해 일부 IPC가 필요하며 AMQP 대기열 (물론 다른 것)을 다시 사용합니다. 아이디어는 각 노동자, 그것은이
큐 "queue = connection.queue (...)"를 사용할 때마다 실제로 큐를 인스턴스화해야합니까? 서버 (Node.js를) 서버와 인스턴스화 queue = connection.queue('incoming', { // <--- DO I REALLY NEED THAT FOR EVERY REQUEST?
durable : true,
나는 심각한 두통을 불러 일으키는 레거시 RabbitMQ 코드를 물려 받았습니다. 아무도, "공식"설명서 어디로 비슷한 질문을 검색 할 수있는 가리키는 데 도움이 될 수 있습니까? 우리는 어떤 채널과 같이 채널을 사용하여 검색을 수행 노동자 응답을받을 만들 : channelIn.queueDeclare("", false, false, true, null);
AMQP와 XMPP의 차이점을 이해하려고 노력 중입니다. XMPP에 대기열이있는 것처럼 작동하는지 이해하지 못하는 경우가 있습니다. 다양한 클라이언트에게 메시지를 보내면 그 중 하나가 작동 중지되면 어떻게됩니까? 서버가 클라이언트까지 메시지를 다시 대기열에 넣거나 작동하는 방법은 무엇입니까? JID가 오프라인 상태 일 때 그것은 XMPP 서버 구현에 따라
나는 응용 프로그램을 작성 중이며 모든 클라이언트가 특정 대기열로 메시지를 푸시하고 인증 된 사용자 만 대기열에서 메시지를 사용할 수 있도록 허용 할 수 있는지 궁금한가요? 나는 이것에 관해 무엇인가 발견 할 수 없다 :/ 기본적으로 나의 모델은 다음과 같다 : 클라이언트는 모두 같은 대기열에 연결하고 그것에 메시지를 밉니다. 또한 각 클라이언트는 자신이
OS X에 RabbitMQ 서버를 설치하고 명령 줄에서 시작했습니다. 이제는 어떻게 실행을 멈추어야하는지 명확하지 않습니다. 내가 한 후 : sudo rabbitmq-server -detached
를 내가 얻을 : Activating RabbitMQ plugins ...
0 plugins activated:
그것을했다. 어떻게 제대로 종료해야합니까
대부분의 작업은 네트워크에 따라 다르므로 한 번에 하나의 메시지가 아닌 병렬로 큐를 처리하려고합니다. 내 프리 페치 설정을 사용하지 않는 이유는 #!/usr/bin/env ruby
# encoding: utf-8
require "rubygems"
require 'amqp'
EventMachine.run do
connection = AMQ
Rails와 함께 RabbitMQ와 ruby-amqp을 사용하고 있습니다. 메시지가 컨트롤러에 의해 수신되면 나는 다음을 수행 : def create
AMQP.start("amqp://localhost:5672") do |connection|
channel = AMQP::Channel.new(connection)
exchange
CakePHP 프레임 워크와 Java 기반 백엔드로 구성된 프론트 엔드로 구성된 시스템을 개발 중입니다. 이 두 생태계 간의 통신은 CakePHP 컨트롤러에서 RabbitMQ 브로커로 JSON 메시지를 전송하여 수행됩니다. 메시지가 소비되면 결과가 프론트 엔드로 되돌려 보내집니다. 이제 메시지를 소비하고 컨트롤러의 결과를 사용자 브라우저로 푸시해야합니다.