通过Dapr实现一个简单的基于.net的微服务电商系统(五)——一步一步教你如何撸Dapr之状态管理

GET http://localhost:<daprPort>/v1.0/state/<storename>/<key>

POST http://localhost:<daprPort>/v1.0/state/<storename>

DELETE http://localhost:<daprPort>/v1.0/state/<storename>/<key>

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: statestore
spec:
  type: state.redis
  version: v1
  metadata:
  - name: redisHost
    value: redis.infrastructure.svc.cluster.local:6379
  - name: keyPrefix
    value: none

    public class TestState : Oxygen.Client.ServerSymbol.Store.StateStore
    {
        public TestState()
        {
            Key = "TestState";
        }
        public override string Key { get; set; }
        public override object Data { get; set; }
    }

        private readonly IServiceProxyFactory serviceProxyFactory;
        private readonly IStateManager stateManager;
        public ClientCallService(IServiceProxyFactory serviceProxyFactory, IStateManager stateManager) {
            this.serviceProxyFactory = serviceProxyFactory;
            this.stateManager = stateManager;
        }

        public async Task<dynamic> Call()
        {
            var result1 = new OutDto();
            var result2 = new OutDto();
            var remoteService = serviceProxyFactory.CreateProxy<IHelloService>();
            await stateManager.SetState(new TestState() { Data = new OutDto() { Word = "123" } });try
            {
                 result1 = await remoteService.HelloWorld();
                 result2 = await remoteService.HelloWorldByName(new InputDto() { Name = "xiaoming" });
            }
            catch(Exception e)
            {

            }
            return new { result1, result2 };
        }

            var result = await stateManager.GetState<OutDto>(new TestState());
            Console.WriteLine(result.Word);