[TOC] # 簡單測試 ## 定義隊列 ~~~ package com.jdxia.rabbitmq; import org.springframework.amqp.core.Queue; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; //定義隊列 @Configuration public class RabbitConfig { @Bean public Queue helloQueue() { return new Queue("hello"); } } ~~~ ## 發送者 ~~~ package com.jdxia.rabbitmq.hello; import org.springframework.amqp.core.AmqpTemplate; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.Date; //發送者 @Component public class HelloSender { //默認實現 @Autowired private AmqpTemplate rabbitTemplate; public void send() { String context = "hello " + new Date(); System.out.println("Sender : " + context); //轉換并發送 this.rabbitTemplate.convertAndSend("hello", context); } } ~~~ ## 接收者 ~~~ package com.jdxia.rabbitmq.hello; import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.cache.annotation.Cacheable; import org.springframework.stereotype.Component; import java.util.Date; /** * 接收者 * RabbitListener，使? queues 指明隊列名稱 */ @Component @RabbitListener(queues = "hello") public class HelloReceiver { /** * 標記具體接收方法 */ @RabbitHandler public void process(String hello) { //接收的消息 System.out.println("Receiver : " + hello); } } ~~~ ## 測試 ~~~ @Autowired private HelloSender helloSender; @Test public void test() throws InterruptedException { helloSender.send(); Thread.sleep(1000L); } ~~~