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实现发布与订阅模式路由模式通配符模式

SpringBoot整合多个RabbitMQ

RabbitMQ 核心概念及与 Spring Boot 2 的整合

RabbitMQ:第二章:Spring整合RabbitMQ(简单模式,广播模式,路由模式,通配符模式,消息可靠性投递,防止消息丢失,TTL,死信队列,延迟队列,消息积压,消息幂等性)(代码

Spring整合rabbitmq实践(一):基础

SpringBoot 整合RabbitMQ