개발자인생

@Component

@Order(1)

public class CorsFilter implement Filter {

..........

}

@Component

@Order(2)

public class AuthFilter implement Filter {

..........

}

import com.fasterxml.jackson.core.JsonGenerator;

import com.fasterxml.jackson.core.JsonProcessingException;

import com.fasterxml.jackson.databind.JsonSerializer;

import com.fasterxml.jackson.databind.SerializerProvider;

import java.io.IOException;

public class NullToEmptyStringSerializer extends JsonSerializer<Object>{

    @Override

    public void serialize(Object o, JsonGenerator jsonGenerator, SerializerProvider serializerProvider) throws IOException, JsonProcessingException {

        jsonGenerator.writeString("");

    }

}

import com.fasterxml.jackson.databind.ObjectMapper;

public class CustomObjectMapper extends ObjectMapper {

    private static final long serialVersionUID = 1L;

    public CustomObjectMapper(){

        getSerializerProvider().setNullValueSerializer(new NullToEmptyStringSerializer());

    }

}

@Configuration

public class JsonCustomConfigure {

    @Bean

    public MappingJackson2HttpMessageConverter converter() {

        MappingJackson2HttpMessageConverter converter = new MappingJackson2HttpMessageConverter();

        CustomObjectMapper mapper = new CustomObjectMapper();

        mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);

        converter.setObjectMapper(mapper);

        return converter;

    }

}

RestTemplate restTemplate = new RestTemplate();

String result = restTemplate.getForObject("http://localhost:9999/test?param=test=", String.class);

// Connection Timeout 10초, ReadTimeout 10초 설정.

private RestTemplate getRestTemplate() {
    HttpComponentsClientHttpRequestFactory factory 
         = new HttpComponentsClientHttpRequestFactory();
    factory.setConnectTimeout(10*1000);
    factory.setReadTimeout(10*1000);
    RestTemplate restTemplate = new RestTemplate(factory);
    return restTemplate;
}

> java -jar batch.jar

log4j:WARN No appenders could be found for logger (com.BatchMain).

log4j:WARN No appenders could be found for logger.

> java -Dlog4j.configuration=properties/log4j.properties -jar batch.jar

> java -Dlog4j.configuration=file:/root/properties/log4j.properties -jar batch.jar

@Entity

@org.hibernate.annotations.DynamicUpdate

public class Member {

@id

private long id;

private String name;

..

..

}

System.getenv("HOSTNAME");

public static String getHostName(){
    String hostname = System.getenv("HOSTNAME");
    if(hostname != null) return hostname;

    String lineStr = "";
    try {
        Process process = Runtime.getRuntime().exec("hostname");
        BufferedReader br = new BufferedReader(new InputStreamReader(process.getInputStream()));
        while((lineStr = br.readLine()) != null ){
            hostname = lineStr;
        }
    }catch (IOException e) {
        e.printStackTrace();
        hostname = "";
    }
    return hostname;
}

springboot+springbatch 조합으로 배치 프로그램 작성

실행파일 jar를 만들어서 배치를 아래와 같이 실행. 

java -Dspring.profile.active=real -jar test-batch.jar batch01

crontab으로 스케쥴링

1시간마다 배치 실행시 오류 발생하지 않음.

5분마다 배치 실행시 첫 배치는 잘 실행 되나, 그 이후에 랜덤하게 오류 발생.

오류내용 java.sql.SQLRecoverableException: IO Error: Connection reset

실행시 다음 옵션을 줘서 해결함.(-Djava.security.egd=file:///dev/urandom)

java -Dspring.profile.active=real -Djava.security.egd=file:///dev/urandom -jar test-batch.jar batch01

11g JDBC 드라이버는 사용시 connect string을 암호화하기 위해서 /dev/random을 이용 40bytes의 난수를 생성하여 connect string을 암호화 하는데 /dev/random은 변동(noise)이 적은 시스템에서는 난수 생성이 중단(block)된다 는 문제점이 발생 (참조 2.1, 2.2) /dev/random의 OS level문제 때문에 시스템이 조용하면 /dev/random이용한 난수 생성이 원활하지 않고, 난수생성이 안되어 11g JDBC사용을 필요로 할때 noise가 적어 /dev/random으로부터 40byte의 난수를 얻지 못한 JDBC는 connect string을 암호화 하지 못하고 암호화가 되지 않아 디비접속을 못해서 JDBC사용시 접속불가 장애가 발생한 것으로 확인이 됨.

urandom은 random과 달리 entropy pool 상황에 상관없이 난수생성이 되므로 JDBC드라이버 사용시 혹은 WAS 구동시 명시적으로 -Djava.security.egd=file:///dev/urandom 이라는 자바옵션을 부여하여 (참조 1.1)

/dev/random 대신 /dev/urandom을 강제적으로 사용을 하면 시스템 noise가 없어도 항상 난수 생성이 되어 JDBC를 이용한 접속시 문제가 발생하지 않음