Dapr .NetCore 调用方法

• Dapr .NetCore 调用方法
  • 创建客户端项目(InvokeMethod)
  • 创建服务端项目(InvokeMethodServer)
  • 运行测试
  • 示例中的参数与描述

创建客户端项目(InvokeMethod)

在Program类中设置日志控制台输出，在 launchSettings.json 设置运行的端口为5001

public static IHostBuilder CreateHostBuilder(string[] args) =>
    Host.CreateDefaultBuilder(args)
        .ConfigureLogging(logging =>
        {
            logging.ClearProviders();
            logging.AddConsole();
            logging.AddDebug();
        })
        .ConfigureWebHostDefaults(webBuilder =>
        {
            webBuilder.UseStartup<Startup>();
        });

{
    "profiles": {
        "InvokeMethod": {
            "commandName": "Project",
            "launchBrowser": true,
            "launchUrl": "weatherforecast",
            "applicationUrl": "http://localhost:5001",
            "environmentVariables": {
                "ASPNETCORE_ENVIRONMENT": "Development"
            }
        }
    }
}

安装dapr的依赖包 Dapr.AspNetCore，我这里的版本是1.4.0

Install-Package Dapr.AspNetCore
# or
dotnet add package Dapr.AspNetCore

安装json序列化的包（Newtonsoft.Json）

Install-Package Newtonsoft.Json
# or
dotnet add package Newtonsoft.Json

安装Dapr服务

services.AddControllers().AddDapr();

创建 SendMessageController 控制器，其中里面有三个可请求的方法
(Send) 将mydata发送Get请求到appId为myserver的Request方法中
(Sendv2) 比上面一个多一种http请求方式，且是POST方法，判断请求是否成功
(Sendv3) 比上面多接受处理返回结果

[ApiController]
[Route("[controller]")]
public class SendMessageController : ControllerBase
{
    private readonly ILogger<SendMessageController> _logger;
    private readonly DaprClient _client;
    public SendMessageController(ILogger<SendMessageController> logger,DaprClient client )
    {
        _logger = logger;
        _client = client;
    }
    [HttpGet]
    public async Task<string> Send()
    {
        var idnumber = new Random().Next(0,99);
        _logger.LogInformation("正在发送");
        var mydata = new MyClass(idnumber,$"MyClass{idnumber}");
        await _client.InvokeMethodAsync<MyClass>(HttpMethod.Get,"myserver","Request",mydata);
        _logger.LogInformation("发送成功");
        return "ok";
    }
    [HttpGet("sendv2")]
    public async Task<string> Sendv2()
    {
        var idnumber = new Random().Next(0,99);
        var mydata = new MyClass(idnumber,$"MyClass{idnumber}");
        _logger.LogInformation("正在发送");
        var client = DaprClient.CreateInvokeHttpClient(appId: "myserver");
        _logger.LogInformation("发送成功");
        // http的方式
        var response = await client.PostAsJsonAsync("/Request/v2", mydata);
        if (response.IsSuccessStatusCode)
        {
            return "ok";
        }else{
            return "bad";
        }
    }
    [HttpGet("sendv3")]
    public async Task<string> Sendv3()
    {
        var idnumber = new Random().Next(0,99);
        var mydata = new MyClass(idnumber,$"MyClass{idnumber}");
        var client = DaprClient.CreateInvokeHttpClient(appId: "myserver");
        // http的方式
        var response = await client.PostAsJsonAsync("/Request/v3", mydata);
        if (response.IsSuccessStatusCode)
        {
            var newdata = await response.Content.ReadFromJsonAsync<MyClass>();
            _logger.LogInformation($"得到服务器端处理的新数据：{newdata.Id} {newdata.Name}");
            return JsonConvert.SerializeObject(newdata);
        }else{
            return "bad";
        }
    }
    public class MyClass
    {
        public MyClass(){}
        public MyClass(int id,string name)
        {
            Id = id;
            Name = name;
        }
        public int Id { get; set; }
        public string Name { get; set; }
    }
}

创建服务端项目(InvokeMethodServer)

在Program类中设置日志控制台输出，在 launchSettings.json 设置运行的端口为5000

public static IHostBuilder CreateHostBuilder(string[] args) =>
    Host.CreateDefaultBuilder(args)
        .ConfigureLogging(logging =>
        {
            logging.ClearProviders();
            logging.AddConsole();
            logging.AddDebug();
        })
        .ConfigureWebHostDefaults(webBuilder =>
        {
            webBuilder.UseStartup<Startup>();
        });

{
    "profiles": {
        "InvokeMethod": {
            "commandName": "Project",
            "launchBrowser": true,
            "launchUrl": "weatherforecast",
            "applicationUrl": "http://localhost:5000",
            "environmentVariables": {
                "ASPNETCORE_ENVIRONMENT": "Development"
            }
        }
    }
}

安装dapr的依赖包 Dapr.AspNetCore

Install-Package Dapr.AspNetCore
# or
dotnet add package Dapr.AspNetCore

安装json序列化的包（Newtonsoft.Json）

Install-Package Newtonsoft.Json
# or
dotnet add package Newtonsoft.Json

安装Dapr服务

services.AddControllers().AddDapr();

接着定义RequestController控制器与客户端相对应的请求处理方法

[ApiController]
[Route("[controller]")]
public class RequestController : ControllerBase
{
    private readonly ILogger<RequestController> _logger;
    public RequestController(ILogger<RequestController> logger)
    {
        _logger = logger;
    }
    [HttpGet]
    public void Get(MyClass mydata)
    {
        _logger.LogInformation($"Server Finish! Result: {mydata.Id} {mydata.Name}");
    }
    [HttpPost("v2")]
    public void GetV2(MyClass mydata)
    {
        _logger.LogInformation($"Server Finish v2 ! Result: {mydata.Id} {mydata.Name}");
    }
    [HttpPost("v3")]
    public Task<MyClass> GetV3(MyClass mydata)
    {
        _logger.LogInformation($"Server Get Data v3 ! Data: {mydata.Id} {mydata.Name}");
        mydata.Id = new Random().Next(1,99);
        mydata.Name = "From My Server Data";
        _logger.LogInformation($"Server Updata Data: {mydata.Id} {mydata.Name}");
        return Task.FromResult(mydata);
    }
    public class MyClass
    {
        public MyClass(){}
        public MyClass(int id,string name)
        {
            Id = id;
            Name = name;
        }
        public int Id { get; set; }
        public string Name { get; set; }
    }
}

运行测试

# 客户端运行
dapr run --app-id myclient --app-port 5001 --dapr-http-port 3501 -- dotnet run
# 服务器端运行
dapr run --app-id myserver --app-port 5000 --dapr-http-port 3500 -- dotnet run

通过dapr list查看运行列表

测试方法

dapr invoke --app-id myclient --method SendMessage --verb GET
dapr invoke --app-id myclient --method SendMessage/sendv2 --verb GET
dapr invoke --app-id myclient --method SendMessage/sendv3 --verb GET

或者以http请求的方式进行访问

curl http://localhost:3501/v1.0/invoke/myclient/method/SendMessage
curl http://localhost:3501/v1.0/invoke/myclient/method/SendMessage/sendv2
curl http://localhost:3501/v1.0/invoke/myclient/method/SendMessage/sendv3

客户端请求信息

服务器端处理信息

示例中的参数与描述