{"id":42672,"date":"2024-12-01T09:58:29","date_gmt":"2024-12-01T01:58:29","guid":{"rendered":"https:\/\/fwq.ai\/blog\/42672\/"},"modified":"2024-12-01T09:58:29","modified_gmt":"2024-12-01T01:58:29","slug":"%e4%bd%bf%e7%94%a8-etcd-%e9%9b%86%e7%be%a4%e7%94%9f%e6%88%90%e5%ba%8f%e5%88%97%e5%8f%b7","status":"publish","type":"post","link":"https:\/\/fwq.ai\/blog\/42672\/","title":{"rendered":"\u4f7f\u7528 etcd \u96c6\u7fa4\u751f\u6210\u5e8f\u5217\u53f7"},"content":{"rendered":"<p><b><\/b> <\/p>\n<p>\u5f53\u524d\u4f4d\u7f6e\uff1a <span>&gt;<\/span>  <span>&gt;<\/span>  <span>&gt;<\/span>  <span>&gt;<\/span> <span>\u4f7f\u7528 etcd \u96c6\u7fa4\u751f\u6210\u5e8f\u5217\u53f7<\/span><\/p>\n<h1>\u4f7f\u7528 etcd \u96c6\u7fa4\u751f\u6210\u5e8f\u5217\u53f7<\/h1>\n<p><span>\u6765\u6e90\uff1astackoverflow<\/span><br \/>\n<span>2024-04-25 10:15:36<\/span><br \/>\n<span><i><\/i>0\u6d4f\u89c8<\/span><br \/>\n<span style=\"cursor: pointer\"><i><\/i>\u6536\u85cf<\/span> <\/p>\n<p>\u672c\u7bc7\u6587\u7ae0\u7ed9\u5927\u5bb6\u5206\u4eab\u300a\u4f7f\u7528 etcd \u96c6\u7fa4\u751f\u6210\u5e8f\u5217\u53f7\u300b\uff0c\u8986\u76d6\u4e86Golang\u7684\u5e38\u89c1\u57fa\u7840\u77e5\u8bc6\uff0c\u5176\u5b9e\u4e00\u4e2a\u8bed\u8a00\u7684\u5168\u90e8\u77e5\u8bc6\u70b9\u4e00\u7bc7\u6587\u7ae0\u662f\u4e0d\u53ef\u80fd\u8bf4\u5b8c\u7684\uff0c\u4f46\u5e0c\u671b\u901a\u8fc7\u8fd9\u4e9b\u95ee\u9898\uff0c\u8ba9\u8bfb\u8005\u5bf9\u81ea\u5df1\u7684\u638c\u63e1\u7a0b\u5ea6\u6709\u4e00\u5b9a\u7684\u8ba4\u8bc6(B \u6570)\uff0c\u4ece\u800c\u5f25\u8865\u81ea\u5df1\u7684\u4e0d\u8db3\uff0c\u66f4\u597d\u7684\u638c\u63e1\u5b83\u3002<\/p>\n<p> \u95ee\u9898\u5185\u5bb9<br \/>\n <\/p>\n<p>\u6211\u6b63\u5728\u63a2\u7d22 etcd \u6765\u5b9e\u73b0\u5206\u5e03\u5f0f\u73af\u5883\u7684\u5e8f\u53f7\u751f\u6210\u5668\u3002\u6211\u7684\u8981\u6c42\u662f\u751f\u6210\u8981\u5728\u540c\u4e00\u5e94\u7528\u7a0b\u5e8f\u7684\u591a\u4e2a\u5b9e\u4f8b\u7684\u6bcf\u4e2a\u8bf7\u6c42\u4e2d\u4f7f\u7528\u7684\u975e\u91cd\u590d\u5e8f\u5217\u53f7\u3002\u5e76\u4e14\u7b26\u5408\u8981\u6c42\u7684\u8fd9\u6837\u7684\u5e94\u7528\u7a0b\u5e8f\u53ef\u4ee5\u6709n\u4e2a\u3002\u6211\u4f7f\u7528 golang \u5ba2\u6237\u7aef\u5305\u4e2d\u63d0\u4f9b\u7684 stm \u548c\u4e92\u65a5\u9501\u4ee5\u591a\u79cd\u65b9\u5f0f\u5bf9\u6b64\u8fdb\u884c\u4e86 poc<\/p>\n<p>\u5728\u672c\u5730\u673a\u5668\u8bbe\u7f6e\u4e2d\u4f7f\u7528\u5355\u8282\u70b9 etcd \u670d\u52a1\u5668\uff08\u5c06\u662f\u81f3\u5c11 3 \u4e2a\u8282\u70b9\u96c6\u7fa4\uff0c\u4ee5\u4fbf raft \u5728\u751f\u4ea7\u4e2d\u5de5\u4f5c\uff09\uff0c\u6211\u7f16\u5199\u4e86\u4e00\u4e2a\u7b80\u5355\u7684\u7a0b\u5e8f\u6765\u5728 500 \u4e2a goroutine \u4e2d\u751f\u6210 ids\uff08\u6570\u5b57\uff09\u3002\u6bcf\u4e2a\u4f8b\u7a0b\u5404\u6709 10 \u4e2a id\uff0c\u56e0\u6b64\u603b\u5171\u6709 5000 \u4e2a id\u3002\u6839\u636e\u65f6\u95f4\u7edf\u8ba1\uff0c\u5177\u6709\u91cd\u8bd5\u5c1d\u8bd5\u7684 stm \u6bd4\u4e92\u65a5\u9501\u8868\u73b0\u66f4\u597d\u3002\u9664\u4e86\u8fd9\u4e9b\u65b9\u6cd5\u4e4b\u5916\uff0c\u662f\u5426\u6709\u66f4\u597d\u7684\u9009\u62e9\u6765\u5b9e\u73b0\u5e8f\u5217\u53f7\u751f\u6210\uff1f\u9996\u5148\uff0cetcd \u53ef\u4ee5\u7528\u4e8e\u6b64\u76ee\u7684\u5417\uff1f<\/p>\n<p>ps\uff1a\u6211\u9644\u4e0a\u4ee3\u7801\u793a\u4f8b\u4ec5\u4f9b\u53c2\u8003\u3002\u6211\u4e0d\u6307\u671b\u5b83\u4f1a\u88ab\u5ba1\u67e5\u3002\u6211\u5173\u5fc3\u7684\u662f\u4f7f\u7528 etcd \u751f\u6210\u5e8f\u5217\u53f7\u7684\u6b63\u786e\u65b9\u6cd5<\/p>\n<pre>package main\n\nimport (\n    \"context\"\n    \"errors\"\n    \"strconv\"\n    \"sync\"\n    \"sync\/atomic\"\n    \"time\"\n\n    CONC \"go.etcd.io\/etcd\/clientv3\/concurrency\"\n\n    \"github.com\/golang\/glog\"\n    ETCD \"go.etcd.io\/etcd\/clientv3\"\n)\n\nvar client *ETCD.Client\nvar deadline = 200 * time.Second\n\nfunc main() {\n    var err error\n    client, err = ETCD.New(ETCD.Config{\n        Endpoints: []string{\"127.0.0.1:2379\"},\n    })\n    if err != nil {\n        glog.Errorln(\"err:\", err)\n        return\n    }\n    idGen := &amp;SeqIDGenerator{key: \"_id\"}\n\n    err = func() error {\n        ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)\n        defer cancel()\n        _, err = client.Put(ctx, idGen.key, strconv.FormatInt(0, 10))\n        return err\n    }()\n    if err != nil {\n        glog.Errorln(\"err:\", err)\n        return\n    }\n    id, err := idGen.nextWithMutex()\n    if err != nil {\n        glog.Errorln(\"err:\", err)\n        return\n    }\n    glog.Errorln(\"done\", id)\n    id, err = idGen.nextWithSTMSerialiazable()\n    if err != nil {\n        glog.Errorln(\"err:\", err)\n        return\n    }\n    glog.Errorln(\"done\", id)\n    \/\/ st := time.Now()\n    \/\/ stressSTMSerialiazableSeq(idGen)\n    \/\/ glog.Errorln(time.Since(st))\n\n}\n\ntype SeqIDGenerator struct {\n    key string\n}\n\nfunc (idGen *SeqIDGenerator) nextWithSTMSerialiazable() (int64, error) {\n\n    var retrived int64\n    ctx, cancel := context.WithTimeout(context.Background(), deadline)\n    defer cancel()\n    var err error\n    retry := retry\n    for retry &gt; 0 {\n        retry--\n        stmresp, err := CONC.NewSTMSerializable(ctx, client, func(s CONC.STM) error {\n            v := s.Get(idGen.key)\n            retrived, err = strconv.ParseInt(v, 10, 64)\n            if err != nil {\n                return err\n            }\n            retrived++\n            s.Put(idGen.key, strconv.FormatInt(retrived, 10))\n            return nil\n        })\n        if err != nil {\n            continue\n        } else if stmresp.Succeeded {\n            return retrived, nil\n        }\n\n    }\n    return 0, errors.New(\"ID gen failed. Retry exceeded\")\n}\n\nfunc (idGen *SeqIDGenerator) nextWithMutex() (int64, error) {\n    s, err := CONC.NewSession(client) \/\/ explore options to pass\n    if err != nil {\n        return 0, err\n    }\n    m := CONC.NewMutex(s, idGen.key)\n    ctx, cancel := context.WithTimeout(context.Background(), deadline)\n    defer cancel()\n    m.Lock(ctx)\n    defer m.Unlock(ctx)\n    resp, err := client.Get(ctx, idGen.key)\n    if err != nil {\n        return 0, err\n    }\n\n    retrived, err := strconv.ParseInt(string(resp.OpResponse().Get().Kvs[0].Value), 10, 64)\n    if err != nil {\n        return 0, err\n    }\n    retrived++\n    _, err = client.Put(ctx, idGen.key, strconv.FormatInt(retrived, 10))\n    if err != nil {\n        return 0, err\n    }\n    return retrived, nil\n}\n\nfunc (idGen *SeqIDGenerator) nextWithSTMReapeatable() (int64, error) {\n\n    var retrived int64\n    ctx, cancel := context.WithTimeout(context.Background(), deadline)\n    defer cancel()\n    var err error\n    retry := retry\n    for retry &gt; 0 {\n        retry--\n        stmresp, err := CONC.NewSTMRepeatable(ctx, client, func(s CONC.STM) error {\n            v := s.Get(idGen.key)\n            retrived, err = strconv.ParseInt(v, 10, 64)\n            if err != nil {\n                return err\n            }\n            retrived++\n            s.Put(idGen.key, strconv.FormatInt(retrived, 10))\n            return nil\n        })\n        if err != nil {\n            continue\n        } else if stmresp.Succeeded {\n            return retrived, nil\n        }\n\n    }\n    return 0, errors.New(\"ID gen failed. Retry exceeded\")\n}\n\nvar n int = 500\nvar retry int = 40 \/\/ move as conf\n\nfunc stressMutex(idGen *SeqIDGenerator) {\n    wg := &amp;sync.WaitGroup{}\n    wg.Add(n)\n    for i := 0; i &lt; n; i++ {\n        go func(i int) {\n            defer wg.Done()\n            for j := 0; j &lt; 10; j++ {\n                _, err := idGen.nextWithMutex()\n                if err != nil {\n                    glog.Errorln(\"err:\", err)\n                    return\n                }\n            }\n        }(i)\n    }\n    wg.Wait()\n\n}\n\nfunc stressMutexSeq(idGen *SeqIDGenerator) {\n    for i := 0; i &lt; n; i++ {\n        for j := 0; j &lt; 10; j++ {\n            _, err := idGen.nextWithMutex()\n            if err != nil {\n                glog.Errorln(\"err:\", err)\n            }\n        }\n    }\n\n}\n\nfunc stressSTMSerialiazableSeq(idGen *SeqIDGenerator) {\n    for i := 0; i &lt; n; i++ {\n        for j := 0; j &lt; 10; j++ {\n            _, err := idGen.nextWithSTMSerialiazable()\n            if err != nil {\n                glog.Errorln(\"err:\", err)\n            }\n        }\n    }\n\n}\n\nfunc stressSTMReapeatableSeq(idGen *SeqIDGenerator) {\n    for i := 0; i &lt; n; i++ {\n        for j := 0; j &lt; 10; j++ {\n            _, err := idGen.nextWithSTMReapeatable()\n            if err != nil {\n                glog.Errorln(\"err:\", err)\n            }\n        }\n    }\n\n}\n\nfunc stressSTMSerialiazable(idGen *SeqIDGenerator) {\n    wg := &amp;sync.WaitGroup{}\n    wg.Add(n)\n    var success int64\n    for i := 0; i &lt; n; i++ {\n        go func(i int) {\n            defer wg.Done()\n            for j := 0; j &lt; 10; j++ {\n                _, err := idGen.nextWithSTMSerialiazable()\n                if err != nil {\n                    glog.Errorln(\"err:\", err)\n                } else {\n                    atomic.AddInt64(&amp;success, 1)\n                }\n\n            }\n        }(i)\n    }\n    wg.Wait()\n    glog.Errorln(\"success:\", success)\n\n}\n\nfunc stressSTMReapeatable(idGen *SeqIDGenerator) {\n    wg := &amp;sync.WaitGroup{}\n    wg.Add(n)\n    var success int64\n    for i := 0; i &lt; n; i++ {\n        go func(i int) {\n            defer wg.Done()\n            for j := 0; j &lt; 10; j++ {\n                _, err := idGen.nextWithSTMReapeatable()\n                if err != nil {\n                    glog.Errorln(\"err:\", err)\n                } else {\n                    atomic.AddInt64(&amp;success, 1)\n                }\n\n            }\n        }(i)\n    }\n    wg.Wait()\n    glog.Errorln(\"success:\", success)\n\n}<\/pre>\n<p> <\/p>\n<h2>\u89e3\u51b3\u65b9\u6848<\/h2>\n<p> <\/p>\n<p>\u6211\u81ea\u5df1\u4e5f\u5728\u770b\u8fd9\u4e2a\u3002\u4ee5\u4e0b\u662f\u4e24\u79cd\u53ef\u80fd\u7684\u65b9\u6cd5\uff1a \uff08\u6211\u662f etcd \u7684\u65b0\u624b\uff0c\u6240\u4ee5\u4e70\u8005\u81ea\u8d1f\uff09<\/p>\n<ol>\n<li>\u5982\u679c\u60a8\u53ef\u4ee5\u63a5\u53d7\u72ec\u7279\u7684\u5355\u8c03\u503c<em>\u548c\u5927\u95f4\u9699<\/em>\uff0c\u60a8\u53ef\u4ee5\u4f7f\u7528etcd\u96c6\u7fa4\u201c\u4fee\u8ba2\u7248\u201d\uff0c\u6bcf\u6b21\u4fee\u6539\u5b58\u50a8\u65f6\u5b83\u90fd\u4f1a\u589e\u52a0\uff1a\u653e\u7f6e\u5bc6\u94a5\u7b49\u3002 \uff08\u8be5\u503c\u662f\u4ece\u6210\u719f\u7684 etcd \u5ba2\u6237\u7aef\u4e2d\u7684 put \u64cd\u4f5c\u8fd4\u56de\u7684\uff09<\/li>\n<\/ol>\n<pre>$ etcdctl put k v -w json\n{\"header\":{\"cluster_id\":14841639068965178418,\"member_id\":10276657743932975437,\"revision\":8,\"raft_term\":3}}<\/pre>\n<p>\u4f7f\u7528\u5ba2\u6237\u7aef\u4e2d\u201c\u4fee\u8ba2\u201d\u8fd4\u56de\u7684\u503c\u3002\u8fd9\u5b9e\u9645\u4e0a\u5e94\u8be5\u662f\u4e00\u4e2a \u4e3a\u8c03\u7528\u201cput\u201d\u7684\u5ba2\u6237\u7aef\u751f\u6210\u552f\u4e00\u503c\uff08\u5168\u5c40\uff09\u7684\u539f\u5b50\u64cd\u4f5c\u3002<\/p>\n<ol>\n<li>\u5982\u679c\u60a8\u9700\u8981\u6ca1\u6709\u95f4\u9699\u7684\u552f\u4e00\u987a\u5e8f\u503c\uff0c\u770b\u8d77\u6765\u60a8\u53ef\u4ee5\u4f7f\u7528\u4e0e\u6bcf\u4e2a\u952e\u5173\u8054\u7684\u201cmod_revision\u201d\u503c\u3002 \u5b83\u662f\u6bcf\u4e2a\u952e\u7684\uff0c\u5e76\u4e14\u5728\u6bcf\u6b21\u653e\u7f6e\u540e\u90fd\u4f1a\u589e\u52a0\u3002 \u5f53\u60a8\u5220\u9664\u5bc6\u94a5\u65f6\uff0c\u5b83\u4f1a\u91cd\u7f6e\u4e3a\u96f6\u3002<\/li>\n<\/ol>\n<p>\u8bd5\u8bd5\u8fd9\u4e2a\uff1a<\/p>\n<pre>$ etcdctl put k v --prev-kv -w json\n{\"header\":{\"cluster_id\":14841639068965178418,\"member_id\":10276657743932975437,\"revision\":10,\"raft_term\":3},\"prev_kv\":{\"key\":\"aw==\",\"create_revision\":8,\"mod_revision\":8,\"version\":1,\"value\":\"dg==\"}}<\/pre>\n<p>\u540c\u6837\uff0c\u5ba2\u6237\u7aef\u4e2d\u4e3a\u201cmod_revision\u201d\u8fd4\u56de\u7684\u503c\u3002 \u8fd9\u53d6\u51b3\u4e8e &#8216;prev-kv&#8217; \u662f\u539f\u5b50 wrt &#8216;put&#8217;\uff0c\u8fd9\u6837\u4efb\u4f55 &#8216;put&#8217;+&#8217;prev-key&#8217; \u5f62\u6210\u539f\u5b50\u64cd\u4f5c\u3002\u6211\u76f8\u4fe1\u786e\u5b9e\u5982\u6b64\uff0c\u4f46\u6ca1\u6709\u5f15\u7528\u3002<\/p>\n<p>\u6211\u7684\u89c4\u5219\u662f\u5982\u4f55\u5728\u4e24\u8005\u4e4b\u95f4\u505a\u51fa\u51b3\u5b9a\u7684\uff1a<\/p>\n<ol>\n<li>\n<p>\u5982\u679c\u6211\u53ef\u4ee5\u63a5\u53d7\u6709\u95f4\u9699\u7684\u552f\u4e00\u503c\uff0c\u8bf7\u4f7f\u7528\u5168\u5c40\u201c\u4fee\u8ba2\u7248\u201d\uff0c \u9664\u975e\u60a8\u4ece\u65b0\u7684 kv \u5b58\u50a8\u5f00\u59cb\uff0c\u5426\u5219\u5b83\u65e0\u6cd5\u91cd\u7f6e\u4e3a\u96f6\u3002 \u8fd9\u662f\u6211\u66f4\u559c\u6b22\u7684\u65b9\u6cd5\uff0c\u56e0\u4e3a\u8fd9\u4e0d\u4f1a\u88ab\u610f\u5916\u91cd\u7f6e\u3002<\/p>\n<\/li>\n<li>\n<p>\u5982\u679c\u60a8\u5fc5\u987b\u5177\u6709\u552f\u4e00\u7684\u987a\u5e8f\u503c\uff0c\u8bf7\u4f7f\u7528\u6bcf\u4e2a\u952e\u201cmod_revision\u201d\u3002 \u4f46\u8bf7\u6ce8\u610f\uff0c\u5982\u679c\u60a8\u4e0d\u5c0f\u5fc3\u5220\u9664\u4e86\u7528\u4e8e\u8ddf\u8e2a mod_revision \u7684 k\/v\uff0c \u5e8f\u5217\u53f7\u5c06\u4ece\u96f6\u5f00\u59cb\uff01\u8fd9\u53ef\u80fd\u4f1a\u7ed9\u60a8\u5e26\u6765\u5927\u95ee\u9898\u3002\u4f46\u8fd9\u91cc\u7684\u4f18\u70b9\u662f\u60a8\u53ef\u4ee5\u62e5\u6709\u591a\u4e2a\u8fde\u7eed\u7684\u552f\u4e00\u5e8f\u5217\u53f7\u3002<\/p>\n<\/li>\n<\/ol>\n<p>\u5230\u8fd9\u91cc\uff0c\u6211\u4eec\u4e5f\u5c31\u8bb2\u5b8c\u4e86\u300a\u4f7f\u7528 etcd \u96c6\u7fa4\u751f\u6210\u5e8f\u5217\u53f7\u300b\u7684\u5185\u5bb9\u4e86\u3002\u4e2a\u4eba\u8ba4\u4e3a\uff0c\u57fa\u7840\u77e5\u8bc6\u7684\u5b66\u4e60\u548c\u5de9\u56fa\uff0c\u662f\u4e3a\u4e86\u66f4\u597d\u7684\u5c06\u5176\u8fd0\u7528\u5230\u9879\u76ee\u4e2d\uff0c\u6b22\u8fce\u5173\u6ce8\u7c73\u4e91\u516c\u4f17\u53f7\uff0c\u5e26\u4f60\u4e86\u89e3\u66f4\u591a\u5173\u4e8e\u7684\u77e5\u8bc6\u70b9\uff01<\/p>\n","protected":false},"excerpt":{"rendered":"<p>\u5f53\u524d\u4f4d\u7f6e\uff1a &gt; &gt; &gt; &gt; \u4f7f\u7528 etcd \u96c6\u7fa4\u751f\u6210\u5e8f\u5217\u53f7 \u4f7f\u7528 etcd \u96c6\u7fa4\u751f\u6210\u5e8f\u5217\u53f7 \u6765\u6e90\uff1astackoverflow 2024-04-25 10:15:36 0\u6d4f\u89c8 \u6536\u85cf \u672c\u7bc7\u6587\u7ae0\u7ed9\u5927\u5bb6\u5206\u4eab\u300a\u4f7f\u7528 etcd \u96c6\u7fa4\u751f\u6210\u5e8f\u5217\u53f7\u300b\uff0c\u8986\u76d6\u4e86Golang\u7684\u5e38\u89c1\u57fa\u7840\u77e5\u8bc6\uff0c\u5176\u5b9e\u4e00\u4e2a\u8bed\u8a00\u7684\u5168\u90e8\u77e5\u8bc6\u70b9\u4e00\u7bc7\u6587\u7ae0\u662f\u4e0d\u53ef\u80fd\u8bf4\u5b8c\u7684\uff0c\u4f46\u5e0c\u671b\u901a\u8fc7\u8fd9\u4e9b\u95ee\u9898\uff0c\u8ba9\u8bfb\u8005\u5bf9\u81ea\u5df1\u7684\u638c\u63e1\u7a0b\u5ea6\u6709\u4e00\u5b9a\u7684\u8ba4\u8bc6(B \u6570)\uff0c\u4ece\u800c\u5f25\u8865\u81ea\u5df1\u7684\u4e0d\u8db3\uff0c\u66f4\u597d\u7684\u638c\u63e1\u5b83\u3002 \u95ee\u9898\u5185\u5bb9 \u6211\u6b63\u5728\u63a2\u7d22 etcd \u6765\u5b9e\u73b0\u5206\u5e03\u5f0f\u73af\u5883\u7684\u5e8f\u53f7\u751f\u6210\u5668\u3002\u6211\u7684\u8981\u6c42\u662f\u751f\u6210\u8981\u5728\u540c\u4e00\u5e94\u7528\u7a0b\u5e8f\u7684\u591a\u4e2a\u5b9e\u4f8b\u7684\u6bcf\u4e2a\u8bf7\u6c42\u4e2d\u4f7f\u7528\u7684\u975e\u91cd\u590d\u5e8f\u5217\u53f7\u3002\u5e76\u4e14\u7b26\u5408\u8981\u6c42\u7684\u8fd9\u6837\u7684\u5e94\u7528\u7a0b\u5e8f\u53ef\u4ee5\u6709n\u4e2a\u3002\u6211\u4f7f\u7528 golang \u5ba2\u6237\u7aef\u5305\u4e2d\u63d0\u4f9b\u7684 stm \u548c\u4e92\u65a5\u9501\u4ee5\u591a\u79cd\u65b9\u5f0f\u5bf9\u6b64\u8fdb\u884c\u4e86 poc \u5728\u672c\u5730\u673a\u5668\u8bbe\u7f6e\u4e2d\u4f7f\u7528\u5355\u8282\u70b9 etcd \u670d\u52a1\u5668\uff08\u5c06\u662f\u81f3\u5c11 3 \u4e2a\u8282\u70b9\u96c6\u7fa4\uff0c\u4ee5\u4fbf raft \u5728\u751f\u4ea7\u4e2d\u5de5\u4f5c\uff09\uff0c\u6211\u7f16\u5199\u4e86\u4e00\u4e2a\u7b80\u5355\u7684\u7a0b\u5e8f\u6765\u5728 500 \u4e2a goroutine \u4e2d\u751f\u6210 ids\uff08\u6570\u5b57\uff09\u3002\u6bcf\u4e2a\u4f8b\u7a0b\u5404\u6709 10 \u4e2a id\uff0c\u56e0\u6b64\u603b\u5171\u6709 5000 \u4e2a id\u3002\u6839\u636e\u65f6\u95f4\u7edf\u8ba1\uff0c\u5177\u6709\u91cd\u8bd5\u5c1d\u8bd5\u7684 stm \u6bd4\u4e92\u65a5\u9501\u8868\u73b0\u66f4\u597d\u3002\u9664\u4e86\u8fd9\u4e9b\u65b9\u6cd5\u4e4b\u5916\uff0c\u662f\u5426\u6709\u66f4\u597d\u7684\u9009\u62e9\u6765\u5b9e\u73b0\u5e8f\u5217\u53f7\u751f\u6210\uff1f\u9996\u5148\uff0cetcd \u53ef\u4ee5\u7528\u4e8e\u6b64\u76ee\u7684\u5417\uff1f ps\uff1a\u6211\u9644\u4e0a\u4ee3\u7801\u793a\u4f8b\u4ec5\u4f9b\u53c2\u8003\u3002\u6211\u4e0d\u6307\u671b\u5b83\u4f1a\u88ab\u5ba1\u67e5\u3002\u6211\u5173\u5fc3\u7684\u662f\u4f7f\u7528 etcd \u751f\u6210\u5e8f\u5217\u53f7\u7684\u6b63\u786e\u65b9\u6cd5 package main [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[17],"tags":[],"class_list":["post-42672","post","type-post","status-publish","format-standard","hentry","category-docker"],"_links":{"self":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/posts\/42672","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/comments?post=42672"}],"version-history":[{"count":0,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/posts\/42672\/revisions"}],"wp:attachment":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/media?parent=42672"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/categories?post=42672"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/tags?post=42672"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}