在两个java项目中实现Redis的发布订阅模式

news2024/9/22 19:40:24

如何在两个java项目中实现Redis的发布订阅模式？

- 1. Redis简介
- 2. 发布订阅模式介绍
- 3. 实现思路
- 4. 代码实现及详细解释
- - 4.1. RedisUtil
  - 4.2. Publisher
  - 4.3. Subscriber
  - 4.4. 运行程序

目录：

Redis简介
发布订阅模式介绍
实现思路
代码实现及详细解释

1. Redis简介

Redis是一种高性能的键值存储系统，常用于缓存、分布式会话和实时分析等场景。它支持多种数据结构（如字符串、哈希、列表、集合和有序集合），同时具备高速读写和持久化功能。

2. 发布订阅模式介绍

Redis的发布订阅模式是其提供的一种通信模式，在这种模式下，消息发布者将消息发送到一个频道，所有订阅该频道的订阅者都会收到这个消息。发布者和订阅者之间通过频道进行信息传递，可以实现解耦和异步处理。

3. 实现思路

要在两个Java项目中实现Redis的发布订阅模式，需要使用Redis的Java客户端，如jedis或lettuce。下面是一种通用的实现思路：

引入Redis的Java客户端依赖：
在两个项目的pom.xml文件中，引入Redis的Java客户端依赖，如jedis或lettuce。可以通过Maven或Gradle等构建工具来管理依赖关系。
初始化Redis连接：
在每个Java项目中，创建一个RedisUtil类来管理Redis连接。在该类中，可以通过配置文件或硬编码的方式，初始化Redis连接池，并提供获取和释放连接的方法。
实现发布者：
在发布者项目中，创建一个Publisher类，通过RedisUtil获取Redis连接，并使用发布方法将消息发送到指定频道。在频道上发布消息时，可以将消息序列化为字符串或其他形式进行传输。
实现订阅者：
在订阅者项目中，创建一个Subscriber类，通过RedisUtil获取Redis连接，并注册一个监听器来监听指定频道上的消息。当有消息发布到频道上时，监听器会调用相应的处理逻辑。

4. 代码实现及详细解释

4.1. RedisUtil

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

/**
 * @author linx 2023-10-24 20:50
 */
public class RedisUtil {

    private static JedisPool jedisPool;

    // 初始化Redis连接
    public static void initRedisPool() {
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(100);
        config.setMaxIdle(20);
        config.setMaxWaitMillis(10000);
        config.setTestOnBorrow(true);

        jedisPool = new JedisPool(config, "redis-server", 6379);
    }

    // 获取Redis连接
    public static Jedis getJedis() {
        if (jedisPool == null) {
            initRedisPool();
        }
        return jedisPool.getResource();
    }

    // 释放Redis连接
    public static void releaseJedis(Jedis jedis) {
        if (jedis != null) {
            jedis.close();
        }
    }


    public static void set(String key, String value, int expireSeconds) {
        Jedis jedis = null;
        try {
            jedis = getJedis();
            jedis.set(key, value);
            if (expireSeconds > 0) {
                jedis.expire(key, expireSeconds);
            }
        } finally {
            releaseJedis(jedis);
        }
    }

    public static String get(String key) {
        Jedis jedis = null;
        try {
            jedis = getJedis();
            return jedis.get(key);
        } finally {
            releaseJedis(jedis);
        }
    }

    public static void delete(String key) {
        Jedis jedis = null;
        try {
            jedis = getJedis();
            jedis.del(key);
        } finally {
            releaseJedis(jedis);
        }
    }

    public static Boolean exists(String key) {
        Jedis jedis = null;
        try {
            jedis = getJedis();
            return jedis.exists(key);
        } finally {
            releaseJedis(jedis);
        }
    }

    public static void publish(String channel, String content) {
        Jedis jedis = null;
        try {
            jedis = getJedis();
            jedis.publish(channel, content);
        } finally {
            releaseJedis(jedis);
        }
    }

    public static void main(String[] args){
      RedisUtil.publish("TESTCHANNEL:001","你好啊");
    }
}

上述代码中，我们使用了jedis作为Redis的Java客户端。在RedisUtil中，初始化了一个Redis连接池，并提供获取和释放连接的方法。

4.2. Publisher

import redis.clients.jedis.Jedis;

public class Publisher {
    public static void main(String[] args) {
        Jedis jedis = RedisUtil.getJedis();
        jedis.publish("channel", "Hello, Redis!");
        RedisUtil.releaseJedis(jedis);
    }
}

上述代码中，我们通过RedisUtil获取一个Redis连接，并使用publish方法将消息发送到名为"channel"的频道上。

4.3. Subscriber

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;

/**
 * @author linx 2023-11-24 4:06
 */
public class Subscriber extends JedisPubSub {
    @Override
    public void onMessage(String channel, String message) {
        System.out.println("Received message: " + message);
    }

    public static void main(String[] args) {
        Jedis jedis = RedisUtil.getJedis();
        Subscriber subscriber = new Subscriber();
        jedis.subscribe(subscriber, "TESTCHANNEL:001");
        RedisUtil.releaseJedis(jedis);
    }
}