message-queue

    3

    1답변

    나는 Flask 앱을 ​​가지고 있는데, 이는 POST 핸들러와 일부 DB 삽입이있는 매우 기본적인 앱이다. DB 삽입은 셀러리를 사용하여 작업으로 설정됩니다. 셀러리 인스턴스 생성 및 작업 정의를 tasks.py 파일에 넣고 내 main.py 파일 (Flask 앱 작성 기능도 포함)에서 함수를 호출하면 out of context error이 표시됩니다.

    0

    1답변

    나는 rabbitmq 소비자에 대한 2 개 질문 (수신기)이 있습니다 이 어떻게 (정적 큐에서) 정의 할 수 있습니다 특정 대기열에 등록 된 소비자가 무엇을 그렇게 하나 개 소비자는 메시지 아래 인 경우 해당 소비자가 다시 올라온 후에도 계속 제공 될 것입니까? 아니면이를 달성 할 다른 방법이 있습니까? 소비자가 아직 생성되지 않은 대기열에 rabbitmq

    0

    1답변

    Java 클라이언트를 사용하여 RabbitMQ에서 기존 큐의 라우팅 키를 변경할 수 있습니까?

    23

    2답변

    메시징 시스템을 배우려고합니다. 나는 RabbitMq와 NServiceBus가 몇 군데에서 함께 사용하고있는 것을 발견했다. 내 질문은 내가 RabbitMQ를 사용하는 경우 왜 NServiceBus가 필요합니까? 반대로 NServiceBus는 할 수 있지만 RabbitMQ 또는 Kafka는 할 수없는 것은 무엇입니까? NServiceBus와 kafka를 함

    2

    1답변

    내 프로젝트의 메시지 중개 시스템으로 wso2 메시지 브로커를 사용하고 있습니다. WSO2 메시지 브로커를 사용하기 전에, 나는 WSO2 메시지 브로커 큐/주제와 관련된 예외적 인 경우 탐구 할 - 얼마나 많은 메시지 큐/토픽 소비자가 다운되어 게시자가 지속적으로/주제를 큐에 메시지를 전송하는 경우 저장할 수 있습니다 ? 대기열/주제를 사용할 수없고 게시자

    0

    1답변

    wso2 메시지 브로커에 MyFirstQueue 및 MySecondQueue 두 개의 대기열을 만들었습니다. here이라는 샘플 애플리케이션을 사용하여 메시지를 게시하고 사용할 수 있습니다. 이제 wso2 AndesAdminService 클래스를 사용하여 생성 된 큐 수, 각 큐의 메시지 수, 큐 삭제 등의 큐 관련 정보를 가져 오려고합니다. 내 코드에서.

    1

    1답변

    직접 교환으로 메시지를 보내는 여러 Java 클라이언트가 있습니다. 각 클라이언트가 ID를 라우팅 키로 사용하거나 헤더 교환으로 변경할 수있는 헤더로 게시하려고합니다. 해당 루트 키를 사용하여 큐에 바인딩 된 경우 다른 큐에 게시합니다. 그렇지 않으면 큐에 글로벌 큐에 게시됩니다. 내 질문에, 어떤 큐에 루팅 키/헤더를 루팅 할 수없는 클라이언트로부터 메시

    0

    1답변

    WSO2 Message Broker에서 내 프로젝트의 메시지 중개 시스템으로 사용하고 있습니다. 대기열 정보 (wso2mb 서버에서 생성 된 모든 대기열, 각 대기열의 메시지 수 등 정보)를 얻으려면 AndesAdminServics WSDL에서 클라이언트를 생성하고 내 API에서 getAllQueues() API를 호출하려고했습니다. 매번 이 요청 된 대상

    0

    1답변

    http://redis.io/commands/rpoplpush "RPOPLPUSH (또는 차단 변형에 대한 BRPOPLPUSH)이이 문제를 방지 할 수있는 방법을 제공합니다. 소비자가 메시지를 가져 오는 동시에 처리리스트에 밀어 그것은 사용 메시지가 처리되면 처리 목록에서 메시지를 제거하기위한 LREM 명령. " 이 안정적인 대기열 패턴을 사용하는 것이 좋

    0

    2답변

    사용자가 등록 할 수있는 웹 응용 프로그램이 있습니다. 확인 메일 (그리고 결국 sms)을 보내야합니다.이 경우 beanstalk 작업자 프로세스 또는 SNS와 함께 SQS를 사용하는 것이 더 좋을까요? 둘 이상의 이점이 있습니까?