rabbitmq与spring整合以后怎么使用topic

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了rabbitmq与spring整合以后怎么使用topic相关的知识,希望对你有一定的参考价值。

参考技术A 下面是RabbitMQ的消息确认机制:“为了确保消息不会丢失,RabbitMQ支持消息确认机制。客户端在接受到消息并处理完后,可以发送一个ack消息给RabbitMQ,告诉它该消息可以安全的删除了。假如客户端在发送ack之前意外死掉了

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之中的其它的组件

以上是关于rabbitmq与spring整合以后怎么使用topic的主要内容,如果未能解决你的问题,请参考以下文章

022 spring与Rabbitmq整合

SpringBoot 整合RabbitMQ

spring整合RabbitMQ

SpringBoot整合多个RabbitMQ

SpringBoot整合rabbitMQ,spring-boot-starter-amqp 的使用

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