RabbitMQ的安装请参考RabbitMQ - CentOS系统安装
创建2个项目
1.Comsumer项目的目录结构如下所示:
1.1.OrderReceiver:
1 | import com.chanchifeng.mq.producer.entity.Order; |
1.2.Order:
1 | import lombok.Data; |
1.3.ComsumerApplication:
1 | import org.springframework.boot.SpringApplication; |
1.4.application.properties:
1 |
1.5.application.yml:
1 | ## springboot整合rabbitmq的基本配置 |
1.6.pom.xml:
1 |
|
2.Producer项目的目录结构如下所示:
2.1.Order:
1 | import lombok.Data; |
2.2.OrderService:
1 | import com.chanchifeng.mq.producer.entity.Order; |
2.3.ProducerApplication:
1 | import org.springframework.boot.SpringApplication; |
2.4.application.properties:
1 |
2.5.application.yml:
1 | server: |
2.6.ProducerApplicationTests:
1 | import com.chanchifeng.mq.producer.entity.Order; |
2.7.pom.xml:
1 |
|
3.测试的时候仅需要使用producer的ProducerApplicationTest中的测试例子即可,在此之前需要启动comsumer的项目,项目运行的效果如下图所示:
项目在Github中的SpringBoot-Sample/SpringBoot-Rabbit-Producer 和 SpringBoot-Sample/SpringBoot-Rabbit-Comsumer :