hazelcast cluster demo created

Author: Juraj Veverka

hazelcast-cluster/.gitignore

@@ -0,0 +1,11 @@
+.gradle
+.settings
+bin
+out
+build
+target
+.classpath
+.project
+.idea
+*.iml
+

hazelcast-cluster/README.md

@@ -0,0 +1,25 @@
+# Hazelcast cluster demo
+Simple clustering demo using hazelcast and jetty to create application cluster.
+When instances of server-node are started on same network, they form hazelcast cluster automatically.
+Architecture below shows 3-node cluster example. This cluster application is dynamic, nodes may be added or removed.
+
+### use of proto3 messages
+Data objects stored in hazelcast are proto3 messages defined in [messages.proto](common/src/main/proto/messages.proto).
+The reason why [proto3](https://developers.google.com/protocol-buffers/docs/proto3) message format is used,
+is that this example avoids standard java serialization and reuses serialization and deserialization provided by proto3 messages.
+
+## Architecture
+![](docs/architecture-01.svg)
+
+
+## Build and run
+```gradle clean build installDist distZip```
+
+Start server-node instance.
+```./server-node/build/install/server-node/bin/server-node```
+Web server port id set to avoid conflict on same ip-address.
+First server-node started will use port 8080, second server-node in cluster will use web server port 8081,
+third will use 8082 an so on.
+
+## Run integration tests
+TODO

hazelcast-cluster/build.gradle

@@ -0,0 +1,39 @@
+subprojects {
+
+    apply plugin: "java"
+
+    /*
+      target compatibility should be 11, but due to several issues with gradle / asm
+      is for now target compatibility set to 10
+      https://github.com/gradle/gradle/issues/5120
+      https://github.com/gradle/gradle/issues/5731
+    */
+    targetCompatibility = '10'
+    sourceCompatibility = '10'
+  
+    repositories {
+        mavenCentral()
+    }
+
+    dependencies {
+        compile 'org.slf4j:slf4j-api:1.8.0-beta2'
+        compile 'org.slf4j:slf4j-simple:1.8.0-beta2'
+    }
+}
+
+project(':common') {
+}
+
+project(':server-node') {
+    dependencies {
+        compile project(':common')
+    }
+}
+
+project(':it-tests') {
+    dependencies {
+        compile project(':common')
+        compile project(':server-node')
+    }
+}
+

hazelcast-cluster/common/build.gradle

@@ -0,0 +1,68 @@
+apply plugin: 'java'
+apply plugin: 'maven'
+apply plugin: 'idea'
+apply plugin: 'application'
+apply plugin: 'com.google.protobuf'
+
+buildscript {
+    repositories {
+        mavenCentral()
+    }
+    dependencies {
+        classpath 'com.google.protobuf:protobuf-gradle-plugin:0.8.6'
+    }
+}
+
+repositories {
+    mavenLocal()
+    mavenCentral()
+}
+
+sourceCompatibility = 11
+targetCompatibility = 11
+
+def grpcVersion = '1.13.2'
+mainClassName = 'itx.examples.grpc.service.Main'
+
+dependencies {
+    compile 'org.slf4j:slf4j-api:1.8.0-beta2'
+    compile 'org.slf4j:slf4j-simple:1.8.0-beta2'
+    compile 'com.beust:jcommander:1.72'
+
+    compile "com.google.api.grpc:proto-google-common-protos:1.12.0"
+    compile "io.grpc:grpc-netty:${grpcVersion}"
+    compile "io.grpc:grpc-protobuf:${grpcVersion}"
+    compile "io.grpc:grpc-stub:${grpcVersion}"
+
+    compile 'javax.annotation:javax.annotation-api:1.3.2'
+
+    testCompile "io.grpc:grpc-testing:${grpcVersion}"
+    testCompile 'org.testng:testng:6.14.3'
+}
+
+protobuf {
+    protoc {
+        artifact = 'com.google.protobuf:protoc:3.3.0'
+    }
+    plugins {
+        grpc {
+            artifact = "io.grpc:protoc-gen-grpc-java:${grpcVersion}"
+        }
+    }
+    generateProtoTasks {
+        all()*.plugins {
+            grpc {
+                option 'enable_deprecated=false'
+            }
+        }
+    }
+}
+
+idea {
+    module {
+        // Not using generatedSourceDirs because of
+        // https://discuss.gradle.org/t/support-for-intellij-2016/15294/8
+        sourceDirs += file("${projectDir}/build/generated/source/proto/main/java");
+        sourceDirs += file("${projectDir}/build/generated/source/proto/main/grpc");
+    }
+}

hazelcast-cluster/common/src/main/proto/messages.proto

@@ -0,0 +1,16 @@
+
+syntax = "proto3";
+
+option java_multiple_files = true;
+option java_package = "itx.hazelcast.cluster.dto";
+
+message InstanceInfo {
+    string id = 1;
+    Address address = 2;
+    int32 webServerPort = 3;
+}
+
+message Address {
+    string hostName = 1;
+    int32 port = 2;
+}