Redis有序Set、無序Set的使用經歷
阿新 • • 發佈:2019-05-03
spa div 利用 ant sequence urn cli ger ble
為了實現一個類似關系數據庫中的賣家信息的單表,首先我們知道單表必然可增刪查改,其次為了區分先來後到又需要有ID主鍵且自增長。開始考慮使用hash數據類型,因為hash是key+列1、列2...這樣一來跟關系型數據庫的數據模型是最像的,但滿足不了第二點。所以後來考慮使用有序set,將各列作為屬性封裝到一個對象中,通過json序列化為String作為有序set的value。key是固定的,我們只能對有序set整體設置失效時間,無法單獨針對具體元素設置失效時間。score均為自增長的序列,score是有序set之所以有序的原因。為了解決最後一個問題,自增長的主鍵我們另外用一個key來維護,利用redis的incr命令來實現自增長。
上面的有序set中維護的是多個賣家的信息,而每個賣家會維護一系列訂單ID列表,這樣我們就能快速的根據訂單ID定位到是哪個賣家了。這次沒有順序要求,當然訂單是不能重復的,所以我選擇無序set。廢話不多說,直接看例子:
package com.crocodile.springboot.redis; import com.crocodile.springboot.model.Merchant; import com.fasterxml.jackson.databind.ObjectMapper; import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.stereotype.Component; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool;import redis.clients.jedis.JedisPoolConfig; import java.io.IOException; import java.util.*; @Component public class JedisOperation { // redis緩存Sorted Set的key private final static String REDIS_SORT_KEY = "merchant_sorted_set"; // json對象映射 private ObjectMapper om = new ObjectMapper(); @Autowired private JedisPool jedisPool; // 讀取applicantion中的redis相關配置項 @Bean @ConfigurationProperties("redis") public JedisPoolConfig jedisPoolConfig() { return new JedisPoolConfig(); } // Jedis的實例池,從配置項的redis.host中讀取redis的ip地址 @Bean(destroyMethod = "close") public JedisPool jedisPool(@Value("${redis.host}") String host) { return new JedisPool(jedisPoolConfig(), host); } /** * 加入有序set,下面已設置了無序set的失效時間,在此之後加入不影響原有失效時間 * @param key * @param orders */ public void addOrdersPerHour(String key, List<Order> orders) { try (Jedis jedis = jedisPool.getResource()) { orders.forEach(order -> { try { jedis.sadd(key, order.getOrderId()); } catch (Exception e) { } }); } } /** * 遍歷訂單列表,放入無序set,一個月後該無序set中全部元素均失效 * @param key * @param orders */ public void addOrdersPerMonth(String key, List<Order> orders) { try (Jedis jedis = jedisPool.getResource()) { jedis.expire(key, 60 * 60 * 24 * 30); orders.forEach(order -> { try { jedis.sadd(key, order.getOrderId()); } catch (Exception e) { } }); } } /** * 獲取總記錄數 * * @return */ public int getCounts() { int count; try (Jedis jedis = jedisPool.getResource()) { count = Integer.valueOf(String.valueOf(jedis.zcard(REDIS_SORT_KEY))); } return count; } /** * 根據起始索引、結束索引查詢有序set * * @param start * @param end * @return */ public List<Merchant> getDatas(int start, int end) { List<Merchant> merchants = new ArrayList<>(); try (Jedis jedis = jedisPool.getResource()) { Set<String> keys = jedis.zrange(REDIS_SORT_KEY, start, end); keys.forEach(merchantStr -> { Merchant merchant = null; try { merchant = om.readValue(merchantStr, Merchant.class); } catch (IOException e) { } if (merchant != null) { merchants.add(merchant); } }); } return merchants; } /** * 根據score(維護key為id的自增序列)添加到有序Set * * @param merchant */ public void addMerchant(Merchant merchant) { try (Jedis jedis = jedisPool.getResource()) { Long sequence = jedis.incr("id"); merchant.setId(sequence); String merchantStr = om.writeValueAsString(merchant); jedis.zadd(REDIS_SORT_KEY, sequence, merchantStr); } catch (Exception e) { return e.getMessage(); } } /** * 根據score修改有序set中的數據,先刪後增 * * @param merchant */ public void modifyMerchant(Merchant merchant) { try (Jedis jedis = jedisPool.getResource()) { String merchantStr = om.writeValueAsString(merchant); jedis.zremrangeByScore(REDIS_SORT_KEY, merchant.getId(), merchant.getId()); jedis.zadd(REDIS_SORT_KEY, merchant.getId(), merchantStr); } catch (Exception e) { return e.getMessage(); } } /** * 根據score刪除有序set中的數據 * * @param id * @return */ public void delMerchant(String id) { try (Jedis jedis = jedisPool.getResource()) { jedis.zremrangeByScore(REDIS_SORT_KEY, Double.valueOf(id), Double.valueOf(id)); } catch (Exception e) { return e.getMessage(); } } }
Redis有序Set、無序Set的使用經歷