通过 Python+Nacos实现微服务，细解微服务架构

shigen坚持更新文章的博客写手，擅长Java、python、vue、shell等编程语言和各种应用程序、脚本的开发。记录成长，分享认知，留住感动。
个人IP：shigen

背景

一直以来的想法比较多，然后就用Python编写各种代码脚本。很多的脚本都是通过Python的Flask框架实现，如[file-server]，然后部署到云服务器。但是这样只提供一个端口就可以通过http访问，无异于在互联网上裸奔。而且这样的服务有很多个，一直在想如何实现一个统一认证然后就可以访问这么多的服务。在Java领域最常见的设计就是使用微服务架构，把每个服务拆分出来，然后通过网关统一拦截、验证、分发流量。蹭了一张架构图（发现飞书的模板已经很好了）：

微服务架构设计

那我的Python服务为什么不能设计成微服务架构呢，当然，还没听说过谁家的Python服务是微服务架构的，姑且一试。

代码实现

考虑到大家的技术栈就是Java，以下的python代码将省略部分细节。

有了之前python flask如何注册到nacos踩坑的经验，这次明显顺利的多了。现在本地搭建nacos环境，并支持http访问，推荐docker-compose的方式搭建：shigen/spring-cloud-platform

因为我的Nacos版本是2.0+的，官方的nacos-sdk-python是这样描述的：

Supported Python version：

Python 2.7 Python 3.6 Python 3.7

Supported Nacos version

Nacos 0.8.0 ~ 1.3.2

于是就使用的是官方的API：Open API 指南

我的服务模块是这样细分的：

microservices-demo/
├── nacos/
├── api-gateway/
│   └── app.py
├── user-service/
│   └── app.py
├── auth-service/
│   └── app.py
└── document-service/
    └── app.py

也就是分成了四个模块：网关、用户中心、鉴权中心、文档中心。接下来就是服务的注册和调用。我们以最简单的auth-service为例：

NACOS_URL = os.getenv(
    "NACOS_URL", "http://localhost:8848/nacos/v1/ns/instance")
SERVICE_NAME = "auth-service"
SERVICE_IP = socket.gethostbyname(socket.gethostname())
SERVICE_PORT = 5002
NAMESPACE = "python"

# 发送到Nacos服务注册接口
def register_service():
    payload = {
        "serviceName": SERVICE_NAME,
        "ip": SERVICE_IP,
        "port": SERVICE_PORT,
        "namespaceId": NAMESPACE,
    }
    response = requests.post(f"{NACOS_URL}", params=payload)

# 每5秒发送一次心跳
def send_heartbeat():
    while True:
        payload = {
            "serviceName": SERVICE_NAME,
            "ip": SERVICE_IP,
            "port": SERVICE_PORT,
            "namespaceId": NAMESPACE,
        }
        response = requests.put(f"{NACOS_URL}/beat", params=payload)
        time.sleep(5)

# 密码验证，获得token
@app.route('/auth', methods=['POST'])
def authenticate():
    pass

# 验证token
@app.route('/verify', methods=['POST'])
def verify_token():
    pass

# 服务启动类
if __name__ == '__main__':
    register_service()
    heartbeat_thread = threading.Thread(target=send_heartbeat)
    heartbeat_thread.daemon = True
    heartbeat_thread.start()
    app.run(port=SERVICE_PORT)

不用尝试读懂代码，很简单：在服务启动的时候注册到nacos，完了就是定时的向nacos发送心跳。@app.route(‘/auth’, methods=[‘POST’])表示提供一个POST请求方式的/auth接口，然后启动服务：

服务启动

服务启动成功之后，可以看到控制台打印的日志信息。同时提供http访问接口。测试的方式如下：

curl --location 'http://127.0.0.1:5002/auth' \
--header 'Content-Type: application/json' \
--data '{
    "username": "user",
    "password": "pass"
}'

其他的几个服务也如法炮制。最终Nacos服务注册表如下：

在这里插入图片描述

在网关这一块可能稍微有一点区别，复习前面提到的网关的作用：流量的拦截和转发、认证拦截、负载均衡…这里我的网关服务设计如下：

NACOS_URL = os.getenv(
    "NACOS_URL", "http://localhost:8848/nacos/v1/ns/instance")
NAMESPACE = "python"


def get_service_url(service_name):
    try:
        response = requests.get(
            f"{NACOS_URL}/list?serviceName={service_name}&namespaceId={NAMESPACE}")
        data = response.json()
        if data and data['hosts']:
            service = data['hosts'][0]
            # return f"http://{service['ip']}:{service['port']}"
            # 这里是本机调用测试
            return f"http://localhost:{service['port']}"
    except Exception as e:
        print(f"Error getting service URL: {e}")
    return None


@app.route('/<service_name>/<path:path>', methods=['GET', 'POST', 'PUT', 'DELETE'])
def proxy(service_name, path):
    service_url = get_service_url(service_name)
    if not service_url:
        return jsonify({"error": "Service not found"}), 404

    # 认证逻辑
    if service_name != "auth-service":
        token = request.headers.get("Authorization")
        if not token:
            return jsonify({"error": "Missing token"}), 401

        auth_url = get_service_url("auth-service")
        if not auth_url:
            return jsonify({"error": "Auth service not found"}), 500

        verify_response = requests.post(
            f"{auth_url}/verify", json={"token": token})
        if verify_response.status_code != 200:
            return jsonify({"error": "Invalid token"}), 401

    url = f"{service_url}/{path}"
    response = requests.request(
        method=request.method,
        url=url,
        headers={key: value for key,
                 value in request.headers if key != 'Host'},
        data=request.get_data(),
        cookies=request.cookies,
        allow_redirects=False
    )

    return (response.content, response.status_code, response.headers.items())


if __name__ == '__main__':
    app.run(port=8080)

这里其实就是请求来了之后，从nacos上拉取服务列表。这个服务列表就是服务名称和对应的服务所在机器的IP（service-name和对应的IP集合）。然后选取对应服务所在的机器之一作为目标机器（这里选用的是第一台机器），从请求头中获得token，进行验证和调用。token校验失败则打给认证服务，重新进行登录验证。为此，我还对比了一下Spring Cloud + Nacos的设计：

在这里插入图片描述

Nacos的API实现的是springframework.cloud.client.discovery的接口，意味着统一的标准：

package com.alibaba.cloud.nacos.discovery;

public class NacosDiscoveryClient implements DiscoveryClient {

        private static final Logger log = LoggerFactory.getLogger(NacosDiscoveryClient.class);

        /**
         * Nacos Discovery Client Description.
         */
        public static final String DESCRIPTION = "Spring Cloud Nacos Discovery Client";

        private NacosServiceDiscovery serviceDiscovery;

        public NacosDiscoveryClient(NacosServiceDiscovery nacosServiceDiscovery) {
                this.serviceDiscovery = nacosServiceDiscovery;
        }

        @Override
        public String description() {
                return DESCRIPTION;
        }

        @Override
        public List<ServiceInstance> getInstances(String serviceId) {
                try {
                        return serviceDiscovery.getInstances(serviceId);
                }
                catch (Exception e) {
                        throw new RuntimeException(
                                        "Can not get hosts from nacos server. serviceId: " + serviceId, e);
                }
        }

        @Override
        public List<String> getServices() {
                try {
                        return serviceDiscovery.getServices();
                }
                catch (Exception e) {
                        log.error("get service name from nacos server fail,", e);
                        return Collections.emptyList();
                }
        }

}

其中的serviceName和serviceId其实是同一概念，意味着我们可以通过服务名获得全部的部署服务的实例信息，实现自定义的负载均衡调用。这里的原理和我直接从Nacos的API中获得服务列表，默认选取第一台机器进行调用的设计如出一辙。

对于以上的Python代码段，可能文字描述有不详细或者不当之处，借助魔法进行进一步的完善：

这段代码实现了一个反向代理服务器，其主要功能是根据服务名称将请求转发到不同的服务，并在转发前进行认证。具体功能如下：

  1. 服务发现：代码通过访问 NACOS（一个服务发现和配置管理平台）来获取目标服务的 URL。NACOS 提供了服务注册和发现的功能，代码中通过 get_service_url(service_name) 函数实现这一功能。
  2. 请求转发：当接收到一个请求时，根据 URL 中的 service_name 和 path，代码会将请求转发到相应的目标服务。转发时，保留了原始请求的 HTTP 方法、头信息、数据和 cookies。
  3. 认证检查：对于非 auth-service 的请求，代码会检查请求头中是否包含 Authorization token。如果没有 token 或 token 无效，则会返回错误响应。具体步骤如下：
    1. 检查请求头中是否包含 Authorization token。
    2. 如果没有 token，返回 401 错误（未授权）。
    3. 如果有 token，向认证服务（auth-service）发送请求，验证 token 的有效性。
    4. 如果 token 无效，返回 401 错误。
  4. 错误处理：代码包含了基本的错误处理逻辑，例如当服务 URL 无法获取或认证服务不可用时，返回相应的错误响应。

通过这些功能，该反向代理服务器能够在微服务架构中充当中间层，路由请求并提供统一的认证机制。

这样下来，我们调用服务只需要直接走网关了，其它的服务端口也不用放行，极大程度上保证了数据的安全。此时，我们需要这样调用服务：

登录

curl --location 'http://127.0.0.1:8080/auth-service/auth' \
--header 'Content-Type: application/json' \
--data '{
"username": "user",
"password": "pass"
}'

服务调用

curl --location 'http://127.0.0.1:8080/document-service/documents' \
--header 'Authorization: xxx'

总结

之前微服务的开发中，可能我们借助Spring Cloud部分组件、Nacos，在项目中加上依赖配置，稍微改一下配置文件，服务就可以正常的调用了。其中依赖的SDK如何的工作，可能只是停留在理论上，缺少实操。这次的这个案例很好的展示Python+Nacos如何实现微服务，并从中细解微服务结构和服务之间的调用原理。是不是觉得Nacos其实也不过如此哈，没什么牛掰、独特之处，其实都是草台班子。

与shigen一起，每天不一样！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mfbz.cn/a/695510.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

在 Ubuntu 中安装 Docker

在 Ubuntu 中安装 Docker

在 Ubuntu 中安装 Docker 首先&#xff0c;更新你的 Ubuntu 系统。 1、更新 Ubuntu 打开终端&#xff0c;依次运行下列命令&#xff1a; sudo apt update sudo apt upgrade sudo apt full-upgrade 2、添加 Docker 库 首先&#xff0c;安装必要的证书并允许 apt 包管理器…
阅读更多...
AI数据分析：根据Excel表格数据绘制柱形图

AI数据分析：根据Excel表格数据绘制柱形图

工作任务&#xff1a;将Excel文件中2013年至2019年间线上图书的销售额&#xff0c;以条形图的形式呈现&#xff0c;每个条形的高度代表相应年份的销售额&#xff0c;同时在每个条形上方标注具体的销售额数值 在deepseek中输入提示词&#xff1a; 你是一个Python编程专家&#…
阅读更多...
XMind v24.04.1 全功能VIP版（思维升级，效率飞跃）

XMind v24.04.1 全功能VIP版（思维升级，效率飞跃）

软件介绍 XMind 是一款功能丰富的思维导图和创新构思工具&#xff0c;可在多个平台助力高效思考。它涵盖了从灵感触发、结构构建到演示展示的完整思维过程&#xff0c;有效提升创建思维导图的效率。这款工具适用于记录灵感、创新思维、问题解决和效率提升等多元场景&#xff0…
阅读更多...
GEE训练教程——如何确定几何形状的中心点坐标和相交的坐标

GEE训练教程——如何确定几何形状的中心点坐标和相交的坐标

简介 在GEE中&#xff0c;可以使用.geometry()方法来获取几何形状的中心点坐标和相交的坐标。 首先&#xff0c;使用.geometry()方法获取几何形状的几何信息&#xff0c;然后使用.centroid()方法获取几何形状的中心点坐标。示例代码如下&#xff1a; // 获取几何形状的中心点…
阅读更多...
Golang | Leetcode Golang题解之第132题分割回文串II

Golang | Leetcode Golang题解之第132题分割回文串II

题目&#xff1a; 题解&#xff1a; func minCut(s string) int {n : len(s)g : make([][]bool, n)for i : range g {g[i] make([]bool, n)for j : range g[i] {g[i][j] true}}for i : n - 1; i > 0; i-- {for j : i 1; j < n; j {g[i][j] s[i] s[j] && g[…
阅读更多...
【Linux文件篇】系统文件、文件描述符与重定向的实用指南

【Linux文件篇】系统文件、文件描述符与重定向的实用指南

W...Y的主页 &#x1f60a; 代码仓库分享&#x1f495; 前言&#xff1a;相信大家对文件都不会太陌生、也不会太熟悉。在没有学习Linux操作系统时&#xff0c;我们在学习C或C时都学过如何去创建、打开、读写等待文件的操作&#xff0c;知道一些语言级别的一些接口与函数。但…
阅读更多...
【C++题解】1389 - 数据分析

【C++题解】1389 - 数据分析

问题&#xff1a;1389 - 数据分析 类型&#xff1a;简单循环 题目描述&#xff1a; 该方法的操作方式为&#xff0c;如果要传递 2 个数字信息给友军&#xff0c;会直接传递给友军一个整数 n&#xff08;n 是一个 10 位以内的整数&#xff09;&#xff0c;该整数的长度代表要传…
阅读更多...
Python私教张大鹏 Vue3整合AntDesignVue之Breadcrumb 面包屑

Python私教张大鹏 Vue3整合AntDesignVue之Breadcrumb 面包屑

显示当前页面在系统层级结构中的位置&#xff0c;并能向上返回。 何时使用 当系统拥有超过两级以上的层级结构时&#xff1b; 当需要告知用户『你在哪里』时&#xff1b; 当需要向上导航的功能时。 案例&#xff1a;面包屑导航基本使用 核心代码&#xff1a; <template…
阅读更多...
[spring] Spring MVC Thymeleaf（上）

[spring] Spring MVC Thymeleaf（上）

[spring] Spring MVC & Thymeleaf&#xff08;上&#xff09; 本章内容主要过一下简单的 Spring MVC 的案例 简单来说&#xff0c;spring mvc 就是比较传统的网页开发流程&#xff0c;目前 boot 是可以比较轻松的配置 thymeleaf——毕竟 spring boot 内置对 thymeleaf 的…
阅读更多...
快速开始一个go程序（极简-快速入门）

快速开始一个go程序（极简-快速入门）

一、 实验介绍 1.1 实验简介 为了能更高效地使用语言进行编码&#xff0c;Go 语言有自己的哲学和编程习惯。Go 语言的设计者们从编程效率出发设计了这门语言&#xff0c;但又不会丢掉访问底层程序结构的能力。设计者们通过一组最少的关键字、内置的方法和语法&#xff0c;最终…
阅读更多...
ChatGPT对话基本原则和玩法

ChatGPT对话基本原则和玩法

一、使用三个准备 1.1 认知上 超级学霸&#xff0c;几乎所有的工作/生活场景&#xff0c;都可以找它帮忙 ChatGPT作为一个人工智能语言模型&#xff0c;具有强大的知识储备和处理能力。这意味着在许多工作和生活场景中&#xff0c;你都可以向它请教问题或寻求帮助。无论是科…
阅读更多...
idea编码问题：需要 ＜标识符＞ 非法的类型 、需要为 class、interface 或 enum 问题解决

idea编码问题：需要 ＜标识符＞ 非法的类型 、需要为 class、interface 或 enum 问题解决

目录 问题现象 问题解决 问题现象 今天在idea 使用中遇到的一个编码的问题就是&#xff0c;出现了这个&#xff1a; Error:(357, 28) java: /home/luya...........anageService.java:357: 需要 <标识符> Error:(357, 41) java: /home/luya............anageService.ja…
阅读更多...
OpenGauss数据库-3.数据库管理

OpenGauss数据库-3.数据库管理

第1关&#xff1a;创建数据库 gsql -d postgres -U gaussdb -w passwd123123 create database accessdb with ownergaussdb templatetemplate0;第2关&#xff1a;修改数据库 gsql -d postgres -U gaussdb -w passwd123123 alter database accessdb rename to human_tpcds; 第…
阅读更多...
【清华大学】《自然语言处理》（刘知远）课程笔记 ——NLP Basics

【清华大学】《自然语言处理》（刘知远）课程笔记 ——NLP Basics

自然语言处理基础&#xff08;Natural Language Processing Basics, NLP Basics&#xff09; 自然语言处理( Natural Language Processing, NLP)是计算机科学领域与人工智能领域中的一个重要方向。它研究能实现人与计算机之间用自然语言进行有效通信的各种理论和方法。自然语言…
阅读更多...
智慧园区建设方案（Word）

智慧园区建设方案（Word）

1. 楼栋管理 2. 物业管理 3. 安防管理 4. 门禁管理 5. 停车管理 6. 能源管理 7. 环保管理 8. 园区生活服务 9. 招商管理 10. 收费中心 11. 园区地图 12. 门户网站 软件整套原件获取&#xff1a;本文末个人名片。
阅读更多...
量化投资分析平台 迅投 QMT（六）资产定价绕不过去的BSM模型

量化投资分析平台 迅投 QMT（六）资产定价绕不过去的BSM模型

量化投资分析平台 迅投 QMT [迅投 QMT](https://www.xuntou.net/?user_code7NYs7O)我目前在使用什么是BSM模型CQF课程介绍模型的五个重要的假设模型公式 我们为啥要学&#xff08;知道&#xff09;这玩意儿呢&#xff1f;隐含波动率&#xff08;Implied Volatility&#xff09…
阅读更多...
【qt】启动窗口的玩法

【qt】启动窗口的玩法

启动窗口的玩法 一.应用场景二.界面类设计窗口三.main中创建四.窗口显示标识五.功能实现1.读取注册表2.md5加密3.登录实现4.保存注册表5.功能演示 六.鼠标事件拖动窗口1.找到鼠标事件的函数2.点击事件3.移动事件4.释放事件 七.总结 一.应用场景 一般我们的软件和应用都会一个登…
阅读更多...
MATLAB实现粒子群算法优化柔性车间调度(PSO-fjsp)

MATLAB实现粒子群算法优化柔性车间调度(PSO-fjsp)

柔性车间调度是典型的N-P问题&#xff0c;数学模型如下&#xff1a; 数学模型 假设有n个工件需要在m台机器上进行加工。每个工件包含一道或多道工序&#xff0c;每道工序可以在多台机器上进行加工&#xff0c;但每道工序的加工时间随机器的不同而不同。 符号定义 n&#xf…
阅读更多...
仓储系统的设计

仓储系统的设计

管理员账户功能包括&#xff1a;系统首页&#xff0c;个人中心&#xff0c;管理员管理&#xff0c;用户管理&#xff0c;试剂管理&#xff0c;安全管理&#xff0c;存储管理 用户账户功能包括&#xff1a;系统首页&#xff0c;个人中心&#xff0c;试剂管理&#xff0c;安全管…
阅读更多...
pytest构建和测试FastAPI CURD API

pytest构建和测试FastAPI CURD API

文章目录 概述目标FASTAPI 介绍CRUD API 项目设置freezepipreqs 代码介绍run APIpytest测试conftest测试用例测试报告 F&Q1.执行uvicorn app.main:app --host localhost --port 8000 --reload 报错 zsh: /usr/local/bin/uvicorn: bad interpreter2.生成requirement.txt时&a…
阅读更多...
最新文章

Copyright @ 2022~2023