오늘의 주제. 안전코딩

1. JAVA 
    1) Object.equals() 을 활용해 볼까?
        - 참조형 변수를 비교시 NULL이 있을경우 NPE가 발생

if ( myName != null && myName.equal("이름") ) {
  // 당신은 멋쟁이!
}

        - myName 이 String 이고 참조형 변수여서 null 가능 하기에 안전한 코드를 위하면 null 이 아님을 항상 확인 필요

if ( Objects.equals(myName, "이름") ) {
  // 당신은 멋쟁이!
}

        - Objects.equals()는 내부에서 NULL 체크하여 NPE 가능성을 줄여줌.
        - Objects.equals(null, null) 의 값은 true

    2) Object.toString() 
        - 우린 가끔 변수에 NULL이 오는 경우를 생각하지 못하고  toString을 실행하여 NPE 발생 시키지요.
        - NPE 발생을 막기 위해 NULL 확인을 하는 조금 더 복잡한 코드가 필요. 

예1) resultName = myName == null ? "이름" : myName;
예2) resultName = Objects.toString(myName, "이름");
// Objects.toString()
public static String toString(Object o, String nullDefault) {
    return (o != null) ? o.toString() : nullDefault;
}


    3) ObjectUtils.isEmpty(), ObjectUtils.isNotEmpty() 
        - 우리는 변수의  형별로 NULL 또는 빈 상태를 체크한는 불편함이 있음
        - ObjectUtils.isEmpty 는 여러가지 형을 동시에 체크해줌! 

// ObjectUtils
public static boolean isEmpty(@Nullable Object obj) {
    if (obj == null) {
        return true;
    } else if (obj instanceof Optional) {
        return !((Optional)obj).isPresent();
    } else if (obj instanceof CharSequence) {
        return ((CharSequence)obj).length() == 0;
    } else if (obj.getClass().isArray()) {
        return Array.getLength(obj) == 0;
    } else if (obj instanceof Collection) {
        return ((Collection)obj).isEmpty();
    } else {
        return obj instanceof Map ? ((Map)obj).isEmpty() : false;
    }
}
ex) 잘못된 예
if(!ObjectUtis.isEmpty(...)) -> 명시적 코드가 아님
ex)올바른 예
//Empty가 아닌것을 체크할 경우 아래처럼 체크하는걸 추천
if(ObjectUtis.isNotEmpty(...))

        - String 의 경우 NULL과 공백을 동시에 체크
        - Spring의 ObjectUtils에는 isNotEmpty가 없음  isNotEmpty가 있는 apache ObjectUtils 추천

2. Javascript 
    1) !! 연산자를 사용하자.
        - JS는 값이 없음을 체크 하기가 참 어렵다 ㅜㅜ  ( ““, NaN, undefined, null 등)
        -  !! 는 값이 없음 체크에 좋다.
        -  !!의 정확한 정의는 : 값을 불리언 값으로 명시적 변환이다. 그래서  false, 0 에 !! 하는 겨우도 false를 반환

!!("str") 	//true
!!("")		//false
!!true		//true
!!false		//false			
!!NaN		//false
!!undefined //false
!!null		//false
!!0			//false -> 0을 허용하는 경우도있으니 조심해서 사용할것
!!777		//true
반응형

환경 :
    기존 : Local 에서 Spring Boot 2.5.4  Spring Security 사용 Redis로 세션관리
    신규 : Local 에서 Spring Boot 3.2.5  Spring Security 사용 Redis로 세션관리

1. 로컬에서 웹 기동시 Redis deserialize  오류 발생
2. 오류 발생 이유는 Spring Security는 다른 버전간에 직렬화가 되지 않는다고 합니다. 
3. 이전 시큐리티에서 생성된 Redis에 등록된 정보를 신규 버전에서 deserialize  를 못하면서 생기는 문제.
4. 기존 프로젝트로 사용해야 하고 신규 프로젝트도 사용 해야 함
5. 기존 프로젝트는  Redis database는 0번 사용 신규 프로젝트는   Redis database는 1번사용으로 설정 변경

org.springframework.data.redis.serializer.SerializationException: Cannot deserialize  
 org.springframework.data.redis.serializer.JdkSerializationRedisSerializer.deserialize(JdkSerializationRedisSerializer.java:108)

참고: https://github.com/spring-projects/spring-boot/issues/38959

반응형

1. CompletableFuture.supplyAsync 사용하여 동기 처럼 사용 도전(결과 완료를 확인하고 진행)
2. 난 공통 스레드풀을 많들어 사용 예정이다. 그래서 공통 쓰레드풀 생성

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
 
@EnableAsync
@Configuration
public class AsyncConfig extends AsyncConfigurerSupport {
 
 
    @Bean("threadPoolTaskExecutorA")
    public Executor threadPoolTaskExecutorMember() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
 
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(5);
        executor.setQueueCapacity(99999);
        executor.setThreadNamePrefix("a-thread-");
        return executor;
    }
 
    @Bean("threadPoolTaskExecutorB")
    public Executor threadPoolTaskExecutorBill() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
 
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(99999);
        executor.setThreadNamePrefix("b-thread-");
        return executor;
    }
 
}
cs


3. 스레드로 메서드 실행 

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
private final Executor threadPoolTaskExecutorA;
private final Executor threadPoolTaskExecutorB;
 
// 스레드 처리 요청목록(ThreadVO: 메서드의 리턴타입)
List<CompletableFuture<ThreadVO>> futures = new ArrayList<>();    
 
// 스레드 메서드 실행 처리
CompletableFuture<ThreadVO> future = CompletableFuture.supplyAsync(() ->
                                this.insertAAAAAProc(excelRows, custPaymentsServiceFlag, custInfo, isAutoMemNoMode, custUniqNo
                                        , custUsrUniqNo, usrId, isAllMember, rowIdxf, excelProgressCount, excelProcessId)
                        , threadPoolTaskExecutorA);
                futures.add(future);    
 
// 스레드 메소드 실행결과 
// allOf, join() 을 하면 스레드가 결과가 모두 콜백 될때까지 기다림.
List<ThreadVO> result = CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]))
                    .thenApply(v -> futures.stream()
                            .map(CompletableFuture::join)
                            .collect(Collectors.toList()))
                    .join();                    
cs

 

4. 이렇게 진행을 했는데. 음. 공통 스레드를 사용하다 보니 스레드가 처리를 못하면 뒤에 들어온 업무는 큐에 계속 쌓이고
    이미 큐에 많이 있는 경우 신규 등록 시 너무 오래 기다림 ㅠㅠ

5. 공통 스레드를 사용하지 않고 등록이 들어오면 스레드를 신규 생성하고 끝나면 지우는 걸로 변경

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
// 큐가 쌓이는 곳
BlockingQueue<Runnable> blockingQueue = new LinkedBlockingQueue<>();
// 스레드 풀 생성
threadPoolExecutor = new ThreadPoolExecutor(333, TimeUnit.SECONDS, blockingQueue);
 
// 스레드 처리 요청목록(ThreadVO: 메서드의 리턴타입)
List<CompletableFuture<ThreadVO>> futures = new ArrayList<>();    
 
// 스레드 메서드 실행 처리
// 끝에 새로 생긴 스레드풀에 하라고 설정
CompletableFuture<ThreadVO> future = CompletableFuture.supplyAsync(() ->
                                this.insertAAAAAProc(excelRows, custPaymentsServiceFlag, custInfo, isAutoMemNoMode, custUniqNo
                                        , custUsrUniqNo, usrId, isAllMember, rowIdxf, excelProgressCount, excelProcessId)
                        , threadPoolExecutor);
futures.add(future);    
 
// 스레드 메소드 실행결과 
// allOf, join() 을 하면 스레드가 모무 끝날 때까지 기다림.
List<ThreadVO> result = CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]))
                    .thenApply(v -> futures.stream()
                            .map(CompletableFuture::join)
                            .collect(Collectors.toList()))
                    .join();    
 
// 스레드풀 정리
threadPoolExecutor.shutdown();
cs

맞는건지 모르겠으나... 모 이렇게.....
스레드 생성시 많은 비용이 든다고 하는데 모름(무시, 모르는척?)!

JAVA 21에서 Virtual thread 라는 좋은 기능이 들어 왔다고 합니다.
전 21버전이 아니라. ㅜㅜ 

https://devel-repository.tistory.com/71

 

spring boot 가상 스레드 적용해보기

JDK 21부터 가상 스레드(virtual thread)가 정식 릴리즈 되었다. 또한 spring boot 3.2부터는 가상 스레드가 지원되어 spring boot 애플리케이션에서 가상 스레드를 시험해 볼 수 있게 되었다. 이번 포스팅에

devel-repository.tistory.com

https://techblog.woowahan.com/15398/

반응형

+ Recent posts