Spring Boot 4 Complete Guide · Aula

Integração com RabbitMQ/Kafka

Implemente produtores e consumidores de mensagens usando Spring AMQP ou Spring Kafka para uma comunicação confiável.

Aula 3 de 412 etapas

Integração com RabbitMQ/Kafka é uma aula grátis de Spring Boot 4 Complete Guide no CoddyKit. Esta é a aula 3 de 4. Você pode ler a aula completa abaixo gratuitamente — depois pratica ao vivo no navegador com um editor de código integrado e um tutor de IA 24/7. Faz parte do caminho de aprendizado de Spring Boot 4 Complete Guide, e seu progresso é sincronizado entre a web e o app CoddyKit. O curso de Spring Boot 4 Complete Guide inclui 4 aulas no total.

Partes desta aula ainda não foram traduzidas e aparecem em inglês.

Decoupling with Message Brokers

In modern applications, components often need to communicate without being tightly coupled. This is where message brokers come in!

They act as intermediaries, allowing different parts of your system to send and receive messages asynchronously. This improves reliability and scalability.

Decoupling: Services don't need to know about each other.
Reliability: Messages are stored until processed.
Scalability: Can handle high volumes of messages.

Spring's Messaging Support

Spring Boot provides excellent support for integrating with various message brokers. It offers high-level abstractions to simplify sending and receiving messages.

Two popular choices we'll explore are:

RabbitMQ: A general-purpose message broker (AMQP).
Apache Kafka: A distributed streaming platform.

Spring provides dedicated modules: Spring AMQP for RabbitMQ and Spring Kafka for Kafka.

Spring AMQP for RabbitMQ Setup

To use RabbitMQ with Spring Boot, you need to add the Spring AMQP starter dependency to your project (e.g., in pom.xml or build.gradle):

org.springframework.boot:spring-boot-starter-amqp

You'll also configure connection details in your application.properties or application.yml, typically specifying the host and port of your RabbitMQ server.

RabbitMQ Producer Example

Sending messages to RabbitMQ is easy with Spring's RabbitTemplate. It handles the low-level details for you.

The code below demonstrates sending a simple string message to a queue named 'coddykit-queue'.

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;

@SpringBootApplication
public class Main {

  public static void main(String[] args) {
    SpringApplication.run(Main.class, args);
  }

  @Bean
  public CommandLineRunner runner(
      RabbitTemplate rabbitTemplate) {
    return args -> {
      System.out.println("Sending to RabbitMQ...");
      rabbitTemplate.convertAndSend(
          "coddykit-queue", "Hello from CoddyKit!");
      System.out.println("Message sent!");
    };
  }
}

RabbitMQ Consumer Example

To receive messages, you use the @RabbitListener annotation. Spring AMQP automatically sets up the necessary infrastructure to listen to a specified queue.

This listener will process messages from 'coddykit-queue' as they arrive.

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class Main {

  public static void main(String[] args) {
    SpringApplication.run(Main.class, args);
  }

  @RabbitListener(queues = "coddykit-queue")
  public void listen(String message) {
    System.out.println(
        "Received RabbitMQ message: '" + message + "'");
  }
}

Spring Kafka Setup

For Kafka integration, you'll need to add the Spring Kafka starter dependency:

org.springframework.boot:spring-boot-starter-kafka

This dependency includes spring-kafka and auto-configures a lot for you. In your application.properties, you'll configure your Kafka broker addresses (e.g., spring.kafka.bootstrap-servers=localhost:9092).

Kafka Producer Example

Spring Kafka provides KafkaTemplate for sending messages to Kafka topics. It's conceptually similar to RabbitTemplate but for Kafka.

This example sends a message to the Kafka topic 'coddykit-topic'.

import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.kafka.core.KafkaTemplate;

@SpringBootApplication
public class Main {

  public static void main(String[] args) {
    SpringApplication.run(Main.class, args);
  }

  @Bean
  public CommandLineRunner runner(
      KafkaTemplate<String, String> kafkaTemplate) {
    return args -> {
      System.out.println("Sending to Kafka...");
      kafkaTemplate.send(
          "coddykit-topic", "Hello from CoddyKit (Kafka)!");
      System.out.println("Message sent!");
    };
  }
}

Kafka Consumer Example

Consuming messages from Kafka is done using the @KafkaListener annotation. You must specify the topic(s) to listen to and a groupId.

The groupId is essential for Kafka consumers to manage message offsets and distribute partitions.

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.kafka.annotation.KafkaListener;

@SpringBootApplication
public class Main {

  public static void main(String[] args) {
    SpringApplication.run(Main.class, args);
  }

  @KafkaListener(
      topics = "coddykit-topic", groupId = "coddykit-group")
  public void listen(String message) {
    System.out.println(
        "Received Kafka message: '" + message + "'");
  }
}

RabbitMQ vs. Kafka: Key Differences

While both are message brokers, they serve different primary use cases:

RabbitMQ: Best for traditional message queuing, task queues, and point-to-point communication. Messages are typically consumed once and removed from the queue.
Kafka: Designed for high-throughput, fault-tolerant event streaming. Messages are persisted in logs and can be consumed multiple times by different consumer groups.

Choosing the Right Broker

Your choice between RabbitMQ and Kafka depends heavily on your application's specific needs:

Use RabbitMQ for reliable task distribution, inter-service communication where messages need assured delivery to one consumer, or complex routing logic.
Use Kafka for building real-time data pipelines, event sourcing, log aggregation, or when you need to process streams of data multiple times.

Both are powerful, but optimized for different scenarios!

Messaging Integration Quiz

You've learned how to integrate Spring Boot with RabbitMQ and Kafka. Let's test your knowledge!

Responda na aula interativa

Lesson Recap & Next Steps

Great job! You've learned how to integrate Spring Boot with two powerful message brokers: RabbitMQ and Kafka.

We covered setting up dependencies for Spring AMQP and Spring Kafka.
You saw practical examples of creating both producers (sending messages) and consumers (receiving messages) for each broker.
Finally, we discussed the key differences and use cases to help you choose the right tool for your project.

Keep exploring these technologies to build robust, scalable, and decoupled applications!

Grátis para começar

Aprenda Java com um tutor de IA — grátis

Escreva e execute código real no seu navegador, obtenha ajuda instantânea de um tutor de IA 24/7 e continue de onde parou na web ou no app.

Cursos: 21
Aulas: 84

Começar a aprender grátis Ver o curso completo

Perguntas Frequentes

A aula “Integração com RabbitMQ/Kafka” é grátis?

Sim — o texto completo de “Integração com RabbitMQ/Kafka” é grátis para ler aqui na web. Para praticá-la interativamente (um editor de código integrado e um tutor de IA 24/7) e desbloquear o restante do curso de Spring Boot 4 Complete Guide, atualize para CoddyKit PRO. O curso de Spring Boot 4 Complete Guide inclui 4 aulas no total.

O que vou aprender em “Integração com RabbitMQ/Kafka”?

Implemente produtores e consumidores de mensagens usando Spring AMQP ou Spring Kafka para uma comunicação confiável. Você pratica Spring Boot 4 Complete Guide com código prático que executa diretamente no navegador, e um tutor de IA 24/7 responde suas dúvidas enquanto trabalha na aula.

Preciso ter experiência prévia para começar Spring Boot 4 Complete Guide?

Nenhuma experiência prévia é necessária. Spring Boot 4 Complete Guide no CoddyKit é estruturado para alunos iniciantes até avançados, então você pode começar aqui ou desde o início e aprender no seu ritmo. Esta é a aula 3 de 4.

Quanto tempo leva a aula “Integração com RabbitMQ/Kafka”?

A maioria das aulas CoddyKit leva cerca de 5–10 minutos. Cada uma é compacta e interativa, então você faz progresso constante e retoma exatamente de onde parou entre web e app.

Posso escrever e executar código nesta aula de Spring Boot 4 Complete Guide?

Sim. Cada aula de Spring Boot 4 Complete Guide inclui um editor de código integrado, então você escreve e executa código real direto no navegador e recebe feedback de IA instantaneamente — nenhuma configuração local necessária.

Todas as aulas deste curso

← Voltar para Spring Boot 4 Complete Guide