CAP 3.0 版本发布通告

Wesley13
• 阅读 463

前言

大家好,我们很高兴宣布 CAP 发布了 3.0 版本正式版。

自从上次 CAP 2.6 版本发布 以来,已经过去了几个月的时间,关注的朋友可能知道,在这几个月的时间里,也发布了几个预览版的 3.0 版本的NuGet包。

3.0 是一个主要版本,在这个版本中我们对代码进行了大量重构,重构的目的是为了让代码保持清洁并且逻辑更加清晰易读,并且接口更加合理。作为一个主要版本并进行大量重构的前提下避免不了会带来一些破坏性更新,但这些都是值得的。

简介

可能有些人还不知道 CAP 是什么,老规矩来一个简介。

CAP 是一个用来解决微服务或者分布式系统中分布式事务问题的一个开源项目解决方案(https://github.com/dotnetcore/CAP)同样可以用来作为EventBus使用,目前已经3岁了,目前已经应用到了很多的公司和项目中, 想对 CAP 更多了解的同学可以看下官方文档

本次在 CAP 3.0 版本中我们主要带来了以下破坏性改变和新特性:

破坏性改变:

  • 消息协议和存储
  • 接口改动
  • 分离 Dashboard 项目

新特性:

  • 新的发布Api
  • 新的序列化接口
  • 全新的 Diagnostics 事件和结构
  • 新的Kafka Transport配置项
  • 其他改进

下面我们就来逐一看一下吧。

破坏性改变

本次版本我们带来了一个破坏性的改变,这导致我们的 3.0 版本是不和 2.0 版本的消息兼容的,所以大家在升级的时候注意一下。

消息协议和存储

在过去,消息是被CAP经过了一次包装然后序列化为json发送到消息队列中,并且消费端也是由CAP进行解包然后反序列化为需要的对象。这样有什么问题呢? 这会导致一是无法对消息进行自定义序列化,二会导致用户在和其他客户端发送到消息队列的消息进行对接的时候需要进行额外的适配工作。

基于以上原因,我们调整了发送和消费的数据结构和存储方式。使用更加原生的方式来实现。你发送的消息将会被直接序列化后传递到消息队列的 Body 中,元数据信息将被传递到消息队列的 Header 中。

数据库的数据结构我们在新版本并没有调整,在升级的过程中需要注意的是消息都已经被消费完成了,这样就不会读到旧的消息从而出现失败的问题。

接口改动

我们重构了一些接口,大部分情况下如果你是按照推荐的方式在使用CAP那么不会对你有影响 ,如果你在升级新版本的过程遇到问题,可以参考最新代码进行调整。

分离 Dashboard 项目

在这个版本中,我们将 Dashboard 相关代码分离了出去形成了一个新的项目,如果你需要使用到 Dashbaord 相关功能,可以从 NuGet 安装它。

PM> Install-Package DotNetCore.CAP.Dashboard

新的发布Api

我们在 ICapPublisher 接口新增了一个Api 用于发送带有头信息的消息。

Task PublishAsync<T>(string name, T contentObj, IDictionary<string, string> headers);

头将被直接发送的消息队列支持的消息头进行传输,通常你可以传递和消息体相关的元数据信息在里面。

默认情况下,我们发送了 消息Id,消息名称,消息类型,发送时间 等,利用此接口你可以添加更多信息到头数据中。

在消费者这边,你可以通过 [FromCap] 标签来从 CapHeader 中读取头信息,下面展示了如何在消费者方法中读取发送的头信息。

[CapSubscribe("sample.rabbitmq.mysql")]
public void Subscriber2(DateTime p, [FromCap]CapHeader header)
{
    // header["my-header"]
}

新的序列化接口

新增了 ISerializer 序列化接口,以支持对发往消息队列的消息体进行自定义序列化,你可以通过自定义实现此接口来使用你喜爱的序列化器。

默认情况下,我们使用的是 json 来对消息进行序列化,我们推荐使用此方式。因为这样你可以在 RabbitMQ Management 控制台来测试发送消息更加的方便。

全新的 Diagnostics 事件和结构

我们改进了 Diagnostics 事件和数据结构,提供对最新事件的追踪。并且我们优化了数据结构,现在可以过的更新运行时的状态信息。

我们已经针对 Skywalking 提交了 PR 已支持最新的 CAP 事件的追踪,新的追踪支持从 Controller 到消息发布,消息消费等全链路的跟踪。

CAP 3.0 版本发布通告

新的Kafka Transport配置项

我们在 Kafka 配置项中增加了 CustomHeaders,如果你需要在消费者方法中记录当前 Kafka 消费的 Offset 或者 Partition 等信息,可以利用此扩展来添加自定义 header。

你可以在这里找到关于如何使用它。

其他改进

  • 支持重命名表名称, 参考 issue #435
  • Bug修复,具体可以查看这里的 release 日志了解更多。
  • 依赖的 NuGet 包更新

总结

以上,就是本版本中支持的一些新特性,感谢大家的支持,我们很开心能够帮助到大家 。大家在使用的过程中遇到问题希望也能够积极的反馈,帮助CAP变得越来越好。:)

如果你喜欢这个项目,可以通过下面的连接点击 Star 给我们支持。

CAP 3.0 版本发布通告

如果你觉得本篇文章对您有帮助的话,感谢您的【推荐】。

如果你对 .NET Core 有兴趣的话可以关注我,我会定期的在博客分享我的学习心得。


本文地址:http://www.cnblogs.com/savorboard/p/cap-3-0.html
作者博客:Savorboard
本文原创授权为:署名 - 非商业性使用 - 禁止演绎,协议普通文本 | 协议法律文本

点赞
收藏
评论区
推荐文章
blmius blmius
2年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
Jacquelyn38 Jacquelyn38
2年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
Wesley13 Wesley13
2年前
Java获得今日零时零分零秒的时间(Date型)
publicDatezeroTime()throwsParseException{    DatetimenewDate();    SimpleDateFormatsimpnewSimpleDateFormat("yyyyMMdd00:00:00");    SimpleDateFormatsimp2newS
Wesley13 Wesley13
2年前
mysql设置时区
mysql设置时区mysql\_query("SETtime\_zone'8:00'")ordie('时区设置失败,请联系管理员!');中国在东8区所以加8方法二:selectcount(user\_id)asdevice,CONVERT\_TZ(FROM\_UNIXTIME(reg\_time),'08:00','0
Wesley13 Wesley13
2年前
00:Java简单了解
浅谈Java之概述Java是SUN(StanfordUniversityNetwork),斯坦福大学网络公司)1995年推出的一门高级编程语言。Java是一种面向Internet的编程语言。随着Java技术在web方面的不断成熟,已经成为Web应用程序的首选开发语言。Java是简单易学,完全面向对象,安全可靠,与平台无关的编程语言。
Stella981 Stella981
2年前
Django中Admin中的一些参数配置
设置在列表中显示的字段,id为django模型默认的主键list_display('id','name','sex','profession','email','qq','phone','status','create_time')设置在列表可编辑字段list_editable
Stella981 Stella981
2年前
Docker 部署SpringBoot项目不香吗?
  公众号改版后文章乱序推荐,希望你可以点击上方“Java进阶架构师”,点击右上角,将我们设为★“星标”!这样才不会错过每日进阶架构文章呀。  !(http://dingyue.ws.126.net/2020/0920/b00fbfc7j00qgy5xy002kd200qo00hsg00it00cj.jpg)  2
Wesley13 Wesley13
2年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
Python进阶者 Python进阶者
4个月前
Excel中这日期老是出来00:00:00,怎么用Pandas把这个去除
大家好,我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下:这日期老是出来00:00:00,怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下:pd.toexcel之前把这