RabbitMQ如何支持动态路由和消息转发

// 创建连接和信道ConnectionFactoryfactory=newConnectionFactory();
factory.setHost("localhost");
Connectionconnection=factory.newConnection();
Channelchannel=connection.createChannel();
// 定义Exchange和队列StringexchangeName="my.topic.exchange";
StringqueueName1="my.topic.queue1";
StringqueueName2="my.topic.queue2";
channel.exchangeDeclare(exchangeName, "topic", true);
channel.queueDeclare(queueName1, true, false, false, null);
channel.queueDeclare(queueName2, true, false, false, null);
// 将队列绑定到Exchange上，指定不同的Routing Key和通配符符号channel.queueBind(queueName1, exchangeName, "*.orange.*");
channel.queueBind(queueName2, exchangeName, "*.*.rabbit");
// 发送消息Stringmessage1="A quick orange rabbit";
Stringmessage2="A lazy brown dog";
channel.basicPublish(exchangeName, "quick.orange.rabbit", null, message1.getBytes());
channel.basicPublish(exchangeName, "lazy.brown.dog", null, message2.getBytes());
// 创建消费者，消费消息Consumerconsumer1=newDefaultConsumer(channel) {
publicvoidhandleDelivery(StringconsumerTag, Envelopeenvelope, AMQP.BasicPropertiesproperties, byte[] body) throwsIOException {
Stringmessage=newString(body, "UTF-8");
System.out.println("Consumer1 received message: "+message);
        }
    };
Consumerconsumer2=newDefaultConsumer(channel) {
publicvoidhandleDelivery(StringconsumerTag, Envelopeenvelope, AMQP.BasicPropertiesproperties, byte[] body) throwsIOException {
Stringmessage=newString(body, "UTF-8");
System.out.println("Consumer2 received message: "+message);
        }
    };
channel.basicConsume(queueName1, true, consumer1);
channel.basicConsume(queueName2, true, consumer2);