当前播放: 33 | 集成事件:使用RabbitMQ来实现EventBus
00:00 / 00:00
高清
  • 高清
1.0x
  • 2.0x
  • 1.5x
  • 1.25x
  • 1.0x
  • 0.5x
网页全屏
全屏
00:00
付费课程,可试看
课程目录
第一章:必备知识 (25讲)
01 | 课程介绍
免费
02 | 内容综述
免费
03 | .NET Core的现状、未来以及环境搭建
免费
04 | Startup:掌握ASP.NET Core的启动过程
免费
05 | 依赖注入:良好架构的起点
免费
06 | 作用域与对象释放行为:你知道IDisposable对象释放的时机和坑吗?
07 | 用Autofac增强容器能力:引入面向切面编程(AOP)的能力
08 | 配置框架:让服务无缝适应各种环境
09 | 命令行配置提供程序:最简单快捷的配置注入方法
10 | 环境变量配置提供程序:容器环境下配置注入的最佳途径
11 | 文件配置提供程序:自由选择配置的格式
12 | 配置变更监听:配置热更新能力的核心
13 | 配置绑定:使用强类型对象承载配置数据
14 | 自定义配置数据源:低成本实现定制化配置方案
15 | 选项框架:服务组件集成配置的最佳实践
16 | 选项数据热更新:让服务感知配置的变化
17 | 为选项数据添加验证:避免错误配置的应用接收用户流量
18 | 日志框架:聊聊记日志的最佳姿势
19 | 日志作用域:解决不同请求之间的日志干扰
20 | 结构化日志组件Serilog:记录对查询分析友好的日志
21 | 中间件:掌控请求处理过程的关键
22 | 异常处理中间件:区分真异常与逻辑异常
23 | 静态文件中间件:前后端分离开发合并部署骚操作
24 | 文件提供程序:让你可以将文件放在任何地方
25 | 路由与终结点:如何规划好你的Web API
第二章:微服务实战篇 (11讲)
26 | 工程结构概览:定义应用分层及依赖关系
27 | 定义Entity:区分领域模型的内在逻辑和外在行为
28 | 工作单元模式(UnitOfWork):管理好你的事务
29 | 定义仓储:使用EF Core实现仓储层
30 | 领域事件:提升业务内聚,实现模块解耦
31 | APIController:定义API的最佳实践
32 | 集成事件:解决跨微服务的最终一致性
33 | 集成事件:使用RabbitMQ来实现EventBus
34 | MediatR:轻松实现命令查询职责分离模式(CQRS)
35 | MediatR:让领域事件处理更加优雅
课程暂停更新声明
33 | 集成事件:使用RabbitMQ来实现EventBus

33 | 集成事件:使用RabbitMQ来实现EventBus

肖伟宇
校宝在线架构师、SkyWalking .NET探针贡献者、NetCorePal组件库创建者
61讲 约600分钟2877
单独订阅¥129
2人成团¥99
本节摘要
登录 后留言

精选留言(6)

  • 艾roger
    应该发布器包装下接口,不要将icappublisher等cap框架直接在领域层引入,而造成领域事件的依赖污染
    2020-03-28
  • 艾roger
    cap如何配置多个exchange?我在exchange A订阅event1后处理成功,再发布event2到另一个exchang B.这个需求如何配置实现?
    2020-03-28
  • 路人乙
    老师,集成事件如果会变更两个数据库的数据,您在efcontext中事物处理时注入的cap能做到跨数据库的一致吗?cap框架的两张表是存到其中的一个数据库,还是两个数据库中都要有这两张表,或者两两张表是不是可以独立创建到新的数据库中。

    作者回复: 你可以看下CAP组件github上的架构说明,一个数据库对应一个微服务,它负责两个微服务之间的Event传递的可靠性,因此,在两个数据库分别有事件的接收和发送表

    2020-03-12
  • 陈正文
    把mysql换成sqlserver后报错如下:System.InvalidOperationException:“ValueFactory attempted to access the Value property of this instance.”
    此异常最初是在此调用堆栈中引发的:
    System.Lazy<T>.ViaFactory(System.Threading.LazyThreadSafetyMode)
    System.Lazy<T>.ExecutionAndPublication(System.LazyHelper, bool)
    System.Lazy<T>.CreateValue()
    System.Lazy<T>.Value.get()
    Microsoft.Extensions.Options.OptionsCache<TOptions>.GetOrAdd(string, System.Func<TOptions>)
    Microsoft.Extensions.Options.OptionsManager<TOptions>.Get(string)
    Microsoft.Extensions.Options.OptionsManager<TOptions>.Value.get()
    DotNetCore.CAP.SqlServer.SqlServerStorageInitializer.GetPublishedTableName()
    DotNetCore.CAP.SqlServer.SqlServerDataStorage.SqlServerDataStorage(Microsoft.Extensions.Options.IOptions<DotNetCore.CAP.CapOptions>, Microsoft.Extensions.Options.IOptions<DotNetCore.CAP.SqlServerOptions>, DotNetCore.CAP.Persistence.IStorageInitializer)

    作者回复: 看起来像是配置没注册对,你需要引入:
    Microsoft.EntityFrameworkCore.SqlServer

    将:
    builder.UseMySql(connectionString);
    改为:
    builder.UseSqlServer(connectionString);

    2020-03-02
    1
  • 陈正文
    我把mysql换成sqlserver,在启动项目时总是报错
    2020-03-02
    1
  • 顾你心安
    听懂了 可以
    2020-02-28
收起评论
看过的人还看
数据结构与算法之美

王争  前Google工程师

79讲 | 77055 人已学习

拼团 ¥79 原价 ¥99
MySQL实战45讲

林晓斌  网名丁奇,前阿里资深技术专家

48讲 | 48169 人已学习

拼团 ¥79 原价 ¥99
DDD实战课

欧创新  人保高级架构师

24讲 | 6575 人已学习

拼团 ¥55 原价 ¥68
Electron开发实战

邓耀龙  美团高级前端工程师

35讲 | 1964 人已学习

拼团 ¥79 原价 ¥99