redis连接及使用

向右看齐 2022-02-21 10:49 218阅读 0赞

### redis连接及使用 ###

方法一:

//获取
    @GetMapping("/testQuery")
    @ResponseBody
    String testQuery(Long cgfId){ 
    
        JedisShardInfo shardInfo = new JedisShardInfo("redis://localhost:6379/9");//这里是连接的本地地址和端口
        shardInfo.setPassword("123456");//这里是密码
        Jedis jedis = new Jedis(shardInfo);
        jedis.connect();
    	String str = jedis.hget("visitCount:article" , String.valueOf(cfgId));
        return str ;
    }   
    
    //赋值
    @GetMapping("/testSet")
    @ResponseBody
    String testSet(Long cgfId){ 
    
            JedisShardInfo shardInfo = new JedisShardInfo("redis://localhost:6379/9");//这里是连接的本地地址和端口
            shardInfo.setPassword("123456");//这里是密码
            Jedis jedis = new Jedis(shardInfo);
            jedis.connect();
            
            jedis.hset("visitCount:article",String.valueOf(cfgId), "1");
            return "SUCCESS";
    }

方法二(spingboot自带的方法RedisTemplate ,推荐):

//获取
    @Autowired
    private RedisTemplate redisTemplate;
    
    
    @GetMapping("/testQuery")
    @ResponseBody
    String testQuery(Long cgfId){ 
    
        JedisConnectionFactory connectionFactory = (JedisConnectionFactory) redisTemplate.getConnectionFactory();
        connectionFactory.setDatabase(9);//选择9号数据库
    
        HashOperations hashOperations = redisTemplate.opsForHash();
        String str =(String) hashOperations.get("visitCount:article", String.valueOf(cfgId));
        return str;
    }

//赋值
    @Autowired
    private RedisTemplate redisTemplate;  
    
    @GetMapping("/testSet")
    @ResponseBody
    String testSet(Long cgfId){ 
    
    		JedisConnectionFactory connectionFactory = (JedisConnectionFactory) redisTemplate.getConnectionFactory();
            connectionFactory.setDatabase(9);//选择9号数据库
    
            HashOperations hashOperations = redisTemplate.opsForHash();
            hashOperations.put("visitCount:article",String.valueOf(cfgId),1);
            
            return "SUCCESS";
    }