한 번에 하늘빛 서비스 버스 대기열 지우기

Question

우리 프로젝트에서 서비스 버스 대기열을 사용하고 있습니다. 관리자가 큐를 지우도록 선택하면 큐에서 모든 메시지를 제거하는 기능이 필요합니다. 그물을 검색했지만 QueueClient 클래스 안에서이 작업을 수행하는 기능을 찾을 수 없습니다.

모든 메시지를 하나씩 팝핑 한 다음 큐를 지우려면 완료 표시를해야합니까? 아니면 더 좋은 방법이 있습니까? 당신이 Receive() 방법은 큐에 나타나는 다른 메시지 기다리고있을 것 같은, 큐가 비어되면 코드가 무기한 실행하게됩니다처럼 while 루프 내에서 Receive() 방법을 사용하여

QueueClient queueClient = _messagingFactory.CreateQueueClient(
           queueName, ReceiveMode.PeekLock); 

BrokeredMessage brokeredMessage = queueClient.Receive(); 

while (brokeredMessage != null) 
{ 
    brokeredMessage.Complete(); 
    brokeredMessage = queueClient.Receive(); 
} 

Answer 1

.

자동으로 실행하려면 Peek() 메서드를 사용해보십시오. 예를 들어

: hocho 언급 한대로이 ReceiveMode.ReceiveAndDelete으로이 간단 다시 만들 수 있습니다

while (queueClient.Peek() != null) 
{ 
    var brokeredMessage = queueClient.Receive(); 
    brokeredMessage.Complete(); 
} 

.

Answer 2

Azure-ServiceBus 대기열의 경우 n - 메시지를 수신 할 수있는 ReceiveBatch-method이 있습니다. ReceiveMode.ReceiveAndDelete과 결합하면보다 효율적으로 큐를 지울 수 있습니다.

경고 메시지의 n이 반환 될 수 있지만이를 보장하지는 않습니다. 또한 메시지 일괄 처리 크기 인 256K에 대한 제한이 있습니다.

Answer 3

사용 :

• 두 (@ScottBrady에서와 @participant) 방식
• 그리고 MessageReceiver 추상화를

당신이 서비스 버스 대기열 또는 주제를 비우는 방법을 쓸 수 있습니다/가입 :

MessageReceiver messageReceiver = ... 
while (messageReceiver.Peek() != null) 
{ 
    // Batch the receive operation 
    var brokeredMessages = messageReceiver.ReceiveBatch(300); 

    // Complete the messages 
    var completeTasks = brokeredMessages.Select(m => Task.Run(() => m.Complete())).ToArray(); 

    // Wait for the tasks to complete. 
    Task.WaitAll(completeTasks); 
} 

Answer 4

가장 빠른 방법은 푸른 SERV를 청소 iceBus 대기열은 매우 짧은 DefaultMessageTimeToLive을 설정하고 몇 초 기다렸다가 강제로 대기열에서 수신을 시도한 다음 초기화하여 DefaultMessageTimeToLive을 복원합니다.

당신은 포털에서 또는 코드에서 그것을 할 수 있습니다 : 당신이 nuget에서 WindowsAzure.Storage 라이브러리를 사용하는 경우 전체 큐를 취소하는 간단한 Clear() 방법이있다

var namespaceManager = NamespaceManager.CreateFromConnectionString(connectionString); 
var queueDescription = _namespaceManager.GetQueue(queueName); 
var queueClient = QueueClient.CreateFromConnectionString(connectionString, queueName, ReceiveMode.ReceiveAndDelete); 

var dl = queueDescription.EnableDeadLetteringOnMessageExpiration; 
var ttl = queueDescription.DefaultMessageTimeToLive; 

queueDescription.EnableDeadLetteringOnMessageExpiration = false; 
queueDescription.DefaultMessageTimeToLive = TimeSpan.FromSeconds(1); 

Thread.Sleep(5000); 
var dumy = queueClient.ReceiveBatch(200, TimeSpan.FromSeconds(1)).ToArray(); 

queueDescription.EnableDeadLetteringOnMessageExpiration = dl; 
queueDescription.DefaultMessageTimeToLive = ttl; 

Answer 5

. 해당 라이브러리의 Microsoft.Windows.Azure.Queue 클래스를 사용하여 큐를 관리합니다. 그렇지 않은 경우 API per their documentation을 통해 액세스 할 수 있습니다. Azure 라이브러리에있는 메소드가 얼마나 오래 있었는지는 모르지만 질문이 원래 요청되었을 때 존재하지 않았지만 REST API는 적어도 2014 년 이후에 다시 발생합니다. this Azure feedback post

전체가 채워집니다.애저 라이브러리 큐를 취소 NET 코드는 다음과 같습니다

string connectionString = "YourAzureConnectionStringHere"; 
string queueName = "YourWebJobQueueName"; 
CloudStorageAccount storageAccount = CloudStorageAccount.Parse(connectionString); 

// Create the queue client, then get a reference to queue 
CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient(); 
queue = queueClient.GetQueueReference(GetQueueName(queueName)); 

// Clear the entire queue 
queue.Clear(); 

Answer 6

내가 ReceiveAndDelete, PrefetchCount, ReceiveBatchAsync의 조합, 간단한 진리 루프를 사용하여 좋은 결과를 가지고보다는 픽을 사용하고 있습니다. 아래 MessagingFactory와 예 :

var receiverFactory = MessagingFactory.CreateFromConnectionString("ConnString"); 
var receiver = receiverFactory.CreateMessageReceiver("QName", ReceiveMode.ReceiveAndDelete); 
receiver.PrefetchCount = 300; 

bool loop = true; 
while (loop) 
{ 
    var messages = await receiver.ReceiveBatchAsync(300, TimeSpan.FromSeconds(1)); 
    loop = messages.Any(); 
} 

만 WindowsAzure.ServiceBus Nuget 패키지가 필요합니다.