Questions Management – Composite Option Service – Xây dựng API thêm mới option

Xem toàn bộ series bài viết hướng dẫn xây dựng ứng dụng Questions Management tại đây.

Trước khi xây dựng API thêm mới option cho Composite Option Service, có mấy việc chúng ta phải làm trước như sau:

Vì Composite Option Service sẽ thao tác liên quan đến các question và các option nên mình sẽ thêm các đối tượng model cho từng loại để chứa thông tin của chúng như sau:

Question:

package com.huongdanjava.optionservice.dto;

import lombok.Data;

@Data
public class Question {

	private String id;

	private String description;

	private String categoryId;

}

package com.huongdanjava.optionservice.dto;

import lombok.Data;

@Data

public class Question {

private String id;

private String description;

private String categoryId;

}

Option:

package com.huongdanjava.optionservice.dto;

import lombok.Data;

@Data
public class Option {

	private String id;

	private String description;

	private String note;

	private Boolean isCorrect;

	private String questionId;
}

package com.huongdanjava.optionservice.dto;

import lombok.Data;

@Data

public class Option {

private String id;

private String description;

private String note;

private Boolean isCorrect;

private String questionId;

}

Vì Composite Option Service sẽ gọi đến Core Question Service và Core Option Service nên mình sẽ thêm mới trong tập tin application.properties thông tin về chúng như sau:

corequestionservice.url=http://localhost:8081
coreoptionservice.url=http://localhost:8083

1 2	corequestionservice.url=http://localhost:8081 coreoptionservice.url=http://localhost:8083

Để handle việc gọi tới Core Question Service, mình sẽ tạo một interface tên là CoreQuestionService:

package com.huongdanjava.optionservice.service;

public interface CoreQuestionService {

	String getServiceUrl();

}

package com.huongdanjava.optionservice.service;

public interface CoreQuestionService {

String getServiceUrl();

}

với implementation là CoreQuestionServiceImpl:

package com.huongdanjava.optionservice.service.impl;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import com.huongdanjava.optionservice.service.CoreQuestionService;

@Service
public class CoreQuestionServiceImpl implements CoreQuestionService {

	@Value("${corequestionservice.url}")
	private String coreQuestionServiceUrl;

	@Override
	public String getServiceUrl() {
		return coreQuestionServiceUrl;
	}

}

package com.huongdanjava.optionservice.service.impl;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.stereotype.Service;

import com.huongdanjava.optionservice.service.CoreQuestionService;

@Service

public class CoreQuestionServiceImpl implements CoreQuestionService {

@Value("${corequestionservice.url}")

private String coreQuestionServiceUrl;

@Override

public String getServiceUrl() {

return coreQuestionServiceUrl;

}

Để handle việc gọi tới Core Option Service, mình sẽ tạo một interface tên là CoreOptionService:

package com.huongdanjava.optionservice.service;

public interface CoreOptionService {

	String getServiceUrl();

}

package com.huongdanjava.optionservice.service;

public interface CoreOptionService {

String getServiceUrl();

}

với implementation là CoreOptionServiceImpl:

package com.huongdanjava.optionservice.service.impl;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import com.huongdanjava.optionservice.service.CoreOptionService;

@Service
public class CoreOptionServiceImpl implements CoreOptionService {

	@Value("${coreoptionservice.url}")
	private String coreOptionServiceUrl;

	@Override
	public String getServiceUrl() {
		return coreOptionServiceUrl;
	}

}

package com.huongdanjava.optionservice.service.impl;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.stereotype.Service;

import com.huongdanjava.optionservice.service.CoreOptionService;

@Service

public class CoreOptionServiceImpl implements CoreOptionService {

@Value("${coreoptionservice.url}")

private String coreOptionServiceUrl;

@Override

public String getServiceUrl() {

return coreOptionServiceUrl;

}

Mình sẽ chạy service này sử dụng port 8183 nên mình cũng sẽ thêm property server.port trong tập tin application.properties như sau:

server.port=8183

1	server.port=8183

OK, mọi thứ chuẩn bị đã xong, bây giờ mình sẽ đi vào phần chính của bài viết này các bạn nhé!

Đầu tiên, mình sẽ tạo mới một controller tên là CompositeOptionController với nội dung như sau:

package com.huongdanjava.optionservice;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/option")
public class CompositeOptionController {

}

package com.huongdanjava.optionservice;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

@RestController

@RequestMapping("/option")

public class CompositeOptionController {

}

Với khai báo trên, mình cũng đã expose các API cho phần Composite Option Service với request URL bắt đầu là “/option”.

Tiếp theo mình sẽ tạo mới một CompositeOptionService để handle tất cả các thao tác liên quan đến Composite Option Service

package com.huongdanjava.optionservice.service;

public interface CompositeOptionService {

}

package com.huongdanjava.optionservice.service;

public interface CompositeOptionService {

}

Thao tác đầu tiên thêm mới option.

Để hiện thực thao tác này, dựa vào thông tin option cần thêm mới, chúng ta sẽ gọi qua Core Question Service xem question id mà option này thuộc về có tồn tại hay không? Nếu tồn tại, chúng ta sẽ gọi qua Core Option Service để thực hiện việc thêm mới option này.

Cụ thể mình sẽ thêm mới một abstract method vào class CompositeOptionService như sau:

package com.huongdanjava.optionservice.service;

import com.huongdanjava.optionservice.dto.Option;

import reactor.core.publisher.Mono;

public interface CompositeOptionService {

	Mono<Option> addNewOption(Option option);

}

package com.huongdanjava.optionservice.service;

import com.huongdanjava.optionservice.dto.Option;

import reactor.core.publisher.Mono;

public interface CompositeOptionService {

Mono<Option> addNewOption(Option option);

}

Để hiện thực được phương thức addNewOption() trên, đầu tiên, chúng ta cần gọi tới Core Question Service để tìm question theo id theo questionId mà đối tượng Option cần thêm mới, thuộc về. Bằng cách thêm mới một method trong CoreQuestionService:

Mono<Question> findById(String questionId);

1	Mono<Question> findById(String questionId);

với phần implementation trong class CoreQuestionServiceImpl như sau:

@Override
public Mono<Question> findById(String questionId) {
    WebClient client = WebClient.builder()
        .baseUrl(getServiceUrl())
        .build();

    WebClient.ResponseSpec responseSpec = client.get()
        .uri("/question/" + questionId)
        .retrieve();

    return responseSpec.bodyToMono(Question.class);
}

@Override

public Mono<Question> findById(String questionId) {

WebClient client = WebClient.builder()

.baseUrl(getServiceUrl())

.build();

WebClient.ResponseSpec responseSpec = client.get()

.uri("/question/" + questionId)

.retrieve();

return responseSpec.bodyToMono(Question.class);

}

Tiếp theo chúng ta sẽ gọi tới Core Option Service để thực hiện việc thêm mới option bằng cách thêm mới một method trong class CoreOptionService:

Mono<Option> addNewOption(Option option);

1	Mono<Option> addNewOption(Option option);

với phần implementation trong class CoreOptionServiceImpl như sau:

@Override
public Mono<Option> addNewOption(Option option) {
    WebClient webClient = WebClient.builder()
        .baseUrl(getServiceUrl())
        .build();

    return webClient.post()
        .uri("/option/add")
        .body(BodyInserters.fromObject(option))
        .retrieve()
        .bodyToMono(Option.class);
}

@Override

public Mono<Option> addNewOption(Option option) {

WebClient webClient = WebClient.builder()

.baseUrl(getServiceUrl())

.build();

return webClient.post()

.uri("/option/add")

.body(BodyInserters.fromObject(option))

.retrieve()

.bodyToMono(Option.class);

}

OK, bây giờ chúng ta sẽ hiện thực phương thức addNewOption() trong class CompositeOptionService các bạn nhé.

Chúng ta sẽ inject 2 class service CoreQuestionService và CoreOptionService vào trước:

@Autowired
private CoreQuestionService coreQuestionService;

@Autowired
private CoreOptionService coreOptionService;

@Autowired

private CoreQuestionService coreQuestionService;

@Autowired

private CoreOptionService coreOptionService;

Trong phương thức addNewOption(), đầu tiên chúng ta sẽ gọi Core Question Service trước:

coreQuestionService.findById(option.getQuestionId())

1	coreQuestionService.findById(option.getQuestionId())

Nếu tồn tại một question với id mà đối tượng Option cần thêm mới đang nắm giữ, một item sẽ được trả về. Khi đó chúng ta sẽ gọi tới Core Option Service để thực hiện việc thêm mới này.

return coreQuestionService.findById(option.getQuestionId())
    .flatMap(question -> coreOptionService.addNewOption(option))
    .subscribeOn(Schedulers.elastic());

return coreQuestionService.findById(option.getQuestionId())

.flatMap(question -> coreOptionService.addNewOption(option))

.subscribeOn(Schedulers.elastic());

Quá trình gọi qua Core Option Service cần thời gian để xử lý nên mình đã cho chạy quá trình này trên một thread khác sử dụng phương thức subscribeOn().

Điều cuối cùng chúng ta cần làm đó là thêm mới một method vào class CompositeOptionController để expose một POST request “/option/add”:

@PostMapping("/add")
public Mono<ResponseEntity<Option>> addNewOption(@RequestBody Option option) {
   
}

@PostMapping("/add")

public Mono<ResponseEntity<Option>> addNewOption(@RequestBody Option option) {

}

rồi khai báo autowire đối tượng CompositeOptionService vào:

@Autowired
private CompositeOptionService compositeOptionService;

1 2	@Autowired private CompositeOptionService compositeOptionService;

để có thể sử dụng phương thức addNewOption() của CompositeOptionService mà chúng ta đã tạo ra ở trên:

@PostMapping("/add")
public Mono<ResponseEntity<Option>> addNewOption(@RequestBody Option option) {
    return compositeOptionService.addNewOption(option)
        .map(o -> ResponseEntity.ok(o))
        .defaultIfEmpty(ResponseEntity.notFound().build());
}

@PostMapping("/add")

public Mono<ResponseEntity<Option>> addNewOption(@RequestBody Option option) {

return compositeOptionService.addNewOption(option)

.map(o -> ResponseEntity.ok(o))

.defaultIfEmpty(ResponseEntity.notFound().build());

}

OK, đến đây là chúng ta đã hoàn thành việc xây dựng API thêm mới option cho Composite Option Service rồi đó các bạn. Test thử xem sao nhé.

Hiện tại mình đang có một số question như sau:

Giả sử bây giờ mình cần thêm mới option cho question với id 5b697df545aac307e5c68be5:

Kết quả sẽ là:

Khanh Nguyen

Share this post

Questions Management – Composite Option Service – Xây dựng API thêm mới option

Add Comment Hủy

Khanh Nguyen

Share this post

You might also like...

Questions Management – Hiện thực Turbine Stream với RabbitMQ

Questions Management – Support Turbine Stream – Khởi tạo project support-turbine-stream sử dụng Spring Tool Suite

Questions Management – Support Monitor Dashboard – Hiện thực Hystrix Dashboard

Questions Management – Support Monitor Dashboard – Khởi tạo project support-monitor-dashboard sử dụng Spring Tool Suite

Add Comment Hủy