Redis用作消息队列实现publish/subscribe

最新推荐文章于 2025-03-10 22:41:10 发布

KING丨殇痕

最新推荐文章于 2025-03-10 22:41:10 发布

阅读量1k

点赞数 1

分类专栏： Redis 文章标签： redis 缓存数据库

本文链接：https://blog.csdn.net/sunp_csdn/article/details/122088673

版权

本文介绍了如何利用Redis实现消息队列的功能，重点讨论了配置文件的设置，以及`RedisMessageListener`、`RedisMessageHelper`两个关键实现类的作用，通过测试确保系统能有效进行发布和订阅操作。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

配置文件
**冒号后面一定要加一个空格

redis:
  host: 127.0.0.1
  port: 6379
  timeout: 3000
  lettuce:
    max-active: -1
    max-wait: -1
    max-idle: 8
    min-idle: 2

实现类

config

import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.connection.lettuce.LettucePoolingClientConfiguration;
import org.springframework.data.redis.core.RedisTemplate;

import java.time.Duration;


@Configuration
public class RedisConfig {
   
    @Value("${redis.host}")
    private String host;

    @Value("${redis.port}")
    private int port;

    @Value("${redis.timeout}")
    private int timeout;

    @Value("${redis.lettuce.max-active}")
    private int max_active;

    @Value("${redis.lettuce.max-wait}")
    private int max_wait;

    @Value(

最低0.47元/天解锁文章