C# 응용 프로그램에서 ActiveMQ에서 오는 메시지 양을 어떻게 조절할 수 있습니까?

Question

.Net 프로그램에서 ActiveMQ를 사용하고 있으며 메시지 이벤트가 넘쳐납니다.

즉, 큐 이벤트 'onMessage (IMessage receivedMsg)'를 얻으면 메시지를 내부 스레드로 보내고 X 스레드는 해당 메시지를 처리합니다.

처음에는 'AcknowledgementMode.AutoAcknowledge'를 사용하여 세션을 만들었으므로 대기열의 모든 메시지가 빨려 들어서 메모리 대기열에 들어갔다는 것을 추측하고 있습니다 (충돌로 인해 모든 것이 위험합니다). 잃어버린).

그래서 세션을 만들 때 'AcknowledgementMode.ClientAcknowledge'를 사용했고 작업자가 메시지를 준비 할 때 메시지의 'commit()'메서드를 호출합니다. 그러나 여전히 모든 메시지가 대기열에서 빠져 나옵니다.

X 개의 메시지 만 처리 중이거나 내부 대기열에 있고 모든 것이 '다운로드 중'이 아니라는 것을 어떻게 구성 할 수 있습니까?

Answer 1

.NET 4.0에 있습니까? BlockingCollection을 사용할 수 있습니다. 포함될 수있는 최대량으로 설정하십시오. 스레드가 초과 요소를 넣으려고하면 모음이 임계 값 아래로 다시 떨어질 때까지 추가 작업이 차단됩니다.

어쩌면 스로틀 링을 위해 그렇게 할 수 있을까요?

또한 Rx 프레임 워크에서 스로틀 링을위한 API가 있지만 구현 방법을 모르겠습니다. 대기열 소스를 Observable로 구현하면이 API를 사용할 수있게되지만 이것이 필요한지는 알 수 없습니다.

Answer 2

클라이언트 프리 페치를 설정하여 클라이언트가 전송할 메시지 수를 제어 할 수 있습니다. Session이 Auto Ack에있을 때 클라이언트는 onMessage 콜백을 통해 또는 동기 수신을 통해 앱에 전달 된 메시지 만 확인합니다. 기본적으로 클라이언트는 브로커에서 1000 개의 메시지를 미리 가져오고, 클라이언트가 다운되면 다른 클라이언트에게 다시 배달됩니다. 그렇지 않으면 대기열이라는 주제로 폐기됩니다. 프리 페치를 1로 설정하면 클라이언트는 서버로부터 하나의 메시지 만 전송되고 onMessage 콜백이 완료 될 때마다 클라이언트가 해당 메시지를 확인한 것처럼 새 메시지가 발송됩니다 (즉, 세션이 자동 수신인 경우). 방법.

모든 옵션에 대한 NMS 구성 페이지를 참조하십시오 http://activemq.apache.org/nms/configuring.html

감사

팀을. FuseSource.com