一 .概述
本次我们使用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之中的其它的组件
原文地址:https://www.cnblogs.com/trekxu/p/9784047.html
时间: 2024-10-31 18:35:27