惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

酷 壳 – CoolShell
酷 壳 – CoolShell
aimingoo的专栏
aimingoo的专栏
P
Proofpoint News Feed
宝玉的分享
宝玉的分享
MyScale Blog
MyScale Blog
The GitHub Blog
The GitHub Blog
钛媒体:引领未来商业与生活新知
钛媒体:引领未来商业与生活新知
月光博客
月光博客
量子位
博客园 - 司徒正美
V
V2EX
I
InfoQ
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
Vercel News
Vercel News
H
Hackread – Cybersecurity News, Data Breaches, AI and More
美团技术团队
N
Netflix TechBlog - Medium
L
LangChain Blog
IT之家
IT之家
Blog — PlanetScale
Blog — PlanetScale
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
Stack Overflow Blog
Stack Overflow Blog
A
About on SuperTechFans
Microsoft Azure Blog
Microsoft Azure Blog

博客园 - 小庄

如何正确的 DDD AI时代的领域驱动设计:DAD 我开发了个人工智能应用, 请大家给点意见 通过代理使用人工智能服务保姆级教程 OnionArch 2.0 - 基于DDD的洋葱架构改进版开源 根据MediatR的Contract Messages自动生成Minimal WebApi接口 MediatRPC - 基于MediatR和Quic通讯实现的RPC示例,新增Server Stream功能,发布开源地址。 MediatRPC - 基于MediatR和Quic通讯实现的RPC框架,比GRPC更简洁更低耦合,开源发布第一版 Dapr实现.Net Grpc服务之间的发布和订阅,并采用WebApi类似的事件订阅方式 关于.Net 7.0 RC gRPC JSON 转码为 Swagger/OpenAPI文档的注意事项 OnionArch - 如何实现更新指定字段的通用Handler OnionArch - 采用DDD+CQRS+.Net 7.0实现的洋葱架构 Blazor+Dapr+K8s微服务之基于WSL安装K8s集群并部署微服务 Blazor+Dapr+K8s微服务之事件发布订阅 Blazor+Dapr+K8s微服务之开发环境调试 Blazor+Dapr+K8s微服务之服务调用 .Net Core 通过依赖注入和动态加载程序集实现宿主程序和接口实现类库完全解构 面向对象之"三段论" 使用WIX打包客户端程序
Blazor+Dapr+K8s微服务之状态管理
小庄 · 2021-08-25 · via 博客园 - 小庄

1         状态管理服务器端接口

1.1         添加Dapr.AspNetCore包

在DaprTest1.Server项目中添加Dapr.AspNetCore包,该包实现了ASP.NET Core与Dapr的集成,例如自动依赖注入DaprClient对象,将状态管理功能直接集成到 ASP.NET Core 模型绑定功能中等。

 

修改DaprTest1.Server项目的Startup.cs文件,将Dapr对象依赖注入到ASP.NET Core。

 public void ConfigureServices(IServiceCollection services)
        {

            services.AddControllersWithViews().AddDapr();
            services.AddRazorPages();
            services.AddScoped<InvocationHandler>();

            // 注入httpClient
            services.AddHttpClient("HttpClient").AddHttpMessageHandler<InvocationHandler>()
            .AddTypedClient(client =>
            {
                client.BaseAddress = new Uri("http://serviceapi1");
                return RestService.For<ICallServiceApi1>(client);
            });
        }

在DaprTest1.Server项目的WeatherForecastController.cs文件中注入DaprClient对象

  private readonly DaprClient _daprClient;

        public WeatherForecastController(ILogger<WeatherForecastController> logger, ICallServiceApi1 callServiceApi1, DaprClient daprClient)
        {
            _logger = logger;
            _callServiceApi1 = callServiceApi1;
            _daprClient = daprClient;
        }

1.2         状态保存接口

在DaprTest1.Server项目的WeatherForecastController.cs文件中增加状态保存接口。

  [HttpPost(nameof(SaveStateValue))]
        public async Task SaveStateValue(StateModel stateModel)
        {
            await _daprClient.SaveStateAsync("statestore", stateModel.Key, stateModel.Value);
        }

其中 StateModel  为自定义的状态模型对象。

1.3         状态删除接口

在DaprTest1.Server项目的WeatherForecastController.cs文件中增加状态删除接口。

 [HttpDelete(nameof(DeleteStateValue) + "/{stateKey}")]
        public async Task DeleteStateValue(string stateKey)
        {
            await _daprClient.DeleteStateAsync("statestore", stateKey);
        }

1.4         状态获取接口

在DaprTest1.Server项目的WeatherForecastController.cs文件中增加两个状态获取接口。

 [HttpGet("GetStateValue/{stateKey}")]
        public async Task<string> GetStateValue(string stateKey)
        {
            return await _daprClient.GetStateAsync<string>("statestore", stateKey);
        }

        [HttpGet(nameof(GetStateValueFromState) + "/{stateKey}")]
        public async Task<string> GetStateValueFromState([FromState("statestore", "stateKey")] StateEntry<string> stateEntry)
        {
            return await Task.FromResult(stateEntry.Value);
        }

注意,第二个状态获取接口是通过ASP.NET Core 模型绑定实现的。

2         状态管理菜单和页面

在DaprTest1.Server项目的NavMenu.razor文件新增状态管理菜单。

 <li class="nav-item px-3">
            <NavLink class="nav-link" href="statemanage">
                <span class="oi oi-list-rich" aria-hidden="true"></span> 状态管理
            </NavLink>
        </li>

在DaprTest1.Server项目新增状态管理页面

@page "/statemanage"
@using DaprTest1.Shared
@using System.Text.Json
@inject HttpClient Http

<h1>状态存储</h1>

<p>This component demonstrates storing state.</p>

<p>状态键: TestStateKey, 状态值:<input type="text" @bind="stateModel.Value" /></p>

<button class="btn btn-primary" @onclick="SaveStateValue">保存状态</button>
<button class="btn btn-primary" @onclick="DeleteStateValue">删除状态</button>
<button class="btn btn-primary" @onclick="GetStateValue">获取状态</button>
<button class="btn btn-primary" @onclick="GetStateValueFromState">获取状态[FromState]</button>


<p>获取到的状态值: @stateValue</p>

@code {
    private StateModel stateModel = new StateModel() { Key = "TestStateKey" };
    private string stateValue = "";

    private async Task SaveStateValue()
    {
        await Http.PostAsJsonAsync<StateModel>("WeatherForecast/SaveStateValue", stateModel);
    }
    private async Task DeleteStateValue()
    {
        await Http.DeleteAsync("WeatherForecast/DeleteStateValue/" + stateModel.Key);
    }
      private async Task GetStateValue()
    {
        stateValue = await Http.GetStringAsync("WeatherForecast/GetStateValue/" + stateModel.Key);
    }
     private async Task GetStateValueFromState()
    {
        stateValue = await Http.GetStringAsync("WeatherForecast/GetStateValueFromState/" + stateModel.Key);
    }
}

3         状态管理测试

和上一节一样,我们先开启每个微服务的SideCar,然后启动两个微服务,访问状态管理页面:

 

我们可以查看缓存,看到状态数据,其中缓存Key是由保存状态的微服务ID+“||”+自定义的缓存Key组成,缓存内容Dapr自动增加了版本号。

相关代码:iamxiaozhuang/dapr-test (github.com)