JedisPool单节点及Cluster通道单条/批量插入，读

清疚 2022-06-13 10:58 135阅读 0赞

@Autowired  
private JedisPool jedisPool;

/\*\*

\*一、 单节点通道批量插入  
\*/  
   Jedis jedis = jedisPool.getResource();  
 Pipeline jcp = jedis.pipelined();  
   Map<String, String> map = new HashMap<String, String>();  
   for (int i = 0; i < list.size(); i++) \{  
   String key = RedisKeysDefine.RT\_HASH\_KEY + infols.get(i).getConnectorID();  
   map.put(RedisKeysDefine.RT\_HASH\_COLUMN\_STATION\_ID, stationId);  
   map.put( RedisKeysDefine.RT\_HASH\_COLUMN\_STATUS, infols.get(i).getStatus()+"");  
   map.put(RedisKeysDefine.RT\_HASH\_COLUMN\_PARKSTATUS, infols.get(i).getParkStatus() + "");  
   map.put(RedisKeysDefine.RT\_HASH\_COLUMN\_LOCKSTATUS, infols.get(i).getLockStatus() + "");  
   map.put(RedisKeysDefine.RT\_HASH\_COLUMN\_DATATIME, dataTime + "");  
   jcp.hmset(key, map);  
\}  
   jcp.sync();

jedis.close();

\-------------------------------------------------------------------------------------------------

二、单节点redis缓存最新一条数据：

Jedis jedis = jedisPool.getResource();  
        String key = RedisKeysDefine.RT\_HASH\_KEY + info.getConnectorID();  
        if(jedis.hexists(key, RedisKeysDefine.RT\_HASH\_COLUMN\_DATATIME))\{  
        /\*\*  
        \* 判断当前数据是否比缓存更新  
        \*/  
        Long lastDataTime = Long.parseLong(jedis.hget(key, RedisKeysDefine.RT\_HASH\_COLUMN\_DATATIME));  
        if(dataTime<lastDataTime) \{  
        jedis.close();  
        return 1;\}

\}  
        jedis.hset(key, RedisKeysDefine.RT\_HASH\_COLUMN\_STATION\_ID, stationId);  
        jedis.hset(key, RedisKeysDefine.RT\_HASH\_COLUMN\_STATUS, info.getStatus() + "");  
        jedis.hset(key, RedisKeysDefine.RT\_HASH\_COLUMN\_PARKSTATUS, info.getParkStatus() + "");  
        jedis.hset(key, RedisKeysDefine.RT\_HASH\_COLUMN\_LOCKSTATUS, info.getLockStatus() + "");  
        jedis.hset(key, RedisKeysDefine.RT\_HASH\_COLUMN\_DATATIME, dataTime + "");  
        jedis.close();

======================在集群Cluster模式下===============================

@Autowired  
private JedisCluster jedisCluster;//在集群Cluster模式下利用通道批量查询

List<StakeRealInfo> list ；//获取存入Cluster的key

JedisClusterPipeline jcp = JedisClusterPipeline.pipelined(jedisCluster);  
jcp.refreshCluster();//刷新集群信息，当集群信息发生变更时调用

List<Object> batchResult = null;  
batchResult = jcp.syncAndReturnAll();//同步读取所有数据 并按命令顺序返回一个列表

jcp.close();

参考的文章：http://lxw1234.com/archives/2015/05/224.htm