.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结构 初探基于遗传学算法的中学自动排课走班(一)

赞(0)

共有 条评论 网友评论

验证码: 看不清楚?
    关注微信小程序
    程序员编程王-随时随地学编程

    扫描二维码或查找【程序员编程王】

    可以随时随地学编程啦!

    技术文章导航 更多>
    扫一扫关注最新编程教程