Andrew blog📖

오늘은 현업에서 여러명이 동시에 프로젝트 작업을 할때 유용한 PullRequest 하는 방법에 대해서 알아보도록 하겠습니다. 사실 혼자만 프로젝트를 진행하게 되면, 은근 이런것들에 대한 개념이 없을 수도 있어서 생각난 김에 적습니다.

Pull Request는 뭘까요?

Pull Request 줄여서 PR이라고 하고, PR은 자신이 작성한 코드를 Remote 원격지에 자기가 작업한 브랜치로 push를 하고, 해당 작업 브랜치를 merge하고 싶은 대상이 되는 branch로 PR을 날립니다. 그러면 Reviewer들이 코드 리뷰를 하고, 최종적으로 Leader가 Confirm하게 되면 내가 작성한 소스가 merge하고 싶은 대상이 되는 branch로 merge가 됩니다.

주로 Open Source를 활동하는 분들이 자신이 관심있어 하는 Project를 Fork를 떠서 작업하고, PR를 날려서, 해당 오픈소스 프로젝트에 Contributor가 되는 방식입니다.

이번시간에는 오픈소스 메세지 브로커인 RabbitMQ를 로컬에 설치하고, Spring Boot 프로젝트를 이용해서 간단하게 메세지를 전송하고, Listening 하는 샘플 프로젝트를 만들어보도록 하겠습니다.!!

RabbitMQ의 구성요소

들어가기에 앞서 RabbitMQ는 메세지큐로 Advanced Message Queuing Protocol(AMQP)의 구현체라고 할 수 있습니다.

출처: https://www.cloudamqp.com/img/blog/exchanges-topic-fanout-direct.png

기본적인 메세지큐에 대해서는 다들 알고 있으니까, 간단한 내용은 생략하겠습니다. Producer가 메세지를 생산하고 Message Broker에게 메세지를 보내고, Consumer는 Broker를 Listening을 하면서 해당 메세지를 소비합니다. RabbitMQ에서는 Exchange라는 개념이 등장하는데, Producer가 어디에다가 보낼래?를 나타냅니다. Exchange 종류에 따라서 Direct, Topic, Fanout 이런 식으로 종류가 나누어지게 됩니다.

그림이 너무 좋아서, 설명을 계속 이어나가자면 Direct는 BindingKey를 통해서 특정 Queue에 직접 보냅니다. 그래서 Direct인거겠죠?

Topic은 주제를 뜻하게 때문에 Direct보다는 범위가 넓습니다. 당연히 Queue가 여러개 등장하고, 그렇다면 각각 Queue에 어떻게 할당할지? 🤔궁금증이 생깁니다. 여기서 등장하는게 Routing Key (Routing Pattern)으로 큐에 메세지를 쌓는 것을 매칭시킬 수 있습니다.

마지막으로 Fanout은 SpreadOut 처럼 흩뿌리기! 라고 생각하면 될것 같습니다. 더 자세한건 문서를 확인하고, 아래에서 Config 설정할때 추가로 다루도록 하겠습니다.

설치하기

docker 로 설치하기

1

$ docker run -d --hostname localhost --name my-rabbitmq  -p 5672:5672 -p 15672:15672 rabbitmq:3-management

• localhost:15672
• guest/guest

의존성 추가

1
2
3
4

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

환경설정

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

private static final String queueName = "message-queue";
private static final String topicExchangeName = "topic-message";

@Bean
public Queue queue() {
  return new Queue(queueName, false);
}

@Bean
public TopicExchange exchange() {
  return new TopicExchange(topicExchangeName);
}

@Bean
public Binding binding(Queue queue, TopicExchange exchange) {
  return BindingBuilder.bind(queue).to(exchange).with("foo.bar.#");
}

• Queue: 메세지를 담을 큐를 설정
• Exchange: 메세지 Producer가 보내는 곳
• Binding: 예제에서는 BindingBuilder를 사용해서 위에서 설정한 Queue와 Exchange 를 바인딩 시킨다. with로 들어가는 값은 RoutingKey 로 foo.bar.하위의 모든 키들과 관계를 맺는다.

1
2
3
4
5
6
7
8
9
10
11

@Bean
RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
  RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
  rabbitTemplate.setMessageConverter(messageConverter());
  return rabbitTemplate;
}

@Bean
MessageConverter messageConverter() {
  return new Jackson2JsonMessageConverter();
}

Jackson 메세지 컨버터를 빈으로 등록하고, RabbitTemplate도 빈으로 등록한다. Spring boot가 ConnectionFactory를 주입해서 넣어준다.

메세지 POJO

메세지를 주고 받을 수 있는 CustomMessage pojo를 만든다.

1
2
3
4

@Data
public class CustomMessage {
    private String text;
}

메세지 보내기

Spring에서 ApplicationRunner 인터페이스를 구현하면 프로젝트가 실행이될때 동작하는 run메서드에서 간단한 메세지를 보내 보겠습니다.

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

private static final String topicExchange = "topic-message";
private static String routingKey = "foo.bar.baz";

@Autowired
private RabbitTemplate rabbitTemplate;

@Override
public void run(ApplicationArguments args) throws Exception {
  log.info("send message.....");
  IntStream.range(0,10)
    .forEach(i-> {
      CustomMessage message = new CustomMessage();
      message.setText("hello message : " + i);
      log.info("send message :{}", message);
      rabbitTemplate.convertAndSend(topicExchange, routingKey, message);
	});
}

rabbitTemplate으로 message 객체를 json으로 변환해서 메세지를 보냅니다.

메세지 받기

1
2
3
4

@RabbitListener(queues = "message-queue")
public void receiveMessage(Message message) {
  log.info("receive message :{}", message);
}

Listener는 비교적 간단하게 앞에서 보냈던 @RabbitListner 어노테이션의 queues 속성을 설정하면 해당 큐에 적재된 메세지를 읽어들일 수 있습니다.

마치며

이번시간에는 아주 간단한 RabbitMQ를 설치하고, SpringBoot 프로젝트랑 연동하는 방법을 알아봤습니다.기본적인 TopicExchnage 외에도 다른 Exchange를 구성하는 방법, Batch로 메세지를 전송하고 Listen하는 방법, 큐 네이밍전략, 클러스터 구성, fail-over 등등.. 많은 것들을 시도해 볼수 있는 프로젝트라고 생각됩니다.

AWS 람다 서비스는 serverless로 서버에 대한 운영을 AWS Lambda 서비스로 제공한다. 기존의 프로그래밍과 다른 방식은 상태값을 유지하지 못하는 stateless이고, 매번 lambda function이 호출되는 것이 비동기이기 때문에 그런것들을 생각하면서 프로그래밍 해야 한다.~

Spring Cloud feign에 대해서 알아보자. feign은 ~체하다 라는 뜻으로, netflix에서 개발한 일종의 restTemplate와 비슷하다고 본다.
비교적 쉬운 설정으로 비즈니스 로직에만 집중할 수 있다는 장점이 있다.

주기적으로 업데이트 예정!

예전에 포맷하고 맥 다시 설치하면서 올렸던 내용인데, 새롭게 정리해서 다시 공유 합니다. 제가 주로 개발할때 쓰는 프로그램 및 플러그인들을 모아봤습니다.

MSA 시스템 특성상 여러개의 프로젝트를 관리하고 띄우다 보면, configuration 정보가 이곳저곳에 흩어져 있다보니까, 변경사항을 한눈에 파악하기가 힘들다.
그래서 spring cloud config 라는 프로젝트가 나왔다.

들어가며

이전 시간에는 연관관계 매핑의 기초 다대일 매핑하는 방법과 연관관계 주인에 대해서 알아보았다. 이번에는 양방향 매핑을 할때, 객체 관점에서 어떻게 처리할지?를 고민해보자.

Future 인터페이스는 java5부터 java.util.concurrency 패키지에서 비동기의 결과값을 받는 용도로 사용했다. 하지만 비동기의 결과값을 조합하거나, error를 핸들링할 수가 없었다.

자바8부터 CompletableFuture 인터페이스가 소개되었고, Future 인터페이스를 구현함과 동시에 CompletionStage 인터페이스를 구현한다. CompletionStage는 비동기 연산 Step을 제공해서 계속 체이닝 형태로 조합이 가능하다.

백엔드 주니어 개발자의 이직 이야기입니다.

Java에서는 문자열을 다루는데 String, StringBuffer,StringBuilder를 사용합니다. 각각 어떤 상황에서 사용해야 하는지 알아보도록 하겠습니다.

String Pool?

1
2
3
4
5
6
7
8
9

public static void main(String[] args){
    String s1 = "Cat";
    String s2 = "Cat";
    String s3 = new String("Cat");
    
    System.out.println(s1==s2); // true
    System.out.println(s1==s3); // false
                    
}

첫번째는 String Pool에 존재하게 되고, 두번째 new 연산자를 사용하게 되면 String pool에 올라가지 않습니다.

그래서 동일성(identity) 비교에서 다음과 같은 결과를 나타냅니다.

왜 String Pool을 사용할까? Connection Pool, Thread Pool, 모든 풀을 사용하는 이유는 당연히 재활용하기 위해서입니다.

String 클래스의 intern메서드는?

if the pool already contains a string equal to this String object as determined by the equals(Object) method, then the string from the pool is returned. Otherwise, this String object is added to the pool and a reference to this String object is returned.

만약에 String pool에 존재하면 pool에서 바로 return 하고, String pool에 존재하지 않으면 pool에 추가하고, String 객체의 참조값을 리턴합니다. 그렇기 때문에 위의 예제에서 s1 == s3.intern() 다음과 같이 하게되면 true값을 리턴합니다.

String은 Immutable 불변 객체 입니다.

불변이라는 말은, 매번 새롭게 만든다. 즉, 한번 만들어진 객체는 수정할 수 없다 라는 뜻입니다. 즉 concat이나 + 오퍼레이션을 통해서 문자열을 합치거나 가공할때 마다 그때 마다 매번 새로운 String 객체를 만든다고 생각하면 됩니다. 새로운 메모리 공간을 할당하고, 예전에 사용하지 않는 String은 GC에 의해서 수거를 합니다.

만약에 엄청난 수의 문자열을 조작한다고 생각해보십시요. 사용하지도 않는 힙 메모리 영역들을 차지하게 되고(나중에 GC에 의해 수거하더라도) 메모리 Leak이 발생할 수 있습니다. 그래서 자바에서는 StringBuffer, StringBuilder를 제공하고 있습니다.

StringBuilder, StringBuffer 는 mutable 합니다.

StringBuffer, StringBuilder는 String과 다르게 mutable 한 객체입니다. append(), insert(), delete() and substring() 이런 메서드들을 통해서 메모리에서 새롭게 할당하는 것이 아닌, 가변적으로 메모리를 늘려나갑니다.

StringBuffer vs StringBuilder의 차이는 무엇일까요 ?

StringBuffer는 모든 public 메서드에 syncronized 키워드가 붙어있습니다. 말인 즉슨, Thread-safe하다는 말입니다. 동시에 Thread-safe하다는 말은 자원을 선점할때 Lock를 걸기 때문에 그만큼의 성능 효율이 매우 안 좋다는 것을 의미합니다. 그래서 1.4때까지는 StringBuffer를 사용했지만, 그 이후 버전에는 StringBuilder를 사용하는 것입니다. StringBuilder는 그에 반해 당연히 성능이 좋습니다.

정리

• String은 imutable클래스 StringBuffer, StringBuilder는 mutable클래스
• StringBuffer는 thread-safe 하지만 성능이 느리다.
• StringBuilder는 thread-safe 하지 않지만, 성능은 빠르다.
• 그래서 멀티스레드 환경이 아닌, 문자열 연산이 많은 경우에는 → StringBuilder를 사용한다.
• 문자열 연산이 많이 없고, 단순히 값들만을 가져오는 경우에는 → String Pool에서 가져오므로 String 사용한다.