求助：Esper VirtualDataWindowLookup与Cache集成及密钥随机问题

• 自定义Virtual Data Window绑定Cache
  要把Cache作为存储介质，你需要实现VirtualDataWindow和VirtualDataWindowLookup接口。在open方法里初始化缓存实例（比如用Caffeine、Guava Cache这类成熟库），指定过期时间、容量限制等参数，将窗口事件存入缓存而非Esper默认的内存结构。示例代码：

  private Cache<String, EventBean> cache;
  
  @Override
  public void open(VirtualDataWindowContext context) {
      cache = Caffeine.newBuilder()
          .expireAfterWrite(10, TimeUnit.MINUTES)
          .maximumSize(1000)
          .build();
  }
  

• 解决密钥随机生成问题
  你之前的问题核心是存缓存时用了随机键，导致查询时无法匹配数据。正确做法是用业务唯一标识或者查询条件组合作为固定键：

  1. 单字段唯一键：比如事件中的orderId、userId，存入时用该字段作为键，查询时直接用条件里的同字段值检索：

     // 存入事件
     @Override
     public void addEvent(EventBean[] events) {
         for (EventBean event : events) {
             String key = (String) event.get("orderId");
             cache.put(key, event);
         }
     }
     
     // 查询逻辑
     @Override
     public Set<EventBean> lookup(Map<String, Object> keys) {
         String orderId = (String) keys.get("orderId");
         EventBean event = cache.getIfPresent(orderId);
         return event != null ? Collections.singleton(event) : Collections.emptySet();
     }
     

  2. 多字段复合键：如果查询条件是多个字段的组合，自定义一个重写equals和hashCode的Key类，用它作为缓存键：

     static class CompositeKey {
         private final String userId;
         private final String productId;
     
         public CompositeKey(String userId, String productId) {
             this.userId = userId;
             this.productId = productId;
         }
     
         @Override
         public boolean equals(Object o) {
             if (this == o) return true;
             if (o == null || getClass() != o.getClass()) return false;
             CompositeKey that = (CompositeKey) o;
             return Objects.equals(userId, that.userId) && Objects.equals(productId, that.productId);
         }
     
         @Override
         public int hashCode() {
             return Objects.hash(userId, productId);
         }
     }
     
     // 存入时用复合键
     cache.put(new CompositeKey(userId, productId), event);
     
     // 查询时构造复合键检索
     CompositeKey lookupKey = new CompositeKey((String)keys.get("userId"), (String)keys.get("productId"));
     EventBean event = cache.getIfPresent(lookupKey);
     

• 注册自定义窗口到Esper
  最后需要将你的Virtual Data Window注册到Esper配置中，让框架能够识别并使用：

  Configuration config = new Configuration();
  config.addPlugInVirtualDataWindow("com.yourpackage", "CacheBackedWindow", CacheBackedVirtualDataWindowFactory.class);
  

内容的提问来源于stack exchange，提问作者Vikas M