Add hazelcast.yml file

Author: pavankjadda

pom.xml

@@ -39,11 +39,11 @@
 			<artifactId>spring-boot-starter-web</artifactId>
 		</dependency>
 
-		<dependency>
-			<groupId>com.hazelcast</groupId>
-			<artifactId>hazelcast</artifactId>
-			<version>${hazelcast.version}</version>
-		</dependency>
+		<!--	<dependency>
+                <groupId>com.hazelcast</groupId>
+                <artifactId>hazelcast</artifactId>
+                <version>${hazelcast.version}</version>
+            </dependency>-->
 		<dependency>
 			<groupId>com.hazelcast</groupId>
 			<artifactId>hazelcast-spring</artifactId>

src/main/java/com/pj/hazelcastdemo/HazelcastDemoApplication.java

@@ -1,5 +1,7 @@
 package com.pj.hazelcastdemo;
 
+import com.hazelcast.client.HazelcastClient;
+import com.hazelcast.client.config.ClientConfig;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
@@ -8,6 +10,14 @@ public class HazelcastDemoApplication
 {
 	public static void main(String[] args)
 	{
+		test();
 		SpringApplication.run(HazelcastDemoApplication.class, args);
 	}
+
+	private static void test()
+	{
+		ClientConfig clientConfig = new ClientConfig();
+		//clientConfig.getNetworkConfig().addAddress("127.0.0.1");
+		HazelcastClient.newHazelcastClient(clientConfig);
+	}
 }

src/main/java/com/pj/hazelcastdemo/config/Client.java

@@ -0,0 +1,26 @@
+package com.pj.hazelcastdemo.config;
+
+import com.hazelcast.client.HazelcastClient;
+import com.hazelcast.client.config.ClientConfig;
+import com.hazelcast.core.HazelcastInstance;
+
+import java.util.concurrent.BlockingQueue;
+
+public class Client
+{
+
+	public static void main(String[] args) throws Exception
+	{
+		ClientConfig clientConfig = new ClientConfig();
+		clientConfig.getNetworkConfig().addAddress("127.0.0.1");
+
+		HazelcastInstance client = HazelcastClient.newHazelcastClient(clientConfig);
+		System.out.println(clientConfig.toString());
+
+		BlockingQueue<String> queue = client.getQueue("queue");
+		queue.put("Hello!");
+		System.out.println("Message sent by Hazelcast Client!");
+
+		HazelcastClient.shutdownAll();
+	}
+}

src/main/java/com/pj/hazelcastdemo/config/HazelCastConfig.java

@@ -0,0 +1,16 @@
+package com.pj.hazelcastdemo.config;
+
+import com.hazelcast.client.config.ClientConfig;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class HazelCastConfig
+{
+	//@Bean
+	public ClientConfig hazelCastConfig()
+	{
+		ClientConfig clientConfig = new ClientConfig();
+		return clientConfig;
+		//Hazelcast.newHazelcastInstance(cfg);
+	}
+}

src/main/java/com/pj/hazelcastdemo/config/Member.java

@@ -0,0 +1,33 @@
+package com.pj.hazelcastdemo.config;
+
+import com.hazelcast.config.Config;
+import com.hazelcast.core.Hazelcast;
+import com.hazelcast.core.HazelcastInstance;
+import com.hazelcast.core.HazelcastInstanceNotActiveException;
+
+import java.util.concurrent.BlockingQueue;
+
+public class Member
+{
+
+	public static void main(String[] args) throws Exception
+	{
+		Config config = new Config();
+		config.getUserCodeDeploymentConfig().setEnabled(true);
+		HazelcastInstance hz = Hazelcast.newHazelcastInstance(config);
+		System.out.println("Hazelcast Member instance is running!");
+
+		BlockingQueue<String> queue = hz.getQueue("queue");
+		try
+		{
+			for (; ; )
+			{
+				System.out.println(queue.take());
+			}
+		}
+		catch (HazelcastInstanceNotActiveException e)
+		{
+			System.err.println("Unable to take from the queue. Hazelcast Member is probably going down!");
+		}
+	}
+}

src/main/java/com/pj/hazelcastdemo/domain/Employee.java

@@ -0,0 +1,18 @@
+package com.pj.hazelcastdemo.domain;
+
+import lombok.Data;
+import org.hibernate.annotations.Cache;
+import org.hibernate.annotations.CacheConcurrencyStrategy;
+
+import javax.persistence.Entity;
+import javax.persistence.Id;
+
+@Data
+@Entity
+@Cache(region = "employeeCache", usage = CacheConcurrencyStrategy.READ_WRITE)
+public class Employee
+{
+	@Id
+	private String empId;
+	private String empName;
+}

src/main/java/com/pj/hazelcastdemo/repository/EmployeeRepository.java

@@ -0,0 +1,8 @@
+package com.pj.hazelcastdemo.repository;
+
+import com.pj.hazelcastdemo.domain.Employee;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface EmployeeRepository extends JpaRepository<Employee, String>
+{
+}

src/main/java/com/pj/hazelcastdemo/web/EmployeeController.java

@@ -0,0 +1,69 @@
+package com.pj.hazelcastdemo.web;
+
+import com.hazelcast.client.HazelcastClient;
+import com.hazelcast.core.DistributedObject;
+import com.hazelcast.core.HazelcastInstance;
+import com.hazelcast.map.IMap;
+import com.pj.hazelcastdemo.domain.Employee;
+import com.pj.hazelcastdemo.repository.EmployeeRepository;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Collection;
+import java.util.List;
+import java.util.Optional;
+import java.util.Random;
+
+@RestController
+@RequestMapping("/api/v1/employee")
+public class EmployeeController
+{
+	private final EmployeeRepository employeeRepository;
+
+	public EmployeeController(EmployeeRepository employeeRepository)
+	{
+		this.employeeRepository = employeeRepository;
+	}
+
+	@GetMapping("/find/all")
+	public List<Employee> findAll()
+	{
+		return employeeRepository.findAll();
+	}
+
+	@GetMapping("/find/{empId}")
+	public Optional<Employee> findById(@PathVariable String empId)
+	{
+		return employeeRepository.findById(empId);
+	}
+
+	@GetMapping("/create")
+	public List<Employee> createNewEmployee()
+	{
+		Employee employee = new Employee();
+		String empId = "emp" + new Random().nextInt();
+		employee.setEmpId(empId);
+		employee.setEmpName(empId);
+		employeeRepository.saveAndFlush(employee);
+
+		return employeeRepository.findAll();
+	}
+
+	@GetMapping("/clear")
+	public void clear()
+	{
+		HazelcastInstance hazelcastInstance = HazelcastClient.newHazelcastClient();
+		Collection<DistributedObject> distributedObjects = hazelcastInstance.getDistributedObjects();
+		for (DistributedObject object : distributedObjects)
+		{
+			if (object instanceof IMap)
+			{
+				hazelcastInstance.getMap(object.getName()).destroy();
+				System.out.println("Map destroyed=" + hazelcastInstance.getMap(object.getName()).getName());
+			}
+		}
+		hazelcastInstance.shutdown();
+	}
+}

src/main/resources/application.properties

@@ -1 +1,8 @@
 
+server.port=8080
+spring.jpa.show-sql=true
+spring.cache.type=hazelcast
+spring.jpa.properties.hibernate.cache.use_query_cache=true
+spring.jpa.properties.hibernate.cache.use_second_level_cache=true
+spring.jpa.properties.hibernate.cache.hazelcast.use_native_client=true
+spring.jpa.properties.hibernate.cache.region.factory_class=com.hazelcast.hibernate.HazelcastCacheRegionFactory

src/main/resources/hazelcast/hazelcast.yml

@@ -0,0 +1,27 @@
+version: '3'
+services:
+  hazelcast1:
+    image: hazelcast/hazelcast
+    environment:
+      - 'JAVA_OPTS=-Dhazelcast.local.publicAddress=192.168.1.157:5701 -Dhazelcast.mancenter.url=http://mancenter:8090/mancenter -Dgroup.name=hz-compose -Dgroup.password=s3crEt'
+    ports:
+      - '5701:5701'
+    links:
+      - 'management-center:mancenter'
+  hazelcast2:
+    image: hazelcast/hazelcast
+    environment:
+      - 'JAVA_OPTS=-Dhazelcast.local.publicAddress=192.168.1.157:5702 -Dhazelcast.mancenter.url=http://mancenter:8090/mancenter -Dgroup.name=hz-compose -Dgroup.password=s3crEt'
+    ports:
+      - '5702:5701'
+    links:
+      - 'management-center:mancenter'
+  management-center:
+    image: hazelcast/management-center
+    volumes:
+      - '~/mancenter3.8:/mancenter-3.8'
+    environment:
+      - MANCENTER_DATA=/mancenter-3.8
+      - JAVA_OPTS=-Dhazelcast.mc.rest.enabled=true
+    ports:
+      - '8090:8080'