.NetCore Cap 结合 RabbitMQ 实现消息订阅

龙码精神 2020/5/6 23:39:37

开源分布式消息框架 Cap 可以在GitHub上拉也可以通过nuget添加上一篇博文写了 Windows RabbitMQ的安装使用 Cap支持事务，通过捕获数据库上下文连接对象实现消息事务，消息持久化怎么来实现消息订阅消费？使用起来非常简单，主要通过这个类来实现发布：ICapPubli

开源分布式消息框架 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

您可能感兴趣的文章:

上一篇：.NetCore下B/S结构初探基于遗传学算法的中学自动排课走班（二）

下一篇：.NetCore下B/S结构初探基于遗传学算法的中学自动排课走班（一）

.NetCore Cap 结合 RabbitMQ 实现消息订阅

怎么来实现消息订阅消费？

配置

数据库消息发布及订阅数据

参考资料

关于找一找教程网

您可能感兴趣的文章:

相关文章

前端开发

后端开发

移动端开发

数据库

服务器运维

人工智能

区块链

游戏开发

网站运营

大数据/云计算

软件工程

软件/开发工具使用

资讯

.NetCore Cap 结合 RabbitMQ 实现消息订阅

怎么来实现消息订阅 消费？

配置

数据库消息发布及订阅数据

参考资料

关于找一找教程网

您可能感兴趣的文章:

怎么来实现消息订阅消费？