我昨天写了一篇关于在微服务应用程序中采用Dapr的好处的文章《从服务之间的调用来看 我们为什么需要Dapr》[1], 在那篇文章中,我们专注于"服务调用"构建块 [2]。在这篇文章中,我想向你展现一个特别有用的功能,它是由"绑定"构建块[3]实现的。Dapr 绑定Dapr 中的"绑定"概念对于任何使用过 Azure Functions 的人来说都很熟悉,它们揭示了与各种第三方服务交互的简化方式,可以说微软的技术都是一脉相承的,Dapr 就是毫不夸张的来说就是微软技术的集大成者。绑定可以是"输入"或"输出"。输入绑定(也称为"触发器")允许 Dapr 订阅外部系统中的事件,并在服务上调用终结点,以便您知道发生了什么。Azure 中的良好示例是订阅事件网格上的事件[4]或服务总线[5]上的消息。但是有许多受支持的绑定,包括Twitter之类的东西,因此每当有符合您的搜索条件的推文时,您都可以收到通知。输出绑定允许您将数据发送到外部服务。在 Azure 中,这可能是将消息发布到队列,将文档写入 Cosmos DB[6]。或者您可以使用它给Twilio发送短信[7]。绑定的优点和缺点绑定的一个优点是,它们可以大大简化应用程序代码,因为它们消除了连接到服务通常需要的许多繁琐的模板代码。另一个优点是它们提供了一定程度的抽象。虽然由于某些绑定处理的数据具有特定于服务的性质,因此无法与其他替代项交换,但交换组件的功能在开发/测试环境中可能非常有用,因为在开发/测试环境中,你可能不希望或不需要与实际服务进行实际通信。绑定的主要缺点是,它们通常只公开基础平台功能的相当有限的子集,按照二八原则,通常这个可以满足我们80%场景的需求了,从这个角度来看也不是什么缺点了,你同意我的看法吗?因此,如果您是高级用户,那么您可能更喜欢直接使用服务的SDK。当然,Dapr不会阻止你这样做 - 绑定是完全可选的功能。Cron绑定我想特别给你介绍的"cron"绑定[8]是一个特例。它不支持连接到外部系统,它却可以轻松设置计划任务。要进行此设置,您需要定义一个组件 YAML 文件。我这里用官方文档里的一个示例[8] 进行说明,您可以自定义 以满足您的需求。这支持常规的 cron 语法和一些简化的快捷方式,例如每十五分钟一次,如下所示。apiVersion: dapr.io/v1alpha1

kind: Component

metadata:   name:    namespace:

spec:   type: bindings.cron   version: v1   metadata:   - name: schedule     value: "@every 15m" # valid cron schedule  scopes:   - catalog

我所做的唯一"高级"操作是通过使用 scopes 属性[9]将此组件限制为仅应用于单个 Dapr 服务- 在此示例中为服务catalog ,现在,我们需要做的就是在与组件名称匹配的终结点上进行侦听。在此示例中,它称为scheduled .请注意,这将作为 HTTP POST请求发出,因此在下面的示例中,我将演示简单的 Node.js Express 应用程序如何在端点上接收调用并向控制台写入消息。app.post('/scheduled', async function(req, res){   console.log("scheduled endpoint called", req.body)   res.status(200).send()

});如果我们运行此命令,我们将看到 Dapr 边车每五分钟调用一次终结点/scheduled。 如果在你的项目中没有计划任务的解决方案,Dapr提供了如此简单易用的开箱即用选项真是太好了。Dapr 的绑定还有很多功能,详细了解可以参考下面几篇文章:Dapr + .NET Core实战(六)绑定 [10]Dapr-绑定构建块 [11]手把手教你学Dapr - 8. 绑定 [12]Dapr项目应用探索[13]相关链接[1] 从服务之间的调用来看 我们为什么需要Dapr : https://www.cnblogs.com/shanyou/p/15864968.html[2] 服务调用构建块 : https://docs.dapr.io/developing-applications/building-blocks/service-invocation/service-invocation-overview/[3] 绑定构建块:https://docs.dapr.io/developing-applications/building-blocks/bindings/bindings-overview/ [4] 事件网格上的事件:https://docs.dapr.io/reference/components-reference/supported-bindings/eventgrid/[5] 服务总线:https://docs.dapr.io/reference/components-reference/supported-bindings/servicebusqueues/[6] 将文档写入Cosmos DB: https://docs.dapr.io/reference/components-reference/supported-bindings/cosmosdb/[7] Twilio 发送短信:https://docs.dapr.io/reference/components-reference/supported-bindings/twilio/ [8] Cron 绑定:https://docs.dapr.io/reference/components-reference/supported-bindings/cron/ [9] scopes属性:https://docs.dapr.io/zh-hans/operations/components/component-scopes/[10] Dapr + .NET Core实战(六)绑定 :https://www.cnblogs.com/chenyishi/p/15343564.html[11] Dapr-绑定构建块 :https://www.cnblogs.com/cwsheng/p/15552408.html[12] 手把手教你学Dapr - 8. 绑定 :https://www.cnblogs.com/MASA/p/15822185.html[13] Dapr项目应用探索 : https://www.cnblogs.com/cwsheng/p/15733159.html

查看原文