首先我们需要创建一个微服务的架构，因为一般来讲这个都是在微服务架构下去使用的（当然单体也没什么不好，看qps）

在父项目中我们需要引入amqp的依赖

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>
</dependencies>

然后选择我们需要的子服务完成消息的首发

首先是消息的发送，使用RabbitTemplate作为消息的发送模版，方法convertAndSend

@SpringBootTest
public class SpringAmqpTest {@Autowiredprivate RabbitTemplate rabbitTemplate;@Testvoid testMsgCaiyiTestQueue(){String msg = "this is message from caiyi";rabbitTemplate.convertAndSend("cybg_study_queue",msg);}
}

然后我们可以创建listener包下的listener类（需要被注册为一个spring的bean）完成消息，通过@RabbitListener

@RabbitListener(queues = "cybg_study_queue")
public void listenQueueMsg(String msg){System.out.println("接收到的msg："+msg);
}

ok，至此完成springAMQP下对于rabbitmq的消息收发