amqp

1열

1답변

RabbitMQ 및 nodejs를 사용하여 독립 실행 형 Java를 실행하는 방법

저는 java 웹 서버 앞에 node.js를 놓고 노드의 비동기 처리를 활용하기 위해 노력해 왔습니다. 일부 조명 처리 및 기타 작업과 결국 socket.io를 수행합니다. 응용 프로그램의 실제 작업의 대부분은 자바로 이루어졌으며 지금까지 모든 요청을 처리하기 위해 부두 웹 서버를 사용해 왔습니다. 나는 처음에 node-http-proxy를 사용하여 (전달

0열

1답변

똑같은 방식으로 처리되는 작업에 대한 독립적 인 정렬 된 대기열

작업을 순서대로 처리하는 데 도움이되는 대기열 작성 도구를 찾고 있습니다. 나는 웹 사이트에 가입하는 사용자의 예를 사용하여 문제를 전달하는데 도움이 될 것입니다. 실생활에서는 각각 1 분, 몇 천 명이 걸릴 수도 있습니다. USER1 - 등록 -> 프로세스 지불 - 사진 사용자 2 크기 조정> - -> 사진을 업로드 비밀번호 재설정 -> 사진을 업로드 -

2열

1답변

Python Celery - pid로 검색 작업

꽤 간단한 질문입니다. celery.task.control.inspect() 님의 active() 메서드를 사용할 때 종종 찾을 수없는 셀러 리 작업 프로세스가 시스템에서 실행되는 것을 볼 수 있습니다. 종종이 과정은 몇 시간 동안 진행될 것입니다. 그리고 나는 그것이 일종의 좀비라고 걱정합니다. 보통 너무 많은 메모리를 사용하고 있습니다. linux pi

2열

1답변

HTTP 요청이 완료된 후 AMQP 메시지를 올바르게 확인하는 방법

AMQP 대기열에서 메시지를 소비하는 컨트롤러 메서드가 있습니다.하지만 http 요청을 한 클라이언트에 가능한 한 확실하게 전달할 때까지 해당 메시지를 확인하고 싶지 않습니다. 데이터 (컨트롤러 메소드를 떠난 후 http 요청이 실패 할 경우 데이터가 손실되지 않도록). 지금까지 내가 발견 한 것은 Spring 인터셉터를 사용하여 요청이 성공적으로 완료된

0열

1답변

내가 RabbitMQ 큐 소비하는 루비 과정이 RabbitMQ와 루비

에서 같은 큐에 요청을 다시 전송 : 나는 그것이 실용적이지 알고 AMQP.start(:host => $AMQP_URL) do |connection| @channel ||= AMQP::Channel.new(connection) @queue ||= @channel.queue("results") @queue.subscribe do

5열

1답변

언제 AMQP를 사용하는 것이 적절합니까?

이전 직장에서는 AMQP의 장점을 사용했지만 rabbitMQ 하위 프로젝트 개발에는 관여하지 않았습니다. 현재 제 직업에서 AMQP 구현 중 하나 (아마 rabbitMQ)를 통합하는 작업을 담당하고 싶습니다. AMQP 사용시 보스에게 확신시켜야 할 문제는 여기에 있습니다. "RabbitMQ in Action"을 읽었으며 Videla는 AMQP가 모든 시스템

1열

1답변

amq.topic의 용도는 무엇입니까?

미리 정의 된 amq.topic 교환의 목적은 무엇입니까? 나는 내 용도로 사용할 수 있습니까?

1열

1답변

MQ 서버가 실패/재시도를 지원합니까?

우리 팀의 앱 중 하나에 큐잉 솔루션이 필요합니다. 메시지 소비자가 메시지를 가져 와서 처리해야하지만 어떤 이유로 든 처리가 실패하면 (다시 말하면 몇 분 후에 다시 시도 할 수 있도록) 메시지 소비자가 대기열에 다시 놓는 것이 이상적입니다. 이 워크 플로우를 지원하는 MQ 서버가 있습니까?

18열

2답변

Java 프로세스에 임베드 할 수있는 MQ 서버가 있습니까?

저는 팀의 앱 중 하나에 대한 큐잉 솔루션을 연구 중입니다. 이상 적으로는 가벼운 in-process 브로커 (스레드 간의 낮은 처리량 메시징 용)와 외부 브로커로 구성 할 수있는 것이 좋습니다. MQ 서버가있을 수 있습니까? 대부분의 경우 외부 엔티티로 설정해야합니다. ZeroMQ는 인 프로세스 솔루션에 가장 가까운 것으로 보이지만 스테로이드의 "UDP

5열

1답변

예외 .NET 클라이언트 프로그래밍에서 'AMQP 작업이 중단되었습니다'(코드 = 406) 발생

2.8.2 RabbitMQ Server와 2.8.2 클라이언트 DLL이 있고 대기열을 선언하고 메시지를받는 코드가 있고, IModel channel=null; ConnectionFactory factory = new ConnectionFactory(); factory.HostName = "192.168.68.4"; _QueueName = "172.1