Dapr(三) Dapr核心组件的使用一

结合前两期 Dapr(一) 基于云原生了解Dapr(Dapr(一) 基于云原生了解Dapr-CSDN博客) Dapr(二) 分布式应用运行时搭建及服务调用(Dapr(二) 分布式应用运行时搭建及服务调用-CSDN博客)

下篇推出dapr服务注册与发现，dapr组件绑定，dapr Actor功能。

目录

1.0 Dapr状态管理

1.1 Dapr状态组件配置文件

1.2 状态控制器

1.3 切换其它状态存储

1.4 工作原理

2.0 发布订阅

2.1 什么是发布订阅

2.2 设置发布订阅组件

2.3 控制器代码

2.3.1 发布控制器

2.3.2 订阅控制器

2.4 修改文件Program.cs

2.5 切换组件 

2.6 工作原理

总结：

1.0 Dapr状态管理

Dapr的状态管理允许应用程序保存和检索键值对数据，具有可插拔的存储、配置的行为和额外的安全特性。以下是主要特点：

  1. 可插拔状态存储：Dapr支持多种数据存储，比如MySQL、Redis、Azure CosmosDB等，可以在不修改代码的情况下切换。

  2. 配置存储行为：你可以指定并发控制和一致性级别。默认是最终一致性，但也支持强一致性。

  3. 并发控制：通过ETags实现乐观并发控制（OCC）。写操作需要匹配当前的ETag值，防止冲突。

  4. 自动加密：预览功能，支持应用程序状态的自动加密和密钥轮换。

  5. 一致性选项：可以选择强一致性的写入，等待所有副本确认，或者默认的最终一致性。

  6. 批量操作：支持一次性处理多条状态记录。

1.1 Dapr状态组件配置文件

Dapr默认使用的Redis进行存储。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:name: statestore
spec:type: state.redisversion: v1metadata:- name: redisHostvalue: localhost:6379- name: redisPasswordvalue: ""- name: actorStateStorevalue: "true"

1.2 状态控制器

 public class StateController : ControllerBase{private readonly ILogger<StateController> _logger;private readonly DaprClient _daprClient;public StateController(ILogger<StateController> logger, DaprClient daprClient){_logger = logger;_daprClient = daprClient;}// 获取一个值[HttpGet]public async Task<ActionResult> GetAsync(){var result = await _daprClient.GetStateAsync<string>("statestore", "guid");return Ok(result);}//保存一个值[HttpPost]public async Task<ActionResult> PostAsync(){await _daprClient.SaveStateAsync<string>("statestore", "guid", Guid.NewGuid().ToString(), new StateOptions() { Consistency = ConsistencyMode.Strong });return Ok("done");}//删除一个值[HttpDelete]public async Task<ActionResult> DeleteAsync(){await _daprClient.DeleteStateAsync("statestore", "guid");return Ok("done");}//通过tag防止并发冲突，保存一个值[HttpPost("withtag")]public async Task<ActionResult> PostWithTagAsync(){var (_, etag) = await _daprClient.GetStateAndETagAsync<string>("statestore", "guid");await _daprClient.TrySaveStateAsync("statestore", "guid", Guid.NewGuid().ToString(), etag);return Ok("done");}//通过tag防止并发冲突，删除一个值[HttpDelete("withtag")]public async Task<ActionResult> DeleteWithTagAsync(){var (_, etag) = await _daprClient.GetStateAndETagAsync<string>("statestore", "guid");return Ok(await _daprClient.TryDeleteStateAsync("statestore", "guid", etag));}// 从绑定获取一个值，健值name从路由模板获取[HttpGet("frombinding/{name}")]public ActionResult GetFromBindingAsync([FromState("statestore", "name")] StateEntry<string> state){return Ok(state.Value);}// 根据绑定获取并修改值，健值name从路由模板获取[HttpPost("withbinding/{name}")]public async Task<ActionResult> PostWithBindingAsync([FromState("statestore", "name")] StateEntry<string> state){state.Value = Guid.NewGuid().ToString();return Ok(await state.TrySaveAsync());}// 获取多个个值[HttpGet("list")]public async Task<ActionResult> GetListAsync(){var result = await _daprClient.GetBulkStateAsync("statestore", new List<string> { "guid" }, 10);return Ok(result);}// 删除多个个值[HttpDelete("list")]public async Task<ActionResult> DeleteListAsync(){var data = await _daprClient.GetBulkStateAsync("statestore", new List<string> { "guid" }, 10);var removeList = new List<BulkDeleteStateItem>();foreach (var item in data){removeList.Add(new BulkDeleteStateItem(item.Key, item.ETag));}await _daprClient.DeleteBulkStateAsync("statestore", removeList);return Ok("done");}}

1.3 切换其它状态存储

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:name: statestore
spec:type: state.mysqlversion: v1metadata:- name: connectionStringvalue: "root:123456@tcp(192.168.157.157:3306)/?allowNativePasswords=true"

切换状态为MySql进行存储。

1.4 工作原理

应用程序与 Dapr sidecar 交互，以存储和检索键/值数据。 在底层，sidecar API 使用**可配置的状态存储组件**来保存数据。 开发人员可以从不断增长的受支持状态存储集合中选择，其中包括 Azure Cosmos DB、SQL Server 和 Cassandra。

2.0 发布订阅

2.1 什么是发布订阅

发布订阅（Publish-Subscribe）是一种通信模式，允许发布者发送消息到一个中心节点（通常是消息代理或主题），而不关心具体哪些订阅者会接收到这些消息。订阅者则注册他们感兴趣的特定类型的消息，当匹配的消息发布时，他们会收到通知。这种模式的特点在于解耦了发布者和订阅者，提高了系统的灵活性和可扩展性。

关键元素包括：

  1. 发布者 (Publisher): 生产消息的实体，它向主题或消息代理发送消息，无需了解谁会接收这些消息。
  2. 订阅者 (Subscriber): 对特定消息感兴趣并希望接收通知的实体，它们通过订阅主题或消息代理来表达兴趣。
  3. 主题 或 消息代理 (Topic or Message Broker): 中间媒介，接收并分发消息，确保消息从发布者到达正确的订阅者。

一个简单的示例是新闻系统，其中发布者发布新闻到特定类别，而订阅者选择关注他们感兴趣的类别。发布者不直接通知订阅者，而是通过消息代理进行，这样订阅者仅接收与其订阅相匹配的新闻。

发布订阅模式的应用场景通常涉及异步通信、事件驱动的系统或需要解耦组件的场景。

2.2 设置发布订阅组件

Dapr默认使用的Redis进行发布订阅。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:name: pubsub
spec:type: pubsub.redisversion: v1metadata:- name: redisHostvalue: localhost:6379- name: redisPasswordvalue: ""

2.3 控制器代码

2.3.1 发布控制器

    [ApiController][Route("[controller]")]public class PubsubController : ControllerBase{private DaprClient _daprClient;private ILogger<PubsubController> _logger;public PubsubController(DaprClient daprClient, ILogger<PubsubController> logger){_daprClient = daprClient;_logger = logger;}/// <summary>/// 发布消息的方法/// </summary>/// <returns></returns>[HttpPost][Route("pub")]public async Task<IActionResult> PublishMessage(){_logger.LogInformation("***发布消息***");var data = new UserInfo(10001,"操作员",19);await _daprClient.PublishEventAsync("pubsub", "topic",data);return Ok("***发布消息成功***");}}

2.3.2 订阅控制器

    [ApiController][Route("[controller]")]public class SubController : ControllerBase{private ILogger<SubController> _logger;public SubController(ILogger<SubController> logger){_logger = logger;}[HttpPost("sub")][Topic("pubsub", "topic")]public IActionResult ConsumerMessage(UserInfo user){_logger.LogInformation("***消费消息***");Console.WriteLine($"userId:{user.UserId} userName:{user.UserName}");return Ok();}}

2.4 修改文件Program.cs

app.UseCloudEvents();
app.MapSubscribeHandler();

2.5 切换组件 

切换为RabbitMQ

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:name: pubsubnamespace: default
spec:type: pubsub.rabbitmqversion: v1metadata:- name: hostvalue: "amqp://123:123@192.168.157.157:5672"- name: durablevalue: "false"- name: deletedWhenUnusedvalue: "false"- name: autoAckvalue: "false"- name: deliveryModevalue: "0"- name: requeueInFailurevalue: "false"- name: prefetchCountvalue: "0"- name: reconnectWaitvalue: "0"- name: concurrencyModevalue: parallel- name: backOffPolicyvalue: "exponential"- name: backOffInitialIntervalvalue: "100"- name: backOffMaxRetriesvalue: "16"

2.6 工作原理

Dapr 发布&订阅构建基块提供了一个与平台无关的 API 框架来发送和接收消息。服务将消息发布到指定主题， 业务服务订阅主题以使用消息。服务在 Dapr sidecar 上调用 pub/sub API。 然后，sidecar 调用预定义 Dapr pub/sub 组件。

总结：

Dapr的发布订阅功能使得在分布式系统中实现发布/订阅消息模式变得更加简单。主要解决了不同消息产品之间实施复杂性和功能差异的问题。你可以通过Dapr的Sidecar API使用HTTP或gRPC来发布和订阅消息。以下是关键操作的概述：

  1. 发布(Publish)消息：

    • 使用http://localhost:<dapr-port>/v1.0/publish/<pub-sub-name>/<topic> URL，其中 <dapr-port> 是Dapr Sidecar监听的端口，<pub-sub-name> 是选择的发布/订阅组件名，而 <topic> 是消息的目标主题。

  2. 订阅(Subscribe)消息：

    • 应用程序在启动时，通过http://localhost:<appPort>/dapr/subscribe指定其订阅，其中 <appPort> 是应用程序监听的端口。
    • 订阅者处理消息后返回非错误响应，Dapr认为消息传递成功。
    • 支持订阅者通过响应负载中的状态进行精细化控制，比如指示重试(RETRY)或丢弃(DROP)消息。

Dapr的状态管理提供了一种跨服务持久化数据的方法，支持多种存储后端。关键特性包括：

  1. 原子性操作：支持原子性的读写操作，保证一致性。

  2. 版本控制：允许跟踪状态更改的历史版本，便于回滚。

  3. 事件驱动：状态变化可触发回调函数，实现基于状态变化的自动化操作。

  4. 过期策略：可设置状态项的过期时间。

  5. 备份与恢复：提供状态备份和恢复机制，确保高可用性。 

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

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

chrome google浏览器添加插件扩展失败怎么办，无法从该网站添加应用、扩展程序和用户脚本确定，

chrome google浏览器添加插件扩展失败怎么办，无法从该网站添加应用、扩展程序和用户脚本确定，

无法从该网站添加应用、扩展程序和用户脚本确定 chrome google浏览器添加插件扩展失败怎么办&#xff0c;无法从该网站添加应用、扩展程序和用户脚本确定&#xff0c; 需要打开调试模式 chrome://extensions/
阅读更多...
安装selenium和关于chrome高版本对应的driver驱动下载安装【Win/Mac 】

安装selenium和关于chrome高版本对应的driver驱动下载安装【Win/Mac 】

目录 一、查看自己电脑上chrome的版本 二、下载 ChromeDriver 三、安装selenium 法一&#xff1a;打开pycharm&#xff0c;点击File&#xff0c;Setting进入配置页面&#xff0c;点击Project下面的Python Interpreter进入环境配置页面&#xff0c;点击。输入selenium。之后…
阅读更多...
产品推荐 | 星嵌基于TI TMS320C6657+Xilinx XC7Z035/045 DSP+FPGA+ARM工业核心板

产品推荐 | 星嵌基于TI TMS320C6657+Xilinx XC7Z035/045 DSP+FPGA+ARM工业核心板

1、产品概述 广州星嵌电子科技有限公司研发的C6657ZYNQ7035/45工业核心板&#xff0c;是基于TI KeyStone 架构C6000 系列TMS320C6657 双核C66x定点/浮点DSP 以及 Xilinx ZYNQ-7000 系列XC7Z035/045 SoC 处理器设计的。 DSP处理器采用TMS320C6657&#xff0c;双核C66x定点/浮点…
阅读更多...
HarmonyOS实战开发-如何实现分布式帐号相关的功能。

HarmonyOS实战开发-如何实现分布式帐号相关的功能。

介绍 本示例主要展示了分布式帐号相关的功能&#xff0c;使用ohos.account.distributedAccount、ohos.account.osAccount等接口&#xff0c;实现了绑定分布式帐号、解绑分布式帐号、更新分布式帐号信息和管理分布式帐号的功能&#xff1b; 效果预览 使用说明 1.首次进入应用会…
阅读更多...
idea 开发serlvet汽车租赁管理系统idea开发sqlserver数据库web结构计算机java编程layUI框架开发

idea 开发serlvet汽车租赁管理系统idea开发sqlserver数据库web结构计算机java编程layUI框架开发

一、源码特点 idea开发 java servlet 汽车租赁管理系统是一套完善的web设计系统sqlserver数据库 系统采用serlvetdaobean mvc 模式开发&#xff0c;对理解JSP java编程开发语言有帮助&#xff0c;系统具有完整的源代码和数据库&#xff0c;系统主要采用B/S模式开发。 java se…
阅读更多...
Mac安装Docker提示Another application changed your Desktop configuration解决方案

Mac安装Docker提示Another application changed your Desktop configuration解决方案

1. 问题描述 Mac安装Docker后&#xff0c;提示Another application changed your Desktop configuration&#xff0c;Re-apply configurations无效 2. 解决方案 在终端执行下述命令即可解决&#xff1a; sudo ln -sf /Applications/Docker.app/Contents/Resources/bin/docke…
阅读更多...
网络驱动器设备：ISCSI服务器

网络驱动器设备：ISCSI服务器

文章目录 使用ISCSI服务部署网络存储ISCSI技术介绍创建RAID磁盘整列配置ISCSI服务端配置Windows端配置Linux客户端iSCSI服务器CHAP单向认证配置Linux端具体步骤Windows端具体步骤 使用ISCSI服务部署网络存储 主机名IPISCSI服务端192.168.200.10ISCSI客户端192.168.200.20Windo…
阅读更多...
Vue 有哪些主要的指令修饰符

Vue 有哪些主要的指令修饰符

目录 1. 什么是指令修饰符 2. 指令修饰符有哪些 2.1. 按键修饰符 2.2. v-model修饰符 2.3. 事件修饰符 1. 什么是指令修饰符 通过 "." 指明一些指令 后缀&#xff0c;不同 后缀 封装了不同的处理操作 目的&#xff1a;简化代码 2. 指令修饰符有哪些 2.1. 按键…
阅读更多...
WPS快速将插入Excle数据插入Word

WPS快速将插入Excle数据插入Word

前置条件&#xff1a; 一张有标题、数据的excle表格word中的表格与excle表格标题对应或包含电脑已经安装WPS软件 第一步、根据word模板设计excle模板&#xff0c;标头对应 第二步、word上面选【引用】--【邮件】&#xff0c;选打开数据源&#xff0c;找到excle文件&#xff0c;…
阅读更多...
Python 基于 OpenCV 视觉图像处理实战 之 OpenCV 简单视频处理实战案例 之二 简单视频闪白效果

Python 基于 OpenCV 视觉图像处理实战 之 OpenCV 简单视频处理实战案例 之二 简单视频闪白效果

Python 基于 OpenCV 视觉图像处理实战 之 OpenCV 简单视频处理实战案例 之二 简单视频闪白效果 目录 Python 基于 OpenCV 视觉图像处理实战 之 OpenCV 简单视频处理实战案例 之二 简单视频闪白效果 一、简单介绍 二、简单视频闪白效果实现原理 三、简单视频闪白效果案例实现…
阅读更多...
什么是GIF?MP4视频如何转换成GIF动图格式？

什么是GIF?MP4视频如何转换成GIF动图格式？

一&#xff0c;什么是GIF GIF的全称是Graphics Interchange Format&#xff0c;可译为图形交换格式&#xff0c;用于以超文本标志语言&#xff08;Hypertext Markup Language&#xff09;方式显示索引彩色图像&#xff0c;在因特网和其他在线服务系统上得到广泛应用。GIF是一种…
阅读更多...
说说TCP为什么需要三次握手和四次挥手？

说说TCP为什么需要三次握手和四次挥手？

一、三次握手 三次握手&#xff08;Three-way Handshake&#xff09;其实就是指建立一个TCP连接时&#xff0c;需要客户端和服务器总共发送3个包 主要作用就是为了确认双方的接收能力和发送能力是否正常、指定自己的初始化序列号为后面的可靠性传送做准备 过程如下&#xff…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023