022 spring与Rabbitmq整合
Posted 最爱五仁月饼
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了022 spring与Rabbitmq整合相关的知识,希望对你有一定的参考价值。
一 .概述
本次我们使用spring帮助我们完成Rabbitmq的使用.
二 .环境的搭建
本次使用springboot的jar文件帮助整合rabbitmq,但是本质上还是使用spring的方式进行整合.
<parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.9.RELEASE</version> </parent> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <configuration> <source>1.8</source> <target>1.8</target> </configuration> </plugin> </plugins> </build>
三 .创建ConnectionFactory
@Configuration public class RabbitmqConfig { @Bean public ConnectionFactory connectionFactory() { CachingConnectionFactory factory = new CachingConnectionFactory(); factory.setAddresses("39.106.154.23:5672"); factory.setVirtualHost("/"); factory.setUsername("root"); factory.setPassword("trek"); return factory; } }
在上面的代码之中,我们创建了一个ConnectionFactory,记住这个Bean是spring为我们提供的哪一个ConnectionFactory,并不是Rabbitmq提供的那一个ConnectionFactory.
下面,我们做一下测试:
@RunWith(SpringRunner.class) @SpringBootTest public class ConfigTest { @Resource private ConnectionFactory connectionFactory; @Test public void testConnectionFactory() { System.out.println(connectionFactory.createConnection()); } }
如果能够正确的得到Connection对象,就说明我们的整合的第一步是成功的了,下面我们会继续整合spirngampq之中的其它的组件
以上是关于022 spring与Rabbitmq整合的主要内容,如果未能解决你的问题,请参考以下文章
RbbitMQ04_Spring整合RabbitMQ实现发布与订阅模式路由模式通配符模式
RabbitMQ 核心概念及与 Spring Boot 2 的整合
RabbitMQ:第二章:Spring整合RabbitMQ(简单模式,广播模式,路由模式,通配符模式,消息可靠性投递,防止消息丢失,TTL,死信队列,延迟队列,消息积压,消息幂等性)(代码