.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
扫描二维码或查找【程序员编程王】
可以随时随地学编程啦！
共有 条评论 网友评论