java集成rabbitmq多种消费模式

package com.liu.rabbitmq; import java.io.IOException; import java.io.StringWriter; import org.springframework.amqp.core.Message; import org.springframework.amqp.core.MessageProperties; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.context.support.ClassPathXmlApplicationContext; import com.fasterxml.jackson.core.JsonGenerationException; import com.fasterxml.jackson.databind.JsonMappingException; import com.fasterxml.jackson.databind.ObjectMapper; public class RabbitmqTest { public static void main(String[] args) { //topic发送 /*ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext("application-context.xml"); RabbitTemplate rabbitTemplate = (RabbitTemplate) context.getBean("rabbitTemplate") ; //第二个参数为路由key(routingKey)的值，当路由可以为test321.hello.test123时，两个消费队列都可以收到消息，当值为test321.hello.aaa时，只有绑定了test321.#的队列才可以收到消息，当值为ta1.hello.test123，只有绑定了*.*.test123的队列才可收到消息 String exchange = "leo.pay.topic.exchange"; String routingKey = "test321.hello.test123"; for(int i = 1; i <= 10; i++) { String str = "hello" + i; Message message = new Message(str.getBytes(), new MessageProperties()); rabbitTemplate.send(exchange, routingKey, message); }*/ //fanout发布者订阅者模式 //往名字为leo.pay.fanout.exchange的路由里面发送数据，客户端中只要是与该路由绑定在一起的队列都会收到相关消息，这类似全频广播，发送端不管队列是谁，都由客户端自己去绑定，谁需要数据谁去绑定自己的处理队列。 ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext("rabbitMQ.xml"); RabbitTemplate rabbitTemplate = (RabbitTemplate) context.getBean("rabbitTemplate") ; //第二个参数为路由key(routingKey)的值，当路由可以为test321.hello.test123时，两个消费队列都可以收到消息，当值为test321.hello.aaa时，只有绑定了test321.#的队列才可以收到消息，当值为ta1.hello.test123，只有绑定了*.*.test123的队列才可收到消息 // String exchange = "leo.pay.fanout.exchange";//fanout // String routingKey = "";//fanout String exchange = "leo.pay.topic.exchange";//topic String routingKey = "test321.hello.test123";//topic for(int i = 1; i <= 10; i++) { String str = "hello" + i; Message message = new Message(str.getBytes(), new MessageProperties()); /* rabbitTemplate.send(exchange, routingKey, message); rabbitTemplate.convertAndSend(routingKey, message); */ rabbitTemplate.convertAndSend(exchange, routingKey, message); } } }