Spring Boot 4 Complete Guide · บทเรียน

การผสานรวม RabbitMQ/Kafka

นำผู้ผลิตและผู้บริโภคข้อความมาใช้โดยใช้ Spring AMQP หรือ Spring Kafka เพื่อการสื่อสารที่เชื่อถือได้

บทเรียน 3 จาก 412 ขั้นตอน

การผสานรวม RabbitMQ/Kafka เป็นบทเรียน Spring Boot 4 Complete Guide ฟรีบน CoddyKit นี่คือบทเรียนที่ 3 จากทั้งหมด 4 บทเรียน คุณสามารถอ่านบทเรียนทั้งหมดด้านล่างฟรี — จากนั้นลองปฏิบัติด้วยตัวคุณเองในเบราว์เซอร์พร้อมตัวแก้ไขโค้ดในตัวและติวเตอร์ AI ตลอด 24/7 บทเรียนนี้เป็นส่วนหนึ่งของเส้นทางการเรียน Spring Boot 4 Complete Guide และความก้าวหน้าของคุณจะซิงค์ข้ามเว็บและแอป CoddyKit คอร์ส Spring Boot 4 Complete Guide มีบทเรียนทั้งหมด 4 บทเรียน

บางส่วนของบทเรียนนี้ยังไม่ได้รับการแปล และแสดงเป็นภาษาอังกฤษ

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!

ตอบคำถามในบทเรียนแบบโต้ตอบ

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!

เริ่มต้นได้ฟรี

เรียนรู้ Java ด้วย AI tutor — ฟรี

เขียนและเรียกใช้โค้ดจริงในเบราว์เซอร์ของคุณ รับความช่วยเหลือทันทีจาก AI tutor 24/7 และเรียนรู้ต่อจากที่คุณหยุดบนเว็บหรือในแอป

คอร์ส: 21
บทเรียน: 84

เริ่มเรียนฟรี ดูหลักสูตรเต็ม

คำถามที่พบบ่อย

บทเรียน “การผสานรวม RabbitMQ/Kafka” ฟรีหรือไม่

ใช่ — ข้อความเต็มของ “การผสานรวม RabbitMQ/Kafka” ฟรีให้อ่านที่นี่บนเว็บ เพื่อปฏิบัติแบบโต้ตอบ (ตัวแก้ไขโค้ดในตัวและติวเตอร์ AI ตลอด 24/7) และปลดล็อคส่วนที่เหลือของคอร์ส Spring Boot 4 Complete Guide ให้อัปเกรดเป็น CoddyKit PRO คอร์ส Spring Boot 4 Complete Guide มีบทเรียนทั้งหมด 4 บทเรียน

คุณจะเรียนรู้อะไรในบทเรียน “การผสานรวม RabbitMQ/Kafka”

นำผู้ผลิตและผู้บริโภคข้อความมาใช้โดยใช้ Spring AMQP หรือ Spring Kafka เพื่อการสื่อสารที่เชื่อถือได้ คุณปฏิบัติ Spring Boot 4 Complete Guide ด้วยโค้ดที่ใช้งานได้จริงที่คุณเรียกใช้โดยตรงในเบราว์เซอร์ และติวเตอร์ AI ตลอด 24/7 ตอบคำถามของคุณขณะที่คุณไปผ่านบทเรียน

คุณต้องมีประสบการณ์ก่อนที่จะเริ่มเรียน Spring Boot 4 Complete Guide หรือไม่

ไม่จำเป็นต้องมีประสบการณ์มาก่อน Spring Boot 4 Complete Guide บน CoddyKit ออกแบบมาสำหรับผู้เริ่มต้นไปจนถึงผู้เรียนขั้นสูง คุณสามารถเริ่มต้นที่นี่หรือเริ่มจากตัวแรกและเรียนด้วยความเร็วของคุณเอง นี่คือบทเรียนที่ 3 จากทั้งหมด 4 บทเรียน

บทเรียน “การผสานรวม RabbitMQ/Kafka” ใช้เวลานานแค่ไหน

บทเรียน CoddyKit ส่วนใหญ่ใช้เวลาประมาณ 5–10 นาที แต่ละบทเรียนจึงสั้นและเป็นแบบโต้ตอบ คุณสามารถก้าวหน้าอย่างต่อเนื่องและกลับมาเรียนต่อจากตรงที่เพิ่งหยุดบนเว็บและแอปได้เลย

ฉันเขียนและรันโค้ดในบทเรียน Spring Boot 4 Complete Guide นี้ได้ไหม

ได้ บทเรียน Spring Boot 4 Complete Guide ทุกบทมีตัวแก้ไขโค้ดในตัว คุณจึงเขียนและรันโค้ดจริงได้เลยในเบราว์เซอร์ และได้รับข้อเสนอแนะจาก AI ในทันที — ไม่ต้องติดตั้งในเครื่องของคุณ

บทเรียนทั้งหมดในหลักสูตรนี้

← กลับไปที่ Spring Boot 4 Complete Guide