标签：print password 代码 col release 组件 pac amqp add
一 .概述
本次我们使用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之中的其它的组件
标签：print password 代码 col release 组件 pac amqp add
原文地址：https://www.cnblogs.com/trekxu/p/9784047.html
