💭Microservice 통신?

MSA를 구성하다보면 service간의 통신이 필요할 때가 있다. 예를 들어 유저의 주문 정보를 가져올때는 user-service에서 주문 정보를 가지고 있는게 아니라 order-service에서 정보를 가져와서 user-service에서 반환해줘야하는 경우가 생긴다. 이럴때 Microserivce간 통신이 생기는데 이 경우 어떻게 처리하는지 확인해보자. 이번에는 java에서 자체적으로 제공하는 RestTemplate를 사용해보려고 한다.

🔨user-serivce에 RestTemplate 등록

@SpringBootApplication
@EnableDiscoveryClient
public class UserServiceApplication {

    ...
    
    @Bean
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

RestTemplate을 반환하는 bean을 등록해주고

@Service
@RequiredArgsConstructor
public class UserServiceImpl implements UserService{
    private final UserRepository userRepository;
    private final BCryptPasswordEncoder pwdEncoder;
    private final RestTemplate restTemplate;
    private final Environment env;
    
    ...
    
    @Override
    public UserDto getUserByUserId(String userId) {
        UserEntity userEntity = userRepository.findByUserId(userId);
        if(userEntity == null) throw new UsernameNotFoundException("user name not found!");
        UserDto userDto = new ModelMapper().map(userEntity, UserDto.class);
//        List<ResponseOrder> orderList = new ArrayList<>();    //이전에 빈 배열을 반환하던 값

        /* Using as RestTemplate */
        String orderUrl = String.format(env.getProperty("order_service.url"), userId);	//(1)
        ResponseEntity<List<ResponseOrder>> orderListResponse =	//(2)
                restTemplate.exchange(orderUrl, HttpMethod.GET, null, new ParameterizedTypeReference<List<ResponseOrder>>() {
                });
        List<ResponseOrder> orderList = orderListResponse.getBody();	//(3)

        userDto.setOrders(orderList);

        return userDto;
    }
}

기존에 빈 배열을 넣어서 반환하던 코드를 위 코드와 같이 수정해주어서 사용한다.

(1) url값을 환경변수 값으로 받아오는 것으로 설정값은 user-service.yml에 설정해두었다.

spring:
  datasource:
    driver-class-name: org.h2.Driver
    url: jdbc:h2:mem:testdb
    username: sa
    password: '{cipher}AQAQZKGZrGe0uaQfpDk90mzuSy8WrSHHU5S/OCTB0g9NUTSrG7x0p6qnhXb/SPHSm/dm/TjWp+BpyYzj+w7tr8uTpEkSTuvNCWPtDM813R6J7SbO2DWAccwiNp4ZoGc4KLxB2QbLTZeQxEvRPFOKUqKLkSMQQQPh+2Pxrk0QhTSbbPRIP6hmfTDQgHBjL4FkZTYaQSo6/rRDIUJdBoo248GjiBw6FYXLGQn2DgukNiuBZJlCHac7RW4Z3ZBBMV2jIn/dCjS1yJrQjKfRmK4ZRZ/39+5+If+leMwRIgAr/u3J7TeCMKofJOJc23wt+JILb30ap2f+is7Nqgmyp3yvTQM4PVO/wPlf2ewRyhbYWSB7cY7+QPGBFnMpo+D8to7Dzlg='
token:
  expiration_time: 86400000
  secret: '{cipher}AQBz0/LWzW++38OSlEhkxwNSROmThDnC8EqAXqFlQSJy0dAMBYByPuJMeYExEGKhazdH8NWNlAA1Dn1iMCTyQF2AdwUtvtAE2ieyJ/gEv/fJ89rOFAskWw8Gzpp5zLOqqh3JocnTbOwgvcsEs8AtnesUthoHJ+/5f1ii5weBYj7ymqo4PW5Q1uSXY55eVHUZIYhreb1Dn5J9wkTaBTTTSjWJNppzAPZsFSvc8n9SgewWqLRIzoS+BNIL2ctuWrfpTyu/ZNrxiuAKezGXarOhg1k/6IWE/H3lCwZdH5a9EpwTcHTOqTH5fYUUVYxP5EtiD1ZgPN1rpPLXeLtULDCNSWoUyxx5fcbqc+BGUXX6/xtW6gViV2+vqStBdSEWlyh7xu0='
order_service:
  url: http://127.0.0.1:8000/order-service/%s/orders

(2) restTemplate의 exchange method를 사용하여 url로 요청하는 방법이다.
exchange(url, method, parameter, response type)순서로 넣는다.
(3) getBody()를 통해 반환받은 데이터에서 body를 꺼내와서 orderList 배열에 담는다.

로그인한 유저 ID로 주문을 하나 생성하고

요청하면

order-service에서 정상적으로 주문 내역을 가져와서 user-service에서 정보를 가져온 것을 확인할 수 있다.

주문내역을 정상적으로 가져온것을 확인할 수 있다.

userid값이 변경되었는데 중간에 코드에 문제가 있어서 수정하고 재실행 하느라 변경되었다.

👏service 주소를 Microservice name으로 사용하는 방법

위 방법을 따라하다보면 yml에 설정 내용에 url이 실제 서버의 ip가 변경될 때 마다 변경해주어야하는 단점이 있다. 이 점을 서비스 명으로 사용해도 정상 작동되도록 하는 방법이 있는데

order_service:
  url: http://ORDER-SERVICE/order-service/%s/orders
  #url: http://127.0.0.1:8000/order-service/%s/orders

기존 url 정보를 다음과 같이 변경해주고

@SpringBootApplication
@EnableDiscoveryClient
public class UserServiceApplication {

    public static void main(String[] args) {
        SpringApplication.run(UserServiceApplication.class, args);
    }

    //password encode를 사용을 위해 bean으로 등록
    @Bean
    public BCryptPasswordEncoder passwordEncoder(){
        return new BCryptPasswordEncoder();
    }

    @Bean
    @LoadBalanced
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

기존에 사용하고 있던 user-service의 RestTemplate에 @LoadBalanced만 추가해주면 된다.

그 후에 동일하게 주문하고 user 정보를 불러와보면

order_service.url의 값이 ip값이 아닌 microservice 이름 값으로 변견된 것을 확인할 수 있다.

결과도 동일하게 잘 나왔다!