springboot整合分布式缓存hazelCast

Hazelcast是一个内存分布式计算平台，用于管理数据并并行执行执行应用程序。

1. 它是用Java编写的。
2. 与其他一些内存数据库(如redis)不同，Hazelcast是多线程的，这意味着可从所有可用的CPU内核中受益。
3. 与其他内存数据网格不同 - 它设计用于分布式环境。它支持每个群集无限数量的map和缓存。

根据基准测试，Hazelcast在获取数据方面比Redis快56％，在设置数据方面比Redis快44％。

Hazelcast是一个高度可扩展的数据分发和集群平台。特性包括：

1. 提供java.util.{Queue, Set, List, Map}分布式实现。
2. 提供java.util.concurrency.locks.Lock分布式实现。
3. 提供java.util.concurrent.ExecutorService分布式实现。
4. 提供用于一对多关系的分布式MultiMap。
5. 提供用于发布/订阅的分布式Topic（主题）。
6. 通过JCA与J2EE容器集成和事务支持。
7. 提供用于安全集群的Socket层加密。
8. 支持同步和异步持久化。
9. 通过JMX监控和管理集群。
10. 支持动态HTTP Session集群。
11. 利用备份实现动态分割。
12. 支持动态故障恢复。

那么如何使用呢：

pom.xml

 <dependency>
            <groupId>com.hazelcast</groupId>
            <artifactId>hazelcast</artifactId>
        </dependency>
        <dependency>
            <groupId>com.hazelcast</groupId>
            <artifactId>hazelcast-spring</artifactId>
        </dependency>
 <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

配置类：

/**
 * @program: red-bag-activity->HazelcastConfiguration
 * @description:
 * @author: cxy
 * @create: 2019-12-31 12:13
 **/
@Configuration
public class HazelcastConfiguration {
    @Bean
    public Config hazelCastConfig(){
        Config config = new Config();
        config.setInstanceName("hazelcast-instance").addMapConfig(new MapConfig()
                .setName("configuration")
                .setMaxSizeConfig(new MaxSizeConfig(200,MaxSizeConfig.MaxSizePolicy.FREE_HEAP_SIZE))
                .setEvictionPolicy(EvictionPolicy.LRU).setTimeToLiveSeconds(1));
        return config;
    }
}

使用：

import com.hazelcast.core.HazelcastInstance;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.Map;

/**
 * @program: red-bag-activity->HazelcastController
 * @description:
 * @author: cxy
 * @create: 2019-12-31 12:17
 **/
@RestController
public class HazelcastController {
    private final Logger logger = LoggerFactory.getLogger(HazelcastController.class);
    private final HazelcastInstance hazelcastInstance;

    @Autowired
    HazelcastController(HazelcastInstance hazelcastInstance) {
        this.hazelcastInstance = hazelcastInstance;
    }

    @PostMapping(value = "/write-data")
    public String writeDataToHazelcast(@RequestParam String key, @RequestParam String value) {
        Map<String, String> hazelcastMap = hazelcastInstance.getMap("my-map");
        hazelcastMap.put(key, value);
        return "Data is stored.";
    }

    @GetMapping(value = "/read-data")
    public String readDataFromHazelcast(@RequestParam String key) {
        Map<String, String> hazelcastMap = hazelcastInstance.getMap("my-map");
        return hazelcastMap.get(key);
    }

    @GetMapping(value = "/read-all-data")
    public Map<String, String> readAllDataFromHazelcast() {
        Map<String, String> hazelcastMap = hazelcastInstance.getMap("my-map");
        return hazelcastInstance.getMap("my-map");
    }
}

启动两个实例：

第一个时候

启动第二个实例：

第一个也会接受到：

 所以可以看到服务都是一样：

再次的调用：

 

 在其中一个服务启动端口8082，8083可以看到在8082上添加缓存，8083上查询可以查询到，说明数据是一个同步