java8 缓存对比并存值

可以使用 MyBatis 获取数据库数据为列表，然后使用 Java 8 的 Stream 流来对比 Redis 值。以下是一个示例实现：
import org.apache.ibatis.session.SqlSession;
import redis.clients.jedis.Jedis;
import java.util.List;
import java.util.stream.Collectors;
import java.util.logging.Logger;

public class OfferingCacheWithMyBatisAndStream {

    private static final Logger logger = Logger.getLogger(OfferingCacheWithMyBatisAndStream.class.getName());
    private static final String REDIS_KEY = "cache";

    public static void main(String[] args) {
        try (SqlSession sqlSession = MyBatisUtil.getSqlSessionFactory().openSession()) {
            // 使用 MyBatis 查询数据库数据并获取列表
            List<OfferingEntity> offeringList = sqlSession.selectList("mapper.OfferingMapper.selectOfferings");

            try (Jedis jedis = new Jedis("localhost", 6379)) {
                offeringList.stream()
                       .forEach(offering -> {
                            String name = offering.getName();
                            String code = offering.getCode();
                            String id = offering.getId();
                            String cachedValue = jedis.hget(REDIS_KEY, name);
                            if (cachedValue == null ||!cachedValue.equals(code + "," + id)) {
                                // 如果数据不同或者未缓存，更新缓存并记录日志
                                jedis.hset(REDIS_KEY, name, code + "," + id);
                                logger.info("Updated cache. Name: " + name + ", Code: " + code + ", ID: " + id);
                            }
                        });
            }
            sqlSession.commit();
        } catch (Exception e) {
            logger.severe("Error in cache update: " + e.getMessage());
        }
    }

    // 假设的数据库实体类
    static class OfferingEntity {
        private String name;
        private String code;
        private String id;

        public String getName() {
            return name;
        }

        public void setName(String name) {
            this.name = name;
        }

        public String getCode() {
            return code;
        }

        public void setCode(String code) {
            this.code = code;
        }

        public String getId() {
            return id;
        }

        public void setId(String id) {
            this.id = id;
        }
    }
}
在上述代码中，首先使用 MyBatis 从数据库中查询数据得到一个列表，然后使用 Stream 流遍历列表中的每个元素，对比 Redis 中的缓存值，如果不同则更新缓存并记录日志。

请注意，你需要根据实际情况配置 MyBatis 的映射文件和数据库连接信息，并确保 Redis 连接正确。