服务发现: Node.js + Eureka

本文主要是介绍服务发现: Node.js + Eureka，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

基于 Node.js 和 Eureka 的完整示例，涵盖了服务的注册、获取服务列表、监听服务变化，以及定期更新健康状态到 Eureka。

安装依赖

首先，安装所需的 Node.js 包，包括 Eureka 的客户端库和一个 HTTP 请求库：

npm install eureka-js-client express axios

完整示例代码

以下示例代码展示了如何注册服务到 Eureka，获取服务列表，定期更新健康状态，以及监听服务变化（通过轮询获取服务列表变化）。

const express = require('express');
const Eureka = require('eureka-js-client').Eureka;
const axios = require('axios');const app = express();
const port = 3000;const eurekaClient = new Eureka({// Eureka server's host and port// Replace with your Eureka server addressinstance: {app: 'my-service',instanceId: 'my-service-id',hostName: 'localhost',ipAddr: '127.0.0.1',port: {'$': port,'@enabled': true},vipAddress: 'my-service',secureVipAddress: 'my-service',dataCenterInfo: {'@class': 'com.netflix.appinfo.InstanceInfo$DefaultDataCenterInfo',name: 'MyOwn'},statusPageUrl: `http://localhost:${port}/info`,healthCheckUrl: `http://localhost:${port}/health`,homePageUrl: `http://localhost:${port}/`,leaseInfo: {renewalIntervalInSecs: 30,durationInSecs: 90}},eureka: {// Eureka server URL// Replace with your Eureka server addresshost: 'localhost',port: 8761,servicePath: '/eureka/apps/'}
});// 注册服务到 Eureka
function registerService() {eurekaClient.start((error) => {if (error) {console.error('Failed to register service:', error);} else {console.log('Service registered with Eureka');startHealthCheck();loadServices();}});
}// 健康检查路由
app.get('/health', (req, res) => {res.send('Service is up and running');
});// 启动服务
app.listen(port, () => {console.log(`Service running on port ${port}`);registerService();
});// 定期更新健康状态到 Eureka
function startHealthCheck() {setInterval(async () => {try {await axios.get(`http://localhost:${port}/health`);console.log('Service health check passed');} catch (error) {console.error('Service health check failed:', error);}}, 30000); // 每30秒检查一次
}// 获取服务列表
async function loadServices() {try {const response = await axios.get(`http://localhost:8761/eureka/apps/my-service`);const services = response.data;console.log('Service list:', services);} catch (error) {console.error('Failed to get service list:', error);}
}// 监听服务变化
function watchServiceChanges() {// 通过定时轮询服务列表setInterval(async () => {try {const response = await axios.get(`http://localhost:8761/eureka/apps/my-service`);const services = response.data;console.log('Updated service list:', services);} catch (error) {console.error('Failed to get updated service list:', error);}}, 30000); // 每30秒轮询一次
}// 启动服务变化监听
watchServiceChanges();

说明

1. 健康检查端点：

• 使用 Express.js 创建了一个 /health 路由，用于检查服务是否正常。

2. 注册服务：

• 使用 eureka-js-client 库将服务注册到 Eureka。Eureka 客户端配置包括服务的基本信息，如 app 名称、端口、健康检查 URL 等。

3. 定期更新健康状态：

• 使用 setInterval 每30秒检查一次服务的健康状态，确保 Eureka 服务器上的服务状态是最新的。

4. 获取服务列表：

• 通过 HTTP 请求从 Eureka 获取服务列表，并打印到控制台。

5. 监听服务变化：

• 通过定时轮询服务列表的方式来监听服务变化。虽然 Eureka 没有内置的事件机制来监听服务变化，但轮询可以有效地检测服务的变化。

启动 Eureka 服务器

确保你已经启动了 Eureka 服务器。你可以使用 Spring Boot 来运行 Eureka 服务器，或者使用现有的 Eureka 实例。如果你使用 Spring Boot，可以通过以下命令启动 Eureka 服务器：

mvn spring-boot:run

总结

这个示例展示了如何在 Node.js 应用中实现服务的注册、健康检查、获取服务列表和监听服务变化。通过这种方式，你可以确保服务列表和健康状态在 Eureka 中始终是最新的。

这篇关于服务发现: Node.js + Eureka的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---