Java之SpringCloud Alibaba【六】【Alibaba微服务分布式事务组件—Seata】

news2024/11/24 14:39:39

一、事务简介

事务(Transaction)是访问并可能更新数据库中各种数据项的一个程序执行单元(unit)。
在关系数据库中，一个事务由一组SQL语句组成。

事务应该具有4个属性:

原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。

原子性(atomicity) ∶个事务是一个不可分割的工作单位，事务中包括的诸操作要么都做，要么都不做。
一致性(consistency) ∶事务必须是使数据库从一个一致性状态变到另一个一致性状态，事务的中间状态不能被观察到的。

隔离性（(isolation):一个事务的执行不能被其他事务干扰。
即一个事务内部的操作及使用的数据对并发的其他事务是隔离的，并发执行的各个事务之间不能互相干扰。

隔离性又分为四个级别:
读未提交(read uncommitted)、
读已提交(read committed，解决脏读)、
可重复读(repeatable read，解决虚读)、
串行化(serializable，解决幻读)。

持久性(durability):持久性也称永久性(permanence)，指一个事务一旦提交，它对数据库中数据的改变就应该是永久性的。

接下来的其他操作或故障不应该对其有任何影响。

任何事务机制在实现时，都应该考虑事务的ACID特性，包括:本地事务、分布式事务，及时不能都很好的满足，也要考虑支持到什么程度。

二、本地事务

@Transaction

大多数场景下，我们的应用都只需要操作单一的数据库，这种情况下的事务称之为本地事务(Local Transaction)。

本地事务的ACID特性是数据库直接提供支持。
本地事务应用架构如下所示:

在这里插入图片描述
在JDBC编程中，我们通过java.sql.Connection对象来开启、关闭或者提交事务。

代码如下所示:

Connection conn = .../获取数据库连接
conn.setAutoCommit(false);//开启事务
try{
	//...执行增删改查sql
	conn.commit();//提交事务
}catch (Exception e){
	conn.rollback( );//事务回滚
}finally{
	conn.close();//关闭链接
}

三、分布式事务

1、分布式事务Seata使用

Seatas是一款开源的分布式事务解决方案，致力于提供高性能和简单易用的分布式事务服务。

Seata将为用户提供了AT、TCC、SAGA和XA事务模式，为用户打造一站式的分布式解决方案。

AT模式是阿里首推的模式,阿里云上有商用版本的GTS (Global Transaction Service 全局事务服务)
官网: https://seata.io/zh-cn/index.html
源码: https://github.com//seata//seata
官方Demo: https://github.com/seata/seata-samples
seata版本: v1.4.0

（1）Seata的三大角色

在Seata的架构中，一共有三个角色:

TC(Transaction Coordinator)-事务协调者
维护全局和分支事务的状态，驱动全局事务提交或回滚。

TM (Transaction Manager)-事务管理器
定义全局事务的范围:开始全局事务、提交或回滚全局事务。

RM(Resource Manager)-资源管理器
管理分支事务处理的资源，与TC交谈以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚。

其中，TC为单独部署的Server服务端，TM和RM为嵌入到应用中的 Client客户端。

在Seata 中，一个分布式事务的生命周期如下:

常见分布式事务解决方案
1、seata阿里分布式事务框架
2、消息队列
3、saga
4、XA
他们有一个共同点，都是"两阶段(2PC)。
"两阶段"是指完成整个分布式事务，划分成两个步骤完成。

实际上，这四种常见的分布式事务解决方案，分别对应着分布式事务的四种模式:

AT、TCC、Saga、XA;
四种分布式事务模式，都有各自的理论基础，分别在不同的时间被提出每种模式都有它的适用场景，同样每个模式也都诞生有各自的代表产品;

而这些代表产品，可能就是我们常见的(全局事务、基于可靠消息、最大努力通知、TCC)。

今天，我们会分别来看4种模式(AT、TCC、Saga、XA)的分布式事务实现。在看具体实现之前，先讲下分布式事务的理论基础。

分布式事务理论基础

解决分布式事务，也有相应的规范和协议。分布式事务相关的协议有2PC、3PC。

由于三阶段提交协议X3PC非常难实现，目前市面主流的分布式事务解决方案都是2PC协议。

这就是文章开始提及的常见分布式事务解决方案里面那些列举的都有一个共同点"两阶段"的内在原因。

有些文章分析2PC时，几乎都会用TCC两阶段的例子，第一阶段try，第二阶段完成confirm或cancel。其实2PC并不是专为实现TCC设计的,2PC具有普适性。

——协议一样的存在，目前绝大多数分布式解决方案都是以两阶段提交协议2PC为基础的。

TCC (Try-Confirm-Cancel)实际上是服务化的两阶段提交协议。

（2）Seata的三大角色2PC两阶段提交协议:

2PC(两阶段提交，Two-Phase Commit)
顾名思义，分为两个阶段:
Prepare和CommitPrepare:提交事务请求
基本流程如下图:

在这里插入图片描述
在这里插入图片描述
1.询问协调者向所有参与者发送事务请求，询问是否可执行事务操作，然后等待各个参与者的响应。

2.执行各个参与者接收到协调者事务请求后，执行事务操作(例如更新一个关系型数据库表中的记录)，并将Undo和Redo 信息记录事务日志中。

3.响应如果参与者成功执行了事务并写入Undo和Redo信息，则向协调者返回YES响应，否则返回NO响应。当然，参与者也可能宕机，从而不会返回响应。

（3）中断事务

在执行Prepare步骤过程中，如果某些参与者执行事务失败、宕机或与协调者之间的网络中断，那么协调者就无法收到所有参与者的YES响应，或者某个参与者返回了No响应，此时，协调者就会进入回退流程，对事务进行回退。

流程如下图红色部分(将Commit请求替换为红色的Rollback请求):

2、2PC的问题

1.同步阻塞参与者在等待协调者的指令时，其实是在等待其他参与者的响应，在此过程中，参与者是无法进行其他操作的，也就是阻塞了其运行。
倘若参与者与协调者之间网络异常导致参与者一直收不到协调者信息，那么会导致参与者一直阻塞下去。

2.单点在2PC中，一切请求都来自协调者，所以协调者的地位是至关重要的，如果协调者宕机，那么就会使参与者一直阻塞并一直占用事务资源。

如果协调者也是分布式，使用选主方式提供服务，那么在一个协调者挂掉后，可以选取另一个协调者继续后续的服务，可以解决单点问题。
但是，新协调者无法知道上一个事务的全部状态信息(例如已等待Prepare响应的时长等)，所以也无法顺利处理上一个事务。

3.数据不一致Commit事务过程中Comit请求Roltack请求可能因为协调者宕机或协调者与参与者网络问题丢失，那么就导致了部分参与者没有收到Conmit/Rollback请求，而其他参与者则正常收到执行了CommitRollback操作，没有收到请求的参与者则继续阻塞。

这时，参与者之间的数据就不再一致了。当参与者执行ComitRollack后会向协调者发送Ack，然而协调者不论是否收到所有的参与者的Ack，该事务也不会再有其他补救措施了，协调者能做的也就是等待超时后像事务发起者返回一个“我不确定该事务是否成功”。

4.环境可靠性依赖

协调者Prepare请求发出后，等待响应，然而如果有参与者宕机或与协调者之间的网络中断，都会导致协调者无法收到所有参与者的响应那么在2PC中，协调者会等待一定时间，然后超时后，会触发事务中断，在这个过程中协调者和所有其他参与者都是出于阻塞的。

这种机制对网络问题常见的现实环境来说太苛刻了。

下面我们分别来看4种模式(AT、TCC、Saga、XA)的分布式事务实现。

3、AT模式

AT模式是一种无侵入的分布式事务解决方案。
阿里Seata框架，实现了该模式。

在AT模式下，用户只需关注自己的"业务SQL"，用户的“业务SQL”作为一阶段，Seata 框架会自动生成事务的二阶段提交和回滚操作。
在这里插入图片描述
AT模式如何做到对业务的无侵入:

  • 一阶段

在一阶段，Seata会拦截业务SQL"，首先解析SQL语义，找到业务SQL要更新的业务数据，在业务数据被更新前，将其保存成"before image”，然后执行"业务SQL"更新业务数据，在业务数据更新之后，再将其保存成"after image”，最后生成行锁。

以上操作全部在一个数据库事务内完成，这样保证了一阶段操作的原子性。

在这里插入图片描述

  • 二阶段提交:

二阶段如果是提交的话，因为"业务SQL"在一阶段已经提交至数据库，
所以Seata 框架只需将一阶段保存的快照数据和行锁删掉，完成数据清理即可。
在这里插入图片描述

  • 二阶段回滚:

二阶段如果是回滚的话，Seata就需要回滚一阶段已经执行的业务SQL”，还原业务数据。

回滚方式便是用"before image"还原业务数据;但在还原前要首先要校验脏写，对比"数据库当前业务数据"和"after image"，如果两份数据完全一致就说明没有脏写，可以还原业务数据，如果不一致就说明有脏写，出现脏写就需要转人工处理。

在这里插入图片描述AT模式的一阶段、二阶段提交和回滚均由Seata框架自动生成，用户只需编写业务SQL”，便能轻松接入分布式事务，AT模式是一种对业务无任何侵入的分布式事务解决方案。

4、TCC模式

TCC模式需要用户根据自己的业务场景实现
Try、Confim和Cancel 三个操作;

事务发起方在一阶段执行Try方式，在二阶段提交执行Confim方法，二阶段回滚执行Cancel方法。
在这里插入图片描述缺点：侵入性比较强，并且得自己实现相关的事务控制逻辑。
优点：在整个过程当中，基本没有锁的概念，性能更加强大。
在这里插入图片描述

5、MQ【可靠消息最终一致性方案】

在这里插入图片描述

四、Seata的三大角色

1、在Seata的架构中，一共有三个角色:

TC (Transaction Coordinator)-事务协调者

维护全局和分支事务的状态，驱动全局事务提交或回滚。

TM (Transaction Manager)-事务管理器

定义全局事务的范围:开始全局事务、提交或回滚全局事务。

RM(Resource Manager)-资源管理器

管理分支事务处理的资源，与TC交谈以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚。

其中，TC为单独部署的Server服务端，TM和RM为嵌入到应用中的Client客户端。

在Seata 中，一个分布式事务的生命周期如下:

在这里插入图片描述
1.TM请求TC开启一个全局事务。

TC会生成一个XID作为该全局事务的编号。XID，会在微服务的调用链路中传播，保证将多个微服务的子事务关联在一起。

2.RM请求TC将本地事务注册为全局事务的分支事务，通过全局事务的XID进行关联。

3.TM请求TC告诉XID对应的全局事务是进行提交还是回滚。

4.TC驱动RM们将XID 对应的自己的本地事务进行提交还是回滚。

2、设计思路

AT模式的核心是对业务无侵入，是一种改进后的两阶段提交，其设计思路如图

第一阶段

业务数据和回滚日志记录在同一个本地事务中提交，释放本地锁和连接资源。

核心在于对业务sql进行解析，转换成undolog，并同时入库，这是怎么做的呢?

先抛出一个概念DataSourceProxy代理数据源，通过名字大家大概也能基本猜到是什么个操作，后面做具体分析

参考官方文档:

https://seata.io/zh-cn/docs/dev/mode/at-mode.html

在这里插入图片描述分布式事务操作失败，TM向TC发送回滚请求，RIM收到协调器TC发来的回滚请求，通过XD和Branch lD找到相应的回滚日志记录，通过回滚记录生成反向的更新SQL并执行，以完成分支的回滚。

在这里插入图片描述
在这里插入图片描述相比与其它分布式事务框架，Seata架构的亮点主要有几个:

1.应用层基于SQL解析实现了自动补偿，从而最大程度的降低业务侵入性;
2.将分布式事务中TC(事务协调者）独立部署，负责事务的注册、回滚;
3.通过全局锁实现了写隔离与读隔离。

3、存在问题

性能损耗
一条Update的SQL，则需要全局事务xd获取（与TC通讯) 、before image(解析SQL，查询一次数据库) 、after image(查询一次数据库)、inser undo log(写一次数据库) 、before commit (与TC通讯，判断锁冲突)，这些操作都需要一次远程通讯RPC，而且是同步的。

另外undo log写入时blob字段的插入性能也是不高的。

每条写SQL都会增加这么多开销,粗略估计会增加5倍响应时间。

性价比
为了进行自动补偿，需要对所有交易生成前后镜像并持久化，可是在实际业务场景下，这个是成功率有多高，或者说分布式事务失败需要回滚的有多少比率?

按照二八原则预估，为了20%的交易回滚，需要将80%的成功交易的响应时间增加5倍，这样的代价相比于让应用开发一个补偿交易是否是值得?

全局锁
热点数据
相比:(XA，Seata 虽然在一阶段成功后会释放数据库锁，但一阶段在comit前全局锁的判定也拉长了对数据锁的占有时间，这个开销比XA的prepare低多少需要根据实际业务场景进行测试。

全局锁的引入实现了隔离性，但带来的问题就是阻塞，降低并发性，尤其是热点数据，这个问题会更加严重。

回滚锁释放时间

五、Seata快速开始

1、Seata Server (TC)环境搭建

https://seata.io/zh-cn/docslops/deploy-guide-beginner.html

Server端存储模式(store.mode）支持三种:

  • file:单机模式，全局事务会话信息内存中读写并持久化本地文件root.data，性能较高(默认)
  • db:高可用模式，全局事务会话信息通过db共享，相应性能差些
    • 打开config/file.conf
    • 修改mode="db"
    • 修改数据库链接信息（URL\USERNAME\PASSWORD）
  • redis: Seata-Server 1.3及以上版本支持,性能较高,存在事务信息丢失风险,请提前配置适合当前场景的redis持久化配置

资源目录: https://github.com/seata/seata/tree/1.3.0/script

  • client
    存放client端sql脚本，参数配置
  • config-center
    各个配置中心参数导入脚本，config.txt(包含server和client，原名nacos-config.txt)为通用参数文件
  • server
    server端数据库脚本及各个容器配置

db存储模式+Nacos(注册&配置中心)部署

步骤一:下载安装包
https://github.com/seata/seata/releases

在这里插入图片描述
在这里插入图片描述

2、建表（仅db模式）

全局事务会话信息由3块内容构成，全局事务-->分支事务-->全局锁，对应表

global_table、branch_table、lock_table

创建数据库seata，执行sql脚本，文件在script/server/db/mysql.sql (seata源码）中

https://github.com/seata/seata/tree/2.x/script/server/db

在这里插入图片描述

-- -------------------------------- The script used when storeMode is 'db' --------------------------------
-- the table to store GlobalSession data
CREATE TABLE IF NOT EXISTS `global_table`
(
    `xid`                       VARCHAR(128) NOT NULL,
    `transaction_id`            BIGINT,
    `status`                    TINYINT      NOT NULL,
    `application_id`            VARCHAR(32),
    `transaction_service_group` VARCHAR(32),
    `transaction_name`          VARCHAR(128),
    `timeout`                   INT,
    `begin_time`                BIGINT,
    `application_data`          VARCHAR(2000),
    `gmt_create`                DATETIME,
    `gmt_modified`              DATETIME,
    PRIMARY KEY (`xid`),
    KEY `idx_status_gmt_modified` (`status` , `gmt_modified`),
    KEY `idx_transaction_id` (`transaction_id`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8mb4;

-- the table to store BranchSession data
CREATE TABLE IF NOT EXISTS `branch_table`
(
    `branch_id`         BIGINT       NOT NULL,
    `xid`               VARCHAR(128) NOT NULL,
    `transaction_id`    BIGINT,
    `resource_group_id` VARCHAR(32),
    `resource_id`       VARCHAR(256),
    `branch_type`       VARCHAR(8),
    `status`            TINYINT,
    `client_id`         VARCHAR(64),
    `application_data`  VARCHAR(2000),
    `gmt_create`        DATETIME(6),
    `gmt_modified`      DATETIME(6),
    PRIMARY KEY (`branch_id`),
    KEY `idx_xid` (`xid`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8mb4;

-- the table to store lock data
CREATE TABLE IF NOT EXISTS `lock_table`
(
    `row_key`        VARCHAR(128) NOT NULL,
    `xid`            VARCHAR(128),
    `transaction_id` BIGINT,
    `branch_id`      BIGINT       NOT NULL,
    `resource_id`    VARCHAR(256),
    `table_name`     VARCHAR(32),
    `pk`             VARCHAR(36),
    `status`         TINYINT      NOT NULL DEFAULT '0' COMMENT '0:locked ,1:rollbacking',
    `gmt_create`     DATETIME,
    `gmt_modified`   DATETIME,
    PRIMARY KEY (`row_key`),
    KEY `idx_status` (`status`),
    KEY `idx_branch_id` (`branch_id`),
    KEY `idx_xid` (`xid`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8mb4;

CREATE TABLE IF NOT EXISTS `distributed_lock`
(
    `lock_key`       CHAR(20) NOT NULL,
    `lock_value`     VARCHAR(20) NOT NULL,
    `expire`         BIGINT,
    primary key (`lock_key`)
) ENGINE = InnoDB
  DEFAULT CHARSET = utf8mb4;

INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('AsyncCommitting', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryCommitting', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryRollbacking', ' ', 0);
INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('TxTimeoutCheck', ' ', 0);

导入数据库
在这里插入图片描述
注意:如果配置了seata sever使用nacos作为配置中心，
则配置信息会从nacos读取,file.conf可以不用配置。

客户端配置registy.conf使用nacos时也要注意group要和seata server中的group一致，

默认group是"DEFAULT_GROUP"获取/seata/script/config-center/config.txt，修改配置信息。

在这里插入图片描述将script目录下载下拉复制到应用的跟目录
在这里插入图片描述在这里插入图片描述

4、seata设置集成nacos

下载好nacos之后本地启动nacos
在这里插入图片描述配置\seata\conf下的registry.conf设置对应的nacos的配置信息
在这里插入图片描述在这里插入图片描述事务分组：异地机房停电容错机制
my_test_tx_group 可以自定义 比如：（guangzhou、shanghai），对应的client也要去设置

service.vgroupMapping.default_tx_group=default

default 必须要等于 registry.confi cluster = "default"
在这里插入图片描述配置参数同步到Nacos
在nacos的安装目录下面
在这里插入图片描述在这里插入图片描述
如果是自定义的nacos需要配置自定义启动参数

sh $(SEATAPATH)/script/config-center/nacos/nacos-config.sh -h localhost -p 8848 -g SEATA_GROUuP -t 5a3c7d6c-f497-4d68-a712-2e5e3340b3ca

参数说明:
-h: host，默认值localhost
-p: port，默认值8848
-g:配置分组，默认值为’SEATA_GROUP’
-t:租户信息，对应 Nacos的命名空间ID字段,默认值为空"
访问：http://localhost:8848/nacos/
在这里插入图片描述

5、启动seata Server

  • 源码启动:执行server模块下io.seata.server.Server.java的main方法
  • 命令启动: bin/seata-server.sh -h 127.0.0.1 -p 8091 -m db -n 1 -e test

支持的启动参数
在这里插入图片描述
启动Seata Server

bin/seata-server. sh -p 8092

双击
在这里插入图片描述
启动成功
在这里插入图片描述

在这里插入图片描述

六、Seata Client快速开始

声明式事务实现(@GlobalTransactional)

接入微服务应用
业务场景:
用户下单，整个业务逻辑由三个微服务构成:

  • 订单服务:根据采购需求创建订单
  • 库存服务:对给定的商品扣除库存数量。

1、项目搭建

在这里插入图片描述在这里插入图片描述在这里插入图片描述在这里插入图片描述
在这里插入图片描述在这里插入图片描述在这里插入图片描述

2、创建数据库

DROP TABLE IF EXISTS `order_tbl`;
CREATE TABLE `order_tbl`  (
  `id` int NOT NULL AUTO_INCREMENT COMMENT '主键',
  `product_id` int NULL DEFAULT NULL COMMENT '项目id',
  `total_amount` int NULL DEFAULT NULL COMMENT '数量',
  `status` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;

-- ----------------------------
-- Records of order_tbl
-- ----------------------------

SET FOREIGN_KEY_CHECKS = 1;

SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;

-- ----------------------------
-- Table structure for stock_tbl
-- ----------------------------
DROP TABLE IF EXISTS `stock_tbl`;
CREATE TABLE `stock_tbl`  (
  `id` int NOT NULL AUTO_INCREMENT COMMENT '主键',
  `product_id` int NULL DEFAULT NULL COMMENT '项目id',
  `count` int NULL DEFAULT NULL COMMENT '数量',
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;

-- ----------------------------
-- Records of stock_tbl
-- ----------------------------
INSERT INTO `stock_tbl` VALUES (1, 9, 100);

SET FOREIGN_KEY_CHECKS = 1;

3、完善上述两个代码

order-seata
seata-stock

在这里插入图片描述
分别启动两个项目
在这里插入图片描述
在这里插入图片描述
http://localhost:8070/order/add
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
再次访问

http://localhost:8070/order/add
在这里插入图片描述

在这里插入图片描述这里添加了事务
在这里插入图片描述
并且抛出了异常
在这里插入图片描述
但是数量依旧减掉了，因此在分布式事务场景下，这样添加事务是失效

4、在SpringCloud Alibaba事务情况，复制之前的工程创建新模块

在这里插入图片描述在这里插入图片描述
在这里插入图片描述
在这里插入图片描述在这里插入图片描述
完善依赖
在这里插入图片描述

   <dependencies>
        <!--nacos服务注册发现-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>

        <!-- openfeign远程调用-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
    </dependencies>

在这里插入图片描述

    <dependencies>
        <!--nacos服务注册发现-->
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>

        <!-- openfeign远程调用-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
    </dependencies>

5、完善上述对应的yml

在这里插入图片描述

  application:
    name: alibaba-order-seata
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
        username: nacos
        password: nacos

在这里插入图片描述

  application:
    name: alibaba-seata-stock
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
        username: nacos
        password: nacos

在这里插入图片描述

6、完善SpringCloud Alibaba相关代码

在这里插入图片描述

@EnableFeignClients

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1050920.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

无人直播间

无人直播间

失败&#xff01;&#xff01; 采用 ffmpeg 技术进行推流 推流代码&#xff1a; 【需要将rtmp替换为你的推流地址】 ffmpeg -re -stream_loop -1 -i "rain.mp4" -c copy -f flv ""推流地址获取 以哔哩哔哩为例 点击下方链接 开播设置 - 个人中心 - …
阅读更多...
Java【手撕链表】LeetCode 143. “重排链表“, 图文详解思路分析 + 代码

Java【手撕链表】LeetCode 143. “重排链表“, 图文详解思路分析 + 代码

文章目录 前言一、两数相加1, 题目2, 思路分析2,1 找到中间结点2.2, 逆序后半段链表2.3, 合并两个链表 3, 代码 前言 各位读者好, 我是小陈, 这是我的个人主页, 希望我的专栏能够帮助到你: &#x1f4d5; JavaSE基础: 基础语法, 类和对象, 封装继承多态, 接口, 综合小练习图书管…
阅读更多...
springcloud之自我介绍

springcloud之自我介绍

写在前面 在这篇文章 中我们分析了单体应用的问题&#xff0c;以及用来解决这些问题的解决的方案微服务&#xff0c;并接着看了微服务需要考虑的各种&#xff0c;如服务调用&#xff0c;负载均衡&#xff0c;服务治理&#xff0c;链路追踪&#xff0c;分布式事务&#xff0c;等…
阅读更多...
Konva离屏缓存

Konva离屏缓存

前言 cache实例方法定义在Node基类上&#xff0c;通过该方法可以实现图形缓存&#xff0c;在Konva中Stage、Layer、Group、Shape等所有容器类和图形类都直接或间接继承了Node基类&#xff0c;故而都可以使用缓存方法。本篇文章就是探讨Konva背后的缓存机制&#xff0c;版本是v…
阅读更多...
300以内的开放耳机哪款好、300以内神级耳机推荐

300以内的开放耳机哪款好、300以内神级耳机推荐

开放式耳机基于不入耳、长久舒适佩戴的特点&#xff0c;在 2023 年迎来了增长爆发期。基于其开放式不入耳设计&#xff0c;佩戴时耳道会持续保持畅通状态&#xff0c;减少了对耳朵的压力&#xff0c;既能在通话或欣赏音乐时提供清晰的声音&#xff0c;又能让周围的环境声音透过…
阅读更多...
Scala第二章节

Scala第二章节

Scala第二章节 scala总目录 章节目标 掌握变量, 字符串的定义和使用掌握数据类型的划分和数据类型转换的内容掌握键盘录入功能理解Scala中的常量, 标识符相关内容 1. 输出语句和分号 1.1 输出语句 方式一: 换行输出 格式: println(里边写你要打印到控制台的数据);方式二…
阅读更多...
【Java 进阶篇】MySQL多表查询之子查询详解

【Java 进阶篇】MySQL多表查询之子查询详解

在数据库查询中&#xff0c;多表查询是一项非常常见且重要的任务。它允许我们从多个相关联的表中检索和组合数据&#xff0c;以满足各种复杂的查询需求。在多表查询中&#xff0c;子查询是一种强大的工具&#xff0c;用于在查询中嵌套另一个查询。本文将深入探讨MySQL中的子查询…
阅读更多...
直播软件开发技巧：7个实时视频传输和弹幕功能的关键步骤

直播软件开发技巧：7个实时视频传输和弹幕功能的关键步骤

近年来&#xff0c;随着直播行业的快速崛起&#xff0c;直播软件的开发变得越来越重要。直播软件的成功不仅依赖于稳定的实时视频传输&#xff0c;还需要强大的弹幕功能来提升用户体验。作为直播软件开发领域的专家&#xff0c;我将与您分享七个关键步骤&#xff0c;帮助您掌握…
阅读更多...
python使用mitmproxy和mitmdump抓包在电脑上抓包

python使用mitmproxy和mitmdump抓包在电脑上抓包

mitmproxy是一个中间人角色&#xff0c;供python抓包使用。 本机环境&#xff1a;win10 64位&#xff0c;python3.10.4。首先安装mitmproxy&#xff0c;参考我的文章 记录一下python2和python3在同一台电脑上共存使用并安装各自的库以及各自在pycharm中使用的方法-CSDN博客 一…
阅读更多...
SimpleCG文字输出基础

SimpleCG文字输出基础

前言 前面已经介绍了图形绘制&#xff0c;本篇将介绍简单的文字输出操作方法。其实文字在计算机中也是作为图形处理的&#xff0c;只是一种特殊的图形&#xff0c;是按固定预设字模图形来绘制的&#xff0c;称为字体。文字输出就是按文字所在字体中的对应图形绘制出来&#xff…
阅读更多...
【golang】调度系统之整体介绍

【golang】调度系统之整体介绍

调度系列 调度系列之goroutine 调度系列之m 调度系列之p 调度系列之sysmon 前面几篇对调度体系的G、M、P、sysmon分别进行了介绍。拆分的介绍有助于聚焦单一的角色&#xff0c;比较快地建立认识&#xff0c;同时也能更深入细节&#xff0c;但是不足以建立全局的认知。本篇在前面…
阅读更多...
C理解(五):编译，链接库，宏，关键字，变量

C理解(五):编译，链接库，宏，关键字，变量

编译 编译过程 文件.c->(预处理)->文件.i->(编译)->文件.S->(汇编)->文件.o->(链接)->elf程序 预处理 内容:加载头文件(#include),清除注释(//,./*),替换条件编译(#if #elif #endif #ifdef),替换宏定义(#define) …
阅读更多...
[杂谈]-ESP32中的无线通信协议

[杂谈]-ESP32中的无线通信协议

ESP32中的无线通信协议 文章目录 ESP32中的无线通信协议1、ESP32 无线通信协议简介2、Bluetooth Low Energy (BLE)3、**Bluetooth Classic**4、**ESP-NOW**5、Wi-Fi&#xff08;客户端-服务器通信协议&#xff09;6、MQTT7、**LoRa**8、**GSM/GPRS/LTE**9、总结 ESP32是一个基于…
阅读更多...
BL808学习日志-0-概念理解

BL808学习日志-0-概念理解

一、主核心的介绍 1.三个核心在FREERTOS系统中相互独立&#xff0c;各负责各自的外设和程序&#xff1b;其中M0和LP核心在一个总线上&#xff0c;D0单独在一个总线上&#xff0c;两个总线使用AXI4.0(??)通讯&#xff1f; CPU0(M0)-E907架构&#xff0c;320MHz; CPU1(LP)-E9…
阅读更多...
基于微信小程序的高校宿舍管理系统设计与实现（亮点：选择宿舍、宿舍评分、宿舍报修）

基于微信小程序的高校宿舍管理系统设计与实现（亮点：选择宿舍、宿舍评分、宿舍报修）

文章目录 前言系统主要功能&#xff1a;具体实现截图论文参考详细视频演示为什么选择我自己的网站自己的小程序&#xff08;小蔡coding&#xff09;有保障的售后福利 代码参考源码获取 前言 &#x1f497;博主介绍&#xff1a;✌全网粉丝10W,CSDN特邀作者、博客专家、CSDN新星计…
阅读更多...
【中秋节快乐】Matplotlib：3d绘图合集

【中秋节快乐】Matplotlib：3d绘图合集

目录 一、环境介绍 二、Matplotlib绘图&#xff08;3d&#xff09; 0. 设置中文字体 1. 3D线框图&#xff08;3D Wireframe Plot&#xff09; 2. 3D散点图&#xff08;3D Scatter Plot&#xff09; 3. 3D条形图&#xff08;3D Bar Plot&#xff09; 4. 3D曲面图&#xff0…
阅读更多...
微信小游戏从零到上线系列文章整理，建议收藏

微信小游戏从零到上线系列文章整理，建议收藏

引言 本系列是《从零开始开发贪吃蛇小游戏到上线系列》&#xff0c;欢迎大家关注分享收藏订阅。 大家中秋快乐&#xff0c;我是亿元程序员&#xff0c;一位有着8年游戏行业经验的主程。前面笔者给大家讲解了微信小游戏如何从零到上线的流程。可能很多小伙伴都还没有看到。 本…
阅读更多...
【深度学习_TensorFlow】卷积神经网络（CNN）

【深度学习_TensorFlow】卷积神经网络（CNN）

写在前面 这篇文章的行文思路如下&#xff1a; 先根据视频了解卷积和卷积神经网络的整体框架 接着了解卷积神经网络构建过程中的一些重要操作&#xff0c;包括内积、填充、池化。 然后介绍卷积层如何实现。 最后用卷积神经网络的开山之作&#xff08;LeNet-5&#xff09;来…
阅读更多...
22 mysql range 查询

22 mysql range 查询

前言 这里主要是 探究一下 explain $sql 中各个 type 诸如 const, ref, range, index, all 的查询的影响, 以及一个初步的效率的判断 这里会调试源码来看一下 各个类型的查询 需要 lookUp 的记录 以及 相关的差异 此系列文章建议从 mysql const 查询 开始看 测试表结构…
阅读更多...
奶茶果饮外卖配送小程序商城的作用是什么

奶茶果饮外卖配送小程序商城的作用是什么

奶茶果饮商家众多&#xff0c;有加盟品牌也有独立自创品牌或小店等&#xff0c;奶茶果饮已经成为众多年轻人群体喜爱的饮品&#xff0c;在实际消费方面&#xff0c;普遍以到店外卖为主&#xff0c;市场需求较高&#xff0c;但同样的竞争压力也不小。 同行竞争激烈&#xff0c;…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023