消息rocketmq事务
一个方法里面部分代码块事务处理方式
#### 一个方法里面部分代码块事务处理方式 > 业务惨景，比如有时候我们在写业务的时候 一般写在service 方法里面，这个时候可能会碰到 你希望 部分业务带事务，部分不需要事务处理（如第3方 接口，通过定时任务什么的去补偿 ）。 ~~~ public CheckOrderTO createOr ......
AT模式【分布式事务】
1、导入 maven 依赖 <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-seata</artifactId> <exclusions> <!--版本较低，1.3. ......
SAP ABAP 动态结构实现发送企业微信应用消息
企业微信官方接口： 应用支持推送文本、图片、视频、文件、图文等类型。 请求方式：POST（HTTPS）请求地址： https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=ACCESS_TOKEN 大概思路： 1. 封装调用企业微信函 ......
kafka 开发时生产者和消费者消息顺序的问题
1 简介 在kafka，生产者生产的消息，只会保证一个生产者生产的消息在一个partion里面是有序的。 所以在编程时，若业务对消息的顺序性有更多的要求，那么就需要自己来保证消息的顺序性了。 消费者消费了消息，offset是需要自己来维护的。也就是说需要自己去保障消费的顺序性。 2 生产者顺序的保证 ......
Kafka生产者异步发送消息产生堵塞
问题描述 使用KafkaTemplate作为生产者发送消息时为了不影响主流业务会采用异步发送的方式，如下 public void producerSendFuture(String topic, String data) { logger.info("kafka异步发送topic:" + topic ......
kafka 消息的无状态和消息的零拷贝
1 简介 零拷贝是指将数据直接从磁盘文件复制到网卡，而不需要经由应用之手。 零拷贝大大提高了应用程序的性能，减少了内核和用户模式之间的上下文切换。 对Linux操作系统而言，零拷贝技术依赖于底层的sendfile()方法实现，对于Java语言，FileChannel.transferTo()方法的底 ......
什么是事务？
事务是指一系列数据库操作被视为一个逻辑单元，这个单元要么完全执行，要么完全不执行。在数据库中，事务通常用于保证数据的一致性和完整性。事务具有以下特性： 1. 原子性（Atomicity）：一个事务中的所有操作要么全部成功，要么全部失败，不会出现部分成功的情况。 2. 一致性（Consistency） ......
Rabbitmq：消息队列介绍、Rabbitmq安装、 基于Queue实现生产者消费者模型、基本使用（生产者消费者模型）、消息安全之ack、 消息安全之durable持久化、发布订阅闲置消费、
[toc] ### 一、消息队列介绍 #### 1.1介绍 消息队列就是基础数据结构中的“先进先出”的一种数据机构。想一下，生活中买东西，需要排队，先排的人先买消费，就是典型的“先进先出” ![image](https://img2023.cnblogs.com/blog/2970690/20230 ......
企业微信添加机器人，并给机器人发送消息
找一个企业微信的群聊，点击右上角的"..."，添加群机器人。 创建一个机器人 填写机器人名字，添加机器人。 保存这里的webhook地址，后面给机器人发消息，就是给这个地址post消息。 具体的配置文档，可以点这里的“配置说明”去了解。 下面介绍，使用py给机器人发送消息 出于隐私的考虑，这里机器人 ......
事务的传播级别
Spring事务定义了7种传播机制：1. PROPAGATION_REQUIRED:默认的Spring事物传播级别，若当前存在事务，则加入该事务，若不存在事务，则新建一个事务。2. PAOPAGATION_REQUIRE_NEW:若当前没有事务，则新建一个事务。若当前存在事务，则新建一个事务，新老事 ......
事件驱动架构：如何在应用程序中实现事件驱动的本地消息服务服务
[toc] 事件驱动架构：如何在应用程序中实现事件驱动的本地消息服务 ## 1. 引言 1.1. 背景介绍 随着互联网应用程序的快速发展，分布式系统在各个领域得到了广泛应用。在分布式系统中，消息服务作为其中重要的一环，承担着传递和处理消息的作用。通过消息服务，分布式系统可以实现异步处理、解耦、容错等 ......
如何处理 SAP Pricing - Document currency missing 的错误消息
# 问题 当添加一个物料主数据到 Quotation 行项目时，遇到如下错误消息： Pricing：Document currency missing 
前言 我们开发的时候常常会遇到多线程事务的问题。以为添加了@Transactional注解就行了，其实你加了注解之后会发现事务失效。 原因：数据库连接spring是放在threadLocal里面，多线程场景下，拿到的数据库连接是不一样的，即是属于不同事务。 本文是基于springboot的@Asyn ......
16. Sprng事务管理
# 1. Spring 事务简介 ## 1.1 相关概念介绍 - ==事务作用：在数据层保障一系列的数据库操作同成功同失败== - Spring 事务作用：在数据层或**==业务层==****保障一系列的数据库操作同成功同失败**保障一系列的数据库操作同成功同失败 **数据层有事务我们可以 ......
Microsoft Message Queuing（MSMQ）是由微软开发的一种消息队列服务，用于在分布式应用程序之间进行异步通信。它提供了一种可靠的方式来在不同的应用程序之间发送消息，并确保消息的可靠传递
Microsoft Message Queuing（MSMQ）是由微软开发的一种消息队列服务，用于在分布式应用程序之间进行异步通信。它提供了一种可靠的方式来在不同的应用程序之间发送消息，并确保消息的可靠传递。 MSMQ基于消息队列的原理，应用程序可以将消息发送到队列中，然后其他应用程序可以从队列中接 ......
03 | 事务隔离：为什么你改了我还看不见？
## 03 | 事务隔离：为什么你改了我还看不见？ ### 隔离性与隔离级别 当数据库上有多个事务同时执行的时候，就可能出现**脏读（dirty read）**、不可重复读（non-repeatable read）、**幻读（phantom read）**的问题，为了解决这些问题，就有了“隔离级别” ......
事务超时异常：org.springframework.transaction.TransactionTimedOutException: Transaction timed out: deadline was Sun Jun 25 17:34:03 CST 2023
报错如下： 代码如下： Controller import com.zwh.service.impl.TimeOutService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotati ......
MSDTC（Microsoft Distributed Transaction Coordinator）是微软的分布式事务协调器，它是Windows操作系统中的一个组件。MSDTC 提供了跨多个资源管理器（如数据库、消息队列等）执行事务的能力，确保事务的原子性、一致性、隔离性和持久性。
MSDTC（Microsoft Distributed Transaction Coordinator）是微软的分布式事务协调器，它是Windows操作系统中的一个组件。MSDTC 提供了跨多个资源管理器（如数据库、消息队列等）执行事务的能力，确保事务的原子性、一致性、隔离性和持久性。 MSDTC ......
kafka01 kafka及消息队列简介
1 Kafka是什么 Kafka是一种高吞吐量的分布式发布订阅消息系统（消息引擎系统）。 2 消息系统简介 一个消息系统负责将数据从一个应用传递到另外一个应用，应用只需关注于数据，无需关注数据在两个或多个应用间是如何传递的。分布式消息传递基于可靠的消息队列，在客户端应用和消息系统之间异步传递消息。有 ......
RocketMQ安装教程
RocketMQ是阿里巴巴在2012年开发的分布式消息中间件，专为万亿级超大规模的消息处理而设计，具有高吞吐量、低延迟、海量堆积、顺序收发等特点。它是阿里巴巴双十一购物狂欢节和众多大规模互联网业务场景的必备基础设施。在同一年，阿里巴巴正式开源了RocketMQ的第一个版本。 2015年，Rocket ......
飞书推送消息
### 功能介绍 企业存在给特定群组自动推送消息的场景，例如，推送监控报警、运营内容等。在该类场景下，你可以在群组中添加自定义机器人，自定义机器人默认提供 webhook，通过服务端调用 webhook 地址，即可将外部系统的消息通知即时推送到群组中。 实现起来也非常简单，就是发一下 http 请求 ......
Apache RocketMQ EventBridge：构建下一代事件驱动引擎
事件驱动，这个词在部分人印象中，它是一个过时的技术——没什么新意。从时间上看，确实也是这样，上世纪 60 年代，事件驱动就已经被正式提出，经常会被在 GUI 编程中。但是在有些人印象中，事件驱动又是一个非常陌生，非常新颖的技术。 ......
docker部署rocketmq
参考网址：https://www.cnblogs.com/MUQINGFENG123/p/17036619.html 一、拉镜像 docker pull foxiswho/rocketmq:server-4.7.0 （拉取镜像） docker pull foxiswho/rocketmq:broke ......
MySQL---事务
**概述** 1. 数据库的事务（Transaction）是一种机制、一个操作序列，包含了一组数据库操作命令。 2. 事务把所有的命令作为一个整体一起向系统提交或撤销操作请求，即这一组数据库命令要么同时成功，要么同时失败。 3. 事务是一个不可分割的工作逻辑单元。 **语法** 开启事务 ![](h ......
什么是数据库事务的幻读？
"幻读"是数据库事务隔离级别中的一种现象，它与不可重复读有些相似，但主要关注的是插入操作。 具体而言，幻读可以分为以下几个步骤： 事务A开始并执行了一个查询语句，返回了符合条件的数据结果集。 在此期间，事务B在同一个事务中对数据进行了插入操作，并提交了事务。 事务A再次执行相同的查询语句，发现返回的 ......
什么是数据库事务的不可重复读？
"不可重复读"是数据库事务隔离级别中的一种现象，指的是在同一个事务内，多次读取同一行数据时，获取到的数据值发生了变化。 具体而言，不可重复读可以分为以下几个步骤： 事务A开始并执行了一个SELECT语句，读取了某行数据的字段值。 在此期间，事务B对该行数据进行了修改并提交了事务。 事务A再次执行相同 ......