首页
视频
资源
登录
原
Dapr .NetCore 绑定输入输出
4874
人阅读
2021/12/22 10:31
总访问:
2534646
评论:
0
收藏:
0
手机
分类:
.net后台框架
![](https://img.tnblog.net/arcimg/hb/896fd38e95b346f9a0d98c54b135bb94.jpg) >#Dapr .NetCore 绑定输入输出 [TOC] 输入绑定 ------------ tn2>简单来说通过你的应用所对应的dapr边车绑定队列的消息处理,但是这个消息中间件可以自定义。 比如我们接下来的案例大致如下: ![](https://img.tnblog.net/arcimg/hb/cde85f1964bb4c10b50a75391584a230.png) tn>这里没用Redis的原因是因为它不支持,关于中间价支持的列表参考如下: https://docs.dapr.io/reference/components-reference/supported-bindings/ >###Demo tn2>首先我们需要创建Rabbitmq中间件,可以参考我的这两篇文章 https://www.tnblog.net/hb/article/details/6627 https://www.tnblog.net/hb/article/details/5179 ![](https://img.tnblog.net/arcimg/hb/42856d069af140e19abfdc754baddda5.png) tn2>随后我们创建一个.netcore的webapi,并添加相关依赖 ```csharp <PackageReference Include="Dapr.AspNetCore" Version="1.4.0" /> ``` tn2>添加相关服务 ```csharp services.AddControllers().AddDapr(); ``` tn2>定义控制器(`MyRabbitmq`) ```csharp [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); } } ``` tn2>接着我们需要在我们的`~/.dapr/components`下定义我们Rabbitmq(`rabbitmqbind.yaml`)的组件,请参考如下示例: ```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 ``` tn2>关于定义中route是定义我们的rabbitmq消息在该应用中在哪儿进行处理。其他参数请参考: https://docs.dapr.io/reference/components-reference/supported-bindings/ 最后执行如下命令运行我们的app ```bash dapr run --app-id myapp --app-port 5000 --dapr-http-port 3500 -- dotnet run ``` tn2>最后我们在rabbitmq中找到我们定义的queue1队列,并在里面进行发布消息,可以看到它已经在我们的程序中进行了消息处理。 ![](https://img.tnblog.net/arcimg/hb/46d206fc7cbc499f927f9e215c403777.png) ![](https://img.tnblog.net/arcimg/hb/a2852599cb79469899e0d342b39ed804.png) 绑定输出 ------------ tn2>简单来说就是绑定输入倒过来,你只需要在应用中把消息发送给相关队列其他的你不用管消息应该如何消费。 ![](https://img.tnblog.net/arcimg/hb/11fe6232b67c496ca3b2e54204e7da62.png) tn2>很简单我们再在控制器中添加接口方法,进行发送事件 ```csharp [HttpPost("OutCheck")] public async Task OutRegisterBind([FromServices] DaprClient dapr) { var msg = "9999999"; _log.LogInformation($"发送消息:{msg}"); //组件名 创建操作 消息内容 await dapr.InvokeBindingAsync("myrabbitmq", "create", msg); } ``` ![](https://img.tnblog.net/arcimg/hb/083f1878352040e992bfa40a3956b2c3.png) tn2>由于我输出与输入绑定是在同一个应用上所以立马就处理了。
欢迎加群讨论技术,1群:677373950(满了,可以加,但通过不了),2群:656732739
👈{{preArticle.title}}
👉{{nextArticle.title}}
评价
{{titleitem}}
{{titleitem}}
{{item.content}}
{{titleitem}}
{{titleitem}}
{{item.content}}
尘叶心繁
这一世以无限游戏为使命!
博主信息
排名
6
文章
6
粉丝
16
评论
8
文章类别
.net后台框架
166篇
linux
17篇
linux中cve
1篇
windows中cve
0篇
资源分享
10篇
Win32
3篇
前端
28篇
传说中的c
4篇
Xamarin
9篇
docker
15篇
容器编排
101篇
grpc
4篇
Go
15篇
yaml模板
1篇
理论
2篇
更多
Sqlserver
4篇
云产品
39篇
git
3篇
Unity
1篇
考证
2篇
RabbitMq
23篇
Harbor
1篇
Ansible
8篇
Jenkins
17篇
Vue
1篇
Ids4
18篇
istio
1篇
架构
2篇
网络
7篇
windbg
4篇
AI
18篇
threejs
2篇
人物
1篇
嵌入式
2篇
python
13篇
HuggingFace
8篇
pytorch
9篇
opencv
6篇
最新文章
最新评价
{{item.articleTitle}}
{{item.blogName}}
:
{{item.content}}
关于我们
ICP备案 :
渝ICP备18016597号-1
网站信息:
2018-2024
TNBLOG.NET
技术交流:
群号656732739
联系我们:
contact@tnblog.net
欢迎加群
欢迎加群交流技术