共計(jì) 977 個(gè)字符,預(yù)計(jì)需要花費(fèi) 3 分鐘才能閱讀完成。
在 Java 中監(jiān)聽 Redis 某個(gè)數(shù)據(jù)可以使用 Redis 的發(fā)布 / 訂閱功能。
首先,你需要在 Java 中使用 Jedis 庫連接到 Redis 服務(wù)器。你可以使用以下代碼來連接到 Redis 服務(wù)器:
Jedis jedis = new Jedis("localhost", 6379);
然后,你需要?jiǎng)?chuàng)建一個(gè)新的線程來監(jiān)聽 Redis 的消息。可以使用以下代碼來創(chuàng)建監(jiān)聽器線程:
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
是一個(gè)抽象類,你需要重寫它的方法來處理接收到的消息。在 onMessage
方法中,你可以處理接收到的消息。在 onSubscribe
方法中,你可以處理訂閱通道的事件。
最后,你可以使用以下代碼來發(fā)布消息到 Redis 服務(wù)器:
jedis.publish("your-channel", "your-message");
這將會(huì)向名為 "your-channel" 的頻道發(fā)布一條消息。
注意:在你的 Java 程序中要保持 Redis 連接的活躍狀態(tài),否則將無法接收到訂閱的消息。
丸趣 TV 網(wǎng) – 提供最優(yōu)質(zhì)的資源集合!
正文完