ตัวแลกเปลี่ยน Topic สำหรับการกำหนดเส้นทางที่ยืดหยุ่น
เชี่ยวชาญตัวแลกเปลี่ยน Topic สำหรับรูปแบบการกำหนดเส้นทางที่ซับซ้อนด้วยการจับคู่ไวลด์การ์ด ออกแบบโครงสร้างการกำหนดเส้นทางข้อความที่ยืดหยุ่นและขยายระบบได้
ตัวแลกเปลี่ยน Topic สำหรับการกำหนดเส้นทางที่ยืดหยุ่น เป็นบทเรียน RabbitMQ Messaging & Async Systems ฟรีบน CoddyKit นี่คือบทเรียนที่ 3 จากทั้งหมด 4 บทเรียน คุณสามารถอ่านบทเรียนทั้งหมดด้านล่างฟรี — จากนั้นลองปฏิบัติด้วยตัวคุณเองในเบราว์เซอร์พร้อมตัวแก้ไขโค้ดในตัวและติวเตอร์ AI ตลอด 24/7 บทเรียนนี้เป็นส่วนหนึ่งของเส้นทางการเรียน RabbitMQ Messaging & Async Systems และความก้าวหน้าของคุณจะซิงค์ข้ามเว็บและแอป CoddyKit คอร์ส RabbitMQ Messaging & Async Systems มีบทเรียนทั้งหมด 4 บทเรียน
บางส่วนของบทเรียนนี้ยังไม่ได้รับการแปล และแสดงเป็นภาษาอังกฤษ
Topic Exchange: Flexible Routing
Welcome to the Topic Exchange! This exchange type offers the most flexible message routing, letting you send messages to queues based on complex patterns.
Unlike the simple Fanout or direct-match Direct exchange, Topic exchanges use special wildcards in routing keys to match messages dynamically.
Understanding Topic Routing Keys
With a Topic exchange, routing keys aren't exact matches. They are strings made of words separated by dots (.), much like parts of a filename or URL.
- Example:
animal.rabbit.fast - Example:
log.error.database
Each word provides a level of detail, allowing for hierarchical routing.
The Single-Word Wildcard: `*`
The asterisk (*) wildcard matches exactly one word in a routing key segment.
- Binding key:
animal.*.fastmatchesanimal.rabbit.fast - Binding key:
animal.*.fastdoes not matchanimal.dog.lazy.fast(too many words) - Binding key:
*.error.*matcheslog.error.database
It's great for matching a specific position in the key.
The Zero-or-More Wildcard: `#`
The hash (#) wildcard matches zero or more words in a routing key. It's much more powerful than *.
- Binding key:
log.#matcheslog.error,log.info.web,log.debug.cache.entry - Binding key:
animal.#matchesanimal.rabbit,animal.cat.sleepy
Use # to capture all messages that start with a certain pattern.
Producer: Declaring Topic Exchange
First, our producer needs to declare the Topic exchange. The type is simply "topic".
Try running this snippet to set up the exchange:
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
public class TopicProducerSetup {
private static final String EXCHANGE_NAME = "topic_logs";
public static void main(String[] argv) throws Exception {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost"); // Connect to local RabbitMQ
try (Connection connection = factory.newConnection();
Channel channel = connection.createChannel()) {
channel.exchangeDeclare(EXCHANGE_NAME, "topic");
System.out.println("Topic exchange '" + EXCHANGE_NAME + "' declared.");
}
}
}Producer: Sending Messages
Now, let's send some messages using different routing keys. The exchange will use these keys to decide which queues receive the messages.
Notice how the keys are dot-separated, allowing for detailed categories.
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.nio.charset.StandardCharsets;
public class TopicMessageSender {
private static final String EXCHANGE_NAME = "topic_logs";
public static void main(String[] argv) throws Exception {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
try (Connection connection = factory.newConnection();
Channel channel = connection.createChannel()) {
channel.exchangeDeclare(EXCHANGE_NAME, "topic");
sendMessage(channel, "animal.rabbit.fast", "A fast rabbit runs.");
sendMessage(channel, "animal.cat.sleepy", "A sleepy cat naps.");
sendMessage(channel, "log.error.db", "Database connection failed!");
sendMessage(channel, "log.info.web", "User logged in.");
System.out.println("Sent various topic messages.");
}
}
private static void sendMessage(Channel channel, String routingKey, String message) throws Exception {
channel.basicPublish(EXCHANGE_NAME, routingKey, null, message.getBytes(StandardCharsets.UTF_8));
System.out.println(" [x] Sent '" + routingKey + ":'" + message + "'");
}
}Consumer: Binding with `*`
Consumers bind their queues to the Topic exchange using binding keys that can contain wildcards. This consumer uses *.orange.*.
It will receive messages like animal.orange.fast but not fruit.apple.sweet or animal.orange.
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DeliverCallback;
public class TopicConsumerOrange {
private static final String EXCHANGE_NAME = "topic_logs";
public static void main(String[] argv) throws Exception {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
channel.exchangeDeclare(EXCHANGE_NAME, "topic");
String queueName = channel.queueDeclare().getQueue();
String bindingKey = "*.orange.*"; // Matches e.g., 'animal.orange.fast'
channel.queueBind(queueName, EXCHANGE_NAME, bindingKey);
System.out.println(" [x] Waiting for messages matching: '" + bindingKey + "'");
DeliverCallback deliverCallback = (consumerTag, delivery) -> {
String message = new String(delivery.getBody(), "UTF-8");
System.out.println(" [x] Received '" + delivery.getEnvelope().getRoutingKey() + ":'" + message + "'");
};
channel.basicConsume(queueName, true, deliverCallback, consumerTag -> {});
}
}Consumer: Binding with `#`
This consumer uses the log.# binding key. This means it will receive all messages whose routing key starts with log., regardless of how many words follow.
This is extremely useful for systems like logging, where you might want a 'catch-all' listener for a category.
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DeliverCallback;
public class TopicConsumerLogs {
private static final String EXCHANGE_NAME = "topic_logs";
public static void main(String[] argv) throws Exception {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
channel.exchangeDeclare(EXCHANGE_NAME, "topic");
String queueName = channel.queueDeclare().getQueue();
String bindingKey = "log.#"; // Matches e.g., 'log.error.db', 'log.info.web'
channel.queueBind(queueName, EXCHANGE_NAME, bindingKey);
System.out.println(" [x] Waiting for messages matching: '" + bindingKey + "'");
DeliverCallback deliverCallback = (consumerTag, delivery) -> {
String message = new String(delivery.getBody(), "UTF-8");
System.out.println(" [x] Received '" + delivery.getEnvelope().getRoutingKey() + ":'" + message + "'");
};
channel.basicConsume(queueName, true, deliverCallback, consumerTag -> {});
}
}Topic Exchange Use Cases
Topic exchanges shine in scenarios requiring flexible and hierarchical routing:
- Logging Systems: Route logs based on severity, source, and component (e.g.,
app.error.auth,app.info.payment). - Real-time Data Streams: Filter sensor data (e.g.,
sensor.room1.temp,sensor.room2.humidity). - Content Distribution: Deliver news articles to subscribers interested in specific categories or regions.
They provide fine-grained control over message flow.
Topic Routing Challenge
Consider the following messages and binding keys. Which messages will be delivered to a queue bound with the key animal.*.#.fast?
Recap: Topic Exchange Power
You've mastered the Topic exchange! It's an incredibly powerful tool for building flexible and scalable messaging architectures.
- Uses dot-separated routing keys.
*matches exactly one word.#matches zero or more words.- Ideal for logging, real-time analytics, and content filtering.
By using wildcards, you can create sophisticated routing rules to ensure messages go exactly where they're needed.
เรียนรู้ RabbitMQ Messaging & Async Systems ด้วย AI tutor — ฟรี
เขียนและเรียกใช้โค้ดจริงในเบราว์เซอร์ของคุณ รับความช่วยเหลือทันทีจาก AI tutor 24/7 และเรียนรู้ต่อจากที่คุณหยุดบนเว็บหรือในแอป
- คอร์ส
- 11
- บทเรียน
- 44
คำถามที่พบบ่อย
บทเรียน “ตัวแลกเปลี่ยน Topic สำหรับการกำหนดเส้นทางที่ยืดหยุ่น” ฟรีหรือไม่
ใช่ — ข้อความเต็มของ “ตัวแลกเปลี่ยน Topic สำหรับการกำหนดเส้นทางที่ยืดหยุ่น” ฟรีให้อ่านที่นี่บนเว็บ เพื่อปฏิบัติแบบโต้ตอบ (ตัวแก้ไขโค้ดในตัวและติวเตอร์ AI ตลอด 24/7) และปลดล็อคส่วนที่เหลือของคอร์ส RabbitMQ Messaging & Async Systems ให้อัปเกรดเป็น CoddyKit PRO คอร์ส RabbitMQ Messaging & Async Systems มีบทเรียนทั้งหมด 4 บทเรียน
คุณจะเรียนรู้อะไรในบทเรียน “ตัวแลกเปลี่ยน Topic สำหรับการกำหนดเส้นทางที่ยืดหยุ่น”
เชี่ยวชาญตัวแลกเปลี่ยน Topic สำหรับรูปแบบการกำหนดเส้นทางที่ซับซ้อนด้วยการจับคู่ไวลด์การ์ด ออกแบบโครงสร้างการกำหนดเส้นทางข้อความที่ยืดหยุ่นและขยายระบบได้ คุณปฏิบัติ RabbitMQ Messaging & Async Systems ด้วยโค้ดที่ใช้งานได้จริงที่คุณเรียกใช้โดยตรงในเบราว์เซอร์ และติวเตอร์ AI ตลอด 24/7 ตอบคำถามของคุณขณะที่คุณไปผ่านบทเรียน
คุณต้องมีประสบการณ์ก่อนที่จะเริ่มเรียน RabbitMQ Messaging & Async Systems หรือไม่
ไม่จำเป็นต้องมีประสบการณ์มาก่อน RabbitMQ Messaging & Async Systems บน CoddyKit ออกแบบมาสำหรับผู้เริ่มต้นไปจนถึงผู้เรียนขั้นสูง คุณสามารถเริ่มต้นที่นี่หรือเริ่มจากตัวแรกและเรียนด้วยความเร็วของคุณเอง นี่คือบทเรียนที่ 3 จากทั้งหมด 4 บทเรียน
บทเรียน “ตัวแลกเปลี่ยน Topic สำหรับการกำหนดเส้นทางที่ยืดหยุ่น” ใช้เวลานานแค่ไหน
บทเรียน CoddyKit ส่วนใหญ่ใช้เวลาประมาณ 5–10 นาที แต่ละบทเรียนจึงสั้นและเป็นแบบโต้ตอบ คุณสามารถก้าวหน้าอย่างต่อเนื่องและกลับมาเรียนต่อจากตรงที่เพิ่งหยุดบนเว็บและแอปได้เลย
ฉันเขียนและรันโค้ดในบทเรียน RabbitMQ Messaging & Async Systems นี้ได้ไหม
ได้ บทเรียน RabbitMQ Messaging & Async Systems ทุกบทมีตัวแก้ไขโค้ดในตัว คุณจึงเขียนและรันโค้ดจริงได้เลยในเบราว์เซอร์ และได้รับข้อเสนอแนะจาก AI ในทันที — ไม่ต้องติดตั้งในเครื่องของคุณ
บทเรียนทั้งหมดในหลักสูตรนี้
- ตัวแลกเปลี่ยน Fanout สำหรับ Pub/Sub
- ตัวแลกเปลี่ยน Direct สำหรับการกำหนดเส้นทาง
- ตัวแลกเปลี่ยน Topic สำหรับการกำหนดเส้นทางที่ยืดหยุ่น
- Exchange เริ่มต้นและการผูกโดยนัย