在Java中监听Redis某个数据可以使用Redis的发布/订阅功能。
首先,你需要在Java中使用Jedis库连接到Redis服务器。你可以使用以下代码来连接到Redis服务器:
Jedis jedis = new Jedis("localhost", 6379);
然后,你需要创建一个新的线程来监听Redis的消息。可以使用以下代码来创建监听器线程:
Thread listenerThread = new Thread(new Runnable() { @Override public void run() { JedisPubSub jedisPubSub = new JedisPubSub() { @Override public void onMessage(String channel, String message) { // 处理接收到的消息 System.out.println("Received message: " + message); } @Override public void onSubscribe(String channel, int subscribedChannels) { System.out.println("Subscribed to channel: " + channel); } @Override public void onUnsubscribe(String channel, int subscribedChannels) { System.out.println("Unsubscribed from channel: " + channel); } }; jedis.subscribe(jedisPubSub, "your-channel"); } }); listenerThread.start();
在上面的代码中,JedisPubSub
是一个抽象类,你需要重写它的方法来处理接收到的消息。在onMessage
方法中,你可以处理接收到的消息。在onSubscribe
方法中,你可以处理订阅通道的事件。
最后,你可以使用以下代码来发布消息到Redis服务器:
jedis.publish("your-channel", "your-message");
这将会向名为"your-channel"的频道发布一条消息。
注意:在你的Java程序中要保持Redis连接的活跃状态,否则将无法接收到订阅的消息。