最简单的springboot2整合redis 10行代码完成发布和订阅

songze 发布于2019-08-16 17:38 / 2145人阅读

pom：


    org.springframework.boot
    spring-boot-starter-data-redis

代码：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.ChannelTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;

@Configuration
public class RedisSubListenerConfig {
    @Bean
    MessageListenerAdapter messageListener() {
        //abstract methods overwrite
        return new MessageListenerAdapter((MessageListener) (message, pattern) -> {
            System.out.println("Message received: " + message.toString());
        });
    }

    @Bean
    RedisMessageListenerContainer redisContainer(RedisConnectionFactory connectionFactory) {
        RedisMessageListenerContainer container
                = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(messageListener(), topic());
        return container;
    }

    @Bean
    ChannelTopic topic() {
        return new ChannelTopic("messageQueue");
    }
}

测试类：

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import javax.annotation.Resource;

/**
 * @date 2019-05-25 10:59
 */
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
public class RedisTest {
    @Resource
    private StringRedisTemplate stringRedisTemplate;
    @Test
    public void test(){
        stringRedisTemplate.convertAndSend("messageQueue","hello world");
    }
}

云内存存储UMem Redis 最简单的asp代码发布订阅模式订阅发布模式 sqlserver发布订阅

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/74628.html

SpringBoot2.0之三优雅整合Spring Data JPA

摘要：的配置后在其他低版本的中也有使用这种配置的，具体根据版本而定。等注解是的相关知识，后面的文章将详细讲述。在我们的实际开发的过程中，无论多复杂的业务逻辑到达持久层都回归到了增删改查的基本操作，可能会存在关联多张表的复杂sql，但是对于单表的增删改查也是不可避免的，大多数开发人员对于这个简单而繁琐的操作都比较烦恼。为了解决这种大量枯燥的简单数据库操作，大致的解决该问题的有三种方...

ningwang 2019-08-15 18:19 评论0 收藏0
SpringBoot2.0之四简单整合MyBatis

摘要：从最开始的到后来的，到目前的随着框架的不断更新换代，也为我们广大的程序猿提供了更多的方便，一起搭建一个从控制层到持久层的项目可能需要一两天的时间，但是采用的方式，我们可能只需要分钟就能轻松完成一个项目的搭建，下面我们介绍一下整合的方法一新建从最开始的SSH（Struts+Spring+Hibernate）,到后来的SMM（SpringMVC+Spring+MyBatis），到目前...

Sanchi 2019-08-15 18:19 评论0 收藏0
springboot 整合redis

摘要：与整合默认使用的是，相较于，是一个可伸缩的，线程安全的客户端。在处理高并发方面有更多的优势。使用依赖主要需要的依赖为配置配置使用与整合可以在不更改现有代码逻辑的基础上，通过增加注解的方式，实现缓存。 springboot2.0 与redis整合默认使用的是Lettuce，相较于jedis，lettuce 是一个可伸缩的，线程安全的redis客户端。在处理高并发方面有更多的优势。 Red...

elarity 2019-08-06 13:37 评论0 收藏0