message-queue

1열

1답변

많은 언어의 대기열 유형 (http://docs.oracle.com/javase/7/docs/api/java/util/Queue.html)이 있습니다. 대기열 유형을 구현하는 라이브러리 (첫 번째, 먼저 데이터 구조)를 찾을 수 없습니다. 대기열이 부족하여 나를 놀라게합니다. D가 대기열을 처리하는 다른 방법이 있습니까? 나는이 유사 할 것이라고 기대하는

0열

1답변

Wildfly 10의 원격 대기열에서 메시지를 소비하는 MDB의 현재 예제를 찾고

대기열을 정의하고 해당 대기열에 게시하고 MDB를 통해 대기열에서 수신하는 Wildfly 10 인스턴스가 있습니다. 그것은 성취되었습니다. 이제 다른 시스템에서 실행되는 두 번째 Wildfly 10 인스턴스를 추가하고 첫 번째 인스턴스에서 정의 된 동일한 (원격) 대기열에서 메시지를 받겠습니다. 2 일 동안이 작업을 수행하는 방법에 대한 예제를 찾아 보았습

0열

1답변

메시지 대기열을 사용하는 스레드 동기화가 올바르지 않습니다.

다음 코드는 Raymond's Pycon keynotes on cuncurrency에서 제공됩니다. 그것은 조금 긴, 그래서 나는 질문을 시작합니다 :는 큐에 함께 추가됩니다 하면 메시지 및 스레드가있는 오는 방법, 완료로 간주되기 전에 모두 인쇄한다 얼룩덜룩 한 인쇄 된? 스레드 초기화 사이에 100ms 지연을 추가하면이 문제가 해결되며 예상대로 출력됩니

1열

1답변

동일한 RabbitMQ 큐에서 여러 소비자를 실행하고 싶습니다.

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

0열

1답변

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

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

1열

1답변

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

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

0열

1답변

redis/kafka 구현이 중복 사용을 금지하는 방법

redis와 다른 대기열로 작업하는 동안 동일한 대기열의 두 소비자가 동일한 값을 가질 수 있는지 궁금합니다. 누구든지 redis 또는 kafka가이 문제를 어떻게 해결하고 성능이 어떻다는 것을 알고 있습니까?

0열

1답변

브로커에서 카프카를 섭취 하시겠습니까?

./bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test ./bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test kakfa가 동물원을 필요로하는 이유는 무엇입니까? 나는 중개인으로부터 카프카를 소비 할

1열

1답변

다중 소스 대기열 메시지 유형을 처리하는 방법

저는 일반적으로 병렬 프로그래밍에 다소 익숙하며 시스템이 대기하는 여러 유형의 메시지를 처리하는 방법을 이해하려고합니다. 이 질문은 주로 내 이해를 확인하기위한 것입니다. 내 특정 시스템은 Microsoft Concurrency Runtime (C++)을 사용하여 구현됩니다. 는 이러한 다른 두 개의 SO 문제가 발생 데 - 그것은 일반적인 접근 방식은 메

0열

1답변

제출 후 주문 보증이 포함 된 메시지 대기열

메시지를 소비자 ("근로자")가 순서대로 처리하는지 확인하는 대기열 처리 메커니즘을 사용해야하는 유스 케이스가 있습니다. 나는 과거에 RabbitMQ를 사용했으며 메시지를받은 순서를 보장합니다. 하지만 그 명령이 맞지 않으면 어떨까요? 메시지 [4, 5, 3, 2, 1]을 제출한다고 가정 해 봅시다. RabbitMQ 소비자는 메시지를 순서대로 처리합니다.