Está lib tem como objetivo facilitar o processo de implementação de mensageria aos projetos legados.
Para adicionar mensageria ao seu projeto, basta adicionar a lib:
<dependency>
<groupId>com.nortetec</groupId>
<artifactId>custom-messaging</artifactId>
<version>1.0.0</version>
</dependency>
Depois, deve-se encontrar a classe de configuração da aplicação (ConfiguracaoAplicacao.java) que se encontra no modulo api das aplicações, e adicione os seguintes codigos:
Para Kafka: @EnableCustomKafka
Para RabbitMq: @EnableCustomRabbitMQ
Para que as aplicações possam consumir e produzir eventos, se faz necessario a criacao
de um arquivo de configuração chamado mensageria.properties.
Com esse arquivo é possivel configurar as seguintes propriedades:
- Para o utilização do KAFKA
mensageria.kafka.host=<HOST>
mensageria.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
mensageria.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
mensageria.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
mensageria.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
- Para utilização do RABBITMQ
mensageria.rabbitmq.host=<HOST>
mensageria.rabbitmq.port=<PORTA>
mensageria.rabbitmq.usuario=<USUARIO_APLICACAO>
mensageria.rabbitmq.senha=<SENHA>
mensageria.rabbitmq.projetoTag=<NOME_PROJETO_MAVEN>
Para ignorar os logs gerados no weblogic, adicione no arquivo de logs os comandos abaixo:
log4j.logger.org.springframework.amqp.rabbit.listener=off
log4j.logger.org.springframework.kafka=off
log4j.logger.org.apache.kafka.clients=off
Para criação de um consumidor RabbitMQ basta usar o modelo abaixo:
@RabbitListener(queues = "<NOME-DA-FILA>")
public void consumeMessage(@Payload Message mensagem) {
logger.info("Payload recebido: {} ", new String(mensagem.getBody()));
}
Para criação de um produtor RabbitMQ basta usar o modelo abaixo:
@Autowired
private RabbitTemplate rabbitTemplate;
public void send(String order) {
rabbitTemplate.convertAndSend(<NOME-DA-FILA>, order);
}
Para criação de um consumidor Kafka basta usar o modelo abaixo:
@KafkaListener(topics = "<NOME-DO-TOPICO>", groupId = "<NOME-DA-APLICACAO>")
public void receiveMessage(ConsumerRecord<String, String> payload) {
logger.info("Tópico: {}", payload.topic());
logger.info("key: {}", payload.key());
logger.info("Headers: {}", payload.headers());
logger.info("Partion: {}", payload.partition());
logger.info("Order: {}", payload.value());
logger.info("Aplicacao: {}", getProjeto());
}
Para criação de um produtor Kafka basta usar o modelo abaixo:
@Autowired
private KafkaTemplate<String, String> kafkaTemplate;
public void send(String evento){
kafkaTemplate.send("<NOME-DO-TOPICO>", evento);
}
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent