{"id":198871,"date":"2025-04-10T15:31:13","date_gmt":"2025-04-10T07:31:13","guid":{"rendered":"https:\/\/server.hk\/cnblog\/?p=198871"},"modified":"2025-04-23T17:31:48","modified_gmt":"2025-04-23T09:31:48","slug":"go%e8%af%ad%e8%a8%80channel%e5%ae%9e%e6%88%98%ef%bc%9a%e9%a6%99%e6%b8%af%e6%9c%8d%e5%8a%a1%e5%99%a8%e9%ab%98%e5%b9%b6%e5%8f%91%e6%95%b0%e6%8d%ae%e6%89%b9%e9%87%8f%e5%a4%84%e7%90%86%e6%96%b9%e6%a1%88","status":"publish","type":"post","link":"https:\/\/server.hk\/cnblog\/198871\/","title":{"rendered":"Go\u8bed\u8a00Channel\u6279\u91cf\u8bfb\u53d6\u6280\u5de7\u5168\u9762\u89e3\u6790\uff1a\u5e76\u53d1\u6027\u80fd\u4f18\u5316\u7684\u5b9e\u6218\u6307\u5357"},"content":{"rendered":"

\u5728\u73b0\u4ee3\u9ad8\u5e76\u53d1\u573a\u666f\u4e2d\uff0cGo\u8bed\u8a00<\/strong>\u4ee5\u5176\u8f7b\u91cf\u7ea7\u7684\u534f\u7a0b\uff08goroutine\uff09\u548c\u539f\u751f\u5e76\u53d1\u652f\u6301\u5e7f\u53d7\u6b22\u8fce\u3002\u5176\u4e2d\uff0cchannel<\/code>\u4f5c\u4e3aGo\u5e76\u53d1\u6a21\u578b\u7684\u6838\u5fc3\u7ec4\u4ef6\uff0c\u627f\u62c5\u7740\u534f\u7a0b\u95f4\u901a\u4fe1\u7684\u5173\u952e\u89d2\u8272\u3002\u5728\u5b9e\u9645\u5f00\u53d1\u4e2d\uff0c\u5f00\u53d1\u8005\u5e38\u5e38\u9700\u8981\u6279\u91cf\u8bfb\u53d6channel\u4e2d\u7684\u6570\u636e\uff0c\u4ee5\u63d0\u5347\u5904\u7406\u6548\u7387\u3001\u51cf\u5c11\u5207\u7247\u6269\u5bb9\u6b21\u6570\uff0c\u5e76\u907f\u514d\u8fc7\u591a\u7684\u4e0a\u4e0b\u6587\u5207\u6362\u3002<\/p>\n

\u672c\u6587\u5c06\u7cfb\u7edf\u4ecb\u7ecd\u591a\u79cd\u5728Go\u4e2d\u5b9e\u73b0channel\u6279\u91cf\u8bfb\u53d6\u7684\u65b9\u6cd5\uff0c\u5305\u542b\u57fa\u7840\u8bfb\u53d6\u3001\u8d85\u65f6\u63a7\u5236\u3001\u9ad8\u7ea7\u6a21\u5f0f\u548c\u6027\u80fd\u4f18\u5316\uff0c\u5e76\u7ed3\u5408\u5b9e\u6218\u573a\u666f\u52a0\u4ee5\u8bf4\u660e\uff0c\u9002\u5408\u6784\u5efa\u9ad8\u6027\u80fd\u65e5\u5fd7\u7cfb\u7edf\u3001\u6570\u636e\u5e93\u6279\u91cf\u5165\u5e93\u7b49\u540e\u7aef\u5e94\u7528\u3002\u540c\u65f6\uff0c\u6211\u4eec\u4e5f\u5efa\u8bae\u5c06\u8fd9\u7c7b\u9ad8\u5e76\u53d1\u4efb\u52a1\u90e8\u7f72\u5728\u9999\u6e2fVPS<\/strong>\u6216\u9999\u6e2f\u4e91\u670d\u52a1\u5668<\/strong>\u73af\u5883\u4e2d\uff0c\u00a0\u63d0\u4f9b\u7684\u9ad8\u901f\u7f51\u7edc\u4e0e\u7a33\u5b9a\u8d44\u6e90\uff0c\u6700\u5927\u9650\u5ea6\u4fdd\u969c\u670d\u52a1\u7684\u54cd\u5e94\u901f\u5ea6\u4e0e\u53ef\u9760\u6027\u3002<\/p>\n

\n

\u4e00\u3001\u57fa\u7840\u8bfb\u53d6\u65b9\u5f0f<\/h2>\n

1. \u4f7f\u7528for-range<\/code>\u904d\u5386channel<\/h3>\n

\u6700\u76f4\u63a5\u7684\u65b9\u5f0f\u662f\u4f7f\u7528Go\u7684for-range<\/code>\u8bed\u6cd5\u6301\u7eed\u4ecechannel\u4e2d\u8bfb\u53d6\u6570\u636e\uff0c\u76f4\u5230channel\u88ab\u5173\u95ed\uff1a<\/p>\n

func readAll(ch <-chan int) []int {\r\n    var result []int\r\n    for v := range ch {\r\n        result = append(result, v)\r\n    }\r\n    return result\r\n}\r\n<\/code><\/pre>\n
2. \u6309\u6279\u8bfb\u53d6\u56fa\u5b9a\u6570\u91cf<\/h3>\n
\u5f53\u6bcf\u6b21\u8bfb\u53d6\u7684\u6570\u636e\u91cf\u9700\u8981\u63a7\u5236\u65f6\uff0c\u53ef\u4ee5\u8bbe\u7f6e\u4e00\u4e2a\u6279\u91cf\u5927\u5c0fbatchSize<\/code>\uff0c\u6309\u5757\u8fd4\u56de\uff1a<\/p>\n
func batchRead(ch <-chan int, batchSize int) [][]int {\r\n    var batches [][]int\r\n    batch := make([]int, 0, batchSize)\r\n    for v := range ch {\r\n        batch = append(batch, v)\r\n        if len(batch) == batchSize {\r\n            batches = append(batches, batch)\r\n            batch = make([]int, 0, batchSize)\r\n        }\r\n    }\r\n    if len(batch) > 0 {\r\n        batches = append(batches, batch)\r\n    }\r\n    return batches\r\n}\r\n<\/code><\/pre>\n
\n
\u4e8c\u3001\u5e26\u8d85\u65f6\u63a7\u5236\u7684\u8bfb\u53d6\u6a21\u5f0f<\/h2>\n
1. \u4f7f\u7528time.After<\/code>\u63a7\u5236\u8d85\u65f6\u65f6\u95f4<\/h3>\n
func batchWithTimeout(ch <-chan int, size int, timeout time.Duration) ([]int, error) {\r\n    var batch []int\r\n    timer := time.After(timeout)\r\n    for {\r\n        select {\r\n        case v, ok := <-ch:\r\n            if !ok {\r\n                return batch, nil\r\n            }\r\n            batch = append(batch, v)\r\n            if len(batch) == size {\r\n                return batch, nil\r\n            }\r\n        case <-timer:\r\n            if len(batch) > 0 {\r\n                return batch, nil\r\n            }\r\n            return nil, fmt.Errorf(\"batch timeout\")\r\n        }\r\n    }\r\n}\r\n<\/code><\/pre>\n
2. \u5229\u7528context.Context<\/code>\u4f18\u96c5\u9000\u51fa<\/h3>\n
func batchWithContext(ctx context.Context, ch <-chan int, size int) ([]int, error) {\r\n    var batch []int\r\n    for {\r\n        select {\r\n        case <-ctx.Done():\r\n            return batch, ctx.Err()\r\n        case v, ok := <-ch:\r\n            if !ok {\r\n                return batch, nil\r\n            }\r\n            batch = append(batch, v)\r\n            if len(batch) == size {\r\n                return batch, nil\r\n            }\r\n        }\r\n    }\r\n}\r\n<\/code><\/pre>\n
\n
\u4e09\u3001\u9ad8\u9636\u8bfb\u53d6\u6280\u5de7\uff1a\u975e\u963b\u585e\u4e0e\u901a\u9053\u5d4c\u5957<\/h2>\n
1. \u975e\u963b\u585e\u8bfb\u53d6\u4e00\u6279\u6570\u636e<\/h3>\n
func nonBlockingRead(ch <-chan int, size int) []int {\r\n    var batch []int\r\n    for i := 0; i < size; i++ {\r\n        select {\r\n        case v := <-ch:\r\n            batch = append(batch, v)\r\n        default:\r\n            return batch\r\n        }\r\n    }\r\n    return batch\r\n}\r\n<\/code><\/pre>\n
2. \u4f7f\u7528channel\u7684channel\u4f20\u9012\u5b8c\u6574\u6279\u6b21<\/h3>\n
func sendBatch(ch chan<- []int, size int) {\r\n    defer close(ch)\r\n    batch := make([]int, 0, size)\r\n    for i := 0; i < 1000; i++ {\r\n        batch = append(batch, i)\r\n        if len(batch) == size {\r\n            ch <- batch\r\n            batch = make([]int, 0, size)\r\n        }\r\n    }\r\n    if len(batch) > 0 {\r\n        ch <- batch\r\n    }\r\n}\r\n<\/code><\/pre>\n
\n
\u56db\u3001\u6027\u80fd\u4f18\u5316\u5efa\u8bae<\/h2>\n
1. \u9884\u5206\u914d\u5207\u7247\u51cf\u5c11\u5185\u5b58\u5f00\u9500<\/h3>\n
\u63d0\u524d\u8bbe\u5b9a\u5207\u7247\u5bb9\u91cf\u53ef\u4ee5\u51cf\u5c11\u5185\u5b58\u6269\u5bb9\u5e26\u6765\u7684\u6027\u80fd\u635f\u8017\uff1a<\/p>\n
batch := make([]int, 0, batchSize)\r\n<\/code><\/pre>\n
2. \u4f7f\u7528sync.Pool<\/code>\u590d\u7528\u5185\u5b58\u5bf9\u8c61<\/h3>\n
var pool = sync.Pool{\r\n    New: func() interface{} {\r\n        return make([]int, 0, 100)\r\n    },\r\n}\r\n<\/code><\/pre>\n
\n
\u4e94\u3001\u771f\u5b9e\u6848\u4f8b\uff1a\u65e5\u5fd7\u6536\u96c6\u4e0e\u5904\u7406\u7cfb\u7edf<\/h2>\n
func logAggregator(logCh <-chan LogEntry, batchSize int, flushInterval time.Duration) {\r\n    batch := make([]LogEntry, 0, batchSize)\r\n    ticker := time.NewTicker(flushInterval)\r\n    defer ticker.Stop()\r\n\r\n    for {\r\n        select {\r\n        case log, ok := <-logCh:\r\n            if !ok && len(batch) > 0 {\r\n                flushLogs(batch)\r\n                return\r\n            }\r\n            batch = append(batch, log)\r\n            if len(batch) == batchSize {\r\n                flushLogs(batch)\r\n                batch = make([]LogEntry, 0, batchSize)\r\n            }\r\n        case <-ticker.C:\r\n            if len(batch) > 0 {\r\n                flushLogs(batch)\r\n                batch = make([]LogEntry, 0, batchSize)\r\n            }\r\n        }\r\n    }\r\n}\r\n<\/code><\/pre>\n
\u6b64\u7c7b\u65e5\u5fd7\u5904\u7406\u670d\u52a1\u975e\u5e38\u9002\u5408\u90e8\u7f72\u4e8e\u5e26\u5bbd\u5927\u3001\u5ef6\u8fdf\u4f4e\u7684\u9999\u6e2f\u72ec\u7acb\u670d\u52a1\u5668<\/strong><\/a>\uff0c\u53ef\u524d\u5f80\u5b98\u7f51\u4e86\u89e3\u66f4\u591a\u6027\u80fd\u65b9\u6848\u3002<\/p>\n
\n
\u603b\u7ed3\u4e0e\u63a8\u8350<\/h2>\n
\u901a\u8fc7\u7075\u6d3b\u638c\u63e1Go\u4e2dchannel\u7684\u6279\u91cf\u8bfb\u53d6\u6280\u5de7\uff0c\u4e0d\u4ec5\u80fd\u63d0\u5347\u5e76\u53d1\u5904\u7406\u7684\u6548\u7387\uff0c\u66f4\u80fd\u6784\u5efa\u51fa\u54cd\u5e94\u8fc5\u901f\u3001\u8d44\u6e90\u5229\u7528\u7387\u9ad8\u7684\u540e\u7aef\u7cfb\u7edf\u3002\u5efa\u8bae\u914d\u5408\u53ef\u9760\u7684\u90e8\u7f72\u5e73\u53f0\u4f7f\u7528\uff0c\u5982\u9999\u6e2f\u4e91\u670d\u52a1\u5668<\/strong>\u3001\u9999\u6e2fVPS<\/strong>\u7b49\uff0c\u53ef\u4ee5\u5e2e\u52a9\u5f00\u53d1\u8005\u5728\u9762\u5bf9\u9ad8\u8bbf\u95ee\u91cf\u3001\u9ad8\u6570\u636e\u541e\u5410\u7684\u670d\u52a1\u65f6\uff0c\u4f9d\u65e7\u4fdd\u6301\u7cfb\u7edf\u7684\u9ad8\u7a33\u5b9a\u6027\u4e0e\u53ef\u6269\u5c55\u6027\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u5728\u73b0\u4ee3\u9ad8\u5e76\u53d1\u573a\u666f\u4e2d\uff0cGo\u8bed\u8a00\u4ee5\u5176...<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[4924],"tags":[],"class_list":["post-198871","post","type-post","status-publish","format-standard","hentry","category-setup-tutorials"],"_links":{"self":[{"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/posts\/198871","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/comments?post=198871"}],"version-history":[{"count":0,"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/posts\/198871\/revisions"}],"wp:attachment":[{"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/media?parent=198871"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/categories?post=198871"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/tags?post=198871"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}