rabbitmq

1열

1답변

나는 백엔드에 RabbitMQ가있는 응용 프로그램을 가지고 있습니다. 그래서 RabbitMQ에 응용 프로그램 대기열을 연결하고 데이터를 수집하는 사용자 지정 타사 분석 코드를 개발하려고합니다. 그래서 내 문제는 응용 프로그램과 내 코드가 모두 rabbitmq의 데이터를 잃지 않도록하려는 것입니다. 어떻게하면 RabbitMQ 대기열을 구성 할 수 있습니까?

0열

1답변

Masstransit ReceiveFrom 메소드 및 소비자 행동에 혼동 됨

한 쪽에서 일부 메시지를 보내고 다른 응용 프로그램에서 수신하는 RabbitMq가있는 대기열을 만들고 싶습니다. I'am는 다음 코드를 사용하여 이렇게 : return ServiceBusFactory.New(x => { var uriString = string.Format(@"rabbitmq://{0}/{1}/{2}?prefetch=

2열

1답변

노드의 amqplib을 ssl 연결과 연결하는 방법은 무엇입니까?

나는 SSL을 사용하도록 강요 받고 사용자와 암호로 보호 된 내 RabbitMQ 서버에 연결하려고합니다. 이전에는 C#, PHP 및 Python 응용 프로그램에서이 서버에 연결하는 데 성공했습니다. 이 내 Node.js를 코드 : const amqp = require('amqplib'); const fs = require('fs'); const con

0열

1답변

Application_Start and RabbitMQ

우리는 RabittMQ 대기열에서 데이터를 가져와야하는 ASP.NET MVC 응용 프로그램을 가지고 있지만 수신 된 데이터가 도메인 데이터이기 때문에 연결 및 소비자의 구현이 도메인 계층에 있습니다. 프레젠테이션 계층 (응용 프로그램 서비스를 통해)에서이 연결/소비자를 시작해야하며 해당 프로세스를 계속 실행하여 정보를 캐시해야합니다. DDD 아키텍처 내에서

2열

1답변

RabbitMQ : 팬 아웃 (fanout) 교환기에서 비 승인 메시지를 다시 사용합니다.

여기가 제 문제입니다. 나는 Publish/Subscribe 유행에있는 장난감 응용을 창조하고 싶, 저것을보기로 가지고 갔다. 하지만 나는 소비자들에게 감사의 말을 전하고 싶다. 나는 다음과 같은 행동을 기대한다 : 나의 소비자 중 한 명이 죽은 후에 나는 그 스크립트를 다시 콘솔에서 실행하고, 메시지는 처리된다. 여기 은 게시자에 대한 코드입니다 <?ph

1열

1답변

RabbitMQ가 디스크에 메시지를 쓰지 못하도록하십시오.

메시지를 디스크에 쓰지 않아야한다는 요구 사항이 있습니다. RabbitMQ 설명서에는 다음 내용이 나와 있습니다. 영구 및 일시적인 메시지를 모두 디스크에 쓸 수 있습니다. 영구 메시지는 큐에 도달하자마자 디스크에 쓰여지지만 일시적인 메시지는 메모리 압력 하에서 메모리에서 축출 될 수 있도록 디스크에만 기록됩니다. '기억력 부족'이라는 말은 다소 모호합니다

1열

1답변

Masstransit/RabbitMQ에서 대기열을 구성하는 방법은 무엇입니까?

메시지를 소비하는 모범 사례를 알고 싶습니다. MassTransit 문서를 읽었으며 이에 대해 조사했지만 어떤 결론에 도달하지는 않습니다. 게시 메시지 인 api (버스 인스턴스 호스팅)가 하나 있습니다. 이 API는 마이크로 서비스 (구매, 판매 등을위한 메시지)가 아니기 때문에 다양합니다. 소비자/대기열을 어떻게 구성해야합니까? 큐 유형에 대해 하나의

1열

2답변

Spring RabbitTemplate - 보내는 즉시 자동으로 대기열을 만드는 방법

RabbitMQ와 Spring의 RabbitTemplate을 함께 사용하고 있습니다. 템플릿 send 메소드를 사용하여 대기열로 메시지를 보낼 때 대기열이 이미 존재하지 않으면 자동으로 작성/선언됩니다. 우리의 비즈니스 로직에 따르면 큐 이름은 런타임에 생성되므로 미리 선언 할 수 없으므로 매우 중요합니다. 이전에는 JmsTemplate을 사용했으며 보내거

1열

1답변

autofac을 사용하는 단일 프로세스에 대해 rebus의 여러 인스턴스 구성

내 응용 프로그램이 토끼의 두 개의 다른 가상 호스트에있는 두 개의 대기열에 메시지를 보내고 그 중 하나에서 읽어야하는 상황이 발생했습니다. 이 2 개의 대기열을 하나의 가상 호스트 (완벽한 솔루션 임)로 옮기는 것은 불가능합니다. 따라서 하나의 프로세스에서 2 개의 rebus 인스턴스를 실행해야합니다. 의존성 주입에 autofac을 사용하고 있습니다. 한

0열

1답변

Spring Cloud Stream : Sink에서 RabbitMQ 연결이 끊어졌습니다.

로그 싱크 스트림 app 종속성이있는 사용자 정의 Spring 클라우드 스트림 싱크가 RabbitMQ 중단 중에 RabbitMQ 연결을 잃어 버리고 5 회 연결 시도를 시도한 다음 해당 사용자를 중지합니다. RabbitMQ가 정상적으로 연결되면 앱을 수동으로 다시 시작해야 연결됩니다. rabbitMQ 바인딩 here의 기본 속성을 볼 때 간격 시간이 있지만