DEV Community: Sandro Souza

AMQP - Propriedades de Mensagem

Sandro Souza — Wed, 05 May 2021 19:30:03 +0000

COMPONENTES DE UMA MENSAGEM PUBLICADA

PROPRIEDADES (AMQP)

USO DA APLICAÇÃO

message-id short-string

Alguns tipo de mensagem necessitam de um identificador único para que os sistemas possam identificar esta mensagem individualmente a medida que passam por diversos sistemas.

correlation-id short-string

Embora não haja uma definição formal para o ID de correlação na especificação AMQP, uma opção é usá-lo para transportar um ID de transação ou outros dados semelhantes aos quais a mensagem está fazendo referência.

timestamp timestamp

A propriedade timestamp não tem definição formal, mas pode ser usado para definir quando a mensagem foi criada.
Uma opção é usá-la quando existe um acordo de nível de serviço (SLA) que seus processos precisam aplicar.

delivery-mode octet

O modo de entrega propriedade tem dois valores possíveis:

1 - Para uma mensagem não persistente (gravar em memória).
2 - Para uma mensagem persistente mensagem (gravar no disco).

app-id short-string
Útil para definir qual usuário que está publicando a mensagem. Uma opção é usá-la para o consumidor conseguir validar a origem da mensagem.

user-id short-string
Útil para definir qual usuário que está publicando a mensagem. Uma opção é usá-la para o consumidor conseguir validar o usuário que publicou a mensagem e realizar validações.

contentencoding short-string
Mensagens enviadas pelo AMQP não utiliza compressão por padrão. Isto pode ser problemático com mensagens grande quantidade de conteúdo, por exemplo usando XML, JSON ou YAML.
Desta forma especifique se o corpo da sua mensagem é codificado de alguma forma especial, como zlib, deflate, ou Base64

content-type short-string
Aplicação que especifica o tipo de messagem no corpo das mensagens usando MIME-TYPES (Json, Texto e etc..)

type short-string
Descreve o Tipo de Mensagem ou Payload da mensagem publicada. Uma opção é usá-la para determinar qual o formato de serialização utilizado na mensagem como:

headers table
Tabela de "chave/valor" de formato livre que você pode usar para adicionar metadados adicionais sobre a mensagem.
Sendo possível rotear com base nisso se
desejado.

priority octet
Propriedade para ordenação de prioridade em filas.
É definido como um número inteiro com valores possíveis de 0 a 9 a serem usados para priorização de mensagens em filas.
Conforme especificado, se uma mensagem com prioridade 9 for publicada, e subsequentemente, uma mensagem com prioridade 0 é publicada, um novo
o consumidor receberia a mensagem com a prioridade 0 antes da mensagem com um
prioridade de 9.

expiration short-string

Define o TTL (time to live) da mensagem indicando quando o mensagem irá expirar. Sendo definido um tempo em milissegundo.

Referencias

Messaging Patterns - Correlation Identifier
RabbitMQ in Depth

Integration Patterns (Integrações de Aplicações)

Sandro Souza — Tue, 16 Mar 2021 12:08:17 +0000

Em algum momento as aplicações para atender uma funcionalidade de negócio precisam se comunicar.

Para realizar esta integração existem múltiplas abordagens que podem ser resumidas em quatro estilos de integração.

Integração baseadas em "Arquivo"

Uma aplicação atua como "Publicador de Arquivos" criando ou atualizando arquivos em uma determinada pasta.
Outras aplicações observam a pasta para processar este arquivo.

Integração com "Banco de Dados Compartilhado"

Uma aplicação atua como "Publicador das Tarefas" adicionando um item a uma tabela de 'tarefas' em um banco de dados compartilhado.

Outra aplicação atua como "Consumidor" observando a tabela de 'Tarefas' aguardando itens novos ou não processados.
Processando estes itens e gravando o resultado do processamento na mesma tabela ou uma tabela diferente.

Integração com "Conexão Direta"

Neste padrão o "Publicador" e o "Consumidor" podem se alternar no qual ambos pontos da extremidade podem enviar mensagens para o outro de forma independente.

O tipo de conexão pode ser por exemplo: "TCP/IP" ou "Named Pipes". E a mensagem enviada pode alternar em diversos formatos (Binary, XML, Json e outros).

Após estabelecer conexão são enviadas mensagens entre as aplicações ou serviços.

Integração com "Mensagens assíncronas usando Message Broker"

Aplicações atuam como "Publicador de Mensagens" adicionando mensagens em qualquer formato em uma Aplicação intermediária chamada "Message Brokers ou Message Buses".

A aplicação de "Message Brokers" recebe as mensagens de uma origem e encaminha para um "Alvo" ou "Aplicação consumidora".

Este padrão apresenta algumas vantagens:

Desacoplar 'Publicador' e 'Consumidor'.
Fornecer um modo confiável para processar tarefas assincronamente e se comunicar.
Fornece um modo de implementar uma arquitetura de escalabilidade horizontal.
Fornece um modo eficiente de extração de dados armazenados (Data Store Polling).

Referências

Introduction to Integration Styles

Enterprise Integration Patterns

Chapter 2: "Integration Styles" - Book Enterprise Integration Patterns: Designing, Building, and Deploying

Agregados (DDD)

Sandro Souza — Mon, 01 Feb 2021 12:18:51 +0000

Definição

É maneira de reduzir a complexidade técnica.

É um cluster de objetos de domínio que podem ser tratados como uma única unidade.

Não existe uma classe implementando um agregado.

Representa um conceito do domínio e não um container de itens.

Definir agregados é reversível e uma atividade continua.

Definir Agregados

Limites Transacionais
- Definir a transações conforme a força dependência
Dependências
- Definir tipos de relacionamentos (UML) e Força de dependência
Coleções
- Quantidade de agregados equivale a numero de coleções em banco de dados NoSql
Pensando em Definições Técnicas
- Definir um agregado é um processo continuo influenciado pelo feedback da sua implementação. "Persistência", "Consistência" e "Concorrência" são detalhes de implementação que podem ser difícil de acertar e pode fazer com que você repense seus limites de agregados.

Raiz do Agregado

Ponto de Entrada (Classe) para acesso ao agregado.
- Fornece o nome conceitual do agregado.
Coordena todas as mudanças do agregado
- Assegura que todos os clientes não definam o agregado para um estado inconsistente.

Performance

Agregados grandes pode degradar a performance.
- Devido a quantidade de informações a serem carregadas e salvas.

Definição de Entidade

Surge "Substantivos" surgem as "Entidades"
Podem mudar ao longo do tempo (Utiliza ID)

Informações

Propriedade de navegação
- O Id é uma propriedade para acessar informação

Recomendações

Refatorar Sempre

Definir agregados é uma atividade continua, não coloque sobre você a pressão para criar um definição de agregados perfeita na tentativa inicial. Quanto mais melhorias mais você saberá sobre o Domínio.

Transação

Se você precisa alterar mais de um agregado em uma transação, é um sinal que os limites do seu agregado possa ser melhor alinhado com o problema do domínio.

Interfaces com o Usuário

Agregados não devem ser planejados com base nas Interfaces com o Usuário (UIs).

Banco de Dados

Os associações do modelo de dados não pode influenciar as associações entre os objetos do domínio. Os objetos não são os mesmos como as tabelas do banco de dados. Modelos de dados representam um relacionamento de "Composição" para suportar integridade referencial e construir relatórios para BI (Business Intelligence).

Fatores Técnicos

Fatores técnicos afetam seus agregados principalmente "Performance" e "Escabilidade".

Se você está salvando ou carregando agregados acima das definições de performance pode representar que seu agregado está muito grande.

Referencias

Livro Patterns-Principles-Practices-Domain-Driven-Design

Agregados | DDD do jeito certo | Parte 06

DDD_Aggregate | Martin Fowler

Domain model purity and lazy loading.)

DEV Community: Sandro Souza

AMQP - Propriedades de Mensagem

COMPONENTES DE UMA MENSAGEM PUBLICADA

PROPRIEDADES (AMQP)

USO DA APLICAÇÃO

Referencias

Integration Patterns (Integrações de Aplicações)

Integração baseadas em "Arquivo"

Integração com "Banco de Dados Compartilhado"

Integração com "Conexão Direta"

Integração com "Mensagens assíncronas usando Message Broker"

Referências

Agregados (DDD)

Definição

Definir Agregados

Limites Transacionais

Dependências

Coleções

Pensando em Definições Técnicas

Raiz do Agregado

Ponto de Entrada (Classe) para acesso ao agregado.

Coordena todas as mudanças do agregado

Performance

Definição de Entidade

Informações

Recomendações

Refatorar Sempre

Transação

Interfaces com o Usuário

Banco de Dados

Fatores Técnicos

Referencias