springboot整合各种消息队列（一）：redis消息队列

栏目: Java · 发布时间: 6年前

内容简介：请参考笔者另一篇博客，有详细介绍：新建一个springboot项目，并且修改application.yml文件，pom如下：

springboot整合各种消息队列（一）：redis消息队列本篇博客将介绍使用 redis 作为消息中间件和springboot的整合使用;

安装配置redis

请参考笔者另一篇博客，有详细介绍： https://jsbintask.cn/2019/01/24/middleware/redis-install/#more

整合springboot

新建项目

新建一个springboot项目，并且修改application.yml文件，pom如下：

spring:
  redis:
    host: youripaddress
    password: jsbintask

host和password修改成自己的服务器用户名密码。pom：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.2.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>cn.jsbintask</groupId>
    <artifactId>springboot-redis-learning</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>springboot-redis-learning</name>
    <description>Demo project for Spring Boot redis</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

消息消费者（接收者）

编写一个消息消费者类：

@Log
@Component
public class RedisMessageReceiver {
    @Autowired
    private CountDownLatch countDownLatch;

    public void receivedMsg(String msg) {
        log.info("received msg: " + msg);
        // 计数，减一
        countDownLatch.countDown();
    }
}

并且加入@Component注解，将其作为bean归spring管理，并且通过@Autowried注入了一个CountdownLatch类。

将消息消费者作为监听器监听 redis的消息：

@Configuration
public class RedisConfig {
    public static final String MSG_TOPIC = "chat";

    @Bean
    public CountDownLatch countDownLatch() {
        return new CountDownLatch(1);
    }

    /**
     * 消息消费者 适配器，其中 receivedMsg为定义的消费者的消费方法，必须保持一致
     */
    @Bean
    MessageListenerAdapter listenerAdapter(RedisMessageReceiver receiver) {
        return new MessageListenerAdapter(receiver, "receivedMsg");
    }

    @Bean
    StringRedisTemplate template(RedisConnectionFactory connectionFactory) {
        return new StringRedisTemplate(connectionFactory);
    }

    /**
     * 消息监听容器，将适配器加入， 注意此处的 topic
     */
    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
                                            MessageListenerAdapter listenerAdapter) {

        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(listenerAdapter, new PatternTopic(MSG_TOPIC));

        return container;
    }
}

启动测试类，发送消息

@SpringBootApplication
public class SpringbootRedisLearningApplication {

    public static void main(String[] args) throws Exception {
        ConfigurableApplicationContext applicationContext = SpringApplication.run(SpringbootRedisLearningApplication.class, args);

        //从 spring中取出已经有的bean
        CountDownLatch countDownLatch = applicationContext.getBean(CountDownLatch.class);
        StringRedisTemplate stringRedisTemplate = applicationContext.getBean(StringRedisTemplate.class);
        
        stringRedisTemplate.convertAndSend(RedisConfig.MSG_TOPIC, "hello from jsbintask.");

        // 一直等待消息被接收，没接收不退出
        countDownLatch.await();
    }
}

启动，查看控制台：收到消息并且打印：

这样redis作为消息队列就成功了。源码地址： https://github.com/jsbintask22/springboot-redis-learning

本文原创地址： https://jsbintask.cn/2019/01/25/springboot/springboot-redis-jms/ ，未经允许，禁止转载。

谢谢你支持我分享知识

springboot整合各种消息队列（一）：redis消息队列

扫码打赏，心意已收

打开微信扫一扫，即可进行扫码打赏哦

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。

码农书籍

Web Analytics 2.0

Avinash Kaushik / Sybex / 2009-10-26 / USD 39.99

The bestselling book Web Analytics: An Hour A Day was the first book in the analytics space to move beyond clickstream analysis. Web Analytics 2.0 will significantly evolve the approaches from the fir......一起来看看《Web Analytics 2.0》这本书的介绍吧!

码农工具

XML、JSON 在线转换

在线XML、JSON转换工具

HEX CMYK 转换工具

HEX CMYK 互转工具

HSV CMYK 转换工具

HSV CMYK互换工具