![[PukiWiki]](image/pukiwiki.png "[PukiWiki]")
Hazelcast †goal †Hazelcastをjavaで動かす. What Hazelcast †
What in-memory data grid †
GetStarted? †Get Started with Hazelcast IMDG IntelliJの設定 †
サーバーのたて方 †
import com.hazelcast.core.*;
import com.hazelcast.config.*;
import java.util.Map;
import java.util.Queue;
public class GettingStarted {
public static void main(String[] args) {
Config cfg = new Config();
HazelcastInstance instance = Hazelcast.newHazelcastInstance(cfg);
Map<Integer, String> mapCustomers = instance.getMap("customers");
mapCustomers.put(1, "Joe");
mapCustomers.put(2, "Ali");
mapCustomers.put(3, "Avi");
System.out.println("Customer with key 1: "+ mapCustomers.get(1));
System.out.println("Map Size:" + mapCustomers.size());
Queue<String> queueCustomers = instance.getQueue("customers");
queueCustomers.offer("Tom");
queueCustomers.offer("Mary");
queueCustomers.offer("Jane");
System.out.println("First customer: " + queueCustomers.poll());
System.out.println("Second customer: "+ queueCustomers.peek());
System.out.println("Queue size: " + queueCustomers.size());
}
}
実行結果 Members {size:1, ver:1} [
Member [192.168.0.5]:5701 - f2eb4e2f-028e-4cf4-af5a-005c27591655 this
]
Customer with key 1: Joe
Map Size:3
First customer: Tom
Second customer: Mary
Queue size: 2
2台目 Members {size:2, ver:2} [
Member [192.168.0.5]:5701 - f2eb4e2f-028e-4cf4-af5a-005c27591655
Member [192.168.0.5]:5702 - dc880f43-e9d4-4ad4-8428-2ca2d9732aa7 this
]
12月 29, 2017 5:09:32 午後 com.hazelcast.core.LifecycleService
情報: [192.168.0.5]:5702 [dev] [3.9.1] [192.168.0.5]:5702 is STARTED
Customer with key 1: Joe
Map Size:3
First customer: Mary
Second customer: Jane
Queue size: 4
mapは, <Integer, String>である. そのため, 2台目の場合は上書きしているだけなので, MapSize?は変わらない. Queueはpushしているので, 2台目のデータの数と同じである. クライアントの動かし方 †
package com.hazelcast.test;
import com.hazelcast.client.config.ClientConfig;
import com.hazelcast.client.HazelcastClient;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.core.IMap;
public class GettingStartedClient {
public static void main(String[] args) {
ClientConfig clientConfig = new ClientConfig();
clientConfig.addAddress("127.0.0.1:5701");
HazelcastInstance client = HazelcastClient.newHazelcastClient(clientConfig);
IMap map = client.getMap("customers");
IQueue queue = client.getQueue("customers");
System.out.println("Map Size : " + map.size());
System.out.println("mapCustomers 1 : " + map.get(1));
System.out.println("Queue Size : " + queue.size());
System.out.println("queueCustomers poll : " + queue.poll());
}
}
実行結果 Members [3] {
Member [192.168.0.5]:5701 - f2eb4e2f-028e-4cf4-af5a-005c27591655
Member [192.168.0.5]:5702 - dc880f43-e9d4-4ad4-8428-2ca2d9732aa7
}
Map Size : 3
mapCustomers 1 : Joe
Queue Size : 4
queueCustomers poll : Mary
とりあえず, サーバーで指定したgetMap(String)のStringと同じ名前でgetMap(String)すれば, 同じMapが取れる. 内部について †この2サイトに詳しい説明が書いてある.
パーティションでデータを保存しているため, 例えば4つサーバー(Node)をたて, そのうちのサーバー(Node)が1つなくなったとしても, map, queueに入れたデータは残る.
 教えてもらったもの †このリンク先の記事がとっても役に立つらしい goal2 先輩の手伝い †１．以下のテストを書いてほしいです。 ・１つのローカル内で２つのノードに見立てて立ち上げ、データをやりとりします ・相手ノードのノード名と相手側のデータの２つの入力が揃ったらそれを表示します ・データをインクリメントしてそれを繰り返します インプット： 1 アウトプット： A : 1 B: 2 A : 3 B: 4 A : 5 B : 6 A: 7 B : 8 A: 9 ２．調査：ノード間でトポロジー（ツリーとかリングとか）を形成したいとき、それをサポートする機能はあるか？ ３．調査：送信するデータを圧縮したいとき、それをサポートする機能はあるか？ 1 コード †package jp.ac.uryukyu.ie.aka;
import com.hazelcast.core.*;
import com.hazelcast.config.*;
public class Incrementer {
public static void main(String[] args){
int initData = 0; // dataの初期値
int maxData = 10; // dataの最大値
int nodeNum = 2; // 最終的なnodeの数
char nodeBaseName = 'A';
// nodeの生成
Config config = new Config();
HazelcastInstance instance = Hazelcast.newHazelcastInstance(config);
// 名前の生成とアウトプット
int memberSize = instance.getCluster().getMembers().size();
String localName = String.valueOf((char)(nodeBaseName + memberSize - 1));
String remoteName = String.valueOf((char)(nodeBaseName + memberSize % nodeNum));
System.out.println("local : " + localName);
System.out.println("remote : " + remoteName);
// 自分と相手のデータ構造体Topicの作成, get
ITopic<Integer> localTopic = instance.getTopic(localName);
ITopic<Integer> remoteTopic = instance.getTopic(remoteName);
// 自分のTopicはリッスンする.
localTopic.addMessageListener(message -> {
// 送られてきたデータを受け取る
int data = message.getMessageObject();
System.out.println("from : " + remoteTopic.getName());
System.out.println("data : " + data);
// maxDataに到達するまで, 相手にdata + 1を送り, 到達したら全てのnodeをshutdownする.
if(data < maxData) {
remoteTopic.publish(data + 1);
}else{
//instance.getLifecycleService().terminate();
Hazelcast.shutdownAll();
}
});
// 相手のTopicにデータを送る.
remoteTopic.publish(initData);
}
}
実行結果 †Node A local : A
remote : B
Members {size:2, ver:2} [
Member [10.10.10.167]:5701 - 30098b8c-ebaf-479a-85ed-6ff96389151a this
Member [10.10.10.167]:5702 - d7d30c33-ee10-43d8-aab4-b90f8a9fa513
]
from : B
data : 0
from : B
data : 2
from : B
data : 4
from : B
data : 6
from : B
data : 8
from : B
data : 10
Node B Members {size:2, ver:2} [
Member [10.10.10.167]:5701 - 30098b8c-ebaf-479a-85ed-6ff96389151a
Member [10.10.10.167]:5702 - d7d30c33-ee10-43d8-aab4-b90f8a9fa513 this
]
local : B
remote : A
from : A
data : 1
from : A
data : 3
from : A
data : 5
from : A
data : 7
from : A
data : 9
2. ノード間でトポロジー（ツリーとかリングとか）を形成したいとき、それをサポートする機能はあるか？ †Q: ノード間でトポロジー（ツリーとかリングとか）を形成したいとき、それをサポートする機能はあるか？ A: 読めてないけど解説はありました. ただ, AliceのTopologyManager?みたいなものはなく, プログラムで指定するっぽい...多分. 3. 送信するデータを圧縮したいとき、それをサポートする機能はあるか？ †Q: 送信するデータを圧縮したいとき、それをサポートする機能はあるか？ A: あるっぽいです. https://blog.hazelcast.com/kryo-serializer/ Kryoというシリアライズ + 圧縮をするフレームワーク? 的なものがJavaの外部フレームワークにあるらしく, それを用いるそうです. 参考サイト †
|
