import org.springframework.data.redis.connection.Message; import org.springframework.data.redis.connection.MessageListener; import org.springframework.stereotype.Component; import lombok.extern.slf4j.Slf4j; /** * Session过期监听 * @author Frank Zeng * */ @Slf4j @Component public class ExpirationListener implements MessageListener { @Override public void onMessage(Message message, byte[] pattern) { String key = new String(message.getBody()); log.debug("expired key: {}", key); } }