import redis.clients.jedis.Jedis; 

public class TestJedis { 

public static void main(String[] args) {
        Jedis redis = new Jedis("127.0.0.1", 6379);
        redis.connect(); new Thread(()->{ try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            Jedis redis2 = new Jedis("127.0.0.1", 6379);
            redis2.connect();
            redis2.publish("abcd", "123456");
            redis2.close();
        }).start();
        redis.subscribe(new KeyExpiredListiner(), "abcd");
    }
}

import redis.clients.jedis.JedisPubSub; 
public class KeyExpiredListiner extends JedisPubSub { 
@Override 
public void onSubscribe(String channel, int subscribedChannels) {
        System.out.println("onSubscribe "+channel+" "+subscribedChannels);
    } 
@Override  
public void onMessage(String channel, String message) {
        System.out.println("onMessage "+channel+" "+message);
    } 
@Override  
public void onPSubscribe(String pattern, int subscribedChannels) {
        System.out.println("onPSubscribe "+pattern+" "+subscribedChannels);
    } 
@Override  
public void onPMessage(String pattern, String channel, String message) {
        System.out.println("onPMessage "+pattern+" "+channel+" "+message);
    }
}