Dapr .NetCore 绑定输入输出

• Dapr .NetCore 绑定输入输出
  • 输入绑定
    • Demo
  • 绑定输出

输入绑定

简单来说通过你的应用所对应的dapr边车绑定队列的消息处理，但是这个消息中间件可以自定义。
比如我们接下来的案例大致如下：

Demo

首先我们需要创建Rabbitmq中间件，可以参考我的这两篇文章
https://www.tnblog.net/hb/article/details/6627
https://www.tnblog.net/hb/article/details/5179

随后我们创建一个.netcore的webapi，并添加相关依赖

<PackageReference Include="Dapr.AspNetCore" Version="1.4.0" />

添加相关服务

services.AddControllers().AddDapr();

定义控制器（MyRabbitmq）

[Route("MyRabbitmq")]
[ApiController]
public class MyRabbitmqController:Controller
{
    ILogger<MyRabbitmqController> _log;
    public MyRabbitmqController(
        ILogger<MyRabbitmqController> log
    ){
        _log = log;
    }
    [HttpPost("InputCheck")]
    public void InputRegisterBind()
    {
        Stream stream = Request.Body;
        byte[] buffer = new byte[Request.ContentLength.Value];
        stream.ReadAsync(buffer, 0, buffer.Length);
        string content = Encoding.UTF8.GetString(buffer);
        _log.LogInformation(".............binding............." + content);
    }
}

接着我们需要在我们的~/.dapr/components下定义我们Rabbitmq(rabbitmqbind.yaml)的组件，请参考如下示例：

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: myrabbitmq
spec:
  type: bindings.rabbitmq
  version: v1
  metadata:
  - name: queueName
    value: queue1
  - name: host
    value: amqp://guest:guest@192.168.43.166:5672
  - name: durable
    value: true
  - name: deleteWhenUnused
    value: false
  - name: ttlInSeconds
    value: 60
  - name: prefetchCount
    value: 0
  - name: exclusive
    value: false
  - name: maxPriority
    value: 5
  - name: contentType
    value: "text/plain"
  - name: route
    value: /MyRabbitmq/InputCheck

关于定义中route是定义我们的rabbitmq消息在该应用中在哪儿进行处理。其他参数请参考：
https://docs.dapr.io/reference/components-reference/supported-bindings/
最后执行如下命令运行我们的app

dapr run --app-id myapp --app-port 5000 --dapr-http-port 3500 -- dotnet run

最后我们在rabbitmq中找到我们定义的queue1队列，并在里面进行发布消息，可以看到它已经在我们的程序中进行了消息处理。

绑定输出

简单来说就是绑定输入倒过来，你只需要在应用中把消息发送给相关队列其他的你不用管消息应该如何消费。

很简单我们再在控制器中添加接口方法，进行发送事件

[HttpPost("OutCheck")]
public async Task OutRegisterBind([FromServices] DaprClient dapr)
{
    var msg = "9999999";
    _log.LogInformation($"发送消息：{msg}");
    //组件名 创建操作 消息内容
    await dapr.InvokeBindingAsync("myrabbitmq", "create", msg);
}

由于我输出与输入绑定是在同一个应用上所以立马就处理了。