【微服务架构系列】微服务简介，第3部分：服务注册表

【微服务架构系列】微服务简介，第3部分：服务注册表

在微服务系列的这篇文章中，我们将讨论服务注册表。在第2部分中，我们讨论了API网关，其中我们提到服务已在数据库中注册。网关根据该数据库中包含的信息调度请求。下面我们将探讨如何填充数据库以及服务，客户端和网关与之交互的方式。

服务注册表

服务注册表是一个数据库，其中包含有关如何将请求分派给微服务实例的信息。注册表和其他组件之间的交互可以分为两组，每组有两个子组：

微服务和注册表之间的交互（注册）

自注册第三方注册

客户端与注册表之间的交互（发现）

客户端发现服务器端发现

注册

大多数基于微服务的架构都在不断发展。随着开发团队分离，改进，弃用和完成工作，服务会上下波动。每当服务端点发生更改时，注册表都需要了解更改。这就是注册的全部内容：谁发布或更新有关如何联系每项服务的信息。

自注册迫使微服务自己与注册表进行交互。当服务上升时，它会通知注册表。服务中断时会发生同样的事情。无论注册表需要哪些其他数据，都必须由服务本身提供。如果你一直关注这个系列，你就会知道微服务都是关于处理一个问题，所以自我注册可能看起来像一个反模式。但是，对于简单的体系结构，自注册可能是正确的选择。

第三方注册通常在行业中使用。在这种情况下，有一个管理所有其他服务的进程或服务。此过程以某种方式轮询或检查哪些微服务实例正在运行，并自动更新服务注册表。可以以每服务配置文件（或策略）的形式提供附加数据，注册过程使用该文件来更新数据库。在使用Apache ZooKeeper或Netflix Eureka等工具以及其他服务管理器的架构中，第三方注册很常见。

第三方注册还提供其他好处。例如，当服务出现故障时会发生什么？可以将第三方注册服务配置为为失败的服务提供安全回退。其他案例可能会实施其他政策。例如，服务注册表进程可能会收到高负载情况的通知，并通过请求实例化新的微服务进程或VM来自动添加新端点。可以想象，这些可能性对于大型架构至关重要。

发现

可以想象，从客户的角度来看，发现是注册的对应物。当客户想要访问服务时，它必须找出服务所在的位置（以及执行请求的其他相关信息）。

客户端发现强制客户端在执行实际请求之前查询发现服务。正如自我注册所发生的那样，这要求客户处理除主要目标之外的其他问题。发现服务可能位于API网关后面，也可能不位于API网关后面。如果它不在网关后面，则可能需要为发现服务重新实现平衡，身份验证和其他横切关注点。此外，每个客户端都需要知道要联系发现服务的固定端点（或端点）。这些都是缺点。一个很大的优点是不必在网关系统中编写必要的逻辑。选择发现方法时，请仔细研究。

服务器端发现使API网关处理发现请求的正确端点（或端点）。这通常用于更大的架构。由于所有请求都直接发送到网关，所以与之相关的所有好处都适用（参见第2部分）。网关还可以实现发现缓存，以便许多请求可以具有较低的延迟。高速缓存失效背后的逻辑特定于实现。

“服务器端发现使API网关能够处理发现请求的正确端点。”

服务器端发现

示例：注册表服务

在第2部分中，我们研究了一个简单的API网关实现。在该示例中，我们通过查询到服务数据库来实现动态调度请求。换句话说，我们实现了服务器端发现。对于此示例，我们将通过处理注册方面来扩展我们的微服务架构。我们将以两种方式这样做：

通过提供一个简单的注册库，任何开发团队都可以将其集成到他们的微服务中以执行自我注册。通过提供在启动或关闭期间注册服务的示例systemd单元（使用systemd作为服务管理器的第三方注册）。

为什么要系统？它已成为大多数Linux安装中的事实上的服务管理器。管理服务还有其他选择，但都需要安装和配置。为简单起见，我们选择了大多数发行版中预装的那个，这是systemd。

注册库

我们之前发布的微服务示例是为node.js开发的，所以我们的库也适用于它。这是我们库的主要逻辑：

module.exports.register = function(service, callback) { if(!validateService(service)) { callback(new Error("Invalid service")); } findExisting(service.name, function(err, found) { if(found) { callback(new Error("Existing service")); return; } var dbService = new Service({ name: service.name, url: service.url, endpoints: service.endpoints, authorizedRoles: service.authorizedRoles }); dbService.save(function(err) { callback(err); }); });}module.exports.unregister = function(name, callback) { findExisting(name, function(err, found) { if(!found) { callback(new Error("Service not found")); return; } found.remove(function(err) { callback(err); }); });}

执行自注册的微服务需要在启动或关闭期间调用这些功能（包括异常关闭）。我们已通过以下方式将此库集成到现有的微服务示例中（将SELF_REGISTRY变量设置为任何值以启用此功能）。启动代码：

// Standalone server setupvar port = process.env.PORT || 3001;function (err) { if (err) { logger.error(err); } else { logger.info('Listening on + port); if(process.env.SELF_REGISTRY) { registry.register({ name: serviceName, url: '/tickets', endpoints: [ { type: 'url: '+ port + '/tickets' } ], authorizedRoles: ['tickets-query'] }, function(err) { if(err) { logger.error(err); process.exit(); } }); } }});

和关机代码：

function exitHandler() { if(process.env.SELF_REGISTRY) { registry.unregister(serviceName, function(err) { if(err) { logger.error(err); } process.exit(); }); } else { process.exit(); }}process.on('exit', exitHandler);process.on('SIGINT', exitHandler);process.on('SIGTERM', exitHandler);process.on('uncaughtException', exitHandler);

使用systemd进行第三方注册

我们的网关示例从Mongo数据库中读取服务信息。Mongo提供了一个命令行界面，我们可以在启动或关闭期间使用它来注册服务。这是一个示例systemd单元（如果您使用此帖子中的示例微服务，请记住禁用SELF_REGISTRY环境变量）：

[Unit]Description=Sample tickets query microservice#Uncomment the following line when not running systemd in user mode#After=network.target[Service]#Uncomment the following line to run the service as a specific user#User=sebaEnvironment="MONGO_URL=mongodb://127.0.0.1:27018/test"ExecStart=/usr/bin/node /home/seba/Projects/Ingadv/Auth0/blog-code/microservices/server.jsExecStartPost=/usr/bin/mongo --eval 'db.services.insert({"name": "Tickets Query Service", "url": "/tickets", "endpoints": [{"type": ""url": ""authorizedRoles": ["tickets-query"] });' 127.0.0.1:27017/testExecStopPost=/usr/bin/mongo --eval 'db.services.remove({"name": "Tickets Query Service"});' 127.0.0.1:27017/test[Install]WantedBy=default.target

注册由ExecStartPost和ExecStopPost指令通过调用命令行Mongo客户端（包含在所有标准MongoDB安装中）来处理。

获取代码express = require('express');var app = express();var jwt = require('express-jwt');var jwtCheck = jwt({ secret: new Buffer('your-auth0-client-secret', 'base64'), audience: 'your-auth0-client-id'});app.use('/api/path-you-want-to-protect', jwtCheck);// (...)

您可以通过Auth0仪表板获取客户端ID和客户端密钥。创建一个新帐户并开始黑客攻击！

结论

服务注册表是基于微服务的体系结构的重要组成部分。有不同的处理注册和发现的方法，适合不同的架构复杂性。在承诺之前考虑上述每种替代方案的优缺点。在第4部分中，我们将详细研究服务依赖性以及如何有效地管理它们。

谢谢大家关注，转发，点赞。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。