mindol1004/getting-started
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'master' into cache

Browse Source 
# Conflicts:
#	spring-boot/hazelcast/hazelcast-client-server/src/test/java/io/reflectoring/cache/cleint/AbstractIntegrationTest.java
This commit is contained in:
akuksin
2020-06-18 22:02:15 +02:00
parent 60f6c7e585 31c09ae8dc
commit 2a82919aa1
3 changed files with 27 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-boot/hazelcast/hazelcast-client-server/build.gradle
View File

@@ -22,7 +22,7 @@ dependencies {
implementation 'org.springframework.boot:spring-boot-starter-web'
compileOnly 'org.projectlombok:lombok'
annotationProcessor 'org.projectlombok:lombok'
compile group: 'com.hazelcast', name: 'hazelcast-client', version: '3.12.7'
compile group: 'com.hazelcast', name: 'hazelcast', version: '4.0.1'
testImplementation('org.springframework.boot:spring-boot-starter-test') {
exclude group: 'org.junit.vintage', module: 'junit-vintage-engine'
}

24
spring-boot/hazelcast/hazelcast-client-server/src/main/java/io/reflectoring/cache/cleint/client/CacheClient.java vendored
View File

@@ -1,8 +1,10 @@
package io.reflectoring.cache.cleint.client;
import com.hazelcast.client.HazelcastClient;
import com.hazelcast.client.config.ClientConfig;
import com.hazelcast.config.NearCacheConfig;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.core.IMap;
import com.hazelcast.map.IMap;
import io.reflectoring.cache.cleint.rest.Car;
import org.springframework.stereotype.Component;
@@ -11,15 +13,29 @@ public class CacheClient {
private static final String CARS = "cars";
private HazelcastInstance client = HazelcastClient.newHazelcastClient();
private HazelcastInstance client = HazelcastClient.newHazelcastClient(creatClientConfig());
public Car put(String key, Car car){
public Car put(String key, Car car) {
IMap<String, Car> map = client.getMap(CARS);
return map.putIfAbsent(key, car);
}
public Car get(String key){
public Car get(String key) {
IMap<String, Car> map = client.getMap(CARS);
return map.get(key);
}
private ClientConfig creatClientConfig() {
ClientConfig clientConfig = new ClientConfig();
clientConfig.addNearCacheConfig(createNearCacheConfig());
return clientConfig;
}
private NearCacheConfig createNearCacheConfig() {
NearCacheConfig nearCacheConfig = new NearCacheConfig();
nearCacheConfig.setName(CARS);
nearCacheConfig.setTimeToLiveSeconds(360);
nearCacheConfig.setMaxIdleSeconds(60);
return nearCacheConfig;
}
}

12
spring-boot/hazelcast/hazelcast-client-server/src/test/java/io/reflectoring/cache/cleint/AbstractIntegrationTest.java vendored
View File

@@ -6,13 +6,13 @@ import org.testcontainers.containers.GenericContainer;
public class AbstractIntegrationTest {
static GenericContainer firstMember =
new FixedHostPortGenericContainer("hazelcast/hazelcast:4.0.1")
.withFixedExposedPort(5701, 5701);
static GenericContainer firstMember =
new FixedHostPortGenericContainer("hazelcast/hazelcast:4.0.1")
.withFixedExposedPort(5701, 5701);
static GenericContainer secondMember =
new FixedHostPortGenericContainer("hazelcast/hazelcast:4.0.1")
.withFixedExposedPort(5702, 5701);
static GenericContainer secondMember =
new FixedHostPortGenericContainer("hazelcast/hazelcast:4.0.1")
.withFixedExposedPort(5702, 5701);
@BeforeAll
public static void init() {