文獻: https://yanbin.blog/hazelcast-introduction/

1. queue類型,點對點,只能一臺機消費,可能要改配置,暫未知
2. 客戶端修改集群數(shù)據(jù),文檔說不能修改,現(xiàn)修改成功,暫未知
3. 默認配置是什么樣?

 <!--hazelcast 緩存-->
        <dependency>
            <groupId>com.hazelcast</groupId>
            <artifactId>hazelcast</artifactId>
            <version>3.11.4</version>
        </dependency>
        <dependency>
            <groupId>com.hazelcast</groupId>
            <artifactId>hazelcast-client</artifactId>
            <version>3.11.4</version>
        </dependency>

package com.example.demojar.controller;

import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.HazelcastInstance;
import java.util.List;
import java.util.Map;
import java.util.Queue;

public class HazelcastMaster {
    public static void main(String[] args) {
        //Map、Queue拜轨、MultiMap勺美、Set、List、Semaphore鸡捐、Atomic 等接口

        HazelcastInstance hazelcastInstance = Hazelcast.newHazelcastInstance();
        //創(chuàng)建map類型
        Map<String, Object> myMap = hazelcastInstance.getMap("myMap");
        myMap.put("key1","集群map");

        //創(chuàng)建queue類型,點對點,只能一臺機消費,可能要改配置,暫未知
        Queue<Object> myQueue = hazelcastInstance.getQueue("myQueue");
        myQueue.offer("Holle hazelcast");
        myQueue.offer("Holle hazelcast queue");

        //創(chuàng)建list類型
        List<String> myList = hazelcastInstance.getList("myList");
        myList.add("list類型數(shù)據(jù)1");
        myList.add("list類型數(shù)據(jù)2");
        myList.add("list類型數(shù)據(jù)3");
    }
}

package com.example.demojar.controller;

import com.alibaba.fastjson.JSON;
import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.HazelcastInstance;

import java.util.List;
import java.util.Map;
import java.util.Queue;

public class HazelcastSlave {
    public static void main(String[] args) {
        //創(chuàng)建一個 hazelcastInstance實例
        HazelcastInstance instance = Hazelcast.newHazelcastInstance();
        Map<String, Object> clusterMap = instance.getMap("myMap");
        Queue<Object> clusterQueue = instance.getQueue("myQueue");
        
        System.out.println("Map Value:" + clusterMap.get("key1"));
        System.out.println("Queue Size :" + clusterQueue.size());
        System.out.println("Queue Value 1:" + clusterQueue.poll());
        System.out.println("Queue Value 2:" + clusterQueue.poll());
        System.out.println("Queue Size :" + clusterQueue.size());
        //獲取list類型
        List<String> myList = instance.getList("myList");
        System.out.println(JSON.toJSONString(myList));
    }
}

package com.example.demojar.controller;

import com.alibaba.fastjson.JSON;
import com.hazelcast.client.config.ClientConfig;
import com.hazelcast.core.HazelcastInstance;

import java.util.List;
import java.util.Map;
import java.util.Queue;

public class HazelcastClientDemo {
    public static void main(String[] args) {
        ClientConfig clientConfig = new ClientConfig();
        HazelcastInstance instance = com.hazelcast.client.HazelcastClient.newHazelcastClient(clientConfig);
        //獲取map類型
        Map<String, Object> clusterMap = instance.getMap("myMap");
        //客戶端修改集群數(shù)據(jù),文檔說不能修改,現(xiàn)修改成功暫未知
        clusterMap.put("key1","客戶端put數(shù)據(jù)");
        //獲取queue類型
        Queue<String> clusterQueue = instance.getQueue("myQueue");

        System.out.println("Map Value:" + clusterMap.get("key1"));
        System.out.println("Queue Size :" + clusterQueue.size());
        System.out.println("Queue Value 1:" + clusterQueue.poll());
        System.out.println("Queue Value 2:" + clusterQueue.poll());
        System.out.println("Queue Size :" + clusterQueue.size());

        //獲取list類型
        List<String> myList = instance.getList("myList");
        System.out.println(JSON.toJSONString(myList));

    }
}