AWS SQS가 왜 그렇게 느린가요?

Question

나는 메시지를 보내고 SQS 큐에서 메시지를받는 데 걸리는 시간을 테스트 해왔다. 평균적으로 800-1200ms가 소요되는데, 이것은 오랜 시간이 걸리는 것처럼 보입니다. 여기 테스트를위한 코드가있다. 내가 틀린 일을하고 있는지 말해줘.

var t0; 
sendMessage('hello'); 

function sendMessage(message){ 

    var params = { 
     MessageBody: message, 
     QueueUrl: queueUrl 
    }; 
    t0 = now(); 
    sqs.sendMessage(params, function(err,data){ 
     if(err){ 
      throw err; 
     } else { 
      console.log("Message Send Confirmation"); 
     } 
    }); 
    unbatch(); 
} 

async function unbatch(){ 

    var params = { 
     QueueUrl: queueUrl, 
     MaxNumberOfMessages: 10 
    }; 
    var go = true; 
    while(go){ 
     console.log("Polling..."); 
     sqs.receiveMessage(params, function(err, data){ 
      if(data.Messages){ 
       console.log("Message Received"); 
       console.log("Total Time: " + ((now() - t0)/1000)); 
       go = false; 
       var deleteParams = { 
        QueueUrl: queueUrl, 
        ReceiptHandle: data.Messages[0].ReceiptHandle 
       }; 
       sqs.deleteMessage(deleteParams, function(err, data) { 
        if (err) { 
         console.log("Delete Error", err); 
        } else { 
         console.log("Message Deleted"); 
        } 
       }); 
      } 
     }); 
     await sleep(1); 
    } 
} 

function sleep(ms){ 
    return new Promise(resolve => setTimeout(resolve, ms)); 
} 

메시지를 보내고 즉시 밀리 초마다 메시지를 받기 시작합니다. 수신되면 시간을 계산합니다. 시간이 많이 걸리지 않아야합니까?

Answer 1

대기열을 사용하는 이유는 성능 향상이 아니라 복원력 때문입니다.

큐는 많은 문제를 해결하고 연결이 끊어진 시스템간에 비동기 통신을 제공하므로 시스템을 실제로 확장 할 수 있으며 시스템 장애시 메시지가 "손실"되지 않도록 향상된 복원력을 제공합니다.

대기열을 사용하여 작업 할 때는 eventual consistency이라는 개념을 중심으로 시스템을 설계하는 것이 좋습니다. 그러면 메시지가 결국 도착하고 처리되지만 예상 한 순서대로 처리되지 않을 수도 있습니다. 당신이 매우 높은 IOPS를 찾고 있다면

기능과 같은 속도, 주문, 재 시도 등은 아마도 큐 당신이 원하는 것을하지 큐 구현 (RabbitMq 등 SQS, 카프카,)

에 따라 다를 것입니다.