dreamweaver学生用哪个版本/谷歌seo网站优化
当前使用的版本:rabbitmq-server-windows-3.8.3
1.声明
当前内容用于本人学习和使用RabbitMQ这个消息队列,当前内容为SpringBoot操作RabbitMQ的基本操作
本人使用windows10方式使用RabbitMQ
2.创建一个测试账户
注意这里的Can access virtual hosts必须修改为/,否则可能出现连接失败,这里使用账户为root
3.pom依赖
<parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.5.2.RELEASE</version><relativePath /></parent><groupId>SpringBoot-RabbitMQ</groupId><artifactId>SpringBoot-RabbitMQ</artifactId><version>0.0.1-SNAPSHOT</version><packaging>jar</packaging><name>SpringBoot-RabbitMQ</name><url>http://maven.apache.org</url><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version><!-- 更新SpringCloud的版本 --></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-actuator</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>
4.配置文件application.properties
spring.application.name=rabbitmq-hello
server.port=8080
spring.rabbitmq.host
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=root
spring.rabbitmq.password=root
5.创建入口类
@RestController
@SpringBootApplication
public class RabbitMQApplication {@AutowiredAmqpTemplate amqpTemplate;@RequestMapping("/send")public String send(String msg) {amqpTemplate.convertAndSend("test", msg);return "发送消息成功:===>" + msg;}public static void main(String[] args) {SpringApplication.run(RabbitMQApplication.class, args);}@BeanQueue queue() {return new Queue("test");}@Component@RabbitListener(queues = "test")class MsgCustomer {@RabbitHandlerpublic void handlerMsg(String msg) {System.out.println("消息消费者消费===>" + msg);}}
}
6.测试
7.总结
1.通过使用SpringBoot操作RabbitMQ的时候非常简单,直接使用AmqpTemplate即可
2.通过@RabbitListener指定需要监听的队列,通过@RabbitHandler方式处理监听后的数据
以上纯属个人见解,如有问题请联系本人!