在两个java项目中实现Redis的发布订阅模式_跨系统 实现redis 发布订阅 java

目录：

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

1. Redis简介

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

2. 发布订阅模式介绍

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

3. 实现思路

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

1. 引入Redis的Java客户端依赖：
   在两个项目的pom.xml文件中，引入Redis的Java客户端依赖，如jedis或lettuce。可以通过Maven或Gradle等构建工具来管理依赖关系。

2. 初始化Redis连接：
   在每个Java项目中，创建一个RedisUtil类来管理Redis连接。在该类中，可以通过配置文件或硬编码的方式，初始化Redis连接池，并提供获取和释放连接的方法。

3. 实现发布者：
   在发布者项目中，创建一个Publisher类，通过RedisUtil获取Redis连接，并使用发布方法将消息发送到指定频道。在频道上发布消息时，可以将消息序列化为字符串或其他形式进行传输。

4. 实现订阅者：
   在订阅者项目中，创建一个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","你好啊");
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95

上述代码中，我们使用了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);
    }
}
1
2
3
4
5
6
7
8
9

上述代码中，我们通过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);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

上述代码中，我们创建了一个继承自JedisPubSub的Subscriber类，并重写了onMessage方法来处理接收到的消息。然后，我们通过RedisUtil获取一个Redis连接，并使用subscribe方法注册一个监听器，来监听名为"channel"的频道上的消息。

4.4. 运行程序

在Publisher项目中运行Publisher类，它会向名为"channel"的频道发布一条消息"你好啊"。然后，在Subscriber项目中运行Subscriber类，它会监听"channel"频道上的消息，并在接收到消息时打印出来。

至此，我们已经完成了在两个Java项目中实现Redis的发布订阅模式。

总结：
Redis的发布订阅模式是一种解耦和异步处理的通信模式。通过Redis的Java客户端，我们可以轻松地在多个Java项目中实现该模式。本文通过RedisUtil类对Redis连接进行管理，并通过Publisher和Subscriber类实现了消息的发布和订阅。希望本文对你有所帮助。