java操作redis之按照关键字删除缓存数据

import org.apache.log4j.Logger;
 org.testng.annotations.Test;
 redis.clients.jedis.Jedis;
 java.util.Iterator;
 java.util.Set;

/**
 * @author rong.rong
 * redis操作类
 */
public class RedisDBHelper {


    static Jedis js = null;
    static Logger logger = Logger.getLogger(RedisDBHelper.);
    private static String hostUrl = BaseInfo.getInfo("hostUrl"static int hostPort = Integer.parseInt(BaseInfo.getInfo("hostPort"));
    static String authPassWord = BaseInfo.getInfo("authPassWord");

    
     * 链接redis数据库，进行初始化
     *
     * @return：返回是否初始化链接成功
     */
    boolean init() {
        if (js == ) {
            js = new Jedis(hostUrl,hostPort);
            js.auth(authPassWord);
        }
        if (js != ) {
            logger.info("初始化成功");
            return true;
        } else {
            false;
        }
    }


    
     * 删除数据
     *
     * @param key：要删除数据的key
     * ：返回boolean值，表示是否删除成功
      delete(String key) {
        if (js.exists(key)) {
            if (js.del(key) == 1) {
                logger.info("删除数据成功");
                ;
            }  {
                logger.info("删除数据失败";
            }
        }  {
            logger.info(key + "不存在"
     * 按照关键字删除redis缓存数据
     void deleteData(String keys) {
        //链接redis数据库，进行初始化
        init();
        Set<String> set = js.keys("*");
        if (set.size() != 0) {
            Iterator<String> it = set.iterator();
            while (it.hasNext()) {
                String key = it.next();
                 (key.contains(keys)) {
                    logger.info(key);
                    delete(key);
                }
            }
        }  {
            logger.info("数据库暂时没有数据");
        }
        关闭链接
        unInit();
    }


    
     * 关闭链接
      unInit() {
        ) {
            js.close();
            js = ;
        }
    }

    @Test
     test() {
        deleteData("key");
    }
}