Seata框架是一个业务层的XA（两阶段提交）解决方案。在理解Seata分布式事务机制前，我们先回顾一下数据库层面的XA方案。 1. MySQL XA方案 MySQL从5.7...
发简信
IP属地：北京
-
阿里分布式事务框架Seata原理解析 -
Date、LocalDate、LocalTime、LocalDateTime之间的选择
java8全新的日期和时间API LocalDate、LocalTime、LocalDateTime是java8对日期、时间提供的新接口。实际使用中，计算日期就用LocalD...
-
Spring cloud stream 消费错误处理策略（三）：配置DLQ策略
应用场景 前两天我们已经介绍了两种Spring Cloud Stream对消息失败的处理策略： 自动重试[https://www.jianshu.com/p/3d1b0d7f...
-
spring cloud stream开发遇到的问题（一）：连接mq的问题在使用消息队列开发Spring cloud stream项目时，连接rabbitmq遇到一个问题： 问题1：连接报错信息 com.rabbitmq.client.Shutdo...
-
Spring中propagation的7种事务配置说明
简述在声明式的事务处理中，要配置一个切面，其中就用到了propagation，表示打算对这些方法怎么使用事务，是用还是不用，其中propagation有七种配置，REQUIR...
-
kafka2.8.0版本（一）：搭建部署
在新发布的kafka2.8.0版本中，已经可以不启动zk就可以使用kafka了，在config目录下多了一个kraft目录，在该目录中有一套新的配置文件，可以直接脱离ZooK...
-
kafka简介（三）：kafka架构图从上一章节我们总结了相关概念，其实在kafka架构图中可以直观的看到这些相关的概念，具体如下图： 从上图中我们先来分析相关概念： Producer： Producer即生产者...
-
kafka简介（二）：kafka相关概念
消息(Message)：kafka的数据单元，相当于数据库里面的一个数据行或一条记录。消息由字节数组组成，所以对于Kafka 来说，消息里的数据没有特别的格式或含义。消息可以...
-
kafka简介（一）：kafka概述kafka概述 从官网的介绍来看，Kafka是一个分布式的消息订阅系统，它主要有3种功能：1、It lets you publish and subscribe to str...
-
Spring cloud stream 消费错误处理策略（二）：自定义处理逻辑
自定义的错误处理 自定义错误一般是对于知道要发生什么错误，对于错误消息的一个处理方式，该方式适合在业务上有特殊处理的消息错误，比如错误数据保存到另一个topic或者只是记录到...
-
Spring cloud stream 消费错误处理策略（一）：重试消费重试策略 重试策略就是消费失败后隔一段时间我在消费，这种方案一般是硬卧环境因素导致的失败情况，或者网络问题导致的消费失败，重试消费可能解决上述问题。 配置参数 重试策略是通过...
