服务发现: Node.js + Consul

2024-08-23 07:04

文章标签 服务 js 发现 node consul

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

下面是一个基于 Node.js 和 Consul 的完整示例，它展示了如何注册服务、获取服务列表并监听服务变化。

安装依赖

首先，需要安装 consul 包。如果还没有安装，可以通过以下命令安装：

npm install consul

完整的 Node.js + Consul 示例

以下示例包含了：

服务注册：将服务注册到 Consul。
服务列表获取：从 Consul 获取服务列表并缓存到内存中。
服务变化监听：使用 Consul 的 Watcher 机制监听服务变化并更新缓存。

const Consul = require('consul');
const consul = new Consul();let serviceCache = {};// 注册服务到 Consul
function registerService() {consul.agent.service.register({name: 'my-service',id: 'my-service-id', // 服务 ID（唯一标识符）address: '127.0.0.1',port: 3000,tags: ['api'],check: {http: 'http://127.0.0.1:3000/health',interval: '10s'}}, (err) => {if (err) {console.error('Failed to register service:', err);} else {console.log('Service registered');}});
}// 初始加载服务列表
function loadServices() {consul.catalog.service.list('my-service', (err, result) => {if (err) {console.error('Failed to load services:', err);} else {serviceCache = result.reduce((acc, service) => {acc[service.ServiceID] = service;return acc;}, {});console.log('Initial service cache:', serviceCache);}});
}// 监听服务变化
function watchServices() {consul.watch({method: consul.health.service.bind(consul.health, 'my-service', { passing: true }),filter: (data) => data}).on('change', (result) => {serviceCache = result.reduce((acc, service) => {acc[service.ServiceID] = service;return acc;}, {});console.log('Updated service cache:', serviceCache);});
}// 运行
function main() {registerService();loadServices();watchServices();
}main();

其他配置

健康检查端点：

确保服务有一个健康检查端点（例如 /health），Consul 将使用这个端点来检查服务的健康状态。可以在服务中实现一个简单的健康检查路由：

const express = require('express');
const app = express();app.get('/health', (req, res) => {res.send('Service is up and running');
});app.listen(3000, () => {console.log('Service running on port 3000');
});