如何将Hazelcast与Tomcat上的MongoDB后端Web应用集成并实现数据同步？

嘿，你已经搞定MongoDB和Hazelcast的基础集成，接下来要把这套方案和Tomcat上的Web应用打通，确保UI修改数据库后，IMap的get方法能实时读到最新数据对吧？我来给你一步步拆解具体怎么做：

首先得让Tomcat能识别Hazelcast，有两种常见的集成方式，选哪种看你的需求：

• 全局Tomcat级别集成：把Hazelcast的核心jar包（还有MongoDB相关的依赖jar）放到Tomcat的lib目录下，这样所有部署在这个Tomcat上的Web应用都能共享同一个Hazelcast实例。然后在Tomcat的conf/context.xml里配置Hazelcast的资源：

  <Resource name="hazelcast/Instance"
            auth="Container"
            type="com.hazelcast.core.HazelcastInstance"
            factory="com.hazelcast.tomcat.HazelcastInstanceFactory"
            config-location="/WEB-INF/hazelcast.xml"/>
  

  接着在你的Web应用的WEB-INF/web.xml里添加资源引用：

  <resource-ref>
      <description>Hazelcast Instance</description>
      <res-ref-name>hazelcast/Instance</res-ref-name>
      <res-type>com.hazelcast.core.HazelcastInstance</res-type>
      <res-auth>Container</res-auth>
  </resource-ref>
  

  这样在Web应用里就能通过JNDI获取Hazelcast实例了：

  Context initCtx = new InitialContext();
  HazelcastInstance hazelcastInstance = (HazelcastInstance) initCtx.lookup("java:comp/env/hazelcast/Instance");
  IMap<String, YourEntity> dataMap = hazelcastInstance.getMap("your-target-map");
  

• Web应用内部集成：如果只是这个应用用Hazelcast，那直接把Hazelcast的jar包放到应用的WEB-INF/lib里，然后在应用启动时（比如用ServletContextListener）初始化Hazelcast实例：

  public class HazelcastInitListener implements ServletContextListener {
      private HazelcastInstance hazelcastInstance;
  
      @Override
      public void contextInitialized(ServletContextEvent sce) {
          hazelcastInstance = Hazelcast.newHazelcastInstance(new FileSystemXmlConfig("WEB-INF/hazelcast.xml"));
          sce.getServletContext().setAttribute("hazelcastInstance", hazelcastInstance);
      }
  
      @Override
      public void contextDestroyed(ServletContextEvent sce) {
          hazelcastInstance.shutdown();
      }
  }
  

  然后在web.xml里注册这个监听器就行。

你已经完成了MongoDB和Hazelcast的基础集成，现在要解决的是UI改数据库后，IMap能拿到最新数据的问题，这里有两种靠谱的方案：

• 方案一：用Hazelcast Jet的MongoDB CDC同步
  这是最省心的方式，Hazelcast Jet会监听MongoDB的oplog，一旦数据库有插入、更新、删除操作，自动同步到IMap里。需要在你的hazelcast.xml里配置Jet Job：

  <jet-job name="mongodb-cdc-sync">
      <class-name>com.hazelcast.jet.contrib.mongodb.MongoDbCdcSource</class-name>
      <properties>
          <property name="connectionString">mongodb://localhost:27017</property>
          <property name="database">your-db-name</property>
          <property name="collection">your-collection-name</property>
          <property name="mapName">your-target-map</property>
          <property name="batchSize">100</property>
      </properties>
  </jet-job>
  

  启动Hazelcast和Tomcat后，Jet会自动启动这个同步任务，UI修改数据库后，几秒内IMap里的数据就会更新，调用get方法就能拿到最新值。
• 方案二：业务逻辑里手动同步
  如果不想用CDC，那就在UI触发的后端接口里，做完MongoDB的修改操作后，立刻更新Hazelcast的IMap：

  // 第一步：更新MongoDB
  yourMongoRepo.save(updatedEntity);
  // 第二步：同步更新Hazelcast IMap
  dataMap.put(updatedEntity.getId(), updatedEntity);
  // 如果是删除操作，就调用dataMap.remove(entityId);
  

  这种方式简单直接，但要注意事务一致性：如果MongoDB更新成功但Hazelcast更新失败，会出现数据不一致，所以最好加上重试机制，或者用分布式事务框架来保证两者的原子性。

为了保险起见，你可以给IMap配置合适的缓存策略，防止数据过期或者不一致：

• 设置TTL（数据生存时间）：让IMap里的数据在一定时间后自动过期，下次get的时候会自动从MongoDB加载最新数据：

  // 数据1小时后过期
  dataMap.put(entityId, entity, 1, TimeUnit.HOURS);
  

• 开启Read-Through模式：如果IMap里没有目标数据，自动从MongoDB加载。需要实现MapLoader接口：

  public class YourMongoMapLoader implements MapLoader<String, YourEntity> {
      private final MongoRepository<YourEntity, String> mongoRepo;
  
      // 构造方法注入MongoRepo
      public YourMongoMapLoader(MongoRepository<YourEntity, String> mongoRepo) {
          this.mongoRepo = mongoRepo;
      }
  
      @Override
      public YourEntity load(String key) {
          // 从MongoDB加载数据
          return mongoRepo.findById(key).orElse(null);
      }
  
      @Override
      public Map<String, YourEntity> loadAll(Collection<String> keys) {
          // 批量加载逻辑，可选实现
          return mongoRepo.findAllById(keys).stream()
                  .collect(Collectors.toMap(YourEntity::getId, entity -> entity));
      }
  
      @Override
      public Iterable<String> loadAllKeys() {
          // 返回所有键，可选实现
          return mongoRepo.findAll().stream().map(YourEntity::getId).collect(Collectors.toList());
      }
  }
  

  然后在hazelcast.xml里配置这个MapLoader：

  <map name="your-target-map">
      <map-loader enabled="true">
          <class-name>com.yourcompany.YourMongoMapLoader</class-name>
          <cache-miss-seconds>0</cache-miss-seconds>
      </map-loader>
  </map>
  

  这样即使UI直接修改了MongoDB，当IMap里的数据过期或者不存在时，get方法会自动从MongoDB拉最新的数据。

最后一步就是验证效果：

1. 通过UI修改MongoDB里的某条数据；
2. 调用Web应用的接口，用IMap的get方法获取该数据；
3. 检查返回的是否是修改后的最新数据。

如果用CDC方案，可能需要等1-2秒的同步时间；如果是手动同步，应该是实时生效的。

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