当前播放: 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
第二章:微服务实战篇 (22讲)
26 | 工程结构概览:定义应用分层及依赖关系
27 | 定义Entity:区分领域模型的内在逻辑和外在行为
28 | 工作单元模式(UnitOfWork):管理好你的事务
29 | 定义仓储:使用EF Core实现仓储层
30 | 领域事件:提升业务内聚,实现模块解耦
31 | APIController:定义API的最佳实践
32 | 集成事件:解决跨微服务的最终一致性
33 | 集成事件:使用RabbitMQ来实现EventBus
34 | MediatR:轻松实现命令查询职责分离模式(CQRS)
35 | MediatR:让领域事件处理更加优雅
36 | HttpClientFactory:管理向外请求的最佳实践
37 | gRPC:内部服务间通讯利器
38 | gRPC:用代码生成工具提高生产效率
39 | Polly:用失败重试机制提升服务可用性
40 | Polly:熔断慢请求避免雪崩效应
41 | 网关与BFF:区分场景与职责
42 | 网关与BFF:使用JWT来实现身份认证与授权
43 | 安全:反跨站请求伪造
44 | 安全:防开放重定向攻击
45 | 安全:防跨站脚本
46 | 安全:跨域请求
47 | 缓存:为不同的场景设计合适的缓存策略
第三章:部署到Kubernetes (14讲)
48 | 部署:演示一个部署流程
49 | ConfigMap:实现基本配置方案
50 | 配置:使用分布式配置中心方案版本化管理配置
51 | 健康检查:与Liveness、Readiness、Startup探测集成实现高可用
52 | 健康检查:搭建全量健康检查探针和看板
53 | ForwardedHeaders:确保服务在负载均衡下正常工作
54 | 安全:介绍强制HTTPS的两种方式
55 | 日志:与EFK日志三件套集成
56 | 日志:Exceptionless日志系统
57 | 追踪:集成SkyWalking .NET实现追踪
58 | 监控与告警:Prometheus与AlertManager
59 | 监控与告警:用Granfana实现监控看板
60 | prometheus-net:自定义监控指标利器
61 | 结束语
33 | 集成事件:使用RabbitMQ来实现EventBus

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

肖伟宇
校宝在线架构师、SkyWalking .NET探针贡献者、NetCorePal组件库创建者
全集3769
新人首单 ¥29.9 原价 ¥129
1
本节摘要
登录 后留言

精选留言(10)

  • 张俊杰
    老师,在webform下有什么类似cap框架 ,觉得不错的推荐下呗
    2020-07-28
  • 爱学习的大叔
    老师,你能讲讲rabitMQ到底在这两个地方起了个什么作用吗?
    我们的MediatR首先是把事件放到publish表,然后rabbitMQ从这里边取出来,然后subscribe端从消息队列里取数据然后消费,再把消费结果存到subscribe表里的吗?
    2020-06-21
  • 张志炜
    老师,在这节课遇到了3个问题:
    1、序列化的时候,提示DomainEvents序列化死循环,导致我需要增加[IgnoreDataMember]注解,可是看老师的案例里面没有这个问题,不知道为什么。
    2、在领域事件中,领域事件可以确定只推送了一次,但是Handler这边,却处理了2次,这是为什么了。
    3、在集成事件这边,事件正常发出去了,然后接收到的时候,ID和Address却反序列化失败了,直到我将ID { get; protected set; }改成了ID{get;set;}之后,才能成功获取,Address同样,都需要将Set设置成功Public之后才能正常获取。
    但是其他Order中的参数,Set依然是private,却没有问题?
    ……
    然后我运行了老师的Demo,都没有这些问题。。可是我对比起来,总感觉代码是没有区别的。。老师能说下,这问题出在哪里么。
    或者可能出现在哪些原因上么。。

    作者回复: 看看组件版本的区别

    2020-06-03
  • 路人乙
    老师,我同一个方法中使用_capPublisher发布多次同一类型的消息(集成事件的参数不同)。如_capPublisher.PublishAsync(“CreateOrder”,order)这里每个order,的参数是不同的。多个消息发布后在数据库的发布表中可以看到成功发布了多个消息,而消费表也能消费全部的消息,但消费表执行的集成事件的参数值都是最后发布的参数。相当于发布的消息如果没来得及执行,那最终执行时会全部执行成最后发布消息时传递过来的内容。为了验证是不是因为消息为执行又发布消息引起的问题,我在发布每条消息后线程等待一秒问题就解决了。想知道这种问题要怎么解决,如果有并发出现同一时刻发布了多个同类消息,那消费端会不会就出问题了。
    2020-04-21
    1
  • 王亚
    肖老师:我在本地使用sql数据库调试时 发现当程序在推送集成事件(代码:await _capPublisher.PublishAsync("OrderCreated", new OrderCreatedIntegrationEvent(notification.Order.Id));) 走到这里时, 页面提示异常(异常信息:Microsoft.Data.SqlClient.SqlException (0x80131904): “`”附近有语法错误。
       at Microsoft.Data.SqlClient.SqlConnection.OnError(SqlException exception, Boolean breakConnection, Action`1 wrapCloseInAction)
       at Microsoft.Data.SqlClient.SqlInternalConnection.OnError(SqlException exception, Boolean breakConnection, Action`1 wrapCloseInAction)
       at Microsoft.Data.SqlClient.TdsParser.ThrowExceptionAndWarning(TdsParserStateObject stateObj, Boolean callerHasConnectionLock, Boolean asyncClose)
       at Microsoft.Data.SqlClient.TdsParser.TryRun(RunBehavior runBehavior, SqlCommand cmdHandler, SqlDataReader dataStream, BulkCopySimpleResultSet bulkCopyHandler, TdsParserStateObject stateObj, Boolean& dataReady.......)) 这是什么原因呢?
    2020-04-01
  • 艾roger
    应该发布器包装下接口,不要将icappublisher等cap框架直接在领域层引入,而造成领域事件的依赖污染

    作者回复: 很好的建议,这里应该设计接口进行隔离

    2020-03-28
  • 艾roger
    cap如何配置多个exchange?我在exchange A订阅event1后处理成功,再发布event2到另一个exchang B.这个需求如何配置实现?
    2020-03-28
  • 陈正文
    把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
    2
  • 陈正文
    我把mysql换成sqlserver,在启动项目时总是报错
    2020-03-02
    1
  • 顾你心安
    听懂了 可以
    2020-02-28
收起评论
看过的人还看
数据结构与算法之美

王争  前Google工程师

80讲 | 87594 人已学习

新人首单 ¥29.9 原价 ¥129
DDD实战课

欧创新  人保高级架构师

25讲 | 8400 人已学习

新人首单 ¥9.9 原价 ¥68
Electron开发实战

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

35讲 | 2501 人已学习

新人首单 ¥19.9 原价 ¥99
从0开始学架构

李运华  前阿里资深技术专家

60讲 | 45711 人已学习

新人首单 ¥29.9 原价 ¥129