zoukankan      html  css  js  c++  java
  • 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之中的其它的组件

  • 相关阅读:
    Dropplets – 极简的 Markdown 博客平台
    T3
    Awesomplete
    SVG Drawing Animation
    Dom Animator – 提供 Dom 注释动画的 JS 库
    Electron
    很赞的效果!互动的页面元素拖放着色实验
    BookBlock
    雷军投资的理财网站,年化收益13%!
    Rainyday.js – 使用 JavaScript 实现雨滴效果
  • 原文地址:https://www.cnblogs.com/trekxu/p/9784047.html
Copyright © 2011-2022 走看看