zoukankan      html  css  js  c++  java
  • .NetCore Cap 结合 RabbitMQ 实现消息订阅

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

  • 相关阅读:
    mui-手动触发下拉刷新
    Viewer.js 是一款强大的 jQuery 图像浏览插件。
    svn报错Can‘t install ‘*‘ from pristine store, because no checksum is recorded for this file
    KendoUI系列:ComboBox
    KendoUI系列:DropDownList
    简单使用AutoMapper实现DTO转换
    C# List.ForEach 方法
    C# LINQ需求实现演化
    C# yeild使用
    C#委托(delegate)
  • 原文地址:https://www.cnblogs.com/liyouming/p/9150961.html
Copyright © 2011-2022 走看看