java 建redis topic

在Java中，可以使用Jedis客户端库来连接Redis，并使用其提供的API来建立Redis的Topic（即频道）。

首先需要在Java项目中引入Jedis库的依赖：

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>3.6.3</version>
</dependency>

然后，可以使用以下代码来建立Redis的Topic：

import redis.clients.jedis.Jedis;

public class RedisTopic {

    public static void main(String[] args) {
        // 连接Redis
        Jedis jedis = new Jedis("localhost");

        // 订阅频道
        jedis.subscribe(new JedisPubSub() {
            @Override
            public void onMessage(String channel, String message) {
                // 处理接收到的消息
                System.out.println("Received message: " + message + " from channel: " + channel);
            }
        }, "mytopic");

        // 发布消息到频道
        jedis.publish("mytopic", "hello world");

        // 关闭连接
        jedis.close();
    }
}

在上面的代码中，首先连接到Redis实例。然后使用subscribe方法来订阅一个名为“mytopic”的频道，当有消息发布到该频道时，会调用JedisPubSub类的onMessage方法进行处理。接着使用publish方法向该频道发布一条消息。最后，关闭连接。