thrift의 자바 버전인 swift 를 이용할 때, enum 클래스 에 , 를 추가했다가 에러가 난 상황이 있어서 공유한다.

사실 이외에도 이 에러는 client와 server 간의 enum 클래스의 내용이 맞지 않을 때 발생할 수 있다. 따라서 특별히 조심해야 한다. Thrift 의 enum은 이렇게 문제가 잘 발생한다. 

swift에 쓰이는 enum 클래스 예시이다.

B(2), 를 사용했는데.  runtime 초기화 때, 실패하는 Exception이 발생했다.

즉 맨 마지막 요소에 , 를 사용하면 다음 요소(enum 값)으로 판단하는 로직이 있다. 

https://github.com/facebook/swift/blob/master/swift-codec/src/main/java/com/facebook/swift/codec/internal/EnumThriftCodec.java

더 이상 문제가 발생하지 않도록, 맨 마지막 컴마를 삭제하고 배포하니 문제가 없다. 

jenkins job을 shell (또는 command util)로 실행할 때, exit(또는 return)을 활용하면 실패여부를 알릴 수 있다.

bash script를 쓴다면, exit 0만 성공이고 exit 나머지 값(예, exit 1, exit -1)로 종료되면, jenkins에서 실패로 표시할 수 있다.

spring boot 1.3이 출시되었다. 

https://github.com/spring-projects/spring-boot/wiki/Spring-Boot-1.3-Release-Notes

property가 바뀌었고, spring 4.2, spring security 4.0, cassandra, oauth2, jooq, HTTP persistent session 을 지원한다.

내가 볼 때 가장 좋은 것으로 spring-reload 대신 spring-devtool이다.

CoolReload(LiveReload)를 지원하고 Http세션도 잘 동작한다.

cache auto-configuration을 지원한다.

리눅스에서 서비스로 쓸 수 있다. 

$ ./myapp.jar

$ sudo link -s /var/myapp/myapp.jar /etc/init.d/myapp

임베디드 servlet 애노테이션을 제공한다.

몽고DB 테스트 쉽게 테스트할 수 있도록 embedded할 수 있다.

http://docs.spring.io/spring-boot/docs/current-SNAPSHOT/reference/htmlsingle/#boot-features-mongo-embedded

배너도 쉽게 만들 수 있다. 

${AnsiColor.BRIGHT_GREEN}My Application 

CommandLineRunner 대신 ApplicationRunner로 바뀌었다.

@Autowired
public MyBean(ApplicationArguments args) {
    boolean debug = args.containsOption("debug");
    List<String> files = args.getNonOptionArgs();
    // if run with "--debug logfile.txt" debug=true, files=["logfile.txt"]
}

ObjectMappers 로 바인딩된 jackson 모듈만 사용한다.

undertow를 spring boot에서 쓰려면 다음과 같이 사용할 수 있다.

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <exclusions>
        <exclusion>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-tomcat</artifactId>
        </exclusion>
    </exclusions>
</dependency>

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-undertow</artifactId>
</dependency>

2. gradle (

dependencies {
    compile("org.springframework.boot:spring-boot-starter-web") {
      exclude group: "org.springframework.boot", module: "spring-boot-starter-tomcat"
    }
    compile ("org.springframework.boot:spring-boot-starter-undertow") {
      exclude group: "io.undertow", module: "undertow-websockets-jsr"
    }
..
}

spring boot에서 undertow를 실행하면 tomcat에 비해 1/2정도로 빨리 실행된다. 그 이유는 undertow는 netty 기반이다. 최신 undertow는 netty 4.1을 기반으로 하고 있다. JBOSS에서 밀고 있는 웹 프레임워크이다. 쓰기 편하게 잘 감싸놨다. 

참조 : http://blog.arungupta.me/undertow-benchmarks-wildfly/

사실 undertow가 netty 를 기반으로 되어 있기 때문에 거의 성능이 비슷하다. 그동안 웹 컨테이너가 tomcat, jetty를 쓰고 있었는데, 상용 서비스로 undertow로 써봐도 안정적이고 괜찮은 것 같다. 

* 참고

https://github.com/undertow-io/undertow

http://undertow.io/

아래 코드를 실행하면 몇 개의 cpu가 동작하는지 확인해봤다.

List<String> deletedCid = allIds.parallelStream().filter(this::isDeleted).collect(Collectors.toList());

cpu 개수만큼 thread가 만들어진다. 

jstack 으로 확인해보니.특히 Pool은 ForjJoinPool을 사용한다.

cpu가 8개이면, 아래와 같이 생성한다.

만약 thread 개수를 늘리고 싶다면,  java.util.concurrent.ForkJoinPool.common.parallelism 값으로 조절한다. 

spring boot(1.3.0)를 이용해서 mongodb(mongo 3.0.6)를 사용하고 있다. 

mongo 터미널을 이용해서 mongodb에서 색인 추가/삭제하는 법을 알고, jpa 연동시 주의사항을 본다.

1. mongodb에서 색인 추가/삭제하기

* 참고 자료 : http://docs.mongodb.org/manual/core/index-creation/

customer 콜렉션에 색인 추가하기

customer 콜렉션에 추가했던 색인을 삭제한다.

2. jpa 모델 연동 사항

Customer라는 클래스를 저장 모델로 하여 JPA로 사용하고 있다고 가정한다.

Customer 클래스에 id를 주어 간단하게 모델로 저장할 때는 아래와 같이 사용할 수 있다. 

public class Customer {

 @Id
 private String id;

 private String firstName;

 private String lastName;
 //...
}

import org.springframework.data.mongodb.core.index.Indexed;

public class Customer {

 @Id
 private String id;

 @Indexed
 private String firstName;

 private String lastName;
 //...
}

@Indexed의 정상 동작을 하도록 하려면, 클래스 앞에 반드시 @Document를 추가해야 한다. 그리고 mongo 터미널에서 확인하면 정상적으로 동작하는지 확인할 수 있다.

import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.index.Indexed;
import org.springframework.data.mongodb.core.mapping.Document;
@Document
public class Customer {

 @Id
 private String id;

 @Indexed
 private String firstName;

 private String lastName;
 //...
}

spring boot 애플리케이션으로 개발하는 웹 서버를 다음과 같이 구성할 수 있다.

nginx 설정시 l7check url을 명세하고, 이를 web application에서 처리하도록 설정한다.

HeathChecker라는 Controller를 만들어서 배포시 start,stop할 때마다 호출하여 l7check를 제어할 수 있도록 만들었다.

/l7check/true, /l7check/false url을 주어 health check 결과를 build하도록 하였다. 참고로, spring boot는 health check down시는 503 에러를 발생하도록 되어 있어 l7check를 아주 손쉽게 처리할 수 있다. 

import org.springframework.boot.actuate.health.Health;
import org.springframework.boot.actuate.health.HealthIndicator;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
public class HealthChecker implements HealthIndicator {

 private Boolean isActivating = true;

 @Override
 public Health health() {
  Boolean isOk = check();
  if (!isOk) {
   return Health.down().withDetail("Error Code", 10000).build();
  }
  return Health.up().build();
 }

 public Boolean check() {
  return isActivating;
 }

 @RequestMapping(value="/l7check/{value}", method = RequestMethod.GET)
 @ResponseBody
 public Boolean setActivating(@PathVariable Boolean value) {
  this.isActivating = value;
  return this.isActivating;
 }

}

2014년 spring batch에서 spring retry로 따로 분리되었다. Spring 4이상에서 사용할 수 있다.

(계속 유지보수는 안되고 있는 느낌이지만 유틸리티의 성격이 있어서 간단한 코드에서는 계속 쓸 수 있을 듯 싶다.)

https://github.com/spring-projects/spring-retry

예제만 봐도 깔끔한 느낌이다.

@Configuration
@EnableRetry
public class Application {

    @Bean
    public Service service() {
        return new Service();
    }

}

@Service
class Service {
    @Retryable(RemoteAccessException.class)
    public void service() {
        // ... do something
    }
    @Recover
    public void recover(RemoteAccessException e) {
       // ... panic
    }
}

Retry를 간단하게 아래와 같이 코딩할 수 있다. 

괜찮은 코드는 아래 코드를 추천한다.

https://dzone.com/articles/spring-retry-ways-integrate

http://www.java-allandsundry.com/2014/12/spring-retry-ways-to-integrate-with.html

https://github.com/bijukunjummen/test-spring-retry

간단하게 테스트를 할 수 있는 예제로 테스트해봤다. 2 번 retry를 바로 하는 구조의 호출을 다음과 같이 개발해볼 수 있다. 

public interface RemoteCallService {
 @Retryable(maxAttempts = 2, backoff = @Backoff(delay = 0))
 String call(String url);
}

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.retry.annotation.EnableRetry;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.is;
import static org.mockito.Mockito.*;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration
public class SpringRetryTest {

 @Autowired
 private RemoteCallService remoteCallService;

 @Test
 public void testRetry() {
  String message = this.remoteCallService.call("http://social.google.com");
  verify(remoteCallService, times(2)).call("http://social.google.com");
  System.out.println(message);
  assertThat(message, is("OK"));
 }

  @Configuration
  @EnableRetry
  public static class SpringConfig {

  @Bean
  public RemoteCallService remoteCallService() throws Exception {
   RemoteCallService remoteService = mock(RemoteCallService.class);
   when(remoteService.call("http://social.google.com"))
       .thenThrow(new RuntimeException("Remote Exception 1"))
       .thenReturn("OK");
   return remoteService;
  }
 }
}

Spring RestTemplate의 retry를 spring retry를 이용해서 개발해보았더니. 괜찮아 보였다. 테스트 코드까지 깔끔해진다. 

spring 3.0부터 사용할 수 있는 p, c notation 예제를 RestTemplate으로 설명하는 예제이다.

p는 property, c는 constructor argurment를 의미하는 노테이션이다. 여러 줄에 걸쳐 쓰면 verbose한 느낌이 난다.

그래서 notation을 써보니 깔끔한 느낌이 난다. 

ImageManager라는 클래스를 RestTemplate을 생성하는 예제이다. applicationContext.xml 파일의 timeout 설정을 살펴본다.

public class ImageManager implements InitializingBean {
 private RestTemplate restTemplate;
 public ImageManager(RestTemplate restTemplate) {
  this.restTemplate = restTemplate;
 }
 //...
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:c="http://www.springframework.org/schema/c"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
<beans>

<bean id="imageRequestFactory" class="org.springframework.http.client.HttpComponentsClientHttpRequestFactory" 
      p:readTimeout="250" p:connectTimeout="250" p:connectionRequestTimeout="250"/>
<bean id="imageRestTemplate" class="org.springframework.web.client.RestTemplate" 
      c:requestFactory-ref="imageRequestFactory"/>
<bean id="imageManager" class="com.google.social.util.ImageManager">
    <constructor-arg index="0" ref="imageRestTemplate" />
</bean>
</beans>

spring app을 실행하다가 아래 에러가 발생해서 app 실행이 되지 않으면,

.m2/repository를 삭제하고 다시 maven(gradle) compile을 실행시킨다.

java.lang.IllegalStateException: LifecycleProcessor not initialized - call 'refresh' before invoking lifecycle methods via the context: Root WebApplicationContext: startup date root of context hierarchy