FIFO (First In First Out) quando o Consumer lê as mensagens no SQS na mesma ordem que foram produzidas pelo Producer.

Este modelo é recomendado em cenários de orquestração, isto é, processa a informação A, B, C, ..., Z, onde Z depende da A, B, C.
Problema: quando uma informação não consegue ser processada onde o consumer não ter uma resiliência no tratamento de mensagens inválidas, ocorrerá o enfileiramento das demais mensagens, travando o processamento e requer uma ação humana para correção do problema.

Se você é plantonista e já atendeu este tipo de problema no meio da madrugada, vai perceber com o tempo que o FIFO não faz muito sentido em serviços de mensageria, e as vezes é melhor descartar 1 mensagem do que uma interrupção generalizada do serviço.

Criando uma fila SQS

No Console AWS, acesse Amazon SQS » Filas > Criar fila. Defina o modelo padrão e um nome para a fila.

Tempo limite de visibilidade: Tempo que uma mensagem fica "reservada" para um determinado consumer, quando há uma concorrência na leitura da fila.

Atraso de entrega: É o tempo que a mensagem pode chegar atrasada numa fila. Num cenário de consumer, essa mensagem só ficará disponível após esse atraso.

Tempo espera do recebimento da mensagem: Tempo que cada ciclo da sonda disponível no console aws ficará capturando novas mensagens.

Período da retenção da mensagem: é o tempo máximo que a mensagem fica armazenada no SQS, sendo excluída automaticamente após o período.

Tamanho máximo da mensagem: corresponde ao tamanho máximo de cada mensagem, 256kB.

Após a criação da fila, surgirá a URL, informação necessária para o desenvolvimento abaixo.

Preparando o ambiente

Caso você não tenha instalado o AWSCLI ou realizado um "aws configure", ...

1. Abra o diretório %userprofile% e crie a pasta .aws
2. Crie os arquivos config e credentials

access_key e secret_key são fornecidos em sua conta pessoal na AWS. Declare tais valores no arquivo credentials.

Este procedimento é necessário para que todas as aplicações executadas em seu computador, se conectem automaticamente as suas aplicações na AWS.

Bora codar

git clone https://github.com/leobreda/aws-sqs.git

Abra o ConsoleSQS.sln no Visual Studio

Na classe Program.cs, atualize a URL_SQL com a URL correspondente da fila.

private static string URL_SQS = "https://url-sqs-aqui";

Produzindo mensagens

Execute o aplicativo no Visual Studio. Escolha a opção 1 e aguarde o término do processamento.

Volte para o console AWS e vá até a opção Enviar e receber mensagens para surgir as mensagens produzidas pelo aplicativo.

Voltando ao aplicativo, selecione a opção 2 para criar uma mensagem próxima ao limite máximo (256kB). Volte ao console AWS e procure localizar a mensagem de aprox 240kB

Voltando ao aplicativo, selecione a opção 3 para LER e LIMPAR a fila. Volte ao console AWS e verá que a fila foi limpada.

Informações técnicas

Ler uma mensagem na fila não significa que a mensagem será excluída.
Para manter a mensagem na fila, comente o método DeleteMessageAsync.

client.DeleteMessageAsync(URL_SQS, msg.Messages[i].ReceiptHandle).Wait();

Cada conexão como consumer na fila tem um custo. Você pode ler até 10 mensagens por conexão. Mantenha esse número no máximo para reduzir a quantidade de leituras.

Você pode manter o método ReceiveMessageAsync conectado na fila, por até 20 segundos, "esperando" novas mensagens quando a fila estiver vazia. Tal comportamento é útil para reduzir conexões enquanto a fila estiver com baixo volume de mensagens não consumidas.

private static int MENSAGENS_LEITURA = 10;
private static int SEGUNDOS_QUEUE = 20;
...
return await sqsClient.ReceiveMessageAsync(new ReceiveMessageRequest
{
	QueueUrl = URL_SQS,
	MaxNumberOfMessages = MENSAGENS_LEITURA,
	WaitTimeSeconds = SEGUNDOS_QUEUE
});

Links úteis

Amazon Simple Queue Service Documentation: https://docs.aws.amazon.com/sqs/index.html

Managing large Amazon SQS messages using Amazon S3: https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-s3-messages.html

Acessar todos os artigos »