Spring Eureka를 사용해서 MSA 체험기 (2)

앞서 Spring Eureka가 뭐고 각각의 구성요소를 러프하게 살펴봤다면 이번에는 직접 구현하며 이를 알아볼 것이다.

 

이전 글

https://jaejune0625.tistory.com/58

 

먼저 Server Application - Eureka를 이루는 미들웨어 서버, 즉 클라이언트 요청에 따라 알맞은 MSA 서비스에 보내주는 Application 부터 살펴보자. 아래는 application.yml 파일이다.

server:
  port: 8761 # 기본포트 8761

spring:
  application:
    name: discovery # 서버 이름

eureka:
  client:
    register-with-eureka: false
    fetch-registry: false

• register-with-eureka : eureka에 등록여부를 정하는 부분이다. Server Application의 경우 본인을 등록하지 않기 때문에 이를 false로 설정한다.
• fetch-registry : 해당 registry의 정볼르 가져올지 말지 정하는 부분이다. 이 또한, Client Application의 정보를 가져올 때 설정하기 때문에 Server Application은 false로 설정한다.

다음으로는 Clien A - Eureka Client 중 첫번째로 만든 클라이언트의 application.yml 파일이다.

server:
  port: 9091

spring:
  application:
    name: api-client-A # 서비스 이름

eureka:
  instance:
    instance-id: ${spring.application.name}:${spring.application.instance_id:9091}
    hostname: localhost
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone: http://localhost:8761/eureka

• spring.application.name : 현재 Client Application의 이름을 설정하는 부분이다.
• server.port : 현재 Client A Application이 구동될 포트이다. Localhost에서 실행할 것이니 포트는 겹치지 않게 설정하였다.
• eureka.instance.instance-id: 해당 Client Application의 인스턴스 정보를 기입해준다. 이는 곳 인스턴스의 고유 ID를 만들기 위해서이다.
• eureka.instance.hostname: 해당 host 정보를 입력해준다.
• 위에서 기술했던 부분 중 registry-with-eureka와 fetch-registry를 등록해준다. 이는 해당 인스턴스를 registry에 알리기 위해 설정하는 것이다.
• service-url : Eureka server application의 주소를 기입해준다.

위 와 같이 ClientB도 작성되었다.

 

이 밖에도 여러 설정 값들이 있는데 그것들은 아래 공식 문서에서 확인할 수 있다. (필자가 기술한 값은 구동에 필요한 것만 골라서 사용했다.)

https://cloud.spring.io/spring-cloud-netflix/multi/multi__service_discovery_eureka_clients.html

https://cloud.spring.io/spring-cloud-netflix/multi/multi_spring-cloud-eureka-server.html

 

 

이를 해당하는 서비스가 있도록 Example을 만들었다.

• ClientA - Car
• ClientB - Person

// Client A
@GetMapping("/test")
fun test(): TestCar {
    return TestCar("grandeur", "it's a grandeur.")
}

// Client B
@GetMapping("/test")
fun testPerson() : TestPerson{
    return TestPerson("jjlee", "i am jjlee")
}

 

이제 이를 클라이언트의 요청에 따라 호출할 수 있도록 Server Client의 기입해주면 된다.(필자는 편의상 해당 Car 서비스와 Person 서비스를 같이 호출하여 이를 Response로 보여주었다.)

 

아래는 해당하는 서비스의 요청을 WebClinet로 비동기로 호출하고 있다. (해당 글은 Eureka의 대한 구동 방식을 다루는 글이며, WebClient, 비동기, 코루틴에 대해서는 다른 글에서 자세하게 다룰 것이다.)

// CarAdapter
fun getCar(): Car {
    val webclient = WebClient.create("http://localhost:9091")

    val car = webclient.get().uri("/test")
        .accept(MediaType.APPLICATION_JSON)
        .retrieve()
        .bodyToMono(Car::class.java)

    return car.block()!!
}

// PersonAdapter
fun getPerson(): Person {
    val webclient = WebClient.create("http://localhost:9092")

    val person =  webclient.get().uri("/test")
        .accept(MediaType.APPLICATION_JSON)
        .retrieve()
        .bodyToMono(Person::class.java)

    return person.block()!!
}

 

최종 호출 Response 정보

suspend fun getPersonCar(): PersonCarResponse = coroutineScope {
    val person = async {
        personAdapter.getPerson()
    }
    val car = async {
        carAdapter.getCar()
    }
    PersonCarResponse(
        car.await().name,
        car.await().description,
        person.await().name,
        person.await().description
    )
}

 

각 서버를 구동 시키면 아래와 같은 로그가 보일 것 이다.

// Client A
2024-03-13T14:02:28.537+09:00  INFO 21478 --- [nfoReplicator-0] com.netflix.discovery.DiscoveryClient    : DiscoveryClient_API-CLIENT-A/api-client-A:9091 - registration status: 204
// Client B
2024-03-13T14:02:26.361+09:00  INFO 21471 --- [nfoReplicator-0] com.netflix.discovery.DiscoveryClient    : DiscoveryClient_API-CLIENT-B/api-client-B:9092 - registration status: 204

// Server Application
2024-03-13T14:02:26.961+09:00  INFO 21464 --- [nio-8761-exec-3] c.n.e.registry.AbstractInstanceRegistry  : Registered instance API-CLIENT-B/api-client-B:9092 with status UP (replication=true)
2024-03-13T14:02:29.052+09:00  INFO 21464 --- [nio-8761-exec-6] c.n.e.registry.AbstractInstanceRegistry  : Registered instance API-CLIENT-A/api-client-A:9091 with status UP (replication=true)

 

이제 호출해보면 의도 했던 값들이 각각의 서비스로 부터 받아오는 것을 확인할 수 있다.

{
    "carName": "grandeur",
    "carDescription": "it's a grandeur.",
    "personName": "jjlee",
    "personDescription": "i am jjlee"
}

 

해당 Example code는 아래 깃허브 레포지토리에서 확인할 수 있다.

https://github.com/LeeJejune/Spring-Studying/tree/main/spring-eureka-example