slipp.net의 기능을 보면 Facebook과 연동하는 부분이 있다. Facebook과 연동하는 부분은 성능 상의 이슈도 있고, 실패하더라도 핵심 비지니스 로직이 실패하면 안되기 때문에 Async로 분리해서 구현을 진행했다. 그런데 Async로 처리하다보니 몇 가지 이슈들이 발생해 retry를 해야 하는 상황이 발생했다.

정확한 원인은 Async 처리로 인해 Transaction이 분리되다보니 데이터를 정상적으로 가져오지 못하는 이슈가 있어서 다음과 같이 구현했다. 또한 Facebook과 연동할 때도 가끔씩 Facebook 연동이 실패하는 경우가 있어 retry 기능을 써야했다. retry가 몇 군데 나뉘어서 구현되다보니 중복되는 부분도 발생고 있어 리팩토링을 해야겠다는 생각이 든다. 현재 Facebook과의 연동을 담당하고 있는 클래스는 다음과 같다.

@Service
@Transactional
public class FacebookService {
    [...]


    @Async
    public void sendToQuestionMessage(SocialUser loginUser, Long questionId) {
        log.info("questionId : {}", questionId);
        Question question = questionRepository.findOne(questionId);
        if (question == null) {
            question = retryFindQuestion(questionId);
        }


        if (question == null) {
            log.info("Question of {} is null", questionId);
            return;
        }


        String message = createFacebookMessage(question.getContents());
        String postId = sendMessageToFacebook(loginUser, createLink(question.getQuestionId()), message);
        if (postId != null) {
            question.connected(postId);
        }
    }


    private Question retryFindQuestion(Long questionId) {
        Question question = null;


        int i = 0;
        do {
            if (i > 2) {
                break;
            }


            sleep(500);
            question = questionRepository.findOne(questionId);


            i++;
        } while (question == null);


        return question;
    }


    private void sleep(long millis) {
        try {
            Thread.sleep(millis);
        } catch (InterruptedException e) {
        }
    }


    private String sendMessageToFacebook(SocialUser loginUser, String link, String message) {
        String postId = null;
        try {
            FacebookClient facebookClient = new DefaultFacebookClient(loginUser.getAccessToken());
            int i = 0;
            do {
                if (i > 2) {
                    break;
                }


                FacebookType response = facebookClient.publish("me/feed", FacebookType.class,
                        Parameter.with("link", link), Parameter.with("message", message));
                postId = response.getId();


                i++;
            } while (postId == null);
            log.info("connect post id : {}", postId);
        } catch (Throwable e) {
            log.error("Facebook Connection Failed : {}", e.getMessage());
        }
        return postId;
    }


    @Async
    public void sendToAnswerMessage(SocialUser loginUser, Long answerId) {
        log.info("answerId : {}", answerId);
        Answer answer = answerRepository.findOne(answerId);


        if (answer == null) {
            answer = retryFindAnswer(answerId);
        }


        if (answer == null) {
            log.info("Answer of {} is null", answerId);
            return;
        }


        Question question = answer.getQuestion();
        String message = createFacebookMessage(answer.getContents());


        String postId = sendMessageToFacebook(loginUser, createLink(question.getQuestionId(), answerId), message);
        if (postId != null) {
            answer.connected(postId);
        }
    }


    private Answer retryFindAnswer(Long answerId) {
        Answer answer = null;


        int i = 0;
        do {
            if (i > 2) {
                break;
            }


            sleep(500);
            answer = answerRepository.findOne(answerId);


            i++;
        } while (answer == null);


        return answer;
    }


    [...]
}

위 코드를 보면 모두 3군데에서 retry를 하고 있다. 이 코드를 리팩토링한다면 어떻게 하면 좋을까? 이 코드를 리팩토링하지 않고 이미 존재하는 라이브러리를 쓴다면 추천할만한 라이브러리가 있을까?