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.rhkb.cn/news/300672.html

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

相关文章

SDWAN专线保护企业数据传输安全

SDWAN专线保护企业数据传输安全

企业数字化进程的加速和网络环境的复杂化&#xff0c;数据传输安全已经成为企业网络管理的头等大事。SD-WAN&#xff08;软件定义广域网&#xff09;作为一种新兴的网络技术&#xff0c;不仅能够提升网络性能和效率&#xff0c;还能够有效地保护企业数据传输的安全性。以下是SD…
阅读更多...
项目架构MVC，DDD学习

项目架构MVC，DDD学习

写在前面 本文一起看下项目架构DDD&#xff0c;MVC相关的内容。 1&#xff1a;MVC 不管我们做什么项目&#xff0c;自己想想其实只是做了三件事&#xff0c;如下&#xff1a; 其实&#xff0c;这三件事完全在一个类中做完也可以可以正常把项目完成的&#xff0c;就像下面这…
阅读更多...
论文阅读《Semantic Prompt for Few-Shot Image Recognition》

论文阅读《Semantic Prompt for Few-Shot Image Recognition》

论文地址&#xff1a;https://arxiv.org/pdf/2303.14123.pdf 论文代码&#xff1a;https://github.com/WentaoChen0813/SemanticPrompt 目录 1、存在的问题2、算法简介3、算法细节3.1、预训练阶段3.2、微调阶段3.3、空间交互机制3.4、通道交互机制 4、实验4.1、对比实验4.2、组…
阅读更多...
(Git) gitignore基础使用

(Git) gitignore基础使用

文章目录 前言.gitignore 模式匹配注释 #转义 \直接匹配任意字符匹配 *单个字符匹配 ?目录分割 /多级目录 **范围匹配 []取消匹配 ! 检查是否生效父子文件END 前言 Git - gitignore Documentation (git-scm.com) 在使用git管理的项目中&#xff0c;可以通过.gitignore文件管理…
阅读更多...
Java-类型转换

Java-类型转换

Java数据类型转换的规则掌握后&#xff0c;将使我们对以后的学习事半功倍&#xff0c;下面是我列出的一些重点。 类型转换 由于Java是强类型语言&#xff0c;所以要进行有些运算的时候&#xff0c;需要用到类型转换。底到高依次是&#xff1a;byte,short,char->int->lo…
阅读更多...
React - 连连看小游戏

React - 连连看小游戏

简介 小时候经常玩连连看小游戏。在游戏中&#xff0c;当找到2个相同的元素就可以消除元素。 本文会借助react实现连连看小游戏。 实现效果 实现难点 1.item 生成 1. 每一个图片都是一个item&#xff0c;items数组的大小为size*size。 item对象包括grid布局的位置&#xff0c;…
阅读更多...
代码+视频，手动绘制logistic回归预测模型校准曲线（Calibration curve）（2）

代码+视频，手动绘制logistic回归预测模型校准曲线（Calibration curve）（2）

校准曲线图表示的是预测值和实际值的差距&#xff0c;作为预测模型的重要部分&#xff0c;目前很多函数能绘制校准曲线。 一般分为两种&#xff0c;一种是通过Hosmer-Lemeshow检验&#xff0c;把P值分为10等分&#xff0c;求出每等分的预测值和实际值的差距 另外一种是calibrat…
阅读更多...
【深度学习】StableDiffusion的组件解析，运行一些基础组件效果

【深度学习】StableDiffusion的组件解析，运行一些基础组件效果

文章目录 前言vaeclipUNetunet训练帮助、问询 前言 看了篇文&#xff1a; https://zhuanlan.zhihu.com/p/617134893 运行一些组件试试效果。 vae 代码&#xff1a; import torch from diffusers import AutoencoderKL import numpy as np from PIL import Image# 加载模型…
阅读更多...
前端入门（认识HTML，CSS，JavaScript三件套）

前端入门（认识HTML，CSS，JavaScript三件套）

目录 前言 HTML&#xff08;构建&#xff09; CSS&#xff08;设计&#xff09; JavaScript&#xff08;互动&#xff09; 总结 相关书籍推荐 前言 前端&#xff08;Frontend&#xff09;指的是与用户直接交互的部分&#xff0c;也称为客户端。在网站或者应用程序中&…
阅读更多...
FIN和RST的区别，几种TCP连接出现RST的情况

FIN和RST的区别，几种TCP连接出现RST的情况

一、RST跟FIN的区别&#xff1a; 正常关闭连接的时候发的包是FIN&#xff0c;但是如果是异常关闭连接&#xff0c;则发送RST包 两者的区别在于&#xff1a; 1.RST不必等缓冲区的包都发出去&#xff0c;直接就丢弃缓存区的包发送RST包。而FIN需要先处理完缓存区的包才能发送F…
阅读更多...
实战webSocket压测（三）Jmeter真实接口联调

实战webSocket压测（三）Jmeter真实接口联调

背景&#xff1a; 接口地址为&#xff1a;ws://sunlei.demo 接口说明&#xff1a;websocket接口&#xff0c;首次连接&#xff0c;通过Text请求设置开启标志&#xff0c;然后通过wav文件流传输&#xff0c;达到后端服务可以根据传输信息进行解析满足指定标准后&#xff0c;web…
阅读更多...
这就是AI眼中的物理世界：OpenAI Sora音乐短片《Worldweight》和超现实影片《气球人》

这就是AI眼中的物理世界：OpenAI Sora音乐短片《Worldweight》和超现实影片《气球人》

大家好&#xff0c;我是木易&#xff0c;一个持续关注AI领域的互联网技术产品经理&#xff0c;国内Top2本科&#xff0c;美国Top10 CS研究生&#xff0c;MBA。我坚信AI是普通人变强的“外挂”&#xff0c;所以创建了“AI信息Gap”这个公众号&#xff0c;专注于分享AI全维度知识…
阅读更多...
自定义gitlog格式

自定义gitlog格式

git log命令非常强大而好用&#xff0c;在复杂系统的版本管理中扮演着重要的角色&#xff0c;但默认的git log命令显示出的东西实在太丑&#xff0c;不好好打扮一下根本没法见人&#xff0c;打扮好了用alias命令拍个照片&#xff0c;就正式出道了&#xff01; 在使用git查看lo…
阅读更多...
何为网络协议？一图知晓网络过程。

何为网络协议？一图知晓网络过程。

网络协议就是计算机之间沟通的语言 为了有效地交流&#xff0c;计算机之间需要一种共同的规则或协议&#xff0c; 就像我们和老外沟通之前&#xff0c;要先商量好用哪种语言&#xff0c; 要么大家都说中文&#xff0c;要么大家都说英语&#xff0c;这才能有效地沟通。 网络协…
阅读更多...
JVM 全景图

JVM 全景图

今天我重新复习了一下 jvm 的一些知识点。我以前觉得 jvm 的知识点很多很碎&#xff0c;而且记起来很困难&#xff0c;但是今天我重新复习了一下&#xff0c;对这些知识点进行了简单的梳理之后&#xff0c;产生了不一样的看法。虽然 jvm 的知识点很碎&#xff0c;但是如果你真的…
阅读更多...
如何自定义项目启动时的图案

如何自定义项目启动时的图案

说明&#xff1a;有的项目启动时&#xff0c;会在控制台输出下面的图案。本文介绍Spring Boot项目如何自定义项目启动时的图案&#xff1b; 生成字符图案 首先&#xff0c;找到一张需要设置的图片&#xff0c;使用下面的代码&#xff0c;将图片转为字符文件&#xff1b; impo…
阅读更多...
动态规划刷题（算法竞赛、蓝桥杯）--线段（线性DP）

动态规划刷题（算法竞赛、蓝桥杯）--线段（线性DP）

1、题目链接&#xff1a;P3842 [TJOI2007] 线段 - 洛谷 | 计算机科学教育新生态 (luogu.com.cn) #include <bits/stdc.h> using namespace std; const int N20010; int a[N][2],f[N][2]; //a[i][0]表示l[i],a[i][1]表示r[i] int dis(int a,int b){return abs(a-b); } int…
阅读更多...
基于Swin Transformers的乳腺癌组织病理学图像多分类

基于Swin Transformers的乳腺癌组织病理学图像多分类

乳腺癌的非侵入性诊断程序涉及体检和成像技术&#xff0c;如乳房X光检查、超声检查和磁共振成像。成像程序对于更全面地评估癌症区域和识别癌症亚型的敏感性较低。 CNN表现出固有的归纳偏差&#xff0c;并且对于图像中感兴趣对象的平移、旋转和位置有所不同。因此&#xff0c;…
阅读更多...
flutter升级3.10.6Xcode构建报错

flutter升级3.10.6Xcode构建报错

flutter sdk 升级Xcode报错收集&#xff0c;错误信息如下&#xff1a; Error (Xcode): Cycle inside Runner; building could produce unreliable results.没问题版本信息&#xff1a; Xcode&#xff1a;15.3 flutter sdk &#xff1a;3.7.12 dart sdk&#xff1a;2.19.6 …
阅读更多...
考研||考公||就业||其他？-------愿不再犹豫

考研||考公||就业||其他？-------愿不再犹豫

大三下了&#xff0c;现在已经开学一个多月了&#xff0c;在上个学期的时候陆陆续续吧周围有的行动早的人已经开始准备考研了&#xff0c;当然这只是下小部分人吧&#xff0c;也有一部分人是寒假可能就开始了&#xff0c;更多的则是开学的时候&#xff0c;我的直观感受是图书馆…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023