Merge pull request #49 from What-s-Your-Plan/feat/#48

Embedded Redis 환경 구성

Author: KIMSEI1124

application/wypl-core/build.gradle

@@ -16,5 +16,8 @@ dependencies {
     implementation project(':domain:jpamongo-review-domain')
     implementation project(':domain:jpa-calendar-domain')
     implementation project(':domain:jpa-member-domain')
+    implementation project(':domain:redis-embedded-domain')
     implementation project(':common')
+
+    implementation 'org.springframework.boot:spring-boot-starter-actuator'
 }

application/wypl-core/src/main/resources/application.yml

@@ -3,10 +3,11 @@ spring:
     name: wypl-core
   config:
     import:
+      - security/application-google.yml
       - security/application-mongo.yml
       - security/application-oracle.yml
+      - security/application-redis.yml
       - security/application-weather.yml
-      - security/application-google.yml
     activate:
       on-profile:
         - default

application/wypl-core/src/main/resources/security

@@ -53,7 +53,7 @@ void success() {
 			SocialMember mockSocialMember = SocialMember.builder()
 				.id(1L)
 				.oauthProvider(OauthProvider.GOOGLE)
-				.OauthId(OAUTH_ID)
+				.oauthId(OAUTH_ID)
 				.build();
 
 			given(socialMemberRepository.findByOauthProviderAndOauthId(any(OauthProvider.class), anyString()))

application/wypl-core/src/test/java/com/wypl/wyplcore/auth/AuthMemberServiceImplTest.java

@@ -39,8 +39,8 @@ public String fileUpload(final File file) {
 	 */
 	public void filesRemove(List<String> fileNames) {
 		List<DeleteObjectsRequest.KeyVersion> list = fileNames.stream()
-				.map(DeleteObjectsRequest.KeyVersion::new)
-				.toList();
+			.map(DeleteObjectsRequest.KeyVersion::new)
+			.toList();
 		DeleteObjectsRequest deleteObjectRequest = new DeleteObjectsRequest(awsS3Properties.getBucket());
 		deleteObjectRequest.setKeys(list);
 		amazonS3Client.deleteObjects(deleteObjectRequest);

client/aws-s3-client/src/main/java/com/wypl/awss3client/AwsS3StorageService.java

@@ -7,5 +7,5 @@
 import com.wypl.jpamemberdomain.member.domain.SocialMember;
 
 public interface SocialMemberRepository extends JpaRepository<SocialMember, Long> {
-	Optional<SocialMember> findByOauthProviderAndOauthId(OauthProvider provider, String oauthId);
+	Optional<SocialMember> findByOauthProviderAndOauthId(OauthProvider oauthProvider, String oauthId);
 }

domain/jpa-member-domain/src/main/java/com/wypl/jpamemberdomain/member/SocialMemberRepository.java

@@ -39,6 +39,6 @@ public class SocialMember {
 	private OauthProvider oauthProvider;
 
 	@Column(name = "oauth_id", nullable = false)
-	private String OauthId;
+	private String oauthId;
 }
 

domain/jpa-member-domain/src/main/java/com/wypl/jpamemberdomain/member/domain/SocialMember.java

@@ -0,0 +1,10 @@
+java {
+    toolchain {
+        languageVersion = JavaLanguageVersion.of(17)
+    }
+}
+
+dependencies {
+    implementation "org.springframework.boot:spring-boot-starter-data-redis"
+    implementation "com.github.codemonstur:embedded-redis:1.4.3"
+}

domain/redis-embedded-domain/build.gradle

@@ -0,0 +1,61 @@
+package com.wypl.redisembeddeddomain;
+
+import java.io.IOException;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+
+import com.wypl.redisembeddeddomain.redis.*;
+
+import jakarta.annotation.PostConstruct;
+import jakarta.annotation.PreDestroy;
+import lombok.extern.slf4j.Slf4j;
+import redis.embedded.RedisServer;
+
+@Slf4j
+@Profile({"default", "local", "test"})
+@Configuration
+public class EmbeddedRedisConfig {
+	private static final String OS_NAME = System.getProperty("os.name");
+
+	@Value("${spring.data.redis.port}")
+	private int redisPort;
+
+	private RedisServer redisServer;
+
+	@PostConstruct
+	private void start() throws IOException {
+		RedisAvailablePortFind findAvailablePortUtils = getRedisAvailablePortFind();
+
+		int port = findAvailablePortUtils.isRedisRunning(redisPort)
+			? findAvailablePortUtils.findAvailablePort(redisPort)
+			: redisPort;
+		log.info("Embedded Redis Running Port : [{}]", port);
+
+		redisServer = new RedisServer(port);
+		redisServer.start();
+	}
+
+	@PreDestroy
+	private void stop() throws IOException {
+		if (redisServer != null) {
+			redisServer.stop();
+		}
+	}
+
+	private RedisAvailablePortFind getRedisAvailablePortFind() {
+		if (OS.MAC.contains(OS_NAME)) {
+			return new RedisAvailablePortFindForMac();
+		} else if (OS.WINDOWS.contains(OS_NAME)) {
+			return new RedisAvailablePortFindForWindows();
+		} else if (OS.UBUNTU.contains(OS_NAME)) {
+			return new RedisAvailablePortFindForUbuntu();
+		} else if (OS.LINUX.contains(OS_NAME)) {
+			return new RedisAvailablePortFindForLinux();
+		} else if (OS.DEBIAN.contains(OS_NAME)) {
+			return new RedisAvailablePortFindForDebian();
+		}
+		throw new IllegalArgumentException("Unsupported OS : " + OS_NAME);
+	}
+}

domain/redis-embedded-domain/src/main/java/com/wypl/redisembeddeddomain/EmbeddedRedisConfig.java

@@ -0,0 +1,23 @@
+package com.wypl.redisembeddeddomain.redis;
+
+import lombok.Getter;
+
+@Getter
+public enum OS {
+	MAC("Mac"),
+	WINDOWS("Windows 10"),
+	LINUX("Linux"),
+	UBUNTU("Ubuntu"),
+	DEBIAN("Debian"),
+	;
+
+	private final String value;
+
+	OS(String value) {
+		this.value = value;
+	}
+
+	public boolean contains(String osName) {
+		return osName.contains(value);
+	}
+}

domain/redis-embedded-domain/src/main/java/com/wypl/redisembeddeddomain/redis/OS.java

@@ -0,0 +1,9 @@
+package com.wypl.redisembeddeddomain.redis;
+
+import java.io.IOException;
+
+public abstract class RedisAvailablePortFind {
+	public abstract int findAvailablePort(final int redisPort) throws IOException;
+
+	public abstract boolean isRedisRunning(final int redisPort) throws IOException;
+}

domain/redis-embedded-domain/src/main/java/com/wypl/redisembeddeddomain/redis/RedisAvailablePortFind.java

@@ -0,0 +1,21 @@
+package com.wypl.redisembeddeddomain.redis;
+
+import java.io.IOException;
+
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+public class RedisAvailablePortFindForDebian extends RedisAvailablePortFind {
+
+	private final RedisAvailablePortFindForMac redisAvailablePortFindForMac = new RedisAvailablePortFindForMac();
+
+	@Override
+	public int findAvailablePort(int redisPort) throws IOException {
+		return redisAvailablePortFindForMac.findAvailablePort(redisPort);
+	}
+
+	@Override
+	public boolean isRedisRunning(int redisPort) throws IOException {
+		return redisAvailablePortFindForMac.isRedisRunning(redisPort);
+	}
+}

domain/redis-embedded-domain/src/main/java/com/wypl/redisembeddeddomain/redis/RedisAvailablePortFindForDebian.java

@@ -0,0 +1,18 @@
+package com.wypl.redisembeddeddomain.redis;
+
+import java.io.IOException;
+
+public class RedisAvailablePortFindForLinux extends RedisAvailablePortFind {
+
+	private final RedisAvailablePortFindForMac redisAvailablePortFindForMac = new RedisAvailablePortFindForMac();
+
+	@Override
+	public int findAvailablePort(int redisPort) throws IOException {
+		return redisAvailablePortFindForMac.findAvailablePort(redisPort);
+	}
+
+	@Override
+	public boolean isRedisRunning(int redisPort) throws IOException {
+		return redisAvailablePortFindForMac.isRedisRunning(redisPort);
+	}
+}

domain/redis-embedded-domain/src/main/java/com/wypl/redisembeddeddomain/redis/RedisAvailablePortFindForLinux.java

@@ -0,0 +1,50 @@
+package com.wypl.redisembeddeddomain.redis;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+
+import org.springframework.util.StringUtils;
+
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+public class RedisAvailablePortFindForMac extends RedisAvailablePortFind {
+
+	@Override
+	public int findAvailablePort(final int redisPort) throws IOException {
+		for (int port = 10000; port <= 65535; port++) {
+			Process process = executeGrepProcessCommand(port);
+			if (!isRunning(process)) {
+				return port;
+			}
+		}
+		throw new IllegalArgumentException("Not Found Available port: 10000 ~ 65535");
+	}
+
+	@Override
+	public boolean isRedisRunning(final int redisPort) throws IOException {
+		return isRunning(executeGrepProcessCommand(redisPort));
+	}
+
+	private boolean isRunning(Process process) {
+		String line;
+		StringBuilder pidInfo = new StringBuilder();
+		try (BufferedReader input = new BufferedReader(new InputStreamReader(process.getInputStream()))) {
+			while ((line = input.readLine()) != null) {
+				pidInfo.append(line);
+			}
+		} catch (Exception e) {
+			log.error(e.getMessage());
+		}
+		return StringUtils.hasText(pidInfo.toString());
+	}
+
+	private Process executeGrepProcessCommand(
+			final int port
+	) throws IOException {
+		String command = String.format("netstat -nat | grep LISTEN | grep %d", port);
+		String[] shell = new String[] {"/bin/sh", "-c", command};
+		return Runtime.getRuntime().exec(shell);
+	}
+}

domain/redis-embedded-domain/src/main/java/com/wypl/redisembeddeddomain/redis/RedisAvailablePortFindForMac.java

@@ -0,0 +1,18 @@
+package com.wypl.redisembeddeddomain.redis;
+
+import java.io.IOException;
+
+public class RedisAvailablePortFindForUbuntu extends RedisAvailablePortFind {
+
+	private final RedisAvailablePortFindForMac redisAvailablePortFindForMac = new RedisAvailablePortFindForMac();
+
+	@Override
+	public int findAvailablePort(int redisPort) throws IOException {
+		return redisAvailablePortFindForMac.findAvailablePort(redisPort);
+	}
+
+	@Override
+	public boolean isRedisRunning(int redisPort) throws IOException {
+		return redisAvailablePortFindForMac.isRedisRunning(redisPort);
+	}
+}

domain/redis-embedded-domain/src/main/java/com/wypl/redisembeddeddomain/redis/RedisAvailablePortFindForUbuntu.java

@@ -0,0 +1,44 @@
+package com.wypl.redisembeddeddomain.redis;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+public class RedisAvailablePortFindForWindows extends RedisAvailablePortFind {
+
+	@Override
+	public int findAvailablePort(int redisPort) {
+		for (int port = 10000; port <= 65535; port++) {
+			if (!isRunning(port)) {
+				return port;
+			}
+		}
+		throw new IllegalArgumentException("Not Found Available port: 10000 ~ 65535");
+	}
+
+	@Override
+	public boolean isRedisRunning(int redisPort) {
+		return isRunning(redisPort);
+	}
+
+	private boolean isRunning(final int port) {
+		try {
+			ProcessBuilder builder = new ProcessBuilder("netstat", "-nat");
+			Process process = builder.start();
+			BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));
+
+			String line;
+			while ((line = reader.readLine()) != null) {
+				if (line.contains("LISTEN") && line.contains(String.valueOf(port))) {
+					return true;
+				}
+			}
+		} catch (IOException e) {
+			log.error("Windows Command Error", e);
+		}
+		return false;
+	}
+}

domain/redis-embedded-domain/src/main/java/com/wypl/redisembeddeddomain/redis/RedisAvailablePortFindForWindows.java

@@ -9,12 +9,12 @@ include ':application:wypl-image'
 
 /* Domain Module */
 include ':domain'
-include ':domain:jpa-common' 
+include ':domain:jpa-common'
 include ':domain:jpa-calendar-domain'
 include ':domain:jpa-member-domain'
 include ':domain:jpamongo-review-domain'
 include ':domain:mongo-common'
-
+include ':domain:redis-embedded-domain'
 
 /* Client Module */
 include ':client'