rabbitmq

3열

2답변

내가 이벤트 기반 아키텍처와 캐시 서버에서하고 있어요 , 그것은 것을 모델을 구독하는 것은 다음과 같은 일을합니다 : 나는 (모든 복제본에 전송 Set 작업 (팬 아웃 교환하고 싶습니다 ?)) 및 Get (임의의 단일 교환자 (기본 교환 (?)). 나는 Publish&Subscribe 패턴을 읽었으며 fanout exchange을 사용하여 모든 서버를 응답

-1열

1답변

rabbit mq에서 매우 느림 읽음

나는 rabbitmq 대기열에서 읽어야 만하는 작업을 데이터 저장소에 씁니다. 현재 큐에서 메시지를 읽는 데 AmqpItemReader을 사용하고 있습니다. 읽은 데이터는 Json 형식이며 모든 내 ItemProcessor은 json을 Java 객체로 직렬화합니다. 단일 스레드 솔루션의 성능이 매우 낮습니다. 나는 초당 12ms의 속도로만 소비 할 수있다.

0열

1답변

RabbitMQ 메시지 속도 받기

기존 토끼 mq에 연결하여 환율 (또는 환율)을 얻으려고합니다. 요금을 직접 계산해야합니까 아니면 더 간단한 방법이 있습니까? 미리 감사드립니다.

0열

2답변

지속되는 RabbitMQ 메시지를 검사 할 수있는 방법이 있습니까? 저장 장소는 어디입니까?

로컬 컴퓨터에서 몇 가지 테스트를 수행하면 RabbitMQ (deliveryMode = 2)에 의해 게시되고 지속되는 메시지를 검사하고 싶습니다. 아니면 최소한 메시지가 실제로 지속되는 시간이 있어야합니다. 첫 번째 시도는, 관리자 관리 RabbitMQ 있었다 모든 옵션과 저점 무슨 일이 있었는지 내가 발견 한 것은 다음과 같다 가까운 : rdq exten

0열

1답변

대기열이 제거 된 것을 어떻게 알 수 있습니까?

나는 큐 생성 : _channel = rmqConnection.CreateModel(); _channel.QueueDeclare("myqueue", false, false, false, null); _channel.BasicAcks += _channel_BasicAcks; _channel.BasicNacks += _chan

1열

1답변

RabbitMQ basic_publish가 비동기입니까?

다음 제작자 코드가 있습니다. 메시지은 일부 계산 후에 얻은 dict 데이터입니다. 큐에 메시지을 게시하고 싶습니다. 그런 다음 다른 계산을 위해 메시지을 빈 dict로 재설정합니다. 그러나 소비자는 항상 대기열에서 빈 dict를 받고있다. 기분이 메시지 게시되기 전에 재설정됩니다 (비동기?). 동기시키는 방법? message = {a big dict ..

1열

1답변

STOMP를 통한 RabbitMQ 내구성 큐 손실 메시지

tomcat에 배포 된 스프링 응용 프로그램에 의해 노출되는 javascript/websockets를 사용하여 토끼 mq 브로커에 연결하는 웹 페이지가 있습니다. 메시지는 외부 응용 프로그램에서 초당 1 개씩 생성되며 웹 페이지에 렌더링됩니다. 자바 스크립트 구독은 내구성이 있습니다. 내가 겪고있어 문제는 네트워크 연결이 일정 기간 동안 자바 스크립트 클라

0열

1답변

스케줄러가 작업 대기열에 없음

Kubernetes에서 Airflow를 테스트하려고합니다. 스케줄러, 작업자, 대기열 및 웹 서버는 모두 다른 배포 환경에 있으며 셀러 리 실행 프로그램을 사용하여 작업을 실행하고 있습니다. 스케줄러가 작업을 대기열에 넣을 수 없다는 점을 제외하면 모든 것이 잘 작동합니다. 기류는 웹 UI 나 CLI에서 수동으로 실행할 때 내 작업을 잘 실행할 수 있지만

0열

1답변

왜 내 rabbitMQ 클라이언트에 연결할 수 없습니까?

TLSv1.2를 사용하여 서버와 RabbitMQ 연결을 만들려고하는데 java.net.SocketException이 있습니다. 연결 재설정 또는 javax.net.ssl.SSLHandshakeException : 치명적인 경고 수신 : handshake_failure (이 예외가 변경되는 것처럼 보입니다. 무작위로). 내가 TLSv1.0을 가졌을 때 작동했

1열

1답변

서버가 다운 된 후 Rabbit MQ로 다시 연결하는 방법은 무엇입니까?

나는 Rabbit RPC를 사용하는 스프링 부트 응용 프로그램을 가지고 있습니다. 문제는 응용 프로그램이 시작되면 래빗 서버가 다운되면 응용 프로그램이 서버에 다시 연결되지 않는다는 것입니다. 그리고 토끼 서버가 다운되는 동안 앱이 시작되면 토끼가 다시 올라간 후에 실패하고 토끼에 다시 연결을 시도하지 않습니다. 여기 는 @Configuration pub