울이

Love Code. Work. Sports.

5 분 소요

  • 이벤트 기반 통신은, 여러 서비스 및 관련 도메인 모델에 변경 사항이나 메시지들을 전파할 때 중요하다.
  • 변경사항이 발생했을 경우, 여러 서비스/모델 에서 변경 사항을 적용 할 방법이 필요
  • 메시지큐를 사용하면 안정적인 통신과 기능적용이 가능하다
  • 메시지큐에는 여러가지가 있지만, 이번에는 ActiveMQ를 사용한다

Event 기반 통신 / 아키텍처

이벤트기반 통신은 여러 마이크로 서비스 및 관련 도메인 모델에 변경사항을 전파 할 때 중요하다

변경 사항이 발생했을 경우, 여러 서비스/모델 에서 변경 사항을 적용 할 방법이 필요하다

이벤트 기반 아키텍처를 달성하기 위한 방법은 여러가지가 있지만, 많은 경우에 메시징 패턴을 사용한다

RabbitMQ, ActiveMQ, Apache Kafka 등과 같은 도구들은 메시징 패턴에 사용되는 메시지 브로커이다

이 중, ActiveMQ를 사용해 메시지를 보내고 받아보려고 한다

ActiveMQ 세팅하기

ActiveMQ는 메시지 브로커로써 메시지를 보내고 받을 수 있는 기능을 제공한다

ActiveMQ는 공식페이지에서 다운받아도 괜찮고, docker-compose 를 통해서 설치해도 된다

공식페이지에서 다운받으려면, 아래 페이지에서 사용하면 된다

  • ActiveMQ 공식페이지 링크: http://activemq.apache.org/activemq-5151-release.html

나는 개발환경에 따로 설치하는 것 보다, docker를 선호해서 docker-compose를 사용하려고 한다

version: '3'

services:
  activemq:
    image: rmohr/activemq
    container_name: activemq
    ports:
      - "8161:8161"
      - "1883:1883"
      - "5672:5672"
      - "61613:61613"
      - "61616:61616"
      - "61614:61614"
  • ActiveMQ Web Console은 8161, ActiveMQ Broker는 61616 포트를 사용한다
  • 기타 다른 1883, 5672, 61613, 61614 포트는 다른 프로토콜을 사용한다
  • docker 로그를 확인하면 ActiveMQ의 포트를 모두 확인할 수 있다

SpringBoot 프로젝트 만들기

  • springboot 버전은 2.7.9-SNAPSHOT 버전을 사용한다 
      plugins {
  id 'java'
  id 'org.springframework.boot' version '2.7.9-SNAPSHOT'
  id 'io.spring.dependency-management' version '1.0.15.RELEASE'
  }

SpringBoot Gradle 적용

  • spring web과 activemq 를 넣는다 
      dependencies {
      implementation 'org.springframework.boot:spring-boot-starter-activemq'
      implementation 'org.springframework.boot:spring-boot-starter-web'
      testImplementation 'org.springframework.boot:spring-boot-starter-test'
  }

SpringBoot Resource 설정

  • resources/application.properties 파일 내부에 ActiveMQ의 설정을 넣는다 
      spring.activemq.broker-url=tcp://localhost:61616
  spring.activemq.user=admin
  spring.activemq.password=admin

SpringBoot Application 작성하기

Config

  • Config 패키지를 만들고, 아래의 JmsCOnfig 클래스를 만든다 
      package com.example.springbootactivemq.config;


  import org.apache.activemq.command.ActiveMQQueue;
  import org.springframework.context.annotation.Bean;
  import org.springframework.context.annotation.Configuration;

  import javax.jms.Queue;

  @Configuration
  public class JmsConfig {

      @Bean
      public Queue queue() {
          return new ActiveMQQueue("test-queue");
      }
  }

consumer

  • consumer 패키지를 만들고, 아래와같이 컨슈머를 만든다 
      package com.example.springbootactivemq.consumer;

  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  import org.springframework.jms.annotation.EnableJms;
  import org.springframework.jms.annotation.JmsListener;
  import org.springframework.messaging.handler.annotation.SendTo;
  import org.springframework.stereotype.Component;

  @Component
  public class MessageConsumer {

      private final Logger logger = LoggerFactory.getLogger(MessageConsumer.class);

      @JmsListener(destination = "test-queue")
      public void receiveMessage(String message) {
          logger.info("Received message: {}", message);
      }

      @JmsListener(destination = "test-queue")
      @SendTo("greet-queue")
      public String receiveMessageAndReply(String message) {
          logger.info("Received message: {}", message);
          return "Hello " + message;
      }

      @JmsListener(destination = "greet-queue")
      public void receiveGreeting(String message) {
          logger.info("Received greeting: {}", message);
      }
  }
    • @JmsListener 를 통해서 메시지를 받는다. test-queue 라는 큐에 메시지가 들어오면, receiveMessage 메소드가 실행된다
    • @SendTo 를 통해서 메시지를 보낼 수 있다. test-queue 라는 큐에 메시지가 들어오면, receiveMessageAndReply 메소드가 실행된다
      • @SendTo에 지정한 greet-queue 큐에 메시지를 보낸다
    • receiveGreeting 메소드는 greet-queue 라는 큐에 메시지가 들어오면 실행된다

controller

  • controller를 만들어 API를 통해 Message를 보내는 역할을 만든다 
      package com.example.springbootactivemq.controller;


  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.http.HttpStatus;
  import org.springframework.http.ResponseEntity;
  import org.springframework.jms.core.JmsTemplate;
  import org.springframework.web.bind.annotation.GetMapping;
  import org.springframework.web.bind.annotation.PathVariable;
  import org.springframework.web.bind.annotation.RequestMapping;
  import org.springframework.web.bind.annotation.RestController;

  import javax.jms.Queue;

  @RestController
  @RequestMapping("/api")
  public class MessageController {

      @Autowired
      private Queue queue;

      @Autowired
      private JmsTemplate jmsTemplate;


      @GetMapping("message/{message}")
      public ResponseEntity<String> publishMessage(@PathVariable("message") final String message) {
          jmsTemplate.convertAndSend(queue, message);
          return new ResponseEntity(message, HttpStatus.OK);
      }
  }

실행

  • /api/message/hello 를 호출하면, test-queue 에 메시지가 들어가고, greet-queue 에 메시지가 들어간다
  • 이 모든 과정을 ActiveMQ Web Console 에서 볼 수 있다
  • Event-driven communication is important when propagating changes or messages to multiple services and related domain models.
  • When changes occur, a method is needed to apply changes across multiple services/models
  • Using message queues enables reliable communication and feature implementation
  • There are various message queues, but this time we’ll use ActiveMQ

Event-Based Communication / Architecture

Event-based communication is important when propagating changes to multiple microservices and related domain models

When changes occur, a method is needed to apply changes across multiple services/models

There are various ways to achieve event-driven architecture, but messaging patterns are used in many cases

Tools like RabbitMQ, ActiveMQ, Apache Kafka, etc. are message brokers used in messaging patterns

Among these, we’ll try sending and receiving messages using ActiveMQ

Setting Up ActiveMQ

ActiveMQ is a message broker that provides functionality to send and receive messages

ActiveMQ can be downloaded from the official page or installed through docker-compose

To download from the official page, use the link below

  • ActiveMQ official page link: http://activemq.apache.org/activemq-5151-release.html

I prefer docker over installing separately in the development environment, so I’ll use docker-compose

version: '3'

services:
  activemq:
    image: rmohr/activemq
    container_name: activemq
    ports:
      - "8161:8161"
      - "1883:1883"
      - "5672:5672"
      - "61613:61613"
      - "61616:61616"
      - "61614:61614"
  • ActiveMQ Web Console uses port 8161, ActiveMQ Broker uses port 61616
  • Other ports 1883, 5672, 61613, 61614 use different protocols
  • You can check all ActiveMQ ports by viewing docker logs

Creating SpringBoot Project

  • Using springboot version 2.7.9-SNAPSHOT 
      plugins {
  id 'java'
  id 'org.springframework.boot' version '2.7.9-SNAPSHOT'
  id 'io.spring.dependency-management' version '1.0.15.RELEASE'
  }

Applying SpringBoot Gradle

  • Add spring web and activemq 
      dependencies {
      implementation 'org.springframework.boot:spring-boot-starter-activemq'
      implementation 'org.springframework.boot:spring-boot-starter-web'
      testImplementation 'org.springframework.boot:spring-boot-starter-test'
  }

SpringBoot Resource Configuration

  • Add ActiveMQ configuration inside resources/application.properties file 
      spring.activemq.broker-url=tcp://localhost:61616
  spring.activemq.user=admin
  spring.activemq.password=admin

Writing SpringBoot Application

Config

  • Create a Config package and create the JmsConfig class below 
      package com.example.springbootactivemq.config;


  import org.apache.activemq.command.ActiveMQQueue;
  import org.springframework.context.annotation.Bean;
  import org.springframework.context.annotation.Configuration;

  import javax.jms.Queue;

  @Configuration
  public class JmsConfig {

      @Bean
      public Queue queue() {
          return new ActiveMQQueue("test-queue");
      }
  }

consumer

  • Create a consumer package and create the consumer as follows 
      package com.example.springbootactivemq.consumer;

  import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  import org.springframework.jms.annotation.EnableJms;
  import org.springframework.jms.annotation.JmsListener;
  import org.springframework.messaging.handler.annotation.SendTo;
  import org.springframework.stereotype.Component;

  @Component
  public class MessageConsumer {

      private final Logger logger = LoggerFactory.getLogger(MessageConsumer.class);

      @JmsListener(destination = "test-queue")
      public void receiveMessage(String message) {
          logger.info("Received message: {}", message);
      }

      @JmsListener(destination = "test-queue")
      @SendTo("greet-queue")
      public String receiveMessageAndReply(String message) {
          logger.info("Received message: {}", message);
          return "Hello " + message;
      }

      @JmsListener(destination = "greet-queue")
      public void receiveGreeting(String message) {
          logger.info("Received greeting: {}", message);
      }
  }
    • Messages are received through @JmsListener. When a message enters the test-queue queue, the receiveMessage method is executed
    • Messages can be sent through @SendTo. When a message enters the test-queue queue, the receiveMessageAndReply method is executed
      • Sends a message to the greet-queue queue specified in @SendTo
    • The receiveGreeting method executes when a message enters the greet-queue queue

controller

  • Create a controller to send Messages through API 
      package com.example.springbootactivemq.controller;


  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.http.HttpStatus;
  import org.springframework.http.ResponseEntity;
  import org.springframework.jms.core.JmsTemplate;
  import org.springframework.web.bind.annotation.GetMapping;
  import org.springframework.web.bind.annotation.PathVariable;
  import org.springframework.web.bind.annotation.RequestMapping;
  import org.springframework.web.bind.annotation.RestController;

  import javax.jms.Queue;

  @RestController
  @RequestMapping("/api")
  public class MessageController {

      @Autowired
      private Queue queue;

      @Autowired
      private JmsTemplate jmsTemplate;


      @GetMapping("message/{message}")
      public ResponseEntity<String> publishMessage(@PathVariable("message") final String message) {
          jmsTemplate.convertAndSend(queue, message);
          return new ResponseEntity(message, HttpStatus.OK);
      }
  }

Execution

  • When calling /api/message/hello, a message goes into test-queue, and a message goes into greet-queue
  • All of this process can be viewed in the ActiveMQ Web Console

댓글남기기

참고

ActiveMQ와 JMS를 사용한 SpringBoot 메시지

2 분 소요

SpringBoot를 사용해서 개발을 하다보면 Exception 처리를 해야하는 경우가 생긴다. 해당하는 경우에 어떻게 예외처리하면 좋은지, 어떤 방법들이 있는지 한번 정리해보고자 한다

SpringBoot Exception 처리하기

1 분 소요

SpringBoot를 사용해서 개발을 하다보면 Exception 처리를 해야하는 경우가 생긴다. 해당하는 경우에 어떻게 예외처리하면 좋은지, 어떤 방법들이 있는지 한번 정리해보고자 한다

스프링부트 멀티모듈 구성하기(4) - Stream 어플리케이션

2 분 소요

스트림 모듈을 세팅하면서 Kafka와 어떻게 SpringBoot가 커넥션을 맺고, Consumer와 Producer가 어떻게 세팅되는지 정리해보려고한다. Kafka는 로컬 카프카도 괜찮고, 서버에 띄워진 Kafka, 혹은 Docker, Confluent등등 Kafka를 지원하는 솔...