Trong các bài viết trước, mình đã giới thiệu với các bạn về Eureka Server để quản lý các service trong một hệ thống Microservices và làm cách nào để đăng ký các service này với Eureka Server sử dụng Spring Cloud Netflix. Trong bài viết này, mình sẽ hướng dẫn các bạn cách để một service có thể tìm kiếm thông tin của các service khác trong một Eureka Server, các bạn nhé!
Để làm ví dụ cho bài viết này, mình sẽ sử dụng Eureka Server mà mình đã tạo sử dụng Spring Cloud Netflix trong bài viết trước về Eureka Server cùng với một service mà mình đã tạo trong bài viết về Eureka Client. Giao diện của Eureka Server hiện tại như sau:
Bây giờ, mình sẽ tạo một service khác với Eureka Client dependencies như sau:
Kết quả:
Để có thể tìm kiếm thông tin của các service khác trong một Eureka Server, đầu tiên, các bạn cần đăng ký service này với Eureka Server trước. Các bước mình đã hướng dẫn trong bài viết này, nếu bạn nào chưa biết thì có thể tham khảo nhé. Đối với service mà mình mới tạo ở trên, mình sẽ làm như sau:
SpringCloudDiscoveryApplication:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 |
package com.huongdanjava.springcloud.discovery; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.EnableEurekaClient; @EnableEurekaClient @SpringBootApplication public class SpringCloudDiscoveryApplication { public static void main(String[] args) { SpringApplication.run(SpringCloudDiscoveryApplication.class, args); } } |
application.properties:
|
1 2 3 4 5 |
spring.application.name=Discovery Example eureka.client.service-url.default-zone=http://localhost:8761 server.port=8081 |
Bởi vì, ví dụ trong bài viết Đăng ký các service với Eureka Server sử dụng Eureka Client, với Spring Cloud Netflix đã chạy với port 8080 rồi nên như các bạn thấy, mình đã đổi port mặc định của Tomcat bằng cách sử dụng property server.port của Spring Boot.
Bây giờ, nếu mình chạy ví dụ này lên, giao diện của Eureka Server lúc này sẽ như sau:
Như các bạn thấy, đến đây thì chúng ta đã đăng ký được 2 service trong một Eureka Server rồi. Vậy làm thế nào để từ service trong bài viết này, chúng ta có thể tìm kiếm thông tin của service “Eureka Client Example”, các bạn hãy đọc tiếp nhé!
Bây giờ mình sẽ tạo mới một Controller để dễ minh hoạ. Controller này sẽ có một request giúp người dùng có thể lấy thông tin về host, port của service “Eureka Client Example” từ service này “Discovery Example”.
Nội dung ban đầu của Controller này như sau:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 |
package com.huongdanjava.springcloud.discovery; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; @RestController public class DiscoveryController { @GetMapping("/discover") String discoverService() { String clientURI = null; return clientURI; } } |
Để lấy thông tin về host, port của service “Eureka Client Example”, chúng ta sẽ sử dụng interface org.springframework.cloud.client.discovery.DiscoveryClient với phương thức getInstances(). Tham số của phương thức này là serviceId, đó là tên của service được đăng ký trong Eureka Server đó các bạn. Cụ thể code lúc này của DiscoveryController sẽ như sau:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 |
package com.huongdanjava.springcloud.discovery; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.discovery.DiscoveryClient; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; @RestController public class DiscoveryController { @Autowired private DiscoveryClient discoveryClient; @GetMapping("/discover") String discoverService() { String clientURI = null; List<ServiceInstance> instances = discoveryClient.getInstances("Eureka Client Example"); return clientURI; } } |
với “Eureka Client Example” là tên của service mà chúng ta đang cần tìm kiếm thông tin. Chúng ta có thể đăng ký nhiều service cùng tên nên giá trị trả về sẽ là một danh sách, và class ServiceInstance chính là class nắm giữ thông tin của những service này.
Bởi vì hiện tại mình chỉ đăng ký một service với tên là “Eureka Client Example” nên mình sẽ code như sau:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 |
package com.huongdanjava.springcloud.discovery; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.discovery.DiscoveryClient; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; @RestController public class DiscoveryController { @Autowired private DiscoveryClient discoveryClient; @GetMapping("/discover") String discoverService() { String clientURI = null; List<ServiceInstance> instances = discoveryClient.getInstances("Eureka Client Example"); clientURI = instances.get(0).getUri().toString(); return clientURI; } } |
để lấy thông tin về host, port của service này.
Các bạn cũng có thể viết gọn lại như sau:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 |
package com.huongdanjava.springcloud.discovery; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.discovery.DiscoveryClient; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; @RestController public class DiscoveryController { @Autowired private DiscoveryClient discoveryClient; @GetMapping("/discover") String discoverService() { List<ServiceInstance> instances = discoveryClient.getInstances("Eureka Client Example"); return instances.get(0).getUri().toString(); } } |
Kết quả:
Như các bạn thấy, thông tin về host port của service “Eureka Client Example”, từ những thông tin này các bạn có thể request tới service này để thực hiện nhu cầu của mình. Cũng bởi vì thông tin host port do Eureka Server quản lý nên nếu sau này, service này được deploy lên một server khác đi nữa thì chúng ta cũng ko cần sửa thông tin đó trên service của chúng ta. Mọi thứ sẽ được cập nhập trong Eureka Server và chúng ta không cần làm gì cả.
ilovebka56
quá hay
chumeo
hay quá mọi thứ thật rõ ràng.