Mình đã giới thiệu với các bạn về Microservices và những lợi ích to lớn mà nó mang lại. Quá trình xây dựng một ứng dụng theo kiểu Microservices sẽ có nhiều thử thách và một trong những thử thách đó là làm thế nào quản lý các service được tạo ra, bao gồm việc bảo trì, mở rộng và khả năng high availability của chúng. Ứng dụng càng lớn thì việc quản lý các service này sẽ lại càng khó khăn hơn.
Để giải quyết vấn đề này, người ta đã giới thiệu một khái niệm gọi là Service registration and discovery, nhằm định nghĩa một server, nơi có thể dùng để cho các service đăng ký và quản lý thông tin của chúng.
Server này sẽ chịu trách nhiệm lưu trữ và cung cấp thông tin của các service trong một hệ thống Microservices. Khi một service đăng ký thông tin với server, nó sẽ cung cấp các thông tin như host, port, trạng thái của nó. Và nó cũng thường xuyên gửi heartbeat message để thông báo tình trạng của mình cho server. Do đó, server này có thể dễ dàng cung cấp thông tin về các service khi chúng được gọi tới từ các service khác.
Đây chính là những điểm cơ bản về Eureka Server của Netflix OSS (Open Source Software) mà mình muốn đề cập trong bài viết này đó các bạn!
Trong bài viết này, mình sẽ hướng dẫn các bạn cách setup để có thể chạy một Eureka Server sử dụng Spring Cloud Netflix các bạn nhé!
Đầu tiên, các bạn hãy tạo một Spring Boot project với Eureka Server dependency.
Kết quả của mình như sau:
Sau đó, các bạn hãy vào class main của ứng dụng Spring Boot của chúng ta, khai báo thêm một annotation tên là @EnableEurekaServer như sau:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 |
package com.huongdanjava.springcloud.netflix.eurekaserver; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer; @EnableEurekaServer @SpringBootApplication public class SpringCloudEurekaServerApplication { public static void main(String[] args) { SpringApplication.run(SpringCloudEurekaServerApplication.class, args); } } |
Annotation @EnableEurekaServer sẽ giúp Spring Boot biết là chúng ta cần chạy một Eureka Server sử dụng Eureka Server của Netflix OSS, expose các endpoint để các service có thể đăng ký, discovery và gửi heartbeat.
Bây giờ thì chạy ứng dụng, request tới địa chỉ http://localhost:8080/, các bạn sẽ thấy kết quả như sau:
Trong phần “Instances currently registered with Eureka” sẽ chứa thông tin của tất cả các service đã đăng ký với Eureka Server này. Vì hiện tại chưa có service nào đăng ký nên các bạn sẽ không thấy gì ở đây cả.
Nếu các bạn để ý console log, các bạn sẽ thấy lỗi 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 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 |
2025-07-06T17:47:11.712+08:00 INFO 49060 --- [foReplicator-%d] c.n.d.s.t.d.RedirectingEurekaHttpClient : Request execution error. endpoint=DefaultEndpoint{ serviceUrl='http://localhost:8761/eureka/}, exception=java.net.ConnectException: Connection refused stacktrace=jakarta.ws.rs.ProcessingException: java.net.ConnectException: Connection refused at org.glassfish.jersey.client.internal.HttpUrlConnector.apply(HttpUrlConnector.java:288) at org.glassfish.jersey.client.ClientRuntime.invoke(ClientRuntime.java:300) at org.glassfish.jersey.client.JerseyInvocation.lambda$invoke$0(JerseyInvocation.java:674) at org.glassfish.jersey.client.JerseyInvocation.call(JerseyInvocation.java:709) at org.glassfish.jersey.client.JerseyInvocation.lambda$runInScope$3(JerseyInvocation.java:703) at org.glassfish.jersey.internal.Errors.process(Errors.java:292) at org.glassfish.jersey.internal.Errors.process(Errors.java:274) at org.glassfish.jersey.internal.Errors.process(Errors.java:205) at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:391) at org.glassfish.jersey.client.JerseyInvocation.runInScope(JerseyInvocation.java:703) at org.glassfish.jersey.client.JerseyInvocation.invoke(JerseyInvocation.java:673) at org.glassfish.jersey.client.JerseyInvocation$Builder.method(JerseyInvocation.java:439) at org.glassfish.jersey.client.JerseyInvocation$Builder.post(JerseyInvocation.java:345) at com.netflix.discovery.shared.transport.jersey3.AbstractJersey3EurekaHttpClient.register(AbstractJersey3EurekaHttpClient.java:99) at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator$1.execute(EurekaHttpClientDecorator.java:59) at com.netflix.discovery.shared.transport.decorator.MetricsCollectingEurekaHttpClient.execute(MetricsCollectingEurekaHttpClient.java:70) at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator.register(EurekaHttpClientDecorator.java:56) at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator$1.execute(EurekaHttpClientDecorator.java:59) at com.netflix.discovery.shared.transport.decorator.RedirectingEurekaHttpClient.executeOnNewServer(RedirectingEurekaHttpClient.java:121) at com.netflix.discovery.shared.transport.decorator.RedirectingEurekaHttpClient.execute(RedirectingEurekaHttpClient.java:80) at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator.register(EurekaHttpClientDecorator.java:56) at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator$1.execute(EurekaHttpClientDecorator.java:59) at com.netflix.discovery.shared.transport.decorator.RetryableEurekaHttpClient.execute(RetryableEurekaHttpClient.java:120) at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator.register(EurekaHttpClientDecorator.java:56) at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator$1.execute(EurekaHttpClientDecorator.java:59) at com.netflix.discovery.shared.transport.decorator.SessionedEurekaHttpClient.execute(SessionedEurekaHttpClient.java:76) at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator.register(EurekaHttpClientDecorator.java:56) at com.netflix.discovery.DiscoveryClient.register(DiscoveryClient.java:828) at com.netflix.discovery.InstanceInfoReplicator.run(InstanceInfoReplicator.java:125) at com.netflix.discovery.InstanceInfoReplicator$2.run(InstanceInfoReplicator.java:105) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) at java.base/java.lang.Thread.run(Thread.java:1583) Caused by: java.net.ConnectException: Connection refused at java.base/sun.nio.ch.Net.pollConnect(Native Method) at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:682) at java.base/sun.nio.ch.NioSocketImpl.timedFinishConnect(NioSocketImpl.java:549) at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:592) at java.base/java.net.Socket.connect(Socket.java:751) at java.base/sun.net.NetworkClient.doConnect(NetworkClient.java:178) at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:531) at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:636) at java.base/sun.net.www.http.HttpClient.<init>(HttpClient.java:280) at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:386) at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:408) at java.base/sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1304) at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1237) at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1123) at java.base/sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:1052) at java.base/sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1675) at java.base/sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1599) at java.base/java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:531) at org.glassfish.jersey.client.internal.HttpUrlConnector.handleException(HttpUrlConnector.java:624) at org.glassfish.jersey.client.internal.HttpUrlConnector._apply(HttpUrlConnector.java:450) at org.glassfish.jersey.client.internal.HttpUrlConnector.apply(HttpUrlConnector.java:286) ... 35 more |
Nguyên nhân là bởi vì mặc định Eureka Server này cũng đóng vai trò như là một service, hay còn gọi là một Eureka Client. Eureka Client này sẽ tự động, cứ mỗi 30s, lại call tới địa chỉ http://localhost:8761/eureka/ để đăng ký chính nó với Eureka Server nếu nó chưa đăng ký được và để discover các service khác.
Lỗi ở trên xảy ra là bởi vì port mặc định của Eureka Server là 8761 nhưng ở đây, ứng dụng của mình đang sử dụng port mặc định của Tomcat là 8080. Khi gọi tới port 8761 sẽ bị lỗi.
Để fix lỗi này các bạn hãy cấu hình port cho giống với port mặc định của Eureka Server bằng cách thêm property server.port vào tập tin cấu hình của ứng dụng application.properties.
|
1 |
server.port=8761 |
Chạy lại ứng dụng và đi đến địa chỉ http://localhost:8761/, các bạn sẽ thấy 1 service đã được đăng ký:
Service này chính là Eureka Server đó các bạn!
Nếu các bạn không muốn Eureka Server tự động đăng ký chính nó và discover các service khác, các bạn có thể disable cấu hình mặc định này bằng cách thêm 2 properties sau vào tập tin cấu hình của ứng dụng application.properties:
|
1 2 |
eureka.client.register-with-eureka=false eureka.client.fetch-registry=false |
Khi đó, start lại ứng dụng, các bạn sẽ không thấy Eureka Server không tự động làm như thế nữa!
Như vậy là chúng ta đã setup thành công Eureka Server của Netflix OSS sử dụng Spring Cloud Netflix rồi đó các bạn!
