SpringBoot+RabbitMQ学习笔记(一)
2020-04-28 16:08:46来源:博客园 阅读 ()
SpringBoot+RabbitMQ学习笔记(一)
一丶添加依赖
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency>
配置文件:application.properties
server.port=8883 spring.application.name=hello-world spring.rabbitmq.host=localhost spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest
二丶创建消息队列
package com.example.ampq; import org.springframework.amqp.core.Queue; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; /** * Author:aijiaxiang * Date:2020/4/26 * Description: */ @Configuration public class QueueConfig { /** * 创建队列 * @return */ @Bean public Queue createQueue(){ return new Queue("hello-queue"); } }
三丶创建生产者
package com.example.ampq; import org.springframework.amqp.core.AmqpTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component; /** * Author:aijiaxiang * Date:2020/4/26 * Description:发送消息 */ @Component public class Sender { @Autowired private AmqpTemplate amqpTemplate; /** * 发送消息的方法 * @param msg */ public void send(String msg){ //向消息队列发送消息 //参数1:队列名称 //参数2:消息 this.amqpTemplate.convertAndSend("hello-queue",msg); } }
四丶创建消费者
package com.example.ampq; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; /** * Author:aijiaxiang * Date:2020/4/26 * Description:消息接收者 */ @Component public class Receiver { /** * 接收消息的方法,采用消息队列监听机制 * * 使用 @RabbitListener 注解标记方法,当监听到队列 hello-queue 中有消息时则会进行接收并处理 * * @param msg */ @RabbitListener(queues = "hello-queue") public void process(String msg){ System.out.println("receiver:"+msg); } }
五丶测试一波
package com.example.amqp; import com.example.ampq.Sender; import com.example.helloworld.HelloworldApplication; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner; /** * Author:aijiaxiang * Date:2020/4/26 * Description: */ @RunWith(SpringRunner.class) @SpringBootTest(classes = HelloworldApplication.class) public class QueueTest { @Autowired private Sender sender; /** * 测试消息队列 */ @Test public void test1() throws InterruptedException { while (true){ Thread.sleep(1000); sender.send("hello"); } } }
原文链接:https://www.cnblogs.com/aijiaxiang/p/12795920.html
如有疑问请与原作者联系
标签:
版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有
- 学习Java 8 Stream Api (4) - Stream 终端操作之 collect 2020-06-11
- java学习之第一天 2020-06-11
- Java学习之第二天 2020-06-11
- Spring WebFlux 学习笔记 - (一) 前传:学习Java 8 Stream Ap 2020-06-11
- Java笔记:集合 2020-06-10
IDC资讯: 主机资讯 注册资讯 托管资讯 vps资讯 网站建设
网站运营: 建站经验 策划盈利 搜索优化 网站推广 免费资源
网络编程: Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它
服务器技术: Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护
软件技巧: 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷
网页制作: FrontPages Dreamweaver Javascript css photoshop fireworks Flash