<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><groupId>com.luangeng</groupId><artifactId>boot</artifactId><packaging>pom</packaging><version>1.0-SNAPSHOT</version><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.5.2.RELEASE</version></parent><properties><java.version>1.8</java.version><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- TEST --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

spring.application.name=rabbitmqspring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=lg
spring.rabbitmq.password=lg

@Component
public class Sender {@Autowiredprivate AmqpTemplate rabbitTemplate;private static AtomicInteger count = new AtomicInteger(1);public void send() {String msg = "msg" + count.getAndIncrement() + " at " + new Date();System.out.println("Sender : " + msg);this.rabbitTemplate.convertAndSend(RabbitConfig.queueName, msg);}
}

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
@RabbitListener(queues = RabbitConfig.queueName)
public class Receiver {@RabbitHandlerpublic void process(String msg) {System.out.println("Receiver : " + msg);}}

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class RabbitConfig {public final static String queueName = "myQueue";//注入queue
    @BeanQueue queue() {return new Queue(queueName, false);}//注入exchange
    @BeanExchange exchange() {//return new FanoutExchange("fanout-exchange");//return new DirectExchange("direct-exchange");//return new HeadersExchange("headers-exchange");return new TopicExchange("topic-exchange");}//绑定exchange和queue
    @BeanBinding binding(Queue queue, TopicExchange exchange) {return BindingBuilder.bind(queue).to(exchange).with(queueName);}}

@SpringBootApplication
public class Application {public static void main(String[] args) {SpringApplication.run(Application.class, args);}
}

@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = Application.class)
public class ApplicationTest {@Autowiredprivate Sender sender;@Testpublic void hello() throws Exception {while(true) {sender.send();Thread.sleep(1000);}}}