语言 Chinese, Simplified

SEO Title

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

服务注册表

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

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

自注册
第三方注册

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

客户端发现
服务器端发现

注册

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

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

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

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

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

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

发现

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

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

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

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

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

服务器端发现

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

示例：注册表服务

在第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 setup
var port = process.env.PORT || 3001;
http.createServer(app).listen(port, function (err) {
 if (err) {
 logger.error(err);
 } else { 
 logger.info('Listening on http://localhost:' + port);
 if(process.env.SELF_REGISTRY) {
 registry.register({
 name: serviceName,
 url: '/tickets',
 endpoints: [ {
 type: 'http',
 url: 'http://127.0.0.1:' + 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=seba
Environment="MONGO_URL=mongodb://127.0.0.1:27018/test"
ExecStart=/usr/bin/node /home/seba/Projects/Ingadv/Auth0/blog-code/microservices/server.js
ExecStartPost=/usr/bin/mongo --eval 'db.services.insert({"name": "Tickets Query Service", "url": "/tickets", "endpoints": [{"type": "http", "url": "http://127.0.0.1:3001/tickets"}], "authorizedRoles": ["tickets-query"] });' 127.0.0.1:27017/test
ExecStopPost=/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安装中）来处理。

获取代码https://github.com/auth0/blog-microservices-part3。

另外：使用Auth0作为您的微服务

由于JWT的神奇之处，Auth0和微服务齐头并进。看看这个：

var 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和客户端密钥。创建一个新帐户并开始黑客攻击！