当前位置：首页 > news >正文

逻辑复制parallel并发参数测试

news 来源：原创 2025/7/13 4:06:06

逻辑复制parallel并发参数测试

一、测试结果、测试环境描述

1.1、测试结果

cpu表中有1000万条数据，大小为1652MB,当更新的数据量多于10万条的时候有明显变化，多余30万条的时候相差2倍。
更新的数据量较多时，逻辑复制使用并发参数相比于使用默认参数性能更高。
更新的数据量较少时，逻辑复制使用并发参数相比于使用默认参数性能相差不大。

更新记录条数	streaming	影响到订阅端耗时	执行SQL语句耗时
1000	parallel	71ms	12.077 ms
1000	-	45 ms	15.496 ms
50000	parallel	1199 ms	357.201 ms
50000	-	1396 ms	586.545 ms
100000	parallel	4637 ms	3227.055 ms
100000	-	6153 ms	4591.671 ms
300000	parallel	6815 ms	5567.591 ms
300000	-	11850 ms	6337.377 ms
1000000	parallel	24214 ms	12734.563 ms
1000000	-	46474 ms	15579.122 ms

表中streaming列说明

-- streaming列为 “-”
SELECT substream FROM pg_subscription WHERE subname = 'sub_cpu';substream 
-----------f
(1 row)

-- streaming列为parallel
SELECT substream FROM pg_subscription WHERE subname = 'sub_cpu';substream 
-----------p
(1 row)

1.2、测试环境

数据库版本	PostgreSQL-16.6
内核数	4 core (x86-64)
内存大小	4 GB
OS 系统版本	rhel7
架构	x86-64

二、逻辑复制环境搭建

2.1、发布端环境部署

-- 创建一个表
CREATE TABLE cpu (id SERIAL PRIMARY KEY,   time                   TIMESTAMPTZ NOT NULL,           -- 时间戳，带时区tags_id                INTEGER,                         -- 标签ID，整数类型hostname               TEXT,                            -- 主机名，文本类型usage_user             DOUBLE PRECISION,               -- 用户CPU使用率，双精度浮点数usage_system           DOUBLE PRECISION,               -- 系统CPU使用率，双精度浮点数usage_idle             DOUBLE PRECISION,               -- 空闲CPU使用率，双精度浮点数usage_nice             DOUBLE PRECISION,               -- Nice CPU使用率，双精度浮点数usage_iowait           DOUBLE PRECISION,               -- I/O等待CPU使用率，双精度浮点数usage_irq              DOUBLE PRECISION,               -- 硬中断CPU使用率，双精度浮点数usage_softirq          DOUBLE PRECISION,               -- 软件中断CPU使用率，双精度浮点数usage_steal            DOUBLE PRECISION,               -- 偷取CPU使用率，双精度浮点数usage_guest            DOUBLE PRECISION,               -- Guest CPU使用率，双精度浮点数usage_guest_nice       DOUBLE PRECISION              -- Guest Nice CPU使用率，双精度浮点数
);
-- 给表添加逻辑复制标识
ALTER TABLE cpu REPLICA IDENTITY DEFAULT;-- 创建发布
CREATE PUBLICATION pub_cpu FOR TABLE cpu;-- 创建逻辑复制槽
SELECT pg_create_logical_replication_slot('fd_logical', 'pgoutput');-- 查看逻辑复制槽、发布
SELECT * FROM pg_publication WHERE pubname = 'pub_cpu';
SELECT * FROM pg_replication_slots WHERE slot_name = 'fd_logical';

2.2、订阅端环境部署

-- 订阅端创建表
CREATE TABLE cpu (id SERIAL PRIMARY KEY,   time                   TIMESTAMPTZ NOT NULL,           -- 时间戳，带时区tags_id                INTEGER,                         -- 标签ID，整数类型hostname               TEXT,                            -- 主机名，文本类型usage_user             DOUBLE PRECISION,               -- 用户CPU使用率，双精度浮点数usage_system           DOUBLE PRECISION,               -- 系统CPU使用率，双精度浮点数usage_idle             DOUBLE PRECISION,               -- 空闲CPU使用率，双精度浮点数usage_nice             DOUBLE PRECISION,               -- Nice CPU使用率，双精度浮点数usage_iowait           DOUBLE PRECISION,               -- I/O等待CPU使用率，双精度浮点数usage_irq              DOUBLE PRECISION,               -- 硬中断CPU使用率，双精度浮点数usage_softirq          DOUBLE PRECISION,               -- 软件中断CPU使用率，双精度浮点数usage_steal            DOUBLE PRECISION,               -- 偷取CPU使用率，双精度浮点数usage_guest            DOUBLE PRECISION,               -- Guest CPU使用率，双精度浮点数usage_guest_nice       DOUBLE PRECISION              -- Guest Nice CPU使用率，双精度浮点数
);-- 创建订阅
CREATE SUBSCRIPTION sub_cpu
CONNECTION 'host=192.168.6.108 port=9432 dbname=test user=fbase password=fbase'
PUBLICATION pub_cpu
WITH (slot_name = 'fd_logical',create_slot = false,streaming = 'parallel'
);-- 查看订阅端信息
SELECT * FROM pg_subscription WHERE subname = 'sub_cpu';
-- 查看订阅状态
SELECT * FROM pg_stat_subscription WHERE subid IN (SELECT oid FROM pg_subscription WHERE subname = 'sub_cpu');

给已有的发布端添加表

-- 查看复制状态、逻辑复制槽状态
select * from pg_replication_slots;
select * from pg_stat_replication;-- 发布端、订阅端创建表
CREATE TABLE memory (id SERIAL PRIMARY KEY,   time TIMESTAMPTZ NOT NULL,tags_id INTEGER,hostname TEXT,total_memory BIGINT,        -- 总内存used_memory BIGINT,         -- 已用内存free_memory BIGINT,         -- 空闲内存memory_usage DOUBLE PRECISION -- 内存使用率
);ALTER TABLE memory REPLICA IDENTITY DEFAULT;
-- 添加表到发布端
ALTER PUBLICATION pub_cpu ADD TABLE memory;-- 查看发布端中的表
SELECT * FROM pg_publication_tables WHERE pubname = 'pub_cpu';-- 订阅中建表
CREATE TABLE memory (id SERIAL PRIMARY KEY,   time TIMESTAMPTZ NOT NULL,tags_id INTEGER,hostname TEXT,total_memory BIGINT,        -- 总内存used_memory BIGINT,         -- 已用内存free_memory BIGINT,         -- 空闲内存memory_usage DOUBLE PRECISION -- 内存使用率
);-- 确保订阅端在运行
SELECT * FROM pg_stat_subscription WHERE subid IN (SELECT oid FROM pg_subscription WHERE subname = 'sub_cpu');-- 刷新订阅端ALTER SUBSCRIPTION sub_cpu REFRESH PUBLICATION;-- 查看订阅端信息
SELECT * FROM pg_subscription WHERE subname = 'sub_cpu';

2.3、数据同步验证

-- 发布端插入数据
INSERT INTO cpu (time, tags_id, hostname, usage_user, usage_system, usage_idle, usage_nice, usage_iowait, usage_irq, usage_softirq, usage_steal, usage_guest, usage_guest_nice) VALUES ('2025-01-23 12:00:00+08', 1, 'server1', 20.5, 10.3, 65.2, 2.1, 1.5, 0.3, 0.2, 0.1, 0.5, 0.4);INSERT INTO memory (time, tags_id, hostname, total_memory, used_memory, free_memory, memory_usage) VALUES ('2025-01-23 13:00:00+08', 1, 'server1', 16384, 8192, 8192, 50.0);-- 更新
UPDATE cpu SET hostname = 'server2' WHERE hostname = 'server1';
UPDATE memory SET memory_usage = 60.0 WHERE hostname = 'server1';-- 删除
DELETE FROM cpu WHERE hostname = 'server2';
DELETE FROM memory WHERE hostname = 'server1';-- 订阅端
select count(*) from cpu;
select count(*) from memory;

2.4、给cpu表放入1000万条数据

-- 在发布端给cpu表添加1千万条数据
INSERT INTO cpu (time, tags_id, hostname, usage_user, usage_system, usage_idle, usage_nice, usage_iowait, usage_irq, usage_softirq, usage_steal, usage_guest, usage_guest_nice)
SELECT-- 以当前时间为基准，添加一个 0 到 1 天的随机时间间隔current_timestamp + (random() * interval '1 day'),1 + floor(random() * 10),'host_' || floor(random() * 100), random() * 100,random() * 100, random() * 100, random() * 100,random() * 100,random() * 100,random() * 100, random() * 100,random() * 100,random() * 100
FROM generate_series(1, 10000000);-- 在发布端给memory表添加10万条数据
INSERT INTO memory (time, tags_id, hostname, total_memory, used_memory, free_memory, memory_usage)
SELECTcurrent_timestamp + (random() * interval '1 day'),  -- 随机时间1 + floor(random() * 10),                           -- 随机 tags_id'host_' || floor(random() * 100),                   -- 随机主机名16384 + floor(random() * 1024),                    -- 随机总内存 (单位: MB)floor(random() * 8192),                             -- 随机已用内存floor(random() * 8192),                             -- 随机空闲内存random() * 100                                      -- 随机内存使用率
FROM generate_series(1, 100000);

三、测试

3.1、更新1000条数据

UPDATE cpu
SET hostname = 'server6'
WHERE id IN (SELECT idFROM cpuLIMIT 1000
);

3.1.1、开启并发参数

测试结果

SQL执行耗时，duration: 12.077 ms
逻辑复制耗时 71ms

2025-01-25 09:17:05.912 CST,"fbase","test",2797,"192.168.6.110:58025",67941f5a.aed,1274,"START_REPLICATION",2025-01-25 07:16:42 CST,3/0,0,DEBUG,00000,"sending replication keepalive",,,,,,,,"WalSndKeepalive, walsender.c:3698","sub_cpu","walsender",,02025-01-25 09:17:05.983 CST,"fbase","test",2797,"192.168.6.110:58025",67941f5a.aed,1283,"START_REPLICATION",2025-01-25 07:16:42 CST,3/0,0,DEBUG,00000,"write 3/DBA394C8 flush 3/DBA394C8 apply 3/DBA394C8 reply_time 2025-01-25 09:17:05.983149+08",,,,,,,,"ProcessStandbyReplyMessage, walsender.c:2101","sub_cpu","walsender",,0

在这里插入图片描述

完整的日志内容

2025-01-25 09:17:05.907 CST,"fbase","test",4500,"::1:61697",67943a8e.1194,29,"idle",2025-01-25 09:12:46 CST,5/50,0,DEBUG,00000,"StartTransaction(1) name: unnamed; blockState: DEFAULT; state: INPROGRESS, xid/subid/cid: 0/1/0",,,,,,,,"ShowTransactionStateRec, xact.c:5520","psql","client backend",,0
2025-01-25 09:17:05.908 CST,"fbase","test",4500,"::1:61697",67943a8e.1194,30,"idle",2025-01-25 09:12:46 CST,5/50,0,LOG,00000,"statement: UPDATE cpu
SET hostname = 'server9'
WHERE id IN (SELECT idFROM cpuLIMIT 1000
);",,,,,,,,"exec_simple_query, postgres.c:1078","psql","client backend",,0
2025-01-25 09:17:05.911 CST,,,2790,,67941f4e.ae6,13,,2025-01-25 07:16:30 CST,,0,DEBUG,00000,"snapshot of 1+0 running transaction ids (lsn 3/DB9D9A18 oldest xid 858 latest complete 857 next xid 859)",,,,,,,,"LogCurrentRunningXacts, standby.c:1386","","background writer",,02025-01-25 09:17:05.912 CST,"fbase","test",2797,"192.168.6.110:58025",67941f5a.aed,1274,"START_REPLICATION",2025-01-25 07:16:42 CST,3/0,0,DEBUG,00000,"sending replication keepalive",,,,,,,,"WalSndKeepalive, walsender.c:3698","sub_cpu","walsender",,0
2025-01-25 09:17:05.913 CST,"fbase","test",2797,"192.168.6.110:58025",67941f5a.aed,1275,"START_REPLICATION",2025-01-25 07:16:42 CST,3/0,0,DEBUG,00000,"write 3/DB9D7FF0 flush 3/DB9D7FF0 apply 3/DB9D7FF0 reply_time 2025-01-25 09:17:05.913414+08",,,,,,,,"ProcessStandbyReplyMessage, walsender.c:2101","sub_cpu","walsender",,02025-01-25 09:17:05.918 CST,"fbase","test",4500,"::1:61697",67943a8e.1194,31,"UPDATE",2025-01-25 09:12:46 CST,5/50,858,DEBUG,00000,"CommitTransaction(1) name: unnamed; blockState: STARTED; state: INPROGRESS, xid/subid/cid: 858/1/0 (used)",,,,,,,,"ShowTransactionStateRec, xact.c:5520","psql","client backend",,-4673810378594060932
2025-01-25 09:17:05.920 CST,"fbase","test",4500,"::1:61697",67943a8e.1194,32,"UPDATE",2025-01-25 09:12:46 CST,5/0,0,LOG,00000,"duration: 12.077 ms",,,,,,,,"exec_simple_query, postgres.c:1370","psql","client backend",,-4673810378594060932
2025-01-25 09:17:05.920 CST,"fbase","test",2797,"192.168.6.110:58025",67941f5a.aed,1276,"START_REPLICATION",2025-01-25 07:16:42 CST,3/0,0,DEBUG,00000,"serializing snapshot to pg_logical/snapshots/3-DB9D99E0.snap",,,,,,,,"SnapBuildSerialize, snapbuild.c:1685","sub_cpu","walsender",,0
2025-01-25 09:17:05.921 CST,"fbase","test",2797,"192.168.6.110:58025",67941f5a.aed,1277,"START_REPLICATION",2025-01-25 07:16:42 CST,3/0,0,DEBUG,00000,"purged committed transactions from 0 to 0, xmin: 858, xmax: 843",,,,,,,,"SnapBuildPurgeOlderTxn, snapbuild.c:974","sub_cpu","walsender",,0
2025-01-25 09:17:05.921 CST,"fbase","test",2797,"192.168.6.110:58025",67941f5a.aed,1278,"START_REPLICATION",2025-01-25 07:16:42 CST,3/0,0,DEBUG,00000,"xmin: 858, xmax: 843, oldest running: 858, oldest xmin: 842",,,,,,,,"SnapBuildProcessRunningXacts, snapbuild.c:1262","sub_cpu","walsender",,0
2025-01-25 09:17:05.922 CST,"fbase","test",2797,"192.168.6.110:58025",67941f5a.aed,1279,"START_REPLICATION",2025-01-25 07:16:42 CST,3/20,0,DEBUG,00000,"StartTransaction(1) name: unnamed; blockState: DEFAULT; state: INPROGRESS, xid/subid/cid: 0/1/0",,,,,,,,"ShowTransactionStateRec, xact.c:5520","sub_cpu","walsender",,0
2025-01-25 09:17:05.928 CST,"fbase","test",2797,"192.168.6.110:58025",67941f5a.aed,1280,"START_REPLICATION",2025-01-25 07:16:42 CST,3/0,0,DEBUG,00000,"UpdateDecodingStats: updating stats 0x1815fd0 0 0 0 0 0 0 1 240000",,,,,,,,"UpdateDecodingStats, logical.c:1935","sub_cpu","walsender",,0
2025-01-25 09:17:05.928 CST,"fbase","test",2797,"192.168.6.110:58025",67941f5a.aed,1281,"START_REPLICATION",2025-01-25 07:16:42 CST,3/0,0,DEBUG,00000,"sending replication keepalive",,,,,,,,"WalSndKeepalive, walsender.c:3698","sub_cpu","walsender",,0
2025-01-25 09:17:05.950 CST,"fbase","test",2797,"192.168.6.110:58025",67941f5a.aed,1282,"START_REPLICATION",2025-01-25 07:16:42 CST,3/0,0,DEBUG,00000,"write 3/DBA394C8 flush 3/DB9D7FF0 apply 3/DBA394C8 reply_time 2025-01-25 09:17:05.950609+08",,,,,,,,"ProcessStandbyReplyMessage, walsender.c:2101","sub_cpu","walsender",,0
2025-01-25 09:17:05.983 CST,"fbase","test",2797,"192.168.6.110:58025",67941f5a.aed,1283,"START_REPLICATION",2025-01-25 07:16:42 CST,3/0,0,DEBUG,00000,"write 3/DBA394C8 flush 3/DBA394C8 apply 3/DBA394C8 reply_time 2025-01-25 09:17:05.983149+08",,,,,,,,"ProcessStandbyReplyMessage, walsender.c:2101","sub_cpu","walsender",,0
2025-01-25 09:17:12.806 CST,,,2793,,67941f4e.ae9,728,,2025-01-25 07:16:30 CST,1/363,0,DEBUG,00000,"StartTransaction(1) name: unnamed; blockState: DEFAULT; state: INPROGRESS, xid/subid/cid: 0/1/0",,,,,,,,"ShowTransactionStateRec, xact.c:5520","","autovacuum launcher",,0
2025-01-25 09:17:12.807 CST,,,2793,,67941f4e.ae9,729,,2025-01-25 07:16:30 CST,1/363,0,DEBUG,00000,"CommitTransaction(1) name: unnamed; blockState: STARTED; state: INPROGRESS, xid/subid/cid: 0/1/0",,,,,,,,"ShowTransactionStateRec, xact.c:5520","","autovacuum launcher",,0

3.1.2、使用默认参数

SQL语句耗时，duration: 15.496 ms
逻辑复制耗时45 ms

duration: 15.496 ms
相差45 ms2025-01-25 09:45:59.339 CST,"fbase","test",5080,"192.168.6.110:17521",67943eb1.13d8,314,"START_REPLICATION",2025-01-25 09:30:25 CST,3/0,0,DEBUG,00000,"sending replication keepalive",,,,,,"START_REPLICATION SLOT ""fd_logical"" LOGICAL 1/910B8DF8 (proto_version '4', origin 'any', publication_names '""pub_cpu""')",,"WalSndKeepalive, walsender.c:3698","sub_cpu","walsender",,02025-01-25 09:45:59.384 
CST,"fbase","test",5080,"192.168.6.110:17521",67943eb1.13d8,316,"START_REPLICATION",2025-01-25 09:30:25 CST,3/0,0,DEBUG,00000,"write 1/92ACA520 flush 1/92ACA520 apply 1/92ACA520 reply_time 2025-01-25 09:45:59.384228+08",,,,,,"START_REPLICATION SLOT ""fd_logical"" LOGICAL 1/910B8DF8 (proto_version '4', origin 'any', publication_names '""pub_cpu""')",,"ProcessStandbyReplyMessage, walsender.c:2101","sub_cpu","walsender",,0

在这里插入图片描述

3.2、更新5万条数据

UPDATE cpu
SET hostname = 'server7'
WHERE id IN (SELECT idFROM cpuLIMIT 50000
);

3.2.1、开启并发参数

SQL执行耗时，duration: 357.201 ms
逻辑复制耗时1199 ms

2025-01-25 04:12:34.667 CST,"fbase","test",3434,"192.168.6.110:54263",6793f309.d6a,350,"START_REPLICATION",2025-01-25 04:07:37 CST,3/0,0,DEBUG,00000,"sending replication keepalive",,,,,,,,"WalSndKeepalive, walsender.c:3698","sub_cpu","walsender",,0
2025-01-25 04:12:35.866 CST,"fbase","test",3434,"192.168.6.110:54263",6793f309.d6a,411,"START_REPLICATION",2025-01-25 04:07:37 CST,3/0,0,DEBUG,00000,"write 3/DA3B0468 flush 3/DA3B0468 apply 3/DA3B0468 reply_time 2025-01-25 04:12:35.866369+08",,,,,,,,"ProcessStandbyReplyMessage, walsender.c:2101","sub_cpu","walsender",,0

3.2.2、使用默认参数

SQL执行耗时，duration: 586.545 ms
逻辑复制耗时1396 ms

2025-01-25 03:56:24.050 CST,"fbase","test",2475,"192.168.6.110:42787",6793ea24.9ab,3146,"START_REPLICATION",2025-01-25 03:29:40 CST,3/0,0,DEBUG,00000,"sending replication keepalive",,,,,,"START_REPLICATION SLOT ""fd_logical"" LOGICAL 1/697B9D18 (proto_version '4', origin 'any', publication_names '""pub_cpu""')",,"WalSndKeepalive, walsender.c:3698","sub_cpu","walsender",,02025-01-25 03:56:25.446 CST,"fbase","test",2475,"192.168.6.110:42787",6793ea24.9ab,3234,"START_REPLICATION",2025-01-25 03:29:40 CST,3/0,0,DEBUG,00000,"write 1/910B8DF8 flush 1/910B8DF8 apply 1/910B8DF8 reply_time 2025-01-25 03:56:25.446197+08",,,,,,"START_REPLICATION SLOT ""fd_logical"" LOGICAL 1/697B9D18 (proto_version '4', origin 'any', publication_names '""pub_cpu""')",,"ProcessStandbyReplyMessage, walsender.c:2101","sub_cpu","walsender",,0

3.3、更新10万条数据

UPDATE cpu
SET hostname = 'server5'
WHERE id IN (SELECT idFROM cpuLIMIT 100000
);

3.3.1、开启并发参数

SQL执行耗时，duration: 3227.055 ms
逻辑复制耗时4637 ms

2025-01-24 13:07:13.016 CST,"fbase","test",5800,"192.168.6.110:59635",67931e75.16a8,11192,"START_REPLICATION",2025-01-24 13:00:37 CST,3/0,0,DEBUG,00000,"sending replication keepalive",,,,,,,,"WalSndKeepalive, walsender.c:3698","sub_cpu","walsender",,02025-01-24 13:07:17.653 CST,"fbase","test",5800,"192.168.6.110:59635",67931e75.16a8,11307,"START_REPLICATION",2025-01-24 13:00:37 CST,3/0,0,DEBUG,00000,"write 3/9EEAF098 flush 3/9EEAF098 apply 3/9EEAF098 reply_time 2025-01-24 13:07:17.652963+08",,,,,,,,"ProcessStandbyReplyMessage, walsender.c:2101","sub_cpu","walsender",,0

3.3.2、使用默认参数

SQL执行耗时，duration: 4591.671 ms
逻辑复制耗时6153 ms

2025-01-24 15:13:50.985 CST,"fbase","test",8435,"192.168.6.110:10523",67933c84.20f3,406,"START_REPLICATION",2025-01-24 15:08:52 CST,3/0,0,DEBUG,00000,"sending replication keepalive",,,,,,"START_REPLICATION SLOT ""fd_logical"" LOGICAL 1/5EB27398 (proto_version '4', origin 'any', publication_names '""pub_cpu""')",,"WalSndKeepalive, walsender.c:3698","sub_cpu","walsender",,02025-01-24 15:13:57.138 CST,"fbase","test",8435,"192.168.6.110:10523",67933c84.20f3,487,"START_REPLICATION",2025-01-24 15:08:52 CST,3/0,0,DEBUG,00000,"write 1/697B9D18 flush 1/697B9D18 apply 1/697B9D18 reply_time 2025-01-24 15:13:57.137669+08",,,,,,"START_REPLICATION SLOT ""fd_logical"" LOGICAL 1/5EB27398 (proto_version '4', origin 'any', publication_names '""pub_cpu""')",,"ProcessStandbyReplyMessage, walsender.c:2101","sub_cpu","walsender",,0

3.4、更新30万条数据

UPDATE cpu
SET hostname = 'server5'
WHERE id IN (SELECT idFROM cpuLIMIT 300000
);

3.4.1、开启并发参数

SQL执行耗时，duration: 5567.591 ms
逻辑复制耗时6815 ms

2025-01-24 14:05:10.572 CST,"fbase","test",5800,"192.168.6.110:59635",67931e75.16a8,14675,"START_REPLICATION",2025-01-24 13:00:37 CST,3/0,0,DEBUG,00000,"sending replication keepalive",,,,,,,,"WalSndKeepalive, walsender.c:3698","sub_cpu","walsender",,02025-01-24 14:05:17.387 
CST,"fbase","test",5800,"192.168.6.110:59635",67931e75.16a8,14920,"START_REPLICATION",2025-01-24 13:00:37 CST,3/0,0,DEBUG,00000,"write 3/D493FC30 flush 3/D493FC30 apply 3/D493FC30 reply_time 2025-01-24 14:05:17.386781+08",,,,,,,,"ProcessStandbyReplyMessage, walsender.c:2101","sub_cpu","walsender",,0

3.4.2、使用默认参数

SQL执行耗时，duration: 6337.377 ms
逻辑复制耗时11850 ms

2025-01-25 03:36:10.653 CST,"fbase","test",2475,"192.168.6.110:42787",6793ea24.9ab,1517,"START_REPLICATION",2025-01-25 03:29:40 CST,3/0,0,DEBUG,00000,"sending replication keepalive",,,,,,"START_REPLICATION SLOT ""fd_logical"" LOGICAL 1/697B9D18 (proto_version '4', origin 'any', publication_names '""pub_cpu""')",,"WalSndKeepalive, walsender.c:3698","sub_cpu","walsender",,02025-01-25 03:36:22.503 CST,"fbase","test",2475,"192.168.6.110:42787",6793ea24.9ab,1779,"START_REPLICATION",2025-01-25 03:29:40 CST,3/0,0,DEBUG,00000,"write 1/892E2370 flush 1/892E2370 apply 1/892E2370 reply_time 2025-01-25 03:36:22.502836+08",,,,,,"START_REPLICATION SLOT ""fd_logical"" LOGICAL 1/697B9D18 (proto_version '4', origin 'any', publication_names '""pub_cpu""')",,"ProcessStandbyReplyMessage, walsender.c:2101","sub_cpu","walsender",,0

3.5、更新100万条数据

test=# UPDATE cpu
SET hostname = 'server1'
WHERE id IN (SELECT idFROM cpuLIMIT 1000000
);

3.5.1、开启并发参数

SQL执行耗时，duration: 12734.563 ms
逻辑复制耗时24214 ms

2025-01-24 10:55:58.105 CST,"fbase","test",4844,"192.168.6.110:59629",67930081.12ec,79,"START_REPLICATION",2025-01-24 10:52:49 CST,3/0,0,DEBUG,00000,"serializing snapshot to pg_logical/snapshots/3-48005F70.snap",,,,,,,,"SnapBuildSerialize, snapbuild.c:1685","sub_cpu","walsender",,02025-01-24 10:56:22.319 CST,"fbase","test",4844,"192.168.6.110:59629",67930081.12ec,21047,"START_REPLICATION",2025-01-24 10:52:49 CST,3/0,0,DEBUG,00000,"write 3/6429B010 flush 3/6429B010 apply 3/6429B010 reply_time 2025-01-24 10:56:22.306827+08",,,,,,,,"ProcessStandbyReplyMessage, walsender.c:2101","sub_cpu","walsender",,0

3.5.2、使用默认参数

SQL执行耗时，duration: 15579.122 ms
逻辑复制耗时46474 ms

2025-01-24 09:55:40.783 CST,"fbase","test",2430,"192.168.6.110:10501",6792e20a.97e,2368,"START_REPLICATION",2025-01-24 08:42:50 CST,3/0,0,DEBUG,00000,"sending replication keepalive",,,,,,"START_REPLICATION SLOT ""fd_logical"" LOGICAL 1/1B005368 (proto_version '4', origin 'any', publication_names '""pub_cpu""')",,"WalSndKeepalive, walsender.c:3698","sub_cpu","walsender",,0
2025-01-24 09:56:16.241 CST,"fbase","test",2430,"192.168.6.110:10501",6792e20a.97e,4158,"START_REPLICATION",2025-01-24 08:42:50 CST,3/0,0,DEBUG,00000,"write 1/58CEB118 flush 1/58CEB118 apply 1/58CEB118 reply_time 2025-01-24 09:56:16.241509+08",,,,,,"START_REPLICATION SLOT ""fd_logical"" LOGICAL 1/1B005368 (proto_version '4', origin 'any', publication_names '""pub_cpu""')",,"ProcessStandbyReplyMessage, walsender.c:2101","sub_cpu","walsender",,0

四、逻辑复制参考文献

与逻辑复制相关的参数，官网介绍

31.10.1. 发布者

wal_level 必须设置为 logical。
max_replication_slots 必须设置为至少预期连接的订阅数量，再加上一些预留用于表同步。
max_wal_senders 应设置为至少与 max_replication_slots 相同，再加上同时连接的物理副本数量。
逻辑复制的 WAL 发送进程也会受到 wal_sender_timeout 的影响。

108机器发布端参数配置

参数名称	当前值	含义
`wal_level`	logical	设置 WAL 日志的级别，`logical` 表示启用逻辑复制功能。
`max_replication_slots`	10	最大复制槽的数量，用于逻辑和物理复制。
`max_wal_senders`	10	最大 WAL 发送进程的数量，用于将 WAL 日志发送给订阅者或备用服务器。
`wal_sender_timeout`	60000	WAL 发送进程等待复制确认的超时时间（单位为毫秒）。

test=# SELECT name, setting
FROM pg_settings
WHERE name IN ('wal_level', 'max_replication_slots', 'max_wal_senders', 'wal_sender_timeout');name          | setting 
-----------------------+---------max_replication_slots | 10max_wal_senders       | 10wal_level             | logicalwal_sender_timeout    | 60000
(4 rows)

31.10.2. 订阅者

max_replication_slots 必须设置为至少将添加到订阅者的订阅数量，再加上一些预留用于表同步。
max_logical_replication_workers 必须设置为至少订阅数量（用于主应用工作进程），再加上一些预留用于表同步工作进程和并行应用工作进程。
max_worker_processes 可能需要调整以容纳复制工作进程，至少为 (max_logical_replication_workers + 1)。注意，某些扩展和并行查询也会占用 max_worker_processes 的工作槽。
max_sync_workers_per_subscription 控制订阅初始化时或添加新表时初始数据复制的并行程度。
max_parallel_apply_workers_per_subscription 控制订阅参数 streaming = parallel 时，正在进行的事务流的并行程度。
逻辑复制工作进程也会受到 wal_receiver_timeout、wal_receiver_status_interval 和 wal_retrieve_retry_interval 的影响。

110机器订阅端参数配置

以下是这些参数的表格：

参数名称	当前值	含义
`max_replication_slots`	10	最大复制槽的数量，用于逻辑和物理复制。
`max_logical_replication_workers`	4	最大逻辑复制工作进程的数量，包括主应用工作进程、表同步工作进程和并行应用工作进程。
`max_worker_processes`	8	最大工作进程的数量，用于容纳逻辑复制、并行查询等。
`max_sync_workers_per_subscription`	2	每个订阅的最大同步工作进程数量，用于初始数据复制的并行程度。
`max_parallel_apply_workers_per_subscription`	2	每个订阅的最大并行应用工作进程数量，用于流式传输正在进行的事务。

参数名称	当前值	含义
`wal_receiver_timeout`	60000	WAL 接收进程在等待主库响应时的最大超时时间（单位为毫秒）。
`wal_receiver_status_interval`	10	WAL 接收进程向主库报告状态的最小间隔时间（单位为秒）。
`wal_retrieve_retry_interval`	5000	在尝试重新获取 WAL 日志失败后的重试间隔时间（单位为毫秒）。

test=# SELECT name, setting
FROM pg_settings
WHERE name IN ('max_replication_slots','max_logical_replication_workers','max_worker_processes','max_sync_workers_per_subscription','max_parallel_workers','max_parallel_apply_workers_per_subscription'
);name                     | setting 
---------------------------------------------+---------max_logical_replication_workers             | 4max_parallel_apply_workers_per_subscription | 4max_parallel_workers                        | 8max_replication_slots                       | 10max_sync_workers_per_subscription           | 4max_worker_processes                        | 16
(6 rows)test=# SELECT name, setting
FROM pg_settings
WHERE name IN ('wal_receiver_timeout','wal_receiver_status_interval','wal_retrieve_retry_interval'
);name             | setting 
------------------------------+---------wal_receiver_status_interval | 10wal_receiver_timeout         | 60000wal_retrieve_retry_interval  | 5000
(3 rows)

创建订阅

test=# \h create subscription 
Command:     CREATE SUBSCRIPTION
Description: define a new subscription
Syntax:
CREATE SUBSCRIPTION subscription_nameCONNECTION 'conninfo'PUBLICATION publication_name [, ...][ WITH ( subscription_parameter [= value] [, ... ] ) ]URL: https://www.postgresql.org/docs/16/sql-createsubscription.html

以下是 CREATE SUBSCRIPTION 命令中 WITH 子句支持的参数的简写表格：

streaming（枚举类型）

指定是否为此订阅启用正在进行的事务的流式传输。默认值是 off，意味着所有事务都在发布者上完全解码，然后才作为整体发送给订阅者。

如果设置为 on，则传入的更改将写入临时文件，并且只有在发布者上提交事务并由订阅者接收后才应用。

如果设置为 parallel，则传入的更改将直接通过一个并行应用工作线程应用（如果有可用的话）。如果没有空闲的并行应用工作线程来处理流式事务，那么更改将写入临时文件，并在事务提交后应用。请注意，如果并行应用工作线程中发生错误，远程事务的完成LSN可能不会记录在服务器日志中。

参数名	类型	默认值
connect	boolean	true
create_slot	boolean	true
enabled	boolean	true
slot_name	string	订阅名
binary	boolean	false
copy_data	boolean	true
streaming	enum	off
synchronous_commit	enum	off
two_phase	boolean	false
disable_on_error	boolean	false
password_required	boolean	true
run_as_owner	boolean	false
origin	string	any

修改传输方式

substream由原来的f改为了p

test=# ALTER SUBSCRIPTION sub_cpu SET (streaming = 'parallel');
ALTER SUBSCRIPTION
test=# SELECT * FROM pg_subscription WHERE subname = 'sub_cpu';
-[ RECORD 1 ]-------+-------------------------------------------------------------------
oid                 | 21954
subdbid             | 21947
subskiplsn          | 0/0
subname             | sub_cpu
subowner            | 10
subenabled          | t
subbinary           | f
substream           | p
subtwophasestate    | d
subdisableonerr     | f
subpasswordrequired | t
subrunasowner       | f
subconninfo         | host=192.168.6.108 port=8432 dbname=test user=fbase password=fbase
subslotname         | fd_logical
subsynccommit       | off
subpublications     | {pub_cpu}
suborigin           | any

表

test=# select * from pg_stat_subscription;
-[ RECORD 1 ]---------+------------------------------
subid                 | 16399
subname               | sub_cpu
pid                   | 5954
leader_pid            | 4985
relid                 | 
received_lsn          | 
last_msg_send_time    | 
last_msg_receipt_time | 
latest_end_lsn        | 
latest_end_time       | 
-[ RECORD 2 ]---------+------------------------------
subid                 | 16399
subname               | sub_cpu
pid                   | 4985
leader_pid            | 
relid                 | 
received_lsn          | 2/D2917D80
last_msg_send_time    | 2025-01-23 15:13:46.327977+08
last_msg_receipt_time | 2025-01-23 15:13:46.328158+08
latest_end_lsn        | 2/D2917D80
latest_end_time       | 2025-01-23 15:13:46.327977+08

事件

test=# SELECT pid, wait_event_type, wait_event
FROM pg_stat_activity
WHERE wait_event_type IS NOT NULL;pid  | wait_event_type |        wait_event        
------+-----------------+--------------------------4982 | Activity        | AutoVacuumMain4984 | Activity        | LogicalLauncherMain4985 | Activity        | LogicalApplyMain5954 | Activity        | LogicalParallelApplyMain6125 | Timeout         | VacuumDelay4979 | Activity        | BgWriterHibernate4983 | Activity        | ArchiverMain4978 | Timeout         | CheckpointWriteDelay4981 | Activity        | WalWriterMain
(9 rows)

27977+08


**事件**```sql
test=# SELECT pid, wait_event_type, wait_event
FROM pg_stat_activity
WHERE wait_event_type IS NOT NULL;pid  | wait_event_type |        wait_event        
------+-----------------+--------------------------4982 | Activity        | AutoVacuumMain4984 | Activity        | LogicalLauncherMain4985 | Activity        | LogicalApplyMain5954 | Activity        | LogicalParallelApplyMain6125 | Timeout         | VacuumDelay4979 | Activity        | BgWriterHibernate4983 | Activity        | ArchiverMain4978 | Timeout         | CheckpointWriteDelay4981 | Activity        | WalWriterMain
(9 rows)

逻辑复制parallel并发参数测试

逻辑复制parallel并发参数测试一、测试结果、测试环境描述 1.1、测试结果 cpu表中有1000万条数据，大小为1652MB,当更新的数据量多于10万条的时候有明显变化，多余30万条的时候相差2倍。更新的数据量较多时，逻辑复制使用并发参数相比于使用…...

编程日记 2025/7/13 4:06:06

python学opencv|读取图像（四十六）使用cv2.bitwise_or()函数实现图像按位或运算

【0】基础定义按位与运算：全1取1，其余取0。按位或运算：全0取0，其余取1。【1】引言前序学习进程中，已经对图像按位与计算进行了详细探究，相关文章链接如下： python学opencv|读取图像&…...

编程日记 2025/7/10 13:01:40

2025美赛数学建模C题：奥运金牌榜，完整论文代码模型目前已经更新

2025美赛数学建模C题：奥运金牌榜，完整论文代码模型目前已经更新，获取见文末名片...

编程日记 2025/7/8 18:21:50

Kiwi 安卓浏览器本月停止维护，扩展功能迁移至 Edge Canary

IT之家 1 月 25 日消息，科技媒体 Android Authority 今天（1 月 25 日）发布博文，报道称 Kiwi 安卓浏览器将于本月停止维护，相关扩展支持功能已整合到微软 Edge Canary 浏览器中。开发者 Arnaud42 表示 Kiwi 安卓浏览器…...

编程日记 2025/7/10 21:31:17

Couchbase UI: Server

在 Couchbase UI 中的 Server（服务器）标签页主要用于管理和监控集群中的各个节点。以下是 Server 标签页的主要内容和功能介绍： 1. 节点列表显示集群中所有节点的列表，每个节点的详细信息包括： 节点地址&#xff1…...

编程日记 2025/7/13 1:05:51

（一）HTTP协议：请求与响应

前言爬虫需要基础知识，HTTP协议只是个开始，除此之外还有很多，我们慢慢来记录。今天的HTTP协议，会有助于我们更好的了解网络。一、什么是HTTP协议 （1）定义 HTTP（超文本传输协议&#xff…...

编程日记 2025/7/7 20:44:26

微信阅读网站小程序的设计与实现（LW+源码+讲解）

专注于大学生项目实战开发,讲解,毕业答疑辅导，欢迎高校老师/同行前辈交流合作✌。技术范围：SpringBoot、Vue、SSM、HLMT、小程序、Jsp、PHP、Nodejs、Python、爬虫、数据可视化、安卓app、大数据、物联网、机器学习等设计与开发。主要内容：…...

编程日记 2025/7/9 4:58:51

资源管理输入、工具与技术、输出

过程输入工具与技术输出规划资源管理1.项目章程2.项目管理计划质量管理计划、范围基准3.项目文件项目进度计划、需求文件、风险登记册、干系人登记册4.事业环境因素5.组织过程资产1.专家判断2.数据表现层级型、矩阵型、文本型3.组织理论4.会议1.资源管理计划2.团队章程3.项目文…...

编程日记 2025/7/5 6:21:53

【JavaWeb学习Day13】

Tlias智能学习系统需求： 部门管理：查询、新增、修改、删除员工管理：查询、新增、修改、删除和文件上传报表统计登录认证日志管理班级、学员管理（实战内容） 部门管理： 01准备工作开发规范-…...

编程日记 2025/7/8 14:01:22

mapStruct 使用踩坑指南

一、缓存机制经常因为变更字段(通常会这样)，导致启动失败。需要清理生成的文件。 /Users/uzong/IdeaProjects/uzong-crm/uzong-crm-manager/src/main/java/com/uzong/crm/manager/GroupManager.java:14:67 java: 找不到符号符号: 方法 getId()位置: 类型为com.u…...

编程日记 2025/7/13 4:04:31

Hive详细讲解-概述与环境搭建

文章目录 1.Hive概述1.2.Hive架构原理1.3Driver 2.Hive最小化模式安装部署3.生产环境hive安装部署4.将hive的元数据存储到Mysql5.元数据库概述6.Hive服务的部署6.1HiveServer26.2Metastore 7.HiveServer2使用7.1Metastore嵌入模式配置7.2Metastore独立模式配置* 8.hive常用的参…...

编程日记 2025/7/12 21:43:42

【算法】数论基础——约数个数定理、约数和定理 python

目录前置知识约数约数个数定理约数和定理实战演练总结前置知识需要掌握：唯一分解定理（算术基本定理） 约数约数，即因数，定义为： 如果一个整数a可以被另一个整数b整除（即 a mod b 0),那么b就…...

编程日记 2025/7/10 10:00:49

【阅读笔记】基于整数+分数微分的清晰度评价算子

本文介绍的是一种新的清晰度评价算子，整数微分算子分数微分算子一、概述目前在数字图像清晰度评价函数中常用的评价函数包括三类：灰度梯度评价函数、频域函数和统计学函数，其中灰度梯度评价函数具有计算简单，评价效果好等优点…...

编程日记 2025/7/8 22:41:32

【技术】TensorRT 10.7 安装指南（Ubuntu22.04）

原文链接：https://mengwoods.github.io/post/tech/008-tensorrt-installation/ 本文安装的版本如下： Ubuntu 22.04 Nvidia Driver 538.78 CUDA 12.2 cuDNN 8.9.7 TensorRT 10.7 安装前的准备（可选） 在安装新版本之前&#xf…...

编程日记 2025/7/13 4:06:04

Linux权限有关

文章目录一、添加普通用户二、Xshell下命令行的知识三、 Linux和Windows操作系统四、再探指令和Linux权限五、用户相关用户切换: 今天我们学习与Linux有关的权限等内容，以及一些零碎知识帮助我们理解Linux的系统和Xshell的原理。本篇是在Xshell环境下执行的。一…...

编程日记 2025/7/10 1:39:15

vue router路由复用及刷新问题研究

路由复用问题当路由匹配路径未发生变化时，只是相关的参数发生了变化，路由跳转时，会发现虽然地址栏中的地址更新到了新的链接，但是页面渲染并未触发响应路由组件的created,mounted等钩子函数，也就意味着组件并没有被重…...

编程日记 2025/7/6 13:58:42

XML实体注入漏洞攻与防

JAVA中的XXE攻防回显型无回显型 cve-2014-3574...

编程日记 2025/7/1 3:39:07

【论文阅读】RT-SKETCH: GOAL-CONDITIONED IMITATION LEARNING FROM HAND-DRAWN SKETCHES

RT-Sketch：基于手绘草图的目标条件模仿学习摘要：在目标条件模仿学习（imitation learning，IL）中，自然语言和图像通常被用作目标表示。然而，自然语言可能存在歧义，图像则可能过于具体…...

编程日记 2025/7/8 23:05:08

27. 【.NET 8 实战--孢子记账--从单体到微服务】--简易报表--报表服务

报表是每个记账应用所具备的功能，要实现报表功能就需要把账本的核心功能（记账）完成，因此报表服务作为本专栏第一部分单体应用开发中最后一个要实现的功能，这一篇文章很简单，我们一起来实现一个简单的报表服…...

编程日记 2025/7/3 11:17:56

LeetCode - #194 Swift 实现文件内容转置

网罗开发 （小红书、快手、视频号同名） 大家好，我是展菲，目前在上市企业从事人工智能项目研发管理工作，平时热衷于分享各种编程领域的软硬技能知识以及前沿技术，包括iOS、前端、Harmony OS、Java、Python等…...

编程日记 2025/7/12 10:01:40

【全栈】SprintBoot+vue3迷你商城（9）

【全栈】SprintBootvue3迷你商城（9） 往期的文章都在这里啦，大家有兴趣可以看一下后端部分： 【全栈】SprintBootvue3迷你商城（1） 【全栈】SprintBootvue3迷你商城（2） 【全栈】Spr…...

编程日记 2025/7/13 4:05:21

ThreeJS示例教程200+【目录】

Three.js 是一个强大的 JavaScript 库，旨在简化在网页上创建和展示3D图形的过程。它基于 WebGL 技术，但提供了比直接使用 WebGL 更易于使用的API，使得开发者无需深入了解 WebGL 的复杂细节就能创建出高质量的3D内容。由于目前内容还不多，下面的内容暂时做一个占位。文章目…...

编程日记 2025/7/10 15:22:39

《边界感知的分而治之方法：基于扩散模型的无监督阴影去除解决方案》学习笔记

paper：Boundary-Aware Divide and Conquer: A Diffusion-Based Solution for Unsupervised Shadow Removal 目录摘要 1、介绍 2、相关工作 2.1 阴影去除 2.2 去噪扩散概率模型（Denoising Diffusion Probabilistic Models, DDPM） 3、方…...

编程日记 2025/7/8 5:08:18

PyCharm+RobotFramework框架实现UDS自动化测试- (四)项目实战0x10

1.环境搭建硬件环境：CANoe、待测设备（包含UDS诊断模块） 2.pythonPyCharm环境 pip install robotframework pip install robotframework-ride pip install openpyxl pip install udsoncan pip install python-can pip install can-isotp3…...

编程日记 2025/7/12 19:05:20

基于java实现规则引擎设计思路

背景去年底换了公司，目前在做HR招聘系统，产品要求:管理端手动配置发布招聘要求(支持多个招聘条件AND与OR关系编排)；当C端用户报名该职位时，系统执行该规则，返回报名成功或失败。根据技术调研，采用db存规则…...

编程日记 2025/7/10 19:51:19

TCP协议：互联网数据传输的守护者

在互联网的浩瀚海洋中，数据如同涓涓细流，无时无刻不在流动。而这些数据的稳定、可靠传输，离不开一个重要的协议——TCP（Transmission Control Protocol，传输控制协议）。TCP协议作为互联网协议族中的核心成员…...

编程日记 2025/7/1 23:12:11

2025美国大学生数学建模竞赛（美赛）B题完整思路分析论文（35页）（含模型、可运行代码和运行结果）

2025美国大学生数学建模竞赛B题完整思路分析论文目录摘要一、问题重述二、问题分析三、模型假设四、模型建立与求解 4.1问题1 4.1.1问题1思路分析 4.1.2问题1模型建立 4.1.3问题1样例代码（仅供参考） 4.1.4问题1样例代码运行结…...

编程日记 2025/7/8 17:35:19

InceptionV1_V2

目录不同大小的感受野去提取特征经典 Inception 网络的设计思路与运行流程背景任务：图像分类（以 CIFAR-10 数据集为例） Inception 网络的设计思路 Inception 网络的运行流程打个比方多个损失函数的理解 1. 为什么需要多个损失函数&#…...

编程日记 2025/7/6 19:03:17

面向对象设计原则

面向对象最大的优势是抵御变化理解隔离变化： 从宏观面来看，面向对象构建方式更能适应软件的变化，能将变化所带来的影响减为最少。各司其职：从微观层面来看，面向对象的方式更强调各个类的责任。由于需求变化导致的新…...

编程日记 2025/7/4 1:17:57

近年流行的开发技术

Web 开发领域前端技术 HTML5、CSS3 和 JavaScript HTML5：作为网页结构的基础，引入了新的语义化标签（如<header>、<nav>、<article>等），增强了网页的可读性和搜索引擎优化效果，同时支持…...

编程日记 2025/7/10 8:57:16

Go语言中的Select

Select 在 Go 语言中，select 是一种用于处理多个通道操作的控制结构。它允许你同时监听多个通道上的通信操作（发送或接收），并根据哪个操作先完成来执行相应的代码块。select 是 Go 并发编程中的一个重要工具，常用于实…...

编程日记 2025/7/8 5:50:27

SQL调优讨论

说明：狭义的SQL调优，指对慢SQL（一般是Select语句，或包含Select的语句）优化，在不改变查询结果的情况下提高SQL执行效率。广义上的SQL调优，指对某个慢查询优化，通过一些类操作提高查询…...

编程日记 2025/7/8 20:35:21

【STM32】-TTP223B触摸开关

前言本文章旨在记录博主STM32的学习经验，我自身也在不断的学习当中，如果文章有写的不对的地方，欢迎各位大佬批评指正。准备工作今天这篇文章介绍的是触摸开关这一外围硬件。 ST-link调试器STM32最小系统板单路TTP223B触摸传感器模块LE…...

编程日记 2025/7/10 16:04:37

华为数据之道-读书笔记

内容简介关键字数字化生产已经成为普遍的商业模式，其本质是以数据为处理对象，以ICT平台为生产工具，以软件为载体，以服务为目的的生产过程。信息与通信技术平台（Information and Communication Technology Platf…...

编程日记 2025/7/11 9:36:30

Zookeeper（28）Zookeeper的线性化写入和顺序一致性读是什么？

Zookeeper 是一个分布式协调服务，它在设计上提供了强一致性的保证，其中包括线性化写入和顺序一致性读。这两种一致性模型确保了在分布式系统中数据的一致性和操作的确定性。线性化写入（Linearizable Writes） 线性化写入保证在任…...

编程日记 2025/7/8 19:30:19

Ubuntu安装GitLab

在 Ubuntu 上安装 GitLab 的步骤如下。这里以 GitLab Community Edition（CE）为例： 前提条件确保你的 Ubuntu 系统是 20.04 或更高版本。确保你的系统满足 GitLab 的硬件要求。步骤更新系统包： sudo apt update sudo apt upg…...

编程日记 2025/7/8 5:48:15

Stable Diffusion 3.5 介绍

Stable Diffusion 3.5 是由 Stability AI 推出的最新一代图像生成模型，是 Stable Diffusion 系列的重要升级版本。以下是关于 Stable Diffusion 3.5 的详细信息： 版本概述 Stable Diffusion 3.5 包含三个主要版本： Stable Diffusion 3.5 L…...

编程日记 2025/7/12 13:00:17

力扣hot100--＞滑动窗口、贪心

你好呀，欢迎来到 Dong雨的技术小栈 🌱 在这里，我们一同探索代码的奥秘，感受技术的魅力 ✨。 👉 我的小世界：Dong雨 📌 分享我的学习旅程 🛠️ 提供贴心的实用工具 💡 记…...

编程日记 2025/7/8 21:58:57

### 2.5.3 二叉树的基本操作

2.5.3 二叉树的基本操作 // 获取树中节点的个数 int size(Node root);// 获取叶子节点的个数 int getLeafNodeCount(Node root);// 子问题思路-求叶子结点个数// 获取第K层节点的个数 int getKLevelNodeCount(Node root,int k);// 获取二叉树的高度 int getHeight(Node root);…...

编程日记 2025/7/8 8:03:23

GAEA 社区：从用户到共同创造者

GAEA 模型最引人注目的方面之一是，它将用户视为共同创造者，而不仅仅是被动的消费者。在许多中心化平台中，用户就是用户。但在 GAEA 的生态系统中，每个人都在推动进步。无论您是贡献计算能力、分享有价值的数据还是帮助改进模型&am…...

编程日记 2025/7/9 11:33:38

记录一个连不上docker中的mysql的问题

引言使用的debian12,不同发行版可能有些许差异，连接使用的工具是navicat lite 本来是毫无思绪的，以前在云服务器上可能是防火墙的问题，但是这个桌面环境我压根没有使用防火墙。直到 ying192:~$ mysql -h127.0.0.1 -uroot ERROR 1045 (28…...

编程日记 2025/7/11 11:16:18

doris：MySQL Load

Doris 兼容 MySQL 协议，可以使用 MySQL 标准的 LOAD DATA 语法导入本地文件。MySQL Load 是一种同步导入方式，执行导入后即返回导入结果。可以通过 LOAD DATA 语句的返回结果判断导入是否成功。一般来说，可以使用 MySQL Load 导入 10GB 以下的…...

编程日记 2025/7/8 4:27:57

使用vitepress搭建自己的博客项目

一、介绍can-vitepress-blog 什么是CAN BLOG CAN BLOG是基于vitepress二开的个人博客系统，他能够方便使用者快速构建自己的博客文章，无需繁琐的配置和复杂的代码编写。 CAN BLOG以antdv为UI设计基础，简洁大方，界面友好&#xf…...

编程日记 2025/7/11 12:21:33

Yii框架中的扩展：如何使用外部库

在Yii框架中，扩展功能的一种常见且有效的方式是使用外部库。这些外部库可以帮助开发者实现特定的功能，如调用第三方API、处理图片、生成PDF文件或发送邮件等。以下是使用外部库扩展Yii框架的详细步骤： 一、安装外部库使用Composer&#xff…...

编程日记 2025/7/7 21:06:38

【Elasticsearch】inference ingest pipeline

Elasticsearch 的 Ingest Pipeline 功能允许你在数据索引之前对其进行预处理。通过使用 Ingest Pipeline，你可以执行各种数据转换和富化操作，包括使用机器学习模型进行推理（inference）。这在处理词嵌入、情感分析、图像识别等场景…...

编程日记 2025/7/9 4:27:21

Linux的基本指令（上）

1.ls指令语法：ls [选项] [目录或文件] 功能：对于⽬录，该命令列出该⽬录下的所有⼦⽬录与⽂件。对于⽂件，将列出⽂件名以及其他信息。常用选项： -a 列出⽬录下的所有⽂件，包括以 . 开头的隐含⽂件。 -d 将…...

编程日记 2025/7/8 4:28:05

【贪心算法】洛谷P1106 - 删数问题

2025 - 01 - 22 - 第 46 篇【洛谷】贪心算法题单 - 【贪心算法】 - 【学习笔记】作者(Author): 郑龙浩 / 仟濹(CSND账号名) 目录文章目录目录P1106 删数问题题目描述输入格式输出格式样例 #1样例输入 #1样例输出 #1 提示思路代码 P1106 删数问题题目描述键盘输入一个高…...

编程日记 2025/7/12 23:47:11

【人工智能】Python中的知识图谱构建与应用

《Python OpenCV从菜鸟到高手》带你进入图像处理与计算机视觉的大门！解锁Python编程的无限可能：《奇妙的Python》带你漫游代码世界随着人工智能技术的不断发展，知识图谱已成为信息检索、推荐系统、自然语言处理等领域的重要技术之一。本文将详细介绍如何使用Python构建知…...

编程日记 2025/7/12 14:39:15

Spring WebSocket 与 STOMP 协议结合实现私聊私信功能

目录后端pom.xmlConfig配置类Controller类DTO 前端安装相关依赖websocketService.js接口javascripthtmlCSS 效果展示简单测试连接： 报错解决方法1、vue3 使用SockJS报错 ReferenceError: global is not defined 功能补充拓展1. 安全性和身份验证2. 异常处理3. 消息…...

编程日记 2025/7/12 20:32:16

【Matlab高端绘图SCI绘图模板】第05期绘制高阶折线图

1.折线图简介折线图是一个由点和线组成的统计图表，常用来表示数值随连续时间间隔或有序类别的变化。在折线图中，x 轴通常用作连续时间间隔或有序类别（比如阶段1，阶段2，阶段3）。y 轴用于量化的数据&#x…...

编程日记 2025/7/8 7:45:08

逻辑复制parallel并发参数测试

一、测试结果、测试环境描述

1.1、测试结果

1.2、测试环境

二、逻辑复制环境搭建

2.1、发布端环境部署

2.2、订阅端环境部署

2.3、数据同步验证

2.4、给cpu表放入1000万条数据

三、测试

3.1、更新1000条数据

3.1.1、开启并发参数

3.1.2、使用默认参数

3.2、更新5万条数据

3.2.1、开启并发参数

3.2.2、使用默认参数

3.3、更新10万条数据

3.3.1、开启并发参数

3.3.2、使用默认参数

3.4、更新30万条数据

3.4.1、开启并发参数

3.4.2、使用默认参数

3.5、更新100万条数据

3.5.1、开启并发参数

3.5.2、使用默认参数

四、逻辑复制参考文献

相关文章：