在上篇Routing（消息路由）文章中，我们实现了一个简单的日志系统。Consumer可以监听不同severity的log。但是，这也是它之所以叫做简单日志系统的原因，因为是仅仅能够通过severity设定。不支持更多的标准。
比如syslog unix的日志工具，它可以通过severity (info/warn/crit…) 和模块(auth/cron/kern…)。这可能更是我们想要的：我们可以仅仅需要cron模块的log。
为了实现类似的功能，我们需要用到topic exchange。
对于Message的routing_key是有限制的，不能使任意的。格式是以点号“.”分割的字符表。比如：”stock.usd.nyse”, “nyse.vmw”, “quick.orange.rabbit”。你可以放任意的key在routing_key中，当然最长不能超过255 bytes。
对于routing_key，有两个特殊字符（在正则表达式里叫元字符）：
* (星号) 代表任意 一个单词 # (hash) 0个或者多个单词请看下面一个例子: Producer发送消息时需要设置routing_key，routing_key包含三个单词和两个点号。第一个key是描述了celerity（灵巧，敏捷），第二个是colour（色彩），第三个是species（物种）：
"<celerity>.<colour>.<species>"在这里我们创建了两个绑定： Q1 的binding key 是”*.orange.*”； Q2 是 “*.*.rabbit” 和 “lazy.#”：
Q1 感兴趣所有orange颜色的动物 Q2 感兴趣所有的rabbit和所有的lazy的
比如routing_key是 “quick.orange.rabbit”将会发送到Q1和Q2中。消息”lazy.orange.elephant” 也会发送到Q1和Q2。但是”quick.orange.fox” 会发送到Q1；”lazy.brown.fox”会发送到Q2。”lazy.pink.rabbit” 也会发送到Q2，但是尽管两个routing_key都匹配，它也只是发送一次。”quick.brown.fox” 会被丢弃。
如果发送的单词不是3个呢？ 答案要看情况，因为#是可以匹配0个或任意个单词。比如”orange” or “quick.orange.male.rabbit”，它们会被丢弃。如果是lazy那么就会进入Q2。类似的还有 “lazy.orange.male.rabbit”，尽管它包含四个单词。
Topic exchange和其他exchange
由于有”*” (star) and “#” (hash)， Topic exchange 非常强大并且可以转化为其他的exchange：
如果binding_key 是 “#” - 它会接收所有的Message，不管routing_key是什么，就像是fanout exchange。
如果 “*” (star) and “#” (hash) 没有被使用，那么topic exchange就变成了direct exchange。
现在我们要重新定义我们上篇的日志系统。routing keys 有两个部分:
<facility>.<severity>EmitLogTopic.java
import com.rabbitmq.client.*; import java.io.IOException; public class EmitLogTopic { 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 routingKey = getRouting(argv); String message = getMessage(argv); channel.basicPublish(EXCHANGE_NAME, routingKey, null, message.getBytes()); System.out.println(" [x] Sent '" + routingKey + "':'" + message + "'"); connection.close(); } //... }ReceiveLogsTopic.java
import com.rabbitmq.client.*; import java.io.IOException; public class ReceiveLogsTopic { 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(); if (argv.length < 1) { System.err.println("Usage: ReceiveLogsTopic [binding_key]..."); System.exit(1); } for (String bindingKey : argv) { channel.queueBind(queueName, EXCHANGE_NAME, bindingKey); } System.out.println(" [*] Waiting for messages. To exit press CTRL+C"); Consumer consumer = new DefaultConsumer(channel) { @Override public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException { String message = new String(body, "UTF-8"); System.out.println(" [x] Received '" + envelope.getRoutingKey() + "':'" + message + "'"); } }; channel.basicConsume(queueName, true, consumer); } }