amqp

0열

1답변

나는 RabbitMQ를 사용할 노드 응용 프로그램을 가지고 있으며 amqplib을 사용하여 액세스하고 있습니다. RabbitMQ와 값 비싼 채널에 대한 TCP/IP 연결은 저렴하므로 하나의 연결을 만든 다음 여러 채널을 만드는 것을 이해합니다. 내가 약간 혼란 스러우면 응용 프로그램에서 사용할 수있는 연결 하나를 평가하는 방법이 무엇입니까? 대부분의 자습서

0열

1답변

messageProperties.setCorrelationIdString이 작동하지 않습니다.

메시징 플로우가 상관 ID를 기반으로한다는 시나리오가 있습니다. 그래서 보낸 사람 메시지 등록 정보에 상관 관계 Id 문자열을 설정하고 있습니다. 그러나 수신기 메시지에 동일한 ID를 수신하지 못하고 있습니다. 메시지 프로세서 클래스에서 동일한 상관 ID를 설정하는 다른 옵션을 보았습니다. 메시지를 설정할 수 있습니다. 에서 "변환 및 보내기". 그러나 간

0열

1답변

rabbitMQ에서 온 메시지 가져 오기

rabbitMQ 큐에서 모든 메시지를 가져 오려고합니다. const messages = await rabbit.getMessages(outputQueue, false); 여기에 getMessages 메소드가 구현되었습니다. 문제는 3-5 개의 메시지 만 처리하고 '해결'을 호출한다는 것입니다. 얼마 후 휴식 메시지를 처리하지만 '해결'은 이미 호출되었으

0열

1답변

- net = host를 사용할 때 셀 비트 컨테이너를 rabbitmq 컨테이너에 어떻게 연결할 수 있습니까?

--net = host를 사용할 때 셀러리 컨테이너를 rabbitmq 컨테이너에 연결할 수 없습니다. 내 rabbitmq 서버가 DNS에 정의되어 docker run -d --rm --net=host --hostname=rabbitmq --name=rabbitmq -p 5672:5672 -p 15672:15672 -e RABBITMQ_DEFAULT_USER

2열

1답변

브로커의 ActiveMQ 네트워크에서로드 밸런싱

우리는 ActiveMQ를 사용 중이며 브로커 네트워크를 정의했습니다 (테스트 설정에서 2). 우리는 AMQP 연결을 허용하도록 브로커를 구성하고 우리는과 같이 "updateClusterClients"와 "rebalanceClusterClients"을 수 있습니다 <transportConnector name="amqp" uri="amqp+ssl://0.0.0

0열

1답변

AMQP/JMS 환경에서 BrokerProperty "setScheduledEnqueueTimeUtc"에 해당하는 것은 무엇입니까?

저는 Azure 서비스 버스에 메시지를 보내야하는 Java 응용 프로그램에서 작업 중이므로 특정 지연 후 다음 프로세스에서 메시지를 사용할 수 있습니다. Azure SDK를 사용하면 브로커 메시지에 setScheduledEnqueueTimeUtc BrokerProperty를 설정하여이를 수행 할 수 있지만 AMQP/JMS 환경에서는 이에 상응하는 항목을 찾

1열

1답변

RabbitMQ PRECONDITION_FAILED - 알 수없는 배달 태그

우리는 RabbitMQ에서 WebSocket 연결 (PHP AMQP pecl 확장 v1.7.1 & RabbitMQ 3.6.6)을 사용하여 RabbitMQ에서 연결된 장치로 메시지를 전달하는 PHP 앱을 보유하고 있습니다. 메시지는 대기열 배열 (웹 소켓 연결 당 1 개)에서 소비되며 메시지가 수신되었다는 확인을 웹에서 수신하면 소비자가 확인합니다 (그래서

0열

1답변

웹 소켓이나 폴링이없는 HTTP REST 게이트웨이

웹 소켓이나 폴링을 사용하지 않고 REST API 게이트웨이가 AMQP에서 백엔드 서비스를 실행할 때 REST API 게이트웨이가 브라우저에 GET 요청을 반환하는 방법을 이해하기 위해 고생했습니다.). AMQP 서비스 (RabbitMqs reply_to & correlation_id)와 RPC를 성공적으로 연결했지만 Flask HTTP 요청이 대기 중으로

0열

1답변

HTTP/REST 및 AMQP

동기 및 비동기 프로토콜의 차이점은 무엇입니까? AMQP가 비동기인데 http/rest가 동기 인 이유는 무엇입니까? 이 두 프로토콜에 대한 개요는 어디서 얻을 수 있습니까? 감사합니다.

1열

1답변

pika confirm_delivery는 브로커가 메시지를 받았을 때 또는 소비자가 승인했을 때를 확인합니까?

내 프로듀서 코드에서 소비자가 언제 메시지를 수신했는지 알고 싶습니다. basic.ack channel.confirm_delivery()과 BlockingConnection을 사용하면 설명서에서 1) 브로커가 메시지를 받았거나 2) 소비자가이를 수락했다는 것을 확인해야하는지 확실하지 않습니다. (NO 소비자와)이 코드를 실행 : import pika im