微服务管家:NestJS 如何使用服务发现 Consul 实现高效的微服务节点管理
前言
在微服务架构中,服务发现是一项基础且关键的功能,它允许服务实例在网络中被动态发现。Consul 是一种服务网格解决方案,提供了服务发现、运行状况检查,过去和现代应用程序的连接等功能。
本教程将向您展示如何在 NestJS 框架中集成 Consul 实现服务发现的能力。
什么是 Consul
Consul 是由 HashiCorp 公司开发的一种服务网格解决方案,它提供完整的服务网格特性,并且可以在任何运行您的应用程序的环境中运行。
它具有以下几个主要功能:
- 服务发现 - Consul 客户端可以注册服务,例如一个web服务器,以便其他客户端可以使用 Consul 来发现服务的位置。
- 运行状况检查 - Consul 客户端可以提供任何数量的运行状况检查服务,以便可以自动移除不健康的服务实例。
- KV 存储 - Consul 提供一个简单的键值对存储,用于存储配置和其他用途。
- 多数据中心 - Consul 支持多数据中心,这是其特别适用于大型公司和企业的原因。
使用步骤
以下是在 NestJS 应用程序中集成 Consul 用于服务发现的步骤:
一、 安装 Consul
在您的本地机器或服务器上安装 Consul。详细的安装教程可以在 Consul 的官方网站找到。您可以通过它们的指南快速启动和运行 Consul 代理。
# 例如,在macOS上安装 Consul
brew install consul# 启动 Consul agent
consul agent -dev
二、初始化 NestJS 项目
如果您还没有 NestJS 项目,可以用以下命令创建一个:
nest new project-name
三、安装必要的库
为了使 NestJS 能够与 Consul 集成,您需要安装 node-consul,这是 Consul 的 Node.js 客户端库。
npm install consul
四、创建 Consul 服务模块
在 NestJS 项目中创建一个新模块用于封装 Consul 基本操作:
// consul.service.tsimport { Injectable } from '@nestjs/common';
import * as Consul from 'consul';@Injectable()
export class ConsulService {private consul: Consul.Consul;constructor() {this.consul = new Consul({// Consul 的配置项host: 'localhost',port: 8500 // 根据实际端口号修改});}async registerService(serviceInfo: Consul.Agent.Service.RegisterOptions) {return new Promise<void>((resolve, reject) => {this.consul.agent.service.register(serviceInfo, (err) => {if (err) {reject(err);return;}resolve();});});}// 其他 Consul 的操作方法
}
五、 在 NestJS 应用生命周期中应用 Consul 服务
让 NestJS 在应用启动时自动注册服务,并在应用关闭时自动注销服务。
-
在您的主模块(例如
AppModule
)中导入刚才创建的ConsulService
服务,并在模块中注册:// app.module.ts import { Module } from '@nestjs/common'; import { ConsulService } from './consul.service';@Module({// ...providers: [ConsulService], }) export class AppModule {}
-
修改您的主
AppService
或自定义一个新服务来实现 NestJS 应用的生命周期的钩子onModuleInit
和onApplicationShutdown
:// app.service.ts import { Injectable, OnModuleInit, OnApplicationShutdown } from '@nestjs/common'; import { ConsulService } from './consul.service';@Injectable() export class AppService implements OnModuleInit, OnApplicationShutdown {constructor(private consulService: ConsulService) {}async onModuleInit(): Promise<void> {// 当模块初始化时注册服务try {await this.consulService.registerService({name: 'nestjs-service',// 其他需要的配置});console.log('服务成功注册到Consul');} catch (error) {console.error('服务注册失败:', error);}}async onApplicationShutdown(signal?: string): Promise<void> {// 应用关闭时注销服务try {// 具体的服务注销逻辑console.log(`服务注销成功`);} catch (error) {console.error('服务注销失败:', error);}} }
-
将
AppService
添加到您的主应用模块中去。这样可以确保注册的服务在 NestJS 应用生命周期中被正确管理:// app.module.ts // ... import { AppService } from './app.service';@Module({// ...providers: [ConsulService, AppService], }) export class AppModule {}
这样,当您的 NestJS 服务启动时,它会自动向 Consul 注册服务,当服务关闭时,它又会自动从 Consul 注销服务。
如何调用 Consul 注册的微服务
消费通过 Consul 发现的服务意味着您需要从 Consul 获取服务的地址和端口信息,然后基于这些信息去发起请求。以下步骤将介绍如何在 NestJS 应用中实现这一点。
一、查询服务
在我们创建的 ConsulService
服务中,实现一个方法来获取所有活跃的服务实例。
// consul.service.ts// ... (其他代码)@Injectable()
export class ConsulService {// ... (其他代码)async discoverService(serviceName: string): Promise<Consul.Agent.Service[]> {return new Promise((resolve, reject) => {this.consul.agent.service.list((err, result) => {if (err) {reject(err);return;}const services = [];for (let id in result) {if (result[id].Service === serviceName) {services.push(result[id]);}}resolve(services);});});}
}
二、实现服务消费逻辑
在您要消费服务的地方(比如某个服务或控制器中),调用刚才实现的 discoverService
方法获取服务实例。
// some.service.tsimport { Injectable } from '@nestjs/common';
import { HttpService } from '@nestjs/axios';
import { ConsulService } from './consul.service';
import { firstValueFrom } from 'rxjs';@Injectable()
export class SomeService {constructor(private httpService: HttpService,private consulService: ConsulService) {}async consumeService(serviceName: string) {try {const services = await this.consulService.discoverService(serviceName);if (services.length === 0) {throw new Error('服务未发现');}// 假设我们只关注第一个服务实例const serviceInstance = services[0];// 构建服务实例的地址,以便请求const url = `http://${serviceInstance.Address}:${serviceInstance.Port}/path-to-service-resource`;// 发送请求到服务实例const response = await firstValueFrom(this.httpService.get(url));return response.data;} catch (error) {throw error;}}
}
注意:在实际环境中,您可能希望实现更复杂的逻辑,比如负载均衡(选择多个实例)或者使用失败重试机制等。
三、调用服务
在控制器或者其他需要消费服务的地方调用 SomeService
。
// some.controller.tsimport { Controller, Get } from '@nestjs/common';
import { SomeService } from './some.service';@Controller()
export class SomeController {constructor(private readonly someService: SomeService) {}@Get()async consume() {const data = await this.someService.consumeService('nestjs-service');return data;}
}
这样,当您的控制器收到 HTTP 请求时,它将通过 SomeService
使用 Consul 服务发现机制来消费远端的服务。
总结
集成 Consul 到 NestJS 应用中是微服务架构中一个关键的步骤。通过这一流程,您的服务可以被动态地发现和管理。在微服务架构中,你可以根据实际业务场景,针对性地实现高可用性和负载均衡等策略。使用 NestJS 框架和 Consul 服务发现,你可以构建一个既灵活又可扩展的微服务系统。
相关文章:
微服务管家:NestJS 如何使用服务发现 Consul 实现高效的微服务节点管理
前言 在微服务架构中,服务发现是一项基础且关键的功能,它允许服务实例在网络中被动态发现。Consul 是一种服务网格解决方案,提供了服务发现、运行状况检查,过去和现代应用程序的连接等功能。 本教程将向您展示如何在 NestJS 框架…...

Baumer工业相机堡盟工业相机如何联合NEOAPI SDK和OpenCV实现相机图像转换为Mat图像格式(C++)
Baumer工业相机堡盟工业相机如何通过NEOAPI SDK实现相机掉线自动重连(C) Baumer工业相机Baumer工业相机的图像转换为OpenCV的Mat图像的技术背景在NEOAPI SDK里实现相机图像转换为Mat图像格式联合OpenCV实现相机图像转换为Mat图像格式测试演示图 工业相机…...

铁塔基站数字化管理监测解决方案
截至2023年10月,我国5G基站总数达321.5万个,占全国通信基站总数的28.1%。然而,随着5G基站数量的快速增长,基站的能耗问题也逐渐日益凸显,基站的用电给运营商带来了巨大的电费开支压力,降低5G基站的能耗成为…...
如何使用Python3 Boto3删除AWS CloudFormation的栈(Stacks)
文章目录 小结问题及解决有关Json文件的输入和输出使用Python3及正则表达式查找字符串包含某个子字符串使用Python3 Boto3删除AWS CloudFormation的栈(Stacks) 参考 小结 本文记录了使用Python3的Boto3包删除AWS CloudFormation的栈(Stacks&…...

差分约束算法
差分约束 差分约束系统包含 m m m个涉及 n n n个变量的差额限制条件,这些差额限制条件每个都是形式为 x i − x j ≤ b ∈ [ 1 , m ] x_i-x_j\leq b_{\in[1,m]} xi−xj≤b∈[1,m]的简单线性不等式。 通常我们要求解出一组可行解。 最短路差分约束 如果我们…...

彻底解决vue-video-player播放视频有黑边
需求 最近需要接入海康视频摄像头,然后把视频的画面接入到自己的网站系统中。以前对接过rtsp固定IP的显示视频,这次的不一样,没有了固定IP。海康的解决办法是,摄像头通过配置服务器到萤石云平台,然后购买企业版账号和…...
区域负责人常用的ChatGPT通用提示词模板
区域市场分析:如何分析区域市场的特点、竞争态势和客户需求? 区域销售策略制定:如何制定针对区域市场的销售策略,包括产品定位、价格策略、渠道策略等? 区域销售目标设定:如何设定明确的区域销售目标&…...
Java Spring boot 可變參數,以及弊端
function中 不固定的參數 public boolean sendEmail(String manFrom, String manTo,String manCc, String subject, String... msg); 必須是最後一個參數,傳值時可以多個。 sendEmail(“a.gmail”,"b.gmail","c.gmail","subject",…...
机器视觉系统选型-线阵工业相机选型
线阵相机特点: 1.线阵相机使用的线扫描传感器通常只有一行感光单元(少数彩色线阵使用三行感光单元的传感器) 2.线阵相机每次只采集一行图像; 3.线阵相机每次只输出一行图像; 4.与传统的面阵相机相比,面阵扫…...

单机开机无感全自动进入B\S架构系统
单机开机无感全自动进入B\S架构系统 标题:单机用jar包启动项目bat(批处理)不弹黑窗口,并设置开机自启,打开浏览器,访问系统。引言:在实际工作中,遇到单机部署的情况,如今…...

大一,如何成为一名fpga工程师?
1、数电(必须掌握的基础),然后进阶学模电(选学), 2、掌握HDL(HDLverilogVHDL)可以选择verilog或者VHDL,建议verilog就行。 3、掌握FPGA设计流程/原理(推…...

MyBatisPlus学习三:Service接口、代码生成器
学习教程 黑马程序员最新MybatisPlus全套视频教程,4小时快速精通mybatis-plus框架 Service接口 简介 在MyBatis-Plus框架中,Service接口的作用是为实体类提供一系列的通用CRUD(增删改查)操作方法。通常情况下,Servi…...

产品经理如何选择城市?
年底,全国性的人口大迁徙即将开始。选择城市,堪称年轻人的“二次投胎”,族望留原籍,家贫走他乡。 古人在选择城市时,主要的考量因素是家族势力,这一点放在当代,大致也成立,如果在老…...

再谈“敏捷”与“瀑布”在产品开发过程中的反思
作为一家专注于软件开发的公司《智创有术》,我们致力于为客户提供创新、高效和可靠的解决方案。通过多年的经验和专业知识,我们已经在行业内建立了良好的声誉,并赢得了客户的信任和支持。 支持各种源码,网站搭建,APP&a…...

设计模式② :交给子类
文章目录 一、前言二、Template Method 模式1. 介绍2. 应用3. 总结 三、Factory Method 模式1. 介绍2. 应用3. 总结 参考内容 一、前言 有时候不想动脑子,就懒得看源码又不像浪费时间所以会看看书,但是又记不住,所以决定开始写"抄书&qu…...
Hive 源码
hive 编译 issue Failed to execute goal com.github.os72:protoc-jar-maven-plugin:3.5.1.1:run (default) on project hive-standalone-metastore: Error resolving artifact: com.google.protobuf:protoc:2.5.0: The following artifacts could not be resolved: com.goog…...

调整几行代码,接口吞吐提升 10 倍,性能调优妙啊!
景 分析过程 总结 背景 公司的一个ToB系统,因为客户使用的也不多,没啥并发要求,就一直没有经过压测。这两天来了一个“大客户”,对并发量提出了要求:核心接口与几个重点使用场景单节点吞吐量要满足最低500/s的要求。 当时一想,500/s吞吐量还不简单。Tomcat按照100个线程…...

MACOS Atrust服务异常
MAC版Atrust服务异常 点击进入办公后出现提示其一: 核心服务未启动,部分功能存在异常,确定重新启动吗? 可能的原因: 1.上次已完全退出客户端 2.核心服务被其他程序优化禁用 点击重新启动后,出现提示&#x…...
LLM大语言模型(四):在ChatGLM3-6B中使用langchain
目录 背景准备工作工具添加LangChain 已实现工具Calculator、Weather Tool配置 自定义工具自定义kuakuawo Agent 多工具使用参考 背景 LangChain是一个用于开发由语言模型驱动的应用程序的框架。它使应用程序能够: 具有上下文意识:将语言模型与上下文源(提示指令&…...

Dubbo入门介绍和实战
1. 引言 Dubbo是一款开源的高性能、轻量级的Java RPC(远程过程调用)框架,旨在解决分布式服务之间的通信问题。本文将介绍Dubbo的基础概念、核心特性以及使用场景,包括实际示例演示。 2. 什么是Dubbo? Dubbo是阿里巴…...

AI-调查研究-01-正念冥想有用吗?对健康的影响及科学指南
点一下关注吧!!!非常感谢!!持续更新!!! 🚀 AI篇持续更新中!(长期更新) 目前2025年06月05日更新到: AI炼丹日志-28 - Aud…...
基于大模型的 UI 自动化系统
基于大模型的 UI 自动化系统 下面是一个完整的 Python 系统,利用大模型实现智能 UI 自动化,结合计算机视觉和自然语言处理技术,实现"看屏操作"的能力。 系统架构设计 #mermaid-svg-2gn2GRvh5WCP2ktF {font-family:"trebuchet ms",verdana,arial,sans-…...

如何在看板中体现优先级变化
在看板中有效体现优先级变化的关键措施包括:采用颜色或标签标识优先级、设置任务排序规则、使用独立的优先级列或泳道、结合自动化规则同步优先级变化、建立定期的优先级审查流程。其中,设置任务排序规则尤其重要,因为它让看板视觉上直观地体…...

React19源码系列之 事件插件系统
事件类别 事件类型 定义 文档 Event Event 接口表示在 EventTarget 上出现的事件。 Event - Web API | MDN UIEvent UIEvent 接口表示简单的用户界面事件。 UIEvent - Web API | MDN KeyboardEvent KeyboardEvent 对象描述了用户与键盘的交互。 KeyboardEvent - Web…...

PL0语法,分析器实现!
简介 PL/0 是一种简单的编程语言,通常用于教学编译原理。它的语法结构清晰,功能包括常量定义、变量声明、过程(子程序)定义以及基本的控制结构(如条件语句和循环语句)。 PL/0 语法规范 PL/0 是一种教学用的小型编程语言,由 Niklaus Wirth 设计,用于展示编译原理的核…...

ardupilot 开发环境eclipse 中import 缺少C++
目录 文章目录 目录摘要1.修复过程摘要 本节主要解决ardupilot 开发环境eclipse 中import 缺少C++,无法导入ardupilot代码,会引起查看不方便的问题。如下图所示 1.修复过程 0.安装ubuntu 软件中自带的eclipse 1.打开eclipse—Help—install new software 2.在 Work with中…...
【RockeMQ】第2节|RocketMQ快速实战以及核⼼概念详解(二)
升级Dledger高可用集群 一、主从架构的不足与Dledger的定位 主从架构缺陷 数据备份依赖Slave节点,但无自动故障转移能力,Master宕机后需人工切换,期间消息可能无法读取。Slave仅存储数据,无法主动升级为Master响应请求ÿ…...

【OSG学习笔记】Day 16: 骨骼动画与蒙皮(osgAnimation)
骨骼动画基础 骨骼动画是 3D 计算机图形中常用的技术,它通过以下两个主要组件实现角色动画。 骨骼系统 (Skeleton):由层级结构的骨头组成,类似于人体骨骼蒙皮 (Mesh Skinning):将模型网格顶点绑定到骨骼上,使骨骼移动…...

深入解析C++中的extern关键字:跨文件共享变量与函数的终极指南
🚀 C extern 关键字深度解析:跨文件编程的终极指南 📅 更新时间:2025年6月5日 🏷️ 标签:C | extern关键字 | 多文件编程 | 链接与声明 | 现代C 文章目录 前言🔥一、extern 是什么?&…...

什么是Ansible Jinja2
理解 Ansible Jinja2 模板 Ansible 是一款功能强大的开源自动化工具,可让您无缝地管理和配置系统。Ansible 的一大亮点是它使用 Jinja2 模板,允许您根据变量数据动态生成文件、配置设置和脚本。本文将向您介绍 Ansible 中的 Jinja2 模板,并通…...