.NetCore Cap 结合 RabbitMQ 实现消息订阅
龙码精神 2020/5/6 23:39:37 次
开源分布式消息框架 Cap 可以在GitHub上拉也可以通过nuget添加
上一篇博文写了 Windows RabbitMQ的安装使用
Cap支持事务,通过捕获数据库上下文连接对象实现 消息事务,消息持久化
怎么来实现消息订阅 消费?
使用起来非常简单,主要通过这个类来实现
发布:ICapPublisher 、
订阅:CapSubscribe
DNC的注入就不做介绍了,引用好相关的Cap类,并注入如下,如果需要事务请注入数据库访问上下文对象
public ValuesController(AppDbContext dbContext, ICapPublisher capPublisher) { _dbContext = dbContext; _capBus = capPublisher; }
消息发布 :定义消息名称 参数
_capBus.Publish("sample.rabbitmq.mysql", parameters);
消息订阅 订阅消息名称 本生是Attributes属性,写到 Action上就ok了
[CapSubscribe("sample.rabbitmq.mysql")]
public void ReceiveMessage(string parameters) { //处理方法 }
配置
这里我们用Mysql来试试
//添加数据库上下文服务 services.AddDbContext<AppDbContext>(); //添加cap服务 services.AddCap(x => { x.UseEntityFramework<AppDbContext>(); // x.UseRabbitMQ("localhost"); x.UseRabbitMQ(options => { //上一篇中我创建的用户名密码 options.HostName = "192.168.0.42"; options.UserName = "liyouming"; options.Password = "lym123!@#"; }); //启用仪表盘 x.UseDashboard(); });
在配置Configure
app.UseCap();
启动程序 发布一个消息 并接受订阅 访问下仪表盘
已经发布成功
下面登录下 RabbitMQ Server Management
数据库消息发布及订阅数据
参考资料
https://www.cnblogs.com/savorboard/p/cap.html
https://github.com/dotnetcore/CAP

关于找一找教程网
本站文章仅代表作者观点,不代表本站立场,所有文章非营利性免费分享。
本站提供了软件编程、网站开发技术、服务器运维、人工智能等等IT技术文章,希望广大程序员努力学习,让我们用科技改变世界。
[.NetCore Cap 结合 RabbitMQ 实现消息订阅]http://www.zyiz.net/tech/detail-133225.html
您可能感兴趣的文章:
- 2020-02-22.netcore 3.1高性能微服务架构:加入swagger接口文档
- 2019-09-04迭代器模式随想
- 2019-09-04C#开发BIMFACE系列12 服务端API之文件转换
- 2019-09-04.NET Core 学习资料精选:进阶
- 2019-09-04.Net cache与cache更新
- 2019-09-04ASP.NET Core 2.1 : 十二.内置日志、使用Nlog将日志输出到文件
- 2019-09-04ASP.NET Core 2.2 : 十六.扒一扒新的Endpoint路由方案
- 2021-01-23如何使用 C# 中的 Tuple
- 2021-01-23如何使用 C# 中的 FileSystemWatcher
- 2021-01-23如何使用 C# 中的 Lazy

扫描二维码或查找【程序员编程王】
可以随时随地学编程啦!
共有 条评论 网友评论