Spring Redis：范围查询“大于”字段

Question

我正在使用 Redis 存储一些数据，然后查询它并使用最新信息对其进行更新。

考虑一个例子：

我收到文件数据，其中包含有关文件的信息以及该文件的物理存储位置。

• 一个架子有多个架子，每个架子可以有多个文件。
• 每个文件都有一个版本字段，并在对文件执行操作时更新（递增）。

我打算如何存储？

• 我需要根据“shelfID + rack ID”查询——获取所有文件。
• 我需要根据“shelfID + rack ID + version > XX”查询--获取所有超过指定版本的文件。

现在，要获取属于架子和机架的所有文件，可以在 Spring Data Redis 中实现。 我创建了一个由 2 个 ID 组合而成的键，然后基于此键进行查询。

  private <T> void save(String id, T entity) {
    redisTemplate.opsForValue().set(id, entity);
  }

但是，如何查询版本字段？ 我将“版本”字段保留为@Indexed，但 spring 存储库查询不起作用。

@RedisHash("shelves")
public class ShelfEntity {

  @Indexed
  @Id
  private String id;

  @Indexed
  private String shelfId;

  @Indexed
  private String rackId;

  @Indexed
  private String fileId;

  @Indexed
  private Integer version;

  private String fileName;    

  // and other updatable fields
}         

存储库方法：

List<ShefEntity> findAllByShelfIdAndRackIdAndVersionGreaterThan(String centerCd,
      String floorCd, int version);

上面，给出错误：

java.lang.IllegalArgumentException: GREATER_THAN (1): [IsGreaterThan, Redis 查询派生不支持 GreaterThan]

• 问。如何根据版本大于查询？
• 问。 Spring Data Redis 甚至可以实现吗？
• 问。如果可能，我应该如何对数据进行建模（到什么数据结构中），以便进行此类查询？
• 问。如果我们不使用 Spring，如何在 Redis 中使用 redis-cli 和数据结构来做到这一点？

---

可能是这样的：

我不确定如何在 Redis 中建模？

---

更新 2： 一个架子可以有N个架子。 一个机架可以有 N 个文件。 每个文件对象都有一个版本。 此版本已更新（o -> 1 -> 2....）

我只想存储文件的最新版本。 所以，如果我们有 1 个文件对象 货架编号 - 1 机架 ID - 1 文件 ID - 1 版本 - 0 ....更新版本...我们仍然应该有 1 个文件对象。 版本 - 1

我尝试将 key 作为shelfId + rackId 的MD5 散列保存在散列数据结构中。 但无法查询版本。

我也尝试过使用 ZSet。

这样保存：

  private void saveSet(List<ShelfEntity> shelfInfo) {
    for (ShelfEntity item : shelfInfo) {
      redisTemplate.opsForZSet()
          .add(item.getId(), item, item.getVersion());
    }
  }

所以，版本就变成了乐谱。

但问题是我们无法更新集合中的项目。 所以对于一个fileId，有多个版本。 当我查询时，我得到了重复。

获取代码：

Set<ShelfEntity> objects = (Set<ShelfEntity>) (Object) redisTemplate.opsForZSet()
        .rangeByScore(generateMd5Hash("-", shelfId, rackId), startVersion,
            Double.MAX_VALUE);

现在，这是模仿版本> XX的尝试

Answer 1

为每个 shelfId 和 rackId 组合创建 ZSET

在Redis中使用两种方法保存和更新记录

// this methods stores all shelf info in db
public void save(List<ShelfEntity> shelfInfo) {
    for (ShelfEntity item : shelfInfo) {
      redisTemplate.opsForZSet()
          .add(item.getId(), clonedItem, item.getVersion());
    }
}

使用 update 删除旧的并插入新的，Redis 不支持 key 更新，因为它是一张表，所以你需要删除现有的并添加新记录

public void update(List<ShelfEntity> oldRecords, List<ShelfEntity> newRecords) {
    if (oldRecords.size() != newRecords.size()){
       throw new IlleagalArgumentException("old and new records must have same number of entries");
    }
    for (int i=0;i<oldRecords.size();i++) {
      ShelfEntity oldItem = oldRecords.get(i);
      ShelfEntity newItem = newRecords.get(i);
      redisTemplate.opsForZSet().remove(oldItem.getId(), oldItem); 
      redisTemplate.opsForZSet()
          .add(newItem.getId(), newItem, newItem.getVersion());
    }
}

从 ZSET 中读取带有分数的项目。

List<ShefEntity> findAllByShelfIdAndRackIdAndVersionGreaterThan(String shelfId,
      String rackId, int version){
    Set<TypedTuple<ShelfEntity>> objects = (Set<TypedTuple<ShelfEntity>>)  redisTemplate.opsForZSet()
        .rangeWithScores(generateMd5Hash("-", shelfId, rackId), new Double(version),
            Double.MAX_VALUE);


    List<ShelfEntity> shelfEntities = new ArrayList<>();
    for (TypedTuple<ShelfEntity> entry:  objects) {
      shelfEntities.add(entry.getValue().setVersion( entry.getScore().intValue()));
    }
    return shelfEntities;
  }