{"id":154,"date":"2026-06-19T12:58:24","date_gmt":"2026-06-19T04:58:24","guid":{"rendered":"https:\/\/zhishilib.com\/?p=154"},"modified":"2026-06-19T13:00:45","modified_gmt":"2026-06-19T05:00:45","slug":"%e5%9f%ba%e4%ba%8egolang%e7%9a%84%e6%99%ba%e6%85%a7%e7%9f%bf%e5%b1%b1%e4%bc%a0%e6%84%9f%e5%99%a8%e6%95%b0%e6%8d%ae%e5%ae%9e%e6%97%b6%e5%a4%84%e7%90%86%e7%b3%bb%e7%bb%9f%e8%ae%be%e8%ae%a1%e4%b8%8e","status":"publish","type":"post","link":"https:\/\/zhishilib.com\/index.php\/2026\/06\/19\/%e5%9f%ba%e4%ba%8egolang%e7%9a%84%e6%99%ba%e6%85%a7%e7%9f%bf%e5%b1%b1%e4%bc%a0%e6%84%9f%e5%99%a8%e6%95%b0%e6%8d%ae%e5%ae%9e%e6%97%b6%e5%a4%84%e7%90%86%e7%b3%bb%e7%bb%9f%e8%ae%be%e8%ae%a1%e4%b8%8e\/","title":{"rendered":"\u57fa\u4e8eGolang\u7684\u667a\u6167\u77ff\u5c71\u4f20\u611f\u5668\u6570\u636e\u5b9e\u65f6\u5904\u7406\u7cfb\u7edf\u8bbe\u8ba1\u4e0e\u5b9e\u73b0"},"content":{"rendered":"\n<p class=\"wp-block-paragraph\"><strong>\u4e00\u3001\u80cc\u666f\u4e0e\u6311\u6218<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\">\u5728\u667a\u6167\u77ff\u5c71\u5efa\u8bbe\u4e2d\uff0c\u5404\u7c7b\u4f20\u611f\u5668\uff08\u74e6\u65af\u6d53\u5ea6\u3001\u6e29\u5ea6\u3001\u538b\u529b\u3001\u632f\u52a8\u3001\u4f4d\u79fb\u7b49\uff09\u662f\u77ff\u5c71\u5b89\u5168\u76d1\u6d4b\u7684&#8221;\u795e\u7ecf\u672b\u68a2&#8221;\u3002\u8fd9\u4e9b\u4f20\u611f\u5668\u4ea7\u751f\u7684\u6d77\u91cf\u65f6\u5e8f\u6570\u636e\uff0c\u76f4\u63a5\u5173\u7cfb\u5230\u77ff\u5c71\u751f\u4ea7\u5b89\u5168\u548c\u4eba\u5458\u751f\u547d\u5b89\u5168\u3002\u7136\u800c\uff0c\u77ff\u5c71\u73af\u5883\u590d\u6742\uff0c\u4f20\u611f\u5668\u6570\u636e\u9762\u4e34\u56db\u5927\u6838\u5fc3\u6311\u6218\uff1a<\/p>\n\n\n\n<ul class=\"wp-block-list\">\n<li><strong>\u5b9e\u65f6\u6027<\/strong>\uff1a\u4e95\u4e0b\u4f20\u611f\u5668\u6570\u91cf\u5e9e\u5927\uff0c\u6bcf\u79d2\u4ea7\u751f\u6570\u4e07\u6761\u6570\u636e\uff0c\u9700\u8981\u6beb\u79d2\u7ea7\u5904\u7406\u5ef6\u8fdf<\/li>\n\n\n\n<li><strong>\u6709\u6548\u6027<\/strong>\uff1a\u4f20\u611f\u5668\u6545\u969c\u3001\u7535\u78c1\u5e72\u6270\u3001\u7f51\u7edc\u6296\u52a8\u5bfc\u81f4\u5927\u91cf\u566a\u58f0\u6570\u636e\u548c\u7f3a\u5931\u503c<\/li>\n\n\n\n<li><strong>\u771f\u5b9e\u6027<\/strong>\uff1a\u6570\u636e\u4f20\u8f93\u8fc7\u7a0b\u4e2d\u53ef\u80fd\u88ab\u7be1\u6539\u6216\u4e22\u5931\uff0c\u9700\u8981\u6570\u636e\u5b8c\u6574\u6027\u6821\u9a8c<\/li>\n\n\n\n<li><strong>\u53ca\u65f6\u6027<\/strong>\uff1a\u5f02\u5e38\u60c5\u51b5\uff08\u5982\u74e6\u65af\u8d85\u9650\uff09\u9700\u8981\u79d2\u7ea7\u544a\u8b66\u548c\u5e94\u6025\u54cd\u5e94<\/li>\n<\/ul>\n\n\n\n<p class=\"wp-block-paragraph\">\u672c\u6587\u5c06\u4ecb\u7ecd\u5982\u4f55\u4f7f\u7528Golang\u6784\u5efa\u4e00\u5957\u9ad8\u6027\u80fd\u7684\u4f20\u611f\u5668\u6570\u636e\u5b9e\u65f6\u5904\u7406\u7cfb\u7edf\uff0c\u786e\u4fdd\u6570\u636e\u7684&#8221;\u5b9e\u65f6\u3001\u6709\u6548\u3001\u771f\u5b9e\u3001\u53ca\u65f6&#8221;\u3002<\/p>\n\n\n\n<p class=\"wp-block-paragraph\"><strong>\u4e8c\u3001\u7cfb\u7edf\u6574\u4f53\u67b6\u6784<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\">\u7cfb\u7edf\u91c7\u7528\u5206\u5c42\u67b6\u6784\u8bbe\u8ba1\uff0c\u4ece\u6570\u636e\u63a5\u5165\u5230\u544a\u8b66\u8f93\u51fa\u5f62\u6210\u5b8c\u6574\u7684\u6570\u636e\u5904\u7406\u6d41\u6c34\u7ebf\uff1a<\/p>\n\n\n\n<figure class=\"wp-block-table\"><table class=\"has-fixed-layout\"><tbody><tr><td>\u6838\u5fc3\u8bbe\u8ba1\u7406\u5ff5\uff1a\u6570\u636e\u7ba1\u9053 + \u5e76\u53d1\u5904\u7406 + \u5bb9\u9519\u673a\u5236\uff0c\u786e\u4fdd\u6bcf\u4e00\u6761\u6570\u636e\u90fd\u7ecf\u8fc7\u5b8c\u6574\u7684\u6821\u9a8c\u3001\u6e05\u6d17\u3001\u5206\u6790\u548c\u544a\u8b66\u6d41\u7a0b\u3002<\/td><\/tr><\/tbody><\/table><\/figure>\n\n\n\n<ol class=\"wp-block-list\">\n<li><strong>\u6570\u636e\u63a5\u5165\u5c42<\/strong>\uff1a\u652f\u6301MQTT\u3001Modbus\u3001OPC UA\u7b49\u591a\u79cd\u5de5\u4e1a\u534f\u8bae\u63a5\u5165<\/li>\n\n\n\n<li><strong>\u6570\u636e\u6821\u9a8c\u5c42<\/strong>\uff1a\u683c\u5f0f\u6821\u9a8c\u3001\u8303\u56f4\u6821\u9a8c\u3001\u65f6\u95f4\u6233\u6821\u9a8c\u3001\u7b7e\u540d\u6821\u9a8c<\/li>\n\n\n\n<li><strong>\u6570\u636e\u6e05\u6d17\u5c42<\/strong>\uff1a\u566a\u58f0\u8fc7\u6ee4\u3001\u7f3a\u5931\u503c\u586b\u5145\u3001\u5f02\u5e38\u503c\u8bc6\u522b<\/li>\n\n\n\n<li><strong>\u5b9e\u65f6\u8ba1\u7b97\u5c42<\/strong>\uff1a\u6ed1\u52a8\u7a97\u53e3\u7edf\u8ba1\u3001\u8d8b\u52bf\u5206\u6790\u3001\u9608\u503c\u68c0\u6d4b<\/li>\n\n\n\n<li><strong>\u544a\u8b66\u51b3\u7b56\u5c42<\/strong>\uff1a\u5206\u7ea7\u544a\u8b66\u3001\u544a\u8b66\u6291\u5236\u3001\u8054\u52a8\u54cd\u5e94<\/li>\n\n\n\n<li><strong>\u6570\u636e\u6301\u4e45\u5c42<\/strong>\uff1a\u65f6\u5e8f\u6570\u636e\u5e93\u5b58\u50a8\u3001\u6570\u636e\u5907\u4efd<\/li>\n<\/ol>\n\n\n\n<p class=\"wp-block-paragraph\"><strong>\u4e09\u3001\u6838\u5fc3\u6a21\u5757\u5b9e\u73b0<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\"><strong>3.1 \u6570\u636e\u6a21\u578b\u5b9a\u4e49<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\">\u9996\u5148\u5b9a\u4e49\u4f20\u611f\u5668\u6570\u636e\u7684\u6838\u5fc3\u6570\u636e\u7ed3\u6784\uff0c\u5305\u542b\u6570\u636e\u91c7\u96c6\u7684\u57fa\u672c\u4fe1\u606f\u548c\u6821\u9a8c\u5b57\u6bb5\uff1a<\/p>\n\n\n<pre class=\"wp-block-code synano has-header\" data-header=\"Go\" data-theme=\"atom-one-dark\"><code class=\"language-go\">go\nsensor_data.go - \u6570\u636e\u6a21\u578b\u5b9a\u4e49package model\n\nimport &quot;time&quot;\n\n\/\/ SensorData \u4f20\u611f\u5668\u6570\u636e\u7ed3\u6784\ntype SensorData struct {\n\u00a0\u00a0\u00a0\u00a0SensorID \u00a0\u00a0\u00a0string \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0`json:&quot;sensor_id&quot;` \u00a0\u00a0\u00a0\/\/ \u4f20\u611f\u5668ID\n\u00a0\u00a0\u00a0\u00a0SensorType \u00a0string \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0`json:&quot;sensor_type&quot;` \u00a0\/\/ \u4f20\u611f\u5668\u7c7b\u578b\uff1agas\/temperature\/pressure\/vibration\n\u00a0\u00a0\u00a0\u00a0Value \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0float64 \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0`json:&quot;value&quot;` \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u91c7\u96c6\u503c\n\u00a0\u00a0\u00a0\u00a0Unit \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0string \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0`json:&quot;unit&quot;` \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u5355\u4f4d\n\u00a0\u00a0\u00a0\u00a0Timestamp \u00a0\u00a0time.Time \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0`json:&quot;timestamp&quot;` \u00a0\u00a0\u00a0\/\/ \u91c7\u96c6\u65f6\u95f4\u6233\n\u00a0\u00a0\u00a0\u00a0Location \u00a0\u00a0\u00a0string \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0`json:&quot;location&quot;` \u00a0\u00a0\u00a0\u00a0\/\/ \u5b89\u88c5\u4f4d\u7f6e\n\u00a0\u00a0\u00a0\u00a0Status \u00a0\u00a0\u00a0\u00a0\u00a0SensorStatus \u00a0\u00a0\u00a0\u00a0\u00a0`json:&quot;status&quot;` \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u4f20\u611f\u5668\u72b6\u6001\n\u00a0\u00a0\u00a0\u00a0Signature \u00a0\u00a0string \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0`json:&quot;signature&quot;` \u00a0\u00a0\u00a0\/\/ \u6570\u636e\u7b7e\u540d\uff08\u7528\u4e8e\u771f\u5b9e\u6027\u6821\u9a8c\uff09\n\u00a0\u00a0\u00a0\u00a0Metadata \u00a0\u00a0\u00a0map[string]string `json:&quot;metadata&quot;` \u00a0\u00a0\u00a0\u00a0\/\/ \u6269\u5c55\u5143\u6570\u636e\n}\n\n\/\/ SensorStatus \u4f20\u611f\u5668\u72b6\u6001\u679a\u4e3e\ntype SensorStatus int\n\nconst (\n\u00a0\u00a0\u00a0\u00a0StatusNormal \u00a0\u00a0SensorStatus = iota \/\/ \u6b63\u5e38\n\u00a0\u00a0\u00a0\u00a0StatusFault \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u6545\u969c\n\u00a0\u00a0\u00a0\u00a0StatusOffline \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u79bb\u7ebf\n\u00a0\u00a0\u00a0\u00a0StatusCalibration \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u6821\u51c6\u4e2d\n)\n\n\/\/ DataQuality \u6570\u636e\u8d28\u91cf\u8bc4\u4f30\u7ed3\u679c\ntype DataQuality struct {\n\u00a0\u00a0\u00a0\u00a0IsValid \u00a0\u00a0\u00a0\u00a0bool \u00a0\u00a0\u00a0\u00a0\u00a0`json:&quot;is_valid&quot;` \u00a0\u00a0\u00a0\u00a0\/\/ \u662f\u5426\u6709\u6548\n\u00a0\u00a0\u00a0\u00a0IsReal \u00a0\u00a0\u00a0\u00a0\u00a0bool \u00a0\u00a0\u00a0\u00a0\u00a0`json:&quot;is_real&quot;` \u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u662f\u5426\u771f\u5b9e\uff08\u7b7e\u540d\u6821\u9a8c\u901a\u8fc7\uff09\n\u00a0\u00a0\u00a0\u00a0Confidence \u00a0float64 \u00a0\u00a0`json:&quot;confidence&quot;` \u00a0\u00a0\/\/ \u7f6e\u4fe1\u5ea6 0-1\n\u00a0\u00a0\u00a0\u00a0Issues \u00a0\u00a0\u00a0\u00a0\u00a0[]string \u00a0`json:&quot;issues&quot;` \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u5b58\u5728\u7684\u95ee\u9898\n\u00a0\u00a0\u00a0\u00a0CheckTime \u00a0\u00a0time.Time `json:&quot;check_time&quot;` \u00a0\u00a0\/\/ \u6821\u9a8c\u65f6\u95f4\n}\n\n\/\/ AlertLevel \u544a\u8b66\u7ea7\u522b\ntype AlertLevel int\n\nconst (\n\u00a0\u00a0\u00a0\u00a0AlertInfo \u00a0\u00a0\u00a0\u00a0AlertLevel = iota \/\/ \u63d0\u793a\n\u00a0\u00a0\u00a0\u00a0AlertWarning \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u8b66\u544a\n\u00a0\u00a0\u00a0\u00a0AlertCritical \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u4e25\u91cd\n\u00a0\u00a0\u00a0\u00a0AlertEmergency \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u7d27\u6025\n)<\/code><\/pre>\n\n\n<p class=\"wp-block-paragraph\"><strong>3.2 \u6570\u636e\u771f\u5b9e\u6027\u6821\u9a8c\u6a21\u5757<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\">\u6570\u636e\u771f\u5b9e\u6027\u662f\u667a\u6167\u77ff\u5c71\u7684\u6838\u5fc3\u8981\u6c42\u3002\u6211\u4eec\u91c7\u7528HMAC\u7b7e\u540d\u673a\u5236\uff0c\u786e\u4fdd\u6570\u636e\u5728\u4f20\u8f93\u8fc7\u7a0b\u4e2d\u4e0d\u88ab\u7be1\u6539\uff1a<\/p>\n\n\n<pre class=\"wp-block-code synano has-header\" data-header=\"Go\" data-theme=\"atom-one-dark\"><code class=\"language-go\">go\nvalidator.go - \u6570\u636e\u771f\u5b9e\u6027\u6821\u9a8cpackage validator\n\nimport (\n\u00a0\u00a0\u00a0\u00a0&quot;crypto\/hmac&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;crypto\/sha256&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;encoding\/hex&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;errors&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;fmt&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;time&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;smart-mine\/model&quot;\n)\n\n\/\/ DataValidator \u6570\u636e\u6821\u9a8c\u5668\ntype DataValidator struct {\n\u00a0\u00a0\u00a0\u00a0secretKey string\n\u00a0\u00a0\u00a0\u00a0\/\/ \u5404\u7c7b\u578b\u4f20\u611f\u5668\u7684\u5408\u6cd5\u53d6\u503c\u8303\u56f4\n\u00a0\u00a0\u00a0\u00a0valueRanges map[string]ValueRange\n\u00a0\u00a0\u00a0\u00a0\/\/ \u6700\u5927\u5141\u8bb8\u7684\u65f6\u95f4\u504f\u79fb\uff08\u79d2\uff09\n\u00a0\u00a0\u00a0\u00a0maxTimeOffset int64\n}\n\ntype ValueRange struct {\n\u00a0\u00a0\u00a0\u00a0Min float64\n\u00a0\u00a0\u00a0\u00a0Max float64\n}\n\n\/\/ NewDataValidator \u521b\u5efa\u6570\u636e\u6821\u9a8c\u5668\nfunc NewDataValidator(secretKey string) *DataValidator {\n\u00a0\u00a0\u00a0\u00a0return &amp;DataValidator{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0secretKey: secretKey,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0valueRanges: map[string]ValueRange{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0&quot;gas&quot;: \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0{Min: 0, Max: 100}, \u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u74e6\u65af\u6d53\u5ea6 %LEL\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0&quot;temperature&quot;: {Min: -20, Max: 200}, \u00a0\u00a0\/\/ \u6e29\u5ea6 \u2103\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0&quot;pressure&quot;: \u00a0\u00a0{Min: 0, Max: 50}, \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u538b\u529b MPa\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0&quot;vibration&quot;: \u00a0{Min: 0, Max: 100}, \u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u632f\u52a8 mm\/s\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0&quot;displacement&quot;: {Min: 0, Max: 1000}, \u00a0\u00a0\/\/ \u4f4d\u79fb mm\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0},\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0maxTimeOffset: 300, \/\/ 5\u5206\u949f\n\u00a0\u00a0\u00a0\u00a0}\n}\n\n\/\/ VerifySignature \u9a8c\u8bc1\u6570\u636e\u7b7e\u540d\uff0c\u786e\u4fdd\u6570\u636e\u771f\u5b9e\u6027\nfunc (v *DataValidator) VerifySignature(data *model.SensorData) bool {\n\u00a0\u00a0\u00a0\u00a0\/\/ \u6784\u9020\u7b7e\u540d\u5b57\u7b26\u4e32\uff1asensor_id|value|timestamp\n\u00a0\u00a0\u00a0\u00a0signStr := fmt.Sprintf(&quot;%s|%f|%d&quot;,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0data.SensorID,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0data.Value,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0data.Timestamp.Unix())\n\n\u00a0\u00a0\u00a0\u00a0mac := hmac.New(sha256.New(), []byte(v.secretKey))\n\u00a0\u00a0\u00a0\u00a0mac.Write([]byte(signStr))\n\u00a0\u00a0\u00a0\u00a0expectedSignature := hex.EncodeToString(mac.Sum(nil))\n\n\u00a0\u00a0\u00a0\u00a0return hmac.Equal([]byte(expectedSignature), []byte(data.Signature))\n}\n\n\/\/ Validate \u5b8c\u6574\u6570\u636e\u6821\u9a8c\uff0c\u8fd4\u56de\u6570\u636e\u8d28\u91cf\u8bc4\u4f30\nfunc (v *DataValidator) Validate(data *model.SensorData) *model.DataQuality {\n\u00a0\u00a0\u00a0\u00a0quality := &amp;model.DataQuality{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0IsValid: \u00a0\u00a0\u00a0true,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0IsReal: \u00a0\u00a0\u00a0\u00a0true,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Confidence: 1.0,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0CheckTime: \u00a0time.Now(),\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\/\/ 1. \u771f\u5b9e\u6027\u6821\u9a8c\uff1a\u7b7e\u540d\u9a8c\u8bc1\n\u00a0\u00a0\u00a0\u00a0if !v.VerifySignature(data) {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality.IsReal = false\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality.IsValid = false\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality.Confidence = 0\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality.Issues = append(quality.Issues, &quot;\u6570\u636e\u7b7e\u540d\u6821\u9a8c\u5931\u8d25\uff0c\u53ef\u80fd\u88ab\u7be1\u6539&quot;)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return quality\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\/\/ 2. \u6709\u6548\u6027\u6821\u9a8c\uff1a\u4f20\u611f\u5668ID\u683c\u5f0f\n\u00a0\u00a0\u00a0\u00a0if data.SensorID == &quot;&quot; {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality.IsValid = false\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality.Confidence *= 0.3\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality.Issues = append(quality.Issues, &quot;\u4f20\u611f\u5668ID\u4e3a\u7a7a&quot;)\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\/\/ 3. \u6709\u6548\u6027\u6821\u9a8c\uff1a\u53d6\u503c\u8303\u56f4\n\u00a0\u00a0\u00a0\u00a0if rng, ok := v.valueRanges[data.SensorType]; ok {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if data.Value &lt; rng.Min || data.Value &gt; rng.Max {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality.IsValid = false\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality.Confidence *= 0.5\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality.Issues = append(quality.Issues,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0fmt.Sprintf(&quot;\u6570\u503c\u8d85\u51fa\u5408\u6cd5\u8303\u56f4 [%.2f, %.2f]&quot;, rng.Min, rng.Max))\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\/\/ 4. \u6709\u6548\u6027\u6821\u9a8c\uff1a\u65f6\u95f4\u6233\u5408\u7406\u6027\n\u00a0\u00a0\u00a0\u00a0timeOffset := time.Since(data.Timestamp).Abs().Seconds()\n\u00a0\u00a0\u00a0\u00a0if timeOffset &gt; float64(v.maxTimeOffset) {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality.Confidence *= 0.7\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality.Issues = append(quality.Issues,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0fmt.Sprintf(&quot;\u65f6\u95f4\u6233\u504f\u79fb\u8fc7\u5927\uff1a%.0f\u79d2&quot;, timeOffset))\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\/\/ 5. \u6709\u6548\u6027\u6821\u9a8c\uff1a\u4f20\u611f\u5668\u72b6\u6001\n\u00a0\u00a0\u00a0\u00a0if data.Status != model.StatusNormal {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality.Confidence *= 0.4\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality.Issues = append(quality.Issues,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0fmt.Sprintf(&quot;\u4f20\u611f\u5668\u72b6\u6001\u5f02\u5e38: %d&quot;, data.Status))\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0return quality\n}\n\n\/\/ ErrInvalidData \u6570\u636e\u65e0\u6548\u9519\u8bef\nvar ErrInvalidData = errors.New(&quot;invalid sensor data&quot;)<\/code><\/pre>\n\n\n<p class=\"wp-block-paragraph\"><strong>3.3 \u5b9e\u65f6\u6570\u636e\u5904\u7406\u7ba1\u9053<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\">\u5229\u7528Golang\u7684goroutine\u548cchannel\u6784\u5efa\u9ad8\u6027\u80fd\u6570\u636e\u5904\u7406\u7ba1\u9053\uff0c\u5b9e\u73b0\u6570\u636e\u7684\u6d41\u5f0f\u5904\u7406\uff1a<\/p>\n\n\n<pre class=\"wp-block-code synano has-header\" data-header=\"Go\" data-theme=\"atom-one-dark\"><code class=\"language-go\">go\npipeline.go - \u5b9e\u65f6\u6570\u636e\u5904\u7406\u7ba1\u9053package pipeline\n\nimport (\n\u00a0\u00a0\u00a0\u00a0&quot;context&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;sync&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;time&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;smart-mine\/model&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;smart-mine\/validator&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;smart-mine\/alert&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;smart-mine\/storage&quot;\n)\n\n\/\/ DataPipeline \u6570\u636e\u5904\u7406\u7ba1\u9053\ntype DataPipeline struct {\n\u00a0\u00a0\u00a0\u00a0validator \u00a0\u00a0*validator.DataValidator\n\u00a0\u00a0\u00a0\u00a0alertEngine *alert.Engine\n\u00a0\u00a0\u00a0\u00a0storage \u00a0\u00a0\u00a0\u00a0*storage.TimeSeriesStore\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u8f93\u5165\u901a\u9053\n\u00a0\u00a0\u00a0\u00a0inputChan chan *model.SensorData\n\u00a0\u00a0\u00a0\u00a0\/\/ \u6821\u9a8c\u540e\u901a\u9053\n\u00a0\u00a0\u00a0\u00a0validatedChan chan *ValidatedData\n\u00a0\u00a0\u00a0\u00a0\/\/ \u544a\u8b66\u901a\u9053\n\u00a0\u00a0\u00a0\u00a0alertChan chan *model.Alert\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u5de5\u4f5c\u6c60\u5927\u5c0f\n\u00a0\u00a0\u00a0\u00a0workerCount int\n\n\u00a0\u00a0\u00a0\u00a0wg \u00a0\u00a0\u00a0\u00a0sync.WaitGroup\n\u00a0\u00a0\u00a0\u00a0ctx \u00a0\u00a0\u00a0context.Context\n\u00a0\u00a0\u00a0\u00a0cancel context.CancelFunc\n}\n\n\/\/ ValidatedData \u6821\u9a8c\u540e\u7684\u6570\u636e\ntype ValidatedData struct {\n\u00a0\u00a0\u00a0\u00a0Data \u00a0\u00a0\u00a0*model.SensorData\n\u00a0\u00a0\u00a0\u00a0Quality *model.DataQuality\n}\n\n\/\/ NewDataPipeline \u521b\u5efa\u6570\u636e\u5904\u7406\u7ba1\u9053\nfunc NewDataPipeline(\n\u00a0\u00a0\u00a0\u00a0validator *validator.DataValidator,\n\u00a0\u00a0\u00a0\u00a0alertEngine *alert.Engine,\n\u00a0\u00a0\u00a0\u00a0storage *storage.TimeSeriesStore,\n\u00a0\u00a0\u00a0\u00a0workerCount int,\n) *DataPipeline {\n\u00a0\u00a0\u00a0\u00a0ctx, cancel := context.WithCancel(context.Background())\n\n\u00a0\u00a0\u00a0\u00a0return &amp;DataPipeline{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0validator: \u00a0\u00a0\u00a0\u00a0validator,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0alertEngine: \u00a0\u00a0alertEngine,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0storage: \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0storage,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0inputChan: \u00a0\u00a0\u00a0\u00a0make(chan *model.SensorData, 10000),\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0validatedChan: make(chan *ValidatedData, 8000),\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0alertChan: \u00a0\u00a0\u00a0\u00a0make(chan *model.Alert, 2000),\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0workerCount: \u00a0\u00a0workerCount,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0ctx: \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0ctx,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0cancel: \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0cancel,\n\u00a0\u00a0\u00a0\u00a0}\n}\n\n\/\/ Start \u542f\u52a8\u6570\u636e\u5904\u7406\u7ba1\u9053\nfunc (p *DataPipeline) Start() {\n\u00a0\u00a0\u00a0\u00a0\/\/ \u542f\u52a8\u6821\u9a8c\u5de5\u4f5c\u534f\u7a0b\n\u00a0\u00a0\u00a0\u00a0for i := 0; i &lt; p.workerCount; i++ {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0p.wg.Add(1)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0go p.validateWorker()\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u542f\u52a8\u5904\u7406\u5de5\u4f5c\u534f\u7a0b\n\u00a0\u00a0\u00a0\u00a0for i := 0; i &lt; p.workerCount\/2; i++ {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0p.wg.Add(1)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0go p.processWorker()\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u542f\u52a8\u544a\u8b66\u5904\u7406\u534f\u7a0b\n\u00a0\u00a0\u00a0\u00a0p.wg.Add(1)\n\u00a0\u00a0\u00a0\u00a0go p.alertWorker()\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u542f\u52a8\u5b58\u50a8\u534f\u7a0b\n\u00a0\u00a0\u00a0\u00a0p.wg.Add(1)\n\u00a0\u00a0\u00a0\u00a0go p.storageWorker()\n}\n\n\/\/ validateWorker \u6570\u636e\u6821\u9a8c\u5de5\u4f5c\u534f\u7a0b\nfunc (p *DataPipeline) validateWorker() {\n\u00a0\u00a0\u00a0\u00a0defer p.wg.Done()\n\n\u00a0\u00a0\u00a0\u00a0for {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0select {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0case data := &lt;-p.inputChan:\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u6267\u884c\u6570\u636e\u6821\u9a8c\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0quality := p.validator.Validate(data)\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u53ea\u6709\u771f\u5b9e\u6570\u636e\u624d\u8fdb\u5165\u4e0b\u4e00\u7ea7\u5904\u7406\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if quality.IsReal {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0p.validatedChan &lt;- &amp;ValidatedData{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Data: \u00a0\u00a0\u00a0data,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Quality: quality,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0case &lt;-p.ctx.Done():\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0}\n}\n\n\/\/ processWorker \u6570\u636e\u5904\u7406\u5de5\u4f5c\u534f\u7a0b\nfunc (p *DataPipeline) processWorker() {\n\u00a0\u00a0\u00a0\u00a0defer p.wg.Done()\n\n\u00a0\u00a0\u00a0\u00a0for {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0select {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0case vData := &lt;-p.validatedChan:\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u5b9e\u65f6\u5206\u6790\uff0c\u68c0\u6d4b\u5f02\u5e38\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0alerts := p.alertEngine.Analyze(vData.Data, vData.Quality)\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u53d1\u9001\u544a\u8b66\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0for _, a := range alerts {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0p.alertChan &lt;- a\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u6570\u636e\u5b58\u5165\u65f6\u5e8f\u6570\u636e\u5e93\uff08\u5f02\u6b65\u6279\u91cf\u5199\u5165\uff09\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if vData.Quality.IsValid {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0p.storage.WriteAsync(vData.Data)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0case &lt;-p.ctx.Done():\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0}\n}\n\n\/\/ alertWorker \u544a\u8b66\u5904\u7406\u534f\u7a0b\nfunc (p *DataPipeline) alertWorker() {\n\u00a0\u00a0\u00a0\u00a0defer p.wg.Done()\n\n\u00a0\u00a0\u00a0\u00a0for {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0select {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0case alert := &lt;-p.alertChan:\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u5904\u7406\u544a\u8b66\uff1a\u53d1\u9001\u901a\u77e5\u3001\u8bb0\u5f55\u65e5\u5fd7\u3001\u89e6\u53d1\u8054\u52a8\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0p.alertEngine.HandleAlert(alert)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0case &lt;-p.ctx.Done():\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0}\n}\n\n\/\/ storageWorker \u5b58\u50a8\u5de5\u4f5c\u534f\u7a0b\uff08\u6279\u91cf\u5199\u5165\u4f18\u5316\uff09\nfunc (p *DataPipeline) storageWorker() {\n\u00a0\u00a0\u00a0\u00a0defer p.wg.Done()\n\n\u00a0\u00a0\u00a0\u00a0ticker := time.NewTicker(100 * time.Millisecond)\n\u00a0\u00a0\u00a0\u00a0defer ticker.Stop()\n\n\u00a0\u00a0\u00a0\u00a0var batch []*model.SensorData\n\n\u00a0\u00a0\u00a0\u00a0for {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0select {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0case data := &lt;-p.storage.BatchChan():\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0batch = append(batch, data)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u6279\u91cf\u5927\u5c0f\u8fbe\u5230\u9608\u503c\u65f6\u5199\u5165\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if len(batch) &gt;= 500 {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0p.storage.BatchWrite(batch)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0batch = batch[:0]\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0case &lt;-ticker.C:\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u5b9a\u65f6\u5237\u5199\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if len(batch) &gt; 0 {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0p.storage.BatchWrite(batch)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0batch = batch[:0]\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0case &lt;-p.ctx.Done():\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u9000\u51fa\u524d\u5237\u5199\u5269\u4f59\u6570\u636e\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if len(batch) &gt; 0 {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0p.storage.BatchWrite(batch)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0}\n}\n\n\/\/ Push \u63a8\u9001\u6570\u636e\u5230\u7ba1\u9053\nfunc (p *DataPipeline) Push(data *model.SensorData) {\n\u00a0\u00a0\u00a0\u00a0select {\n\u00a0\u00a0\u00a0\u00a0case p.inputChan &lt;- data:\n\u00a0\u00a0\u00a0\u00a0default:\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u901a\u9053\u6ee1\u65f6\u4e22\u5f03\u5e76\u8bb0\u5f55\u76d1\u63a7\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ metrics.Increment(&quot;pipeline.dropped&quot;)\n\u00a0\u00a0\u00a0\u00a0}\n}\n\n\/\/ Stop \u505c\u6b62\u7ba1\u9053\nfunc (p *DataPipeline) Stop() {\n\u00a0\u00a0\u00a0\u00a0p.cancel()\n\u00a0\u00a0\u00a0\u00a0p.wg.Wait()\n}<\/code><\/pre>\n\n\n<p class=\"wp-block-paragraph\"><strong>3.4 \u667a\u80fd\u544a\u8b66\u5f15\u64ce<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\">\u544a\u8b66\u5f15\u64ce\u91c7\u7528\u5206\u7ea7\u544a\u8b66\u548c\u6ed1\u52a8\u7a97\u53e3\u68c0\u6d4b\u673a\u5236\uff0c\u786e\u4fdd\u5f02\u5e38\u60c5\u51b5\u53ca\u65f6\u54cd\u5e94\uff0c\u540c\u65f6\u907f\u514d\u8bef\u62a5\uff1a<\/p>\n\n\n<pre class=\"wp-block-code synano has-header\" data-header=\"Go\" data-theme=\"atom-one-dark\"><code class=\"language-go\">go\nalert.go - \u667a\u80fd\u544a\u8b66\u5f15\u64cepackage alert\n\nimport (\n\u00a0\u00a0\u00a0\u00a0&quot;fmt&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;sync&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;time&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;smart-mine\/model&quot;\n)\n\n\/\/ Engine \u544a\u8b66\u5f15\u64ce\ntype Engine struct {\n\u00a0\u00a0\u00a0\u00a0\/\/ \u5404\u4f20\u611f\u5668\u7c7b\u578b\u7684\u544a\u8b66\u9608\u503c\u914d\u7f6e\n\u00a0\u00a0\u00a0\u00a0thresholds map[string]ThresholdConfig\n\u00a0\u00a0\u00a0\u00a0\/\/ \u6ed1\u52a8\u7a97\u53e3\u72b6\u6001\uff08\u6309\u4f20\u611f\u5668ID\u7ef4\u62a4\uff09\n\u00a0\u00a0\u00a0\u00a0windowStates sync.Map\n\u00a0\u00a0\u00a0\u00a0\/\/ \u544a\u8b66\u6291\u5236\u72b6\u6001\n\u00a0\u00a0\u00a0\u00a0suppressed sync.Map\n\u00a0\u00a0\u00a0\u00a0\/\/ \u544a\u8b66\u5904\u7406\u5668\n\u00a0\u00a0\u00a0\u00a0handlers []AlertHandler\n}\n\n\/\/ ThresholdConfig \u9608\u503c\u914d\u7f6e\ntype ThresholdConfig struct {\n\u00a0\u00a0\u00a0\u00a0Warning \u00a0\u00a0float64 \/\/ \u8b66\u544a\u9608\u503c\n\u00a0\u00a0\u00a0\u00a0Critical \u00a0float64 \/\/ \u4e25\u91cd\u9608\u503c\n\u00a0\u00a0\u00a0\u00a0Emergency float64 \/\/ \u7d27\u6025\u9608\u503c\n\u00a0\u00a0\u00a0\u00a0\/\/ \u6301\u7eed\u65f6\u95f4\u8981\u6c42\uff08\u79d2\uff09\n\u00a0\u00a0\u00a0\u00a0Duration int\n}\n\n\/\/ windowState \u6ed1\u52a8\u7a97\u53e3\u72b6\u6001\ntype windowState struct {\n\u00a0\u00a0\u00a0\u00a0values \u00a0\u00a0\u00a0[]float64\n\u00a0\u00a0\u00a0\u00a0timestamps []time.Time\n\u00a0\u00a0\u00a0\u00a0windowSize time.Duration\n\u00a0\u00a0\u00a0\u00a0mu \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0sync.Mutex\n}\n\n\/\/ AlertHandler \u544a\u8b66\u5904\u7406\u5668\u63a5\u53e3\ntype AlertHandler interface {\n\u00a0\u00a0\u00a0\u00a0Handle(alert *model.Alert) error\n\u00a0\u00a0\u00a0\u00a0Name() string\n}\n\n\/\/ NewEngine \u521b\u5efa\u544a\u8b66\u5f15\u64ce\nfunc NewEngine() *Engine {\n\u00a0\u00a0\u00a0\u00a0return &amp;Engine{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0thresholds: map[string]ThresholdConfig{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0&quot;gas&quot;: {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Warning: \u00a0\u00a00.8, \u00a0\u00a0\/\/ 0.8% LEL\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Critical: \u00a01.0, \u00a0\u00a0\/\/ 1.0% LEL\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Emergency: 1.5, \u00a0\u00a0\/\/ 1.5% LEL\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Duration: \u00a03, \u00a0\u00a0\u00a0\u00a0\/\/ \u6301\u7eed3\u79d2\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0},\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0&quot;temperature&quot;: {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Warning: \u00a0\u00a060,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Critical: \u00a080,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Emergency: 100,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Duration: \u00a05,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0},\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0&quot;vibration&quot;: {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Warning: \u00a0\u00a010,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Critical: \u00a025,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Emergency: 45,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Duration: \u00a02,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0},\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0},\n\u00a0\u00a0\u00a0\u00a0}\n}\n\n\/\/ AddHandler \u6dfb\u52a0\u544a\u8b66\u5904\u7406\u5668\nfunc (e *Engine) AddHandler(handler AlertHandler) {\n\u00a0\u00a0\u00a0\u00a0e.handlers = append(e.handlers, handler)\n}\n\n\/\/ Analyze \u5206\u6790\u6570\u636e\uff0c\u751f\u6210\u544a\u8b66\nfunc (e *Engine) Analyze(data *model.SensorData, quality *model.DataQuality) []*model.Alert {\n\u00a0\u00a0\u00a0\u00a0var alerts []*model.Alert\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u6570\u636e\u8d28\u91cf\u592a\u5dee\u65f6\u4e0d\u4ea7\u751f\u544a\u8b66\n\u00a0\u00a0\u00a0\u00a0if !quality.IsReal || quality.Confidence &lt; 0.3 {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return alerts\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0threshold, ok := e.thresholds[data.SensorType]\n\u00a0\u00a0\u00a0\u00a0if !ok {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return alerts\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u66f4\u65b0\u6ed1\u52a8\u7a97\u53e3\n\u00a0\u00a0\u00a0\u00a0state := e.getWindowState(data.SensorID)\n\u00a0\u00a0\u00a0\u00a0state.addValue(data.Value, data.Timestamp)\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u8ba1\u7b97\u7a97\u53e3\u5185\u7684\u7edf\u8ba1\u503c\n\u00a0\u00a0\u00a0\u00a0avgValue, duration := state.calculateStats()\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u5224\u65ad\u544a\u8b66\u7ea7\u522b\n\u00a0\u00a0\u00a0\u00a0var level model.AlertLevel\n\u00a0\u00a0\u00a0\u00a0var message string\n\n\u00a0\u00a0\u00a0\u00a0if avgValue &gt;= threshold.Emergency {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0level = model.AlertEmergency\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0message = fmt.Sprintf(&quot;\u3010\u7d27\u6025\u3011%s\u4f20\u611f\u5668\u6570\u503c\u4e25\u91cd\u8d85\u9650\uff01\u5f53\u524d\u503c: %.2f%s&quot;,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0data.SensorType, data.Value, data.Unit)\n\u00a0\u00a0\u00a0\u00a0} else if avgValue &gt;= threshold.Critical {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0level = model.AlertCritical\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0message = fmt.Sprintf(&quot;\u3010\u4e25\u91cd\u3011%s\u4f20\u611f\u5668\u6570\u503c\u8d85\u9650\uff0c\u8bf7\u6ce8\u610f\uff01\u5f53\u524d\u503c: %.2f%s&quot;,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0data.SensorType, data.Value, data.Unit)\n\u00a0\u00a0\u00a0\u00a0} else if avgValue &gt;= threshold.Warning {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0level = model.AlertWarning\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0message = fmt.Sprintf(&quot;\u3010\u8b66\u544a\u3011%s\u4f20\u611f\u5668\u6570\u503c\u63a5\u8fd1\u9608\u503c\u3002\u5f53\u524d\u503c: %.2f%s&quot;,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0data.SensorType, data.Value, data.Unit)\n\u00a0\u00a0\u00a0\u00a0} else {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return alerts \/\/ \u6b63\u5e38\uff0c\u65e0\u544a\u8b66\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u68c0\u67e5\u6301\u7eed\u65f6\u95f4\u8981\u6c42\n\u00a0\u00a0\u00a0\u00a0if duration &lt; time.Duration(threshold.Duration)*time.Second {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return alerts \/\/ \u6301\u7eed\u65f6\u95f4\u4e0d\u8db3\uff0c\u4e0d\u544a\u8b66\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u544a\u8b66\u6291\u5236\u68c0\u67e5\uff08\u907f\u514d\u91cd\u590d\u544a\u8b66\uff09\n\u00a0\u00a0\u00a0\u00a0if e.isSuppressed(data.SensorID, level) {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return alerts\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u751f\u6210\u544a\u8b66\n\u00a0\u00a0\u00a0\u00a0alert := &amp;model.Alert{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0ID: \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0fmt.Sprintf(&quot;alert-%d&quot;, time.Now().UnixNano()),\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0SensorID: \u00a0\u00a0data.SensorID,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0SensorType: data.SensorType,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Level: \u00a0\u00a0\u00a0\u00a0\u00a0level,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Message: \u00a0\u00a0\u00a0message,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Value: \u00a0\u00a0\u00a0\u00a0\u00a0data.Value,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Location: \u00a0\u00a0data.Location,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Timestamp: \u00a0time.Now(),\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Acknowledged: false,\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0alerts = append(alerts, alert)\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u8bbe\u7f6e\u544a\u8b66\u6291\u5236\n\u00a0\u00a0\u00a0\u00a0e.setSuppressed(data.SensorID, level, 30*time.Second)\n\n\u00a0\u00a0\u00a0\u00a0return alerts\n}\n\n\/\/ HandleAlert \u5904\u7406\u544a\u8b66\nfunc (e *Engine) HandleAlert(alert *model.Alert) {\n\u00a0\u00a0\u00a0\u00a0for _, handler := range e.handlers {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0go func(h AlertHandler) {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if err := h.Handle(alert); err != nil {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u8bb0\u5f55\u9519\u8bef\u65e5\u5fd7\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0fmt.Printf(&quot;Alert handler %s error: %v\\n&quot;, h.Name(), err)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}(handler)\n\u00a0\u00a0\u00a0\u00a0}\n}\n\n\/\/ getWindowState \u83b7\u53d6\u6216\u521b\u5efa\u7a97\u53e3\u72b6\u6001\nfunc (e *Engine) getWindowState(sensorID string) *windowState {\n\u00a0\u00a0\u00a0\u00a0state, ok := e.windowStates.Load(sensorID)\n\u00a0\u00a0\u00a0\u00a0if !ok {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0state = &amp;windowState{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0windowSize: 5 * time.Minute,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0e.windowStates.Store(sensorID, state)\n\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0return state.(*windowState)\n}\n\n\/\/ addValue \u6dfb\u52a0\u503c\u5230\u7a97\u53e3\nfunc (s *windowState) addValue(value float64, ts time.Time) {\n\u00a0\u00a0\u00a0\u00a0s.mu.Lock()\n\u00a0\u00a0\u00a0\u00a0defer s.mu.Unlock()\n\n\u00a0\u00a0\u00a0\u00a0s.values = append(s.values, value)\n\u00a0\u00a0\u00a0\u00a0s.timestamps = append(s.timestamps, ts)\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u6e05\u7406\u8fc7\u671f\u6570\u636e\n\u00a0\u00a0\u00a0\u00a0cutoff := ts.Add(-s.windowSize)\n\u00a0\u00a0\u00a0\u00a0for len(s.timestamps) &gt; 0 &amp;&amp; s.timestamps[0].Before(cutoff) {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0s.values = s.values[1:]\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0s.timestamps = s.timestamps[1:]\n\u00a0\u00a0\u00a0\u00a0}\n}\n\n\/\/ calculateStats \u8ba1\u7b97\u7a97\u53e3\u7edf\u8ba1\u503c\nfunc (s *windowState) calculateStats() (float64, time.Duration) {\n\u00a0\u00a0\u00a0\u00a0s.mu.Lock()\n\u00a0\u00a0\u00a0\u00a0defer s.mu.Unlock()\n\n\u00a0\u00a0\u00a0\u00a0if len(s.values) == 0 {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return 0, 0\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0sum := 0.0\n\u00a0\u00a0\u00a0\u00a0for _, v := range s.values {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0sum += v\n\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0avg := sum \/ float64(len(s.values))\n\n\u00a0\u00a0\u00a0\u00a0duration := s.timestamps[len(s.timestamps)-1].Sub(s.timestamps[0])\n\n\u00a0\u00a0\u00a0\u00a0return avg, duration\n}\n\n\/\/ isSuppressed \u68c0\u67e5\u662f\u5426\u5728\u6291\u5236\u671f\u5185\nfunc (e *Engine) isSuppressed(sensorID string, level model.AlertLevel) bool {\n\u00a0\u00a0\u00a0\u00a0key := fmt.Sprintf(&quot;%s-%d&quot;, sensorID, level)\n\u00a0\u00a0\u00a0\u00a0val, ok := e.suppressed.Load(key)\n\u00a0\u00a0\u00a0\u00a0if !ok {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return false\n\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0return time.Now().Before(val.(time.Time))\n}\n\n\/\/ setSuppressed \u8bbe\u7f6e\u6291\u5236\nfunc (e *Engine) setSuppressed(sensorID string, level model.AlertLevel, duration time.Duration) {\n\u00a0\u00a0\u00a0\u00a0key := fmt.Sprintf(&quot;%s-%d&quot;, sensorID, level)\n\u00a0\u00a0\u00a0\u00a0e.suppressed.Store(key, time.Now().Add(duration))\n}<\/code><\/pre>\n\n\n<p class=\"wp-block-paragraph\"><strong>3.5 \u65f6\u5e8f\u6570\u636e\u5b58\u50a8\u6a21\u5757<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\">\u91c7\u7528\u6279\u91cf\u5199\u5165\u7b56\u7565\u4f18\u5316\u65f6\u5e8f\u6570\u636e\u5b58\u50a8\u6027\u80fd\uff0c\u652f\u6301\u591a\u79cd\u5b58\u50a8\u540e\u7aef\uff1a<\/p>\n\n\n<pre class=\"wp-block-code synano has-header\" data-header=\"Go\" data-theme=\"atom-one-dark\"><code class=\"language-go\">go\nstorage.go - \u65f6\u5e8f\u6570\u636e\u5b58\u50a8package storage\n\nimport (\n\u00a0\u00a0\u00a0\u00a0&quot;fmt&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;sync&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;time&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;smart-mine\/model&quot;\n)\n\n\/\/ TimeSeriesStore \u65f6\u5e8f\u6570\u636e\u5b58\u50a8\ntype TimeSeriesStore struct {\n\u00a0\u00a0\u00a0\u00a0batchChan \u00a0chan *model.SensorData\n\u00a0\u00a0\u00a0\u00a0bufferSize int\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u6a21\u62df\u5b58\u50a8\uff08\u5b9e\u9645\u9879\u76ee\u53ef\u66ff\u6362\u4e3aInfluxDB\/TDengine\u7b49\u65f6\u5e8f\u6570\u636e\u5e93\uff09\n\u00a0\u00a0\u00a0\u00a0data \u00a0\u00a0\u00a0\u00a0map[string][]*model.SensorData\n\u00a0\u00a0\u00a0\u00a0dataMu \u00a0\u00a0sync.RWMutex\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u7edf\u8ba1\u6307\u6807\n\u00a0\u00a0\u00a0\u00a0totalWritten int64\n\u00a0\u00a0\u00a0\u00a0totalDropped int64\n}\n\n\/\/ NewTimeSeriesStore \u521b\u5efa\u65f6\u5e8f\u5b58\u50a8\nfunc NewTimeSeriesStore(bufferSize int) *TimeSeriesStore {\n\u00a0\u00a0\u00a0\u00a0return &amp;TimeSeriesStore{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0batchChan: \u00a0make(chan *model.SensorData, bufferSize),\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0bufferSize: bufferSize,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0data: \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0make(map[string][]*model.SensorData),\n\u00a0\u00a0\u00a0\u00a0}\n}\n\n\/\/ BatchChan \u8fd4\u56de\u6279\u91cf\u5199\u5165\u901a\u9053\nfunc (s *TimeSeriesStore) BatchChan() &lt;-chan *model.SensorData {\n\u00a0\u00a0\u00a0\u00a0return s.batchChan\n}\n\n\/\/ WriteAsync \u5f02\u6b65\u5199\u5165\nfunc (s *TimeSeriesStore) WriteAsync(data *model.SensorData) {\n\u00a0\u00a0\u00a0\u00a0select {\n\u00a0\u00a0\u00a0\u00a0case s.batchChan &lt;- data:\n\u00a0\u00a0\u00a0\u00a0default:\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u901a\u9053\u6ee1\u65f6\u4e22\u5f03\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ atomic.AddInt64(&amp;s.totalDropped, 1)\n\u00a0\u00a0\u00a0\u00a0}\n}\n\n\/\/ BatchWrite \u6279\u91cf\u5199\u5165\nfunc (s *TimeSeriesStore) BatchWrite(batch []*model.SensorData) {\n\u00a0\u00a0\u00a0\u00a0if len(batch) == 0 {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0s.dataMu.Lock()\n\u00a0\u00a0\u00a0\u00a0defer s.dataMu.Unlock()\n\n\u00a0\u00a0\u00a0\u00a0for _, data := range batch {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0key := fmt.Sprintf(&quot;%s:%s&quot;, data.SensorType, data.SensorID)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0s.data[key] = append(s.data[key], data)\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u53ea\u4fdd\u7559\u6700\u8fd124\u5c0f\u65f6\u7684\u6570\u636e\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0cutoff := time.Now().Add(-24 * time.Hour)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0values := s.data[key]\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0for len(values) &gt; 0 &amp;&amp; values[0].Timestamp.Before(cutoff) {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0values = values[1:]\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0s.data[key] = values\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\/\/ atomic.AddInt64(&amp;s.totalWritten, int64(len(batch)))\n}\n\n\/\/ Query \u67e5\u8be2\u6570\u636e\nfunc (s *TimeSeriesStore) Query(sensorID string, startTime, endTime time.Time) []*model.SensorData {\n\u00a0\u00a0\u00a0\u00a0s.dataMu.RLock()\n\u00a0\u00a0\u00a0\u00a0defer s.dataMu.RUnlock()\n\n\u00a0\u00a0\u00a0\u00a0var result []*model.SensorData\n\n\u00a0\u00a0\u00a0\u00a0for key, values := range s.data {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u7b80\u5355\u5339\u914dsensorID\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if len(key) &gt; len(sensorID) &amp;&amp; key[len(key)-len(sensorID):] == sensorID {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0for _, v := range values {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if v.Timestamp.After(startTime) &amp;&amp; v.Timestamp.Before(endTime) {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0result = append(result, v)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0return result\n}\n\n\/\/ GetLatest \u83b7\u53d6\u6700\u65b0\u6570\u636e\nfunc (s *TimeSeriesStore) GetLatest(sensorID string) *model.SensorData {\n\u00a0\u00a0\u00a0\u00a0s.dataMu.RLock()\n\u00a0\u00a0\u00a0\u00a0defer s.dataMu.RUnlock()\n\n\u00a0\u00a0\u00a0\u00a0for key, values := range s.data {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if len(key) &gt; len(sensorID) &amp;&amp; key[len(key)-len(sensorID):] == sensorID {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if len(values) &gt; 0 {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return values[len(values)-1]\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0return nil\n}<\/code><\/pre>\n\n\n<p class=\"wp-block-paragraph\"><strong>3.6 \u4e3b\u7a0b\u5e8f\u5165\u53e3<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\">\u5c06\u6240\u6709\u6a21\u5757\u6574\u5408\u8d77\u6765\uff0c\u6784\u5efa\u5b8c\u6574\u7684\u4f20\u611f\u5668\u6570\u636e\u5904\u7406\u670d\u52a1\uff1a<\/p>\n\n\n<pre class=\"wp-block-code synano has-header\" data-header=\"Go\" data-theme=\"atom-one-dark\"><code class=\"language-go\">go\nmain.go - \u4e3b\u7a0b\u5e8f\u5165\u53e3package main\n\nimport (\n\u00a0\u00a0\u00a0\u00a0&quot;encoding\/json&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;fmt&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;log&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;net\/http&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;time&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;smart-mine\/alert&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;smart-mine\/model&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;smart-mine\/pipeline&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;smart-mine\/storage&quot;\n\u00a0\u00a0\u00a0\u00a0&quot;smart-mine\/validator&quot;\n)\n\nfunc main() {\n\u00a0\u00a0\u00a0\u00a0\/\/ 1. \u521d\u59cb\u5316\u5404\u6a21\u5757\n\u00a0\u00a0\u00a0\u00a0secretKey := &quot;smart-mine-secret-key-2024&quot;\n\n\u00a0\u00a0\u00a0\u00a0dataValidator := validator.NewDataValidator(secretKey)\n\u00a0\u00a0\u00a0\u00a0alertEngine := alert.NewEngine()\n\u00a0\u00a0\u00a0\u00a0tsStore := storage.NewTimeSeriesStore(10000)\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u6dfb\u52a0\u544a\u8b66\u5904\u7406\u5668\n\u00a0\u00a0\u00a0\u00a0alertEngine.AddHandler(&amp;ConsoleAlertHandler{})\n\u00a0\u00a0\u00a0\u00a0alertEngine.AddHandler(&amp;WebhookAlertHandler{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0URL: &quot;https:\/\/alert.example.com\/webhook&quot;,\n\u00a0\u00a0\u00a0\u00a0})\n\n\u00a0\u00a0\u00a0\u00a0\/\/ 2. \u521b\u5efa\u5e76\u542f\u52a8\u6570\u636e\u5904\u7406\u7ba1\u9053\n\u00a0\u00a0\u00a0\u00a0dataPipeline := pipeline.NewDataPipeline(\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0dataValidator,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0alertEngine,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0tsStore,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a08, \/\/ 8\u4e2a\u5de5\u4f5c\u534f\u7a0b\n\u00a0\u00a0\u00a0\u00a0)\n\u00a0\u00a0\u00a0\u00a0dataPipeline.Start()\n\n\u00a0\u00a0\u00a0\u00a0defer dataPipeline.Stop()\n\n\u00a0\u00a0\u00a0\u00a0\/\/ 3. \u542f\u52a8HTTP\u670d\u52a1\u63a5\u6536\u6570\u636e\n\u00a0\u00a0\u00a0\u00a0http.HandleFunc(&quot;\/api\/v1\/data&quot;, func(w http.ResponseWriter, r *http.Request) {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if r.Method != http.MethodPost {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0http.Error(w, &quot;Method not allowed&quot;, http.StatusMethodNotAllowed)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0var data model.SensorData\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if err := json.NewDecoder(r.Body).Decode(&amp;data); err != nil {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0http.Error(w, &quot;Invalid request body&quot;, http.StatusBadRequest)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u63a8\u9001\u6570\u636e\u5230\u5904\u7406\u7ba1\u9053\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0dataPipeline.Push(&amp;data)\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0w.WriteHeader(http.StatusAccepted)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0json.NewEncoder(w).Encode(map[string]string{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0&quot;status&quot;: &quot;accepted&quot;,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0})\n\u00a0\u00a0\u00a0\u00a0})\n\n\u00a0\u00a0\u00a0\u00a0\/\/ \u67e5\u8be2\u63a5\u53e3\n\u00a0\u00a0\u00a0\u00a0http.HandleFunc(&quot;\/api\/v1\/query&quot;, func(w http.ResponseWriter, r *http.Request) {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0sensorID := r.URL.Query().Get(&quot;sensor_id&quot;)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if sensorID == &quot;&quot; {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0http.Error(w, &quot;sensor_id is required&quot;, http.StatusBadRequest)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0return\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/ \u9ed8\u8ba4\u67e5\u8be2\u6700\u8fd11\u5c0f\u65f6\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0endTime := time.Now()\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0startTime := endTime.Add(-1 * time.Hour)\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0data := tsStore.Query(sensorID, startTime, endTime)\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0w.Header().Set(&quot;Content-Type&quot;, &quot;application\/json&quot;)\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0json.NewEncoder(w).Encode(map[string]interface{}{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0&quot;sensor_id&quot;: sensorID,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0&quot;count&quot;: \u00a0\u00a0\u00a0\u00a0len(data),\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0&quot;data&quot;: \u00a0\u00a0\u00a0\u00a0\u00a0data,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0})\n\u00a0\u00a0\u00a0\u00a0})\n\n\u00a0\u00a0\u00a0\u00a0log.Println(&quot;Smart Mine Sensor Data Service starting on :8080&quot;)\n\u00a0\u00a0\u00a0\u00a0if err := http.ListenAndServe(&quot;:8080&quot;, nil); err != nil {\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0log.Fatalf(&quot;Server failed: %v&quot;, err)\n\u00a0\u00a0\u00a0\u00a0}\n}\n\n\/\/ ConsoleAlertHandler \u63a7\u5236\u53f0\u544a\u8b66\u5904\u7406\u5668\ntype ConsoleAlertHandler struct{}\n\nfunc (h *ConsoleAlertHandler) Handle(alert *model.Alert) error {\n\u00a0\u00a0\u00a0\u00a0fmt.Printf(&quot;[ALERT][%s] %s - %s (\u4f4d\u7f6e: %s)\\n&quot;,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0alert.Level.String(),\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0alert.Timestamp.Format(&quot;2006-01-02 15:04:05&quot;),\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0alert.Message,\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0alert.Location,\n\u00a0\u00a0\u00a0\u00a0)\n\u00a0\u00a0\u00a0\u00a0return nil\n}\n\nfunc (h *ConsoleAlertHandler) Name() string {\n\u00a0\u00a0\u00a0\u00a0return &quot;console&quot;\n}\n\n\/\/ WebhookAlertHandler Webhook\u544a\u8b66\u5904\u7406\u5668\ntype WebhookAlertHandler struct {\n\u00a0\u00a0\u00a0\u00a0URL string\n}\n\nfunc (h *WebhookAlertHandler) Handle(alert *model.Alert) error {\n\u00a0\u00a0\u00a0\u00a0\/\/ \u5b9e\u9645\u5b9e\u73b0\u4e2d\u53d1\u9001HTTP\u8bf7\u6c42\u5230webhook\n\u00a0\u00a0\u00a0\u00a0\/\/ \u8fd9\u91cc\u7b80\u5316\u5904\u7406\n\u00a0\u00a0\u00a0\u00a0fmt.Printf(&quot;[WEBHOOK] Sending alert to %s: %s\\n&quot;, h.URL, alert.Message)\n\u00a0\u00a0\u00a0\u00a0return nil\n}\n\nfunc (h *WebhookAlertHandler) Name() string {\n\u00a0\u00a0\u00a0\u00a0return &quot;webhook&quot;\n}<\/code><\/pre>\n\n\n<p class=\"wp-block-paragraph\"><strong>\u56db\u3001\u5173\u952e\u6280\u672f\u4e0e\u6027\u80fd\u4f18\u5316<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\"><strong>4.1 \u5e76\u53d1\u6a21\u578b\u8bbe\u8ba1<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\">Golang\u7684goroutine\u548cchannel\u662f\u6784\u5efa\u9ad8\u5e76\u53d1\u6570\u636e\u5904\u7406\u7cfb\u7edf\u7684\u5229\u5668\u3002\u6211\u4eec\u91c7\u7528\u4ee5\u4e0b\u5e76\u53d1\u7b56\u7565\uff1a<\/p>\n\n\n\n<ul class=\"wp-block-list\">\n<li><strong>\u591a\u534f\u7a0b\u5e76\u884c\u5904\u7406<\/strong>\uff1a\u6570\u636e\u6821\u9a8c\u3001\u5206\u6790\u3001\u5b58\u50a8\u5404\u9636\u6bb5\u72ec\u7acb\u534f\u7a0b\u6c60\uff0c\u4e92\u4e0d\u963b\u585e<\/li>\n\n\n\n<li><strong>\u80cc\u538b\u673a\u5236<\/strong>\uff1a\u4f7f\u7528\u5e26\u7f13\u51b2\u7684channel\u5b9e\u73b0\u6d41\u91cf\u63a7\u5236\uff0c\u9632\u6b62\u7cfb\u7edf\u8fc7\u8f7d<\/li>\n\n\n\n<li><strong>\u65e0\u9501\u8bbe\u8ba1<\/strong>\uff1a\u5c3d\u91cf\u4f7f\u7528channel\u4f20\u9012\u6570\u636e\uff0c\u51cf\u5c11\u9501\u7ade\u4e89<\/li>\n\n\n\n<li><strong>\u6279\u91cf\u5904\u7406<\/strong>\uff1a\u5b58\u50a8\u548c\u544a\u8b66\u91c7\u7528\u6279\u91cf\u5904\u7406\uff0c\u51cf\u5c11IO\u6b21\u6570<\/li>\n<\/ul>\n\n\n\n<p class=\"wp-block-paragraph\"><strong>4.2 \u6570\u636e\u8d28\u91cf\u4fdd\u969c\u673a\u5236<\/strong><\/p>\n\n\n\n<figure class=\"wp-block-table\"><table class=\"has-fixed-layout\"><tbody><tr><td>\u4fdd\u969c\u7ef4\u5ea6<\/td><td>\u6280\u672f\u624b\u6bb5<\/td><td>\u5b9e\u73b0\u65b9\u5f0f<\/td><\/tr><tr><td>\u771f\u5b9e\u6027<\/td><td>HMAC\u7b7e\u540d\u6821\u9a8c<\/td><td>\u4f20\u611f\u5668\u7aef\u5bf9\u6570\u636e\u7b7e\u540d\uff0c\u670d\u52a1\u7aef\u9a8c\u8bc1\uff0c\u9632\u6b62\u7be1\u6539<\/td><\/tr><tr><td>\u6709\u6548\u6027<\/td><td>\u591a\u7ef4\u5ea6\u6821\u9a8c<\/td><td>\u8303\u56f4\u6821\u9a8c\u3001\u65f6\u95f4\u6233\u6821\u9a8c\u3001\u72b6\u6001\u6821\u9a8c\u3001\u683c\u5f0f\u6821\u9a8c<\/td><\/tr><tr><td>\u5b9e\u65f6\u6027<\/td><td>\u6d41\u5f0f\u5904\u7406\u7ba1\u9053<\/td><td>\u6570\u636e\u8fdb\u5165\u5373\u5904\u7406\uff0c\u6beb\u79d2\u7ea7\u5ef6\u8fdf<\/td><\/tr><tr><td>\u53ca\u65f6\u6027<\/td><td>\u6ed1\u52a8\u7a97\u53e3\u544a\u8b66<\/td><td>\u6301\u7eed\u5f02\u5e38\u624d\u544a\u8b66\uff0c\u51cf\u5c11\u8bef\u62a5\uff0c\u786e\u4fdd\u54cd\u5e94\u53ca\u65f6<\/td><\/tr><\/tbody><\/table><\/figure>\n\n\n\n<p class=\"wp-block-paragraph\"><strong>4.3 \u6027\u80fd\u4f18\u5316\u8981\u70b9<\/strong><\/p>\n\n\n\n<ol class=\"wp-block-list\">\n<li><strong>\u5bf9\u8c61\u6c60\u590d\u7528<\/strong>\uff1a\u4f7f\u7528sync.Pool\u590d\u7528\u6570\u636e\u5bf9\u8c61\uff0c\u51cf\u5c11GC\u538b\u529b<\/li>\n\n\n\n<li><strong>\u6279\u91cf\u5199\u5165<\/strong>\uff1a\u65f6\u5e8f\u6570\u636e\u6512\u6279\u5199\u5165\uff0c\u63d0\u5347\u5b58\u50a8\u541e\u5410\u91cf<\/li>\n\n\n\n<li><strong>\u5185\u5b58\u4f18\u5316<\/strong>\uff1a\u6ed1\u52a8\u7a97\u53e3\u5b9a\u671f\u6e05\u7406\u8fc7\u671f\u6570\u636e\uff0c\u63a7\u5236\u5185\u5b58\u5360\u7528<\/li>\n\n\n\n<li><strong>\u544a\u8b66\u6291\u5236<\/strong>\uff1a\u76f8\u540c\u7ea7\u522b\u544a\u8b66\u8bbe\u7f6e\u6291\u5236\u671f\uff0c\u907f\u514d\u544a\u8b66\u98ce\u66b4<\/li>\n\n\n\n<li><strong>\u5e76\u884c\u8ba1\u7b97<\/strong>\uff1a\u591a\u4f20\u611f\u5668\u6570\u636e\u5e76\u884c\u5206\u6790\uff0c\u5145\u5206\u5229\u7528\u591a\u6838CPU<\/li>\n<\/ol>\n\n\n\n<p class=\"wp-block-paragraph\"><strong>\u4e94\u3001\u6269\u5c55\u4e0e\u6f14\u8fdb\u65b9\u5411<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\"><strong>5.1 \u534f\u8bae\u63a5\u5165\u6269\u5c55<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\">\u5f53\u524d\u7cfb\u7edf\u652f\u6301HTTP\u63a5\u5165\uff0c\u5b9e\u9645\u77ff\u5c71\u573a\u666f\u8fd8\u9700\u8981\u652f\u6301\u66f4\u591a\u5de5\u4e1a\u534f\u8bae\uff1a<\/p>\n\n\n\n<ul class=\"wp-block-list\">\n<li>MQTT\uff1a\u7269\u8054\u7f51\u573a\u666f\u6700\u5e38\u7528\u7684\u534f\u8bae\uff0c\u9002\u5408\u4f4e\u5e26\u5bbd\u73af\u5883<\/li>\n\n\n\n<li>Modbus RTU\/TCP\uff1a\u4f20\u7edf\u5de5\u4e1a\u8bbe\u5907\u6807\u51c6\u534f\u8bae<\/li>\n\n\n\n<li>OPC UA\uff1a\u5de5\u4e1a4.0\u6807\u51c6\u534f\u8bae\uff0c\u652f\u6301\u590d\u6742\u6570\u636e\u6a21\u578b<\/li>\n\n\n\n<li>LoRaWAN\uff1a\u4f4e\u529f\u8017\u5e7f\u57df\u7f51\uff0c\u9002\u5408\u4e95\u4e0b\u8fdc\u8ddd\u79bb\u4f20\u8f93<\/li>\n<\/ul>\n\n\n\n<p class=\"wp-block-paragraph\"><strong>5.2 \u667a\u80fd\u5206\u6790\u5347\u7ea7<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\">\u5728\u57fa\u7840\u9608\u503c\u544a\u8b66\u4e4b\u4e0a\uff0c\u53ef\u4ee5\u5f15\u5165\u66f4\u9ad8\u7ea7\u7684\u5206\u6790\u80fd\u529b\uff1a<\/p>\n\n\n\n<ul class=\"wp-block-list\">\n<li><strong>\u8d8b\u52bf\u9884\u6d4b<\/strong>\uff1a\u57fa\u4e8e\u5386\u53f2\u6570\u636e\u9884\u6d4b\u4f20\u611f\u5668\u6570\u503c\u53d8\u5316\u8d8b\u52bf\uff0c\u63d0\u524d\u9884\u8b66<\/li>\n\n\n\n<li><strong>\u5f02\u5e38\u68c0\u6d4b<\/strong>\uff1a\u4f7f\u7528\u673a\u5668\u5b66\u4e60\u7b97\u6cd5\u8bc6\u522b\u5f02\u5e38\u6a21\u5f0f\uff0c\u53d1\u73b0\u672a\u77e5\u98ce\u9669<\/li>\n\n\n\n<li><strong>\u5173\u8054\u5206\u6790<\/strong>\uff1a\u591a\u4f20\u611f\u5668\u6570\u636e\u5173\u8054\u5206\u6790\uff0c\u53d1\u73b0\u8bbe\u5907\u95f4\u7684\u5f71\u54cd\u5173\u7cfb<\/li>\n\n\n\n<li><strong>\u6545\u969c\u8bca\u65ad<\/strong>\uff1a\u57fa\u4e8e\u4e13\u5bb6\u77e5\u8bc6\u5e93\u7684\u6545\u969c\u81ea\u52a8\u8bca\u65ad\u548c\u5b9a\u4f4d<\/li>\n<\/ul>\n\n\n\n<p class=\"wp-block-paragraph\"><strong>5.3 \u9ad8\u53ef\u7528\u67b6\u6784<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\">\u751f\u4ea7\u73af\u5883\u9700\u8981\u8003\u8651\u9ad8\u53ef\u7528\u548c\u5bb9\u707e\uff1a<\/p>\n\n\n\n<ul class=\"wp-block-list\">\n<li>\u96c6\u7fa4\u90e8\u7f72\uff1a\u591a\u5b9e\u4f8b\u90e8\u7f72\uff0c\u8d1f\u8f7d\u5747\u8861<\/li>\n\n\n\n<li>\u6570\u636e\u5197\u4f59\uff1a\u591a\u526f\u672c\u5b58\u50a8\uff0c\u9632\u6b62\u6570\u636e\u4e22\u5931<\/li>\n\n\n\n<li>\u6545\u969c\u8f6c\u79fb\uff1a\u4e3b\u5907\u5207\u6362\uff0c\u4fdd\u8bc1\u670d\u52a1\u8fde\u7eed\u6027<\/li>\n\n\n\n<li>\u8fb9\u7f18\u8ba1\u7b97\uff1a\u4e95\u4e0b\u8fb9\u7f18\u8282\u70b9\u9884\u5904\u7406\uff0c\u51cf\u5c11\u7f51\u7edc\u4f9d\u8d56<\/li>\n<\/ul>\n\n\n\n<p class=\"wp-block-paragraph\"><strong>\u516d\u3001\u603b\u7ed3<\/strong><\/p>\n\n\n\n<p class=\"wp-block-paragraph\">\u667a\u6167\u77ff\u5c71\u4f20\u611f\u5668\u6570\u636e\u5904\u7406\u7cfb\u7edf\u662f\u77ff\u5c71\u5b89\u5168\u7684\u6838\u5fc3\u57fa\u7840\u8bbe\u65bd\u3002\u57fa\u4e8eGolang\u6784\u5efa\u7684\u8fd9\u5957\u7cfb\u7edf\uff0c\u901a\u8fc7\u4ee5\u4e0b\u673a\u5236\u786e\u4fdd\u4e86\u6570\u636e\u7684&#8221;\u5b9e\u65f6\u3001\u6709\u6548\u3001\u771f\u5b9e\u3001\u53ca\u65f6&#8221;\uff1a<\/p>\n\n\n\n<figure class=\"wp-block-table\"><table class=\"has-fixed-layout\"><tbody><tr><td>\u56db\u5927\u6838\u5fc3\u4fdd\u969c\uff1aHMAC\u7b7e\u540d\u786e\u4fdd\u6570\u636e\u771f\u5b9e\u3001\u591a\u7ef4\u5ea6\u6821\u9a8c\u786e\u4fdd\u6570\u636e\u6709\u6548\u3001\u6d41\u5f0f\u7ba1\u9053\u786e\u4fdd\u5904\u7406\u5b9e\u65f6\u3001\u6ed1\u52a8\u7a97\u53e3\u786e\u4fdd\u544a\u8b66\u53ca\u65f6\u3002<\/td><\/tr><\/tbody><\/table><\/figure>\n\n\n\n<p class=\"wp-block-paragraph\">Golang\u7684\u5e76\u53d1\u7279\u6027\u8ba9\u8fd9\u5957\u7cfb\u7edf\u80fd\u591f\u8f7b\u677e\u5e94\u5bf9\u6bcf\u79d2\u6570\u4e07\u6761\u4f20\u611f\u5668\u6570\u636e\u7684\u5904\u7406\u538b\u529b\uff0c\u540c\u65f6\u4fdd\u6301\u6781\u4f4e\u7684\u5ef6\u8fdf\u3002\u6a21\u5757\u5316\u7684\u8bbe\u8ba1\u4e5f\u4f7f\u5f97\u7cfb\u7edf\u6613\u4e8e\u6269\u5c55\u548c\u7ef4\u62a4\u3002<\/p>\n\n\n\n<p class=\"wp-block-paragraph\">\u5728\u5b9e\u9645\u843d\u5730\u65f6\uff0c\u8fd8\u9700\u8981\u7ed3\u5408\u77ff\u5c71\u7684\u5177\u4f53\u573a\u666f\uff0c\u9009\u62e9\u5408\u9002\u7684\u901a\u4fe1\u534f\u8bae\u3001\u5b58\u50a8\u65b9\u6848\u548c\u544a\u8b66\u7b56\u7565\uff0c\u5e76\u5efa\u7acb\u5b8c\u5584\u7684\u8fd0\u7ef4\u76d1\u63a7\u4f53\u7cfb\uff0c\u624d\u80fd\u771f\u6b63\u53d1\u6325\u667a\u6167\u77ff\u5c71\u7684\u5b89\u5168\u4ef7\u503c\u3002<\/p>\n\n\n\n<p class=\"wp-block-paragraph\"><em>\u672c\u6587\u4ecb\u7ecd\u7684\u67b6\u6784\u548c\u4ee3\u7801\u53ef\u4ee5\u4f5c\u4e3a\u667a\u6167\u77ff\u5c71\u6570\u636e\u5904\u7406\u7cfb\u7edf\u7684\u57fa\u7840\u53c2\u8003\uff0c\u5b9e\u9645\u9879\u76ee\u4e2d\u8fd8\u9700\u8981\u6839\u636e\u5177\u4f53\u7684\u4e1a\u52a1\u9700\u6c42\u548c\u6280\u672f\u6808\u8fdb\u884c\u8c03\u6574\u548c\u4f18\u5316\u3002<\/em><\/p>\n\n\n\n<p class=\"wp-block-paragraph\"><\/p>\n","protected":false},"excerpt":{"rendered":"<p>\u5728\u667a\u6167\u77ff\u5c71\u5efa\u8bbe\u4e2d\uff0c\u5404\u7c7b\u4f20\u611f\u5668\uff08\u74e6\u65af\u6d53\u5ea6\u3001\u6e29\u5ea6\u3001\u538b\u529b\u3001\u632f\u52a8\u3001\u4f4d\u79fb\u7b49\uff09\u662f\u77ff\u5c71\u5b89\u5168\u76d1\u6d4b\u7684&#8221;\u795e\u7ecf\u672b\u68a2&#8221;\u3002\u8fd9\u4e9b\u4f20\u611f\u5668\u4ea7\u751f\u7684\u6d77\u91cf\u65f6\u5e8f\u6570\u636e\uff0c\u76f4\u63a5\u5173\u7cfb\u5230\u77ff\u5c71\u751f\u4ea7\u5b89\u5168\u548c\u4eba\u5458\u751f\u547d\u5b89\u5168\u3002\u7136\u800c\uff0c\u77ff\u5c71\u73af\u5883\u590d\u6742\uff0c\u4f20\u611f\u5668\u6570\u636e\u9762\u4e34\u56db\u5927\u6838\u5fc3\u6311\u6218\uff1a<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[21],"tags":[],"class_list":["post-154","post","type-post","status-publish","format-standard","hentry","category-21"],"_links":{"self":[{"href":"https:\/\/zhishilib.com\/index.php\/wp-json\/wp\/v2\/posts\/154","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/zhishilib.com\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/zhishilib.com\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/zhishilib.com\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/zhishilib.com\/index.php\/wp-json\/wp\/v2\/comments?post=154"}],"version-history":[{"count":3,"href":"https:\/\/zhishilib.com\/index.php\/wp-json\/wp\/v2\/posts\/154\/revisions"}],"predecessor-version":[{"id":158,"href":"https:\/\/zhishilib.com\/index.php\/wp-json\/wp\/v2\/posts\/154\/revisions\/158"}],"wp:attachment":[{"href":"https:\/\/zhishilib.com\/index.php\/wp-json\/wp\/v2\/media?parent=154"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/zhishilib.com\/index.php\/wp-json\/wp\/v2\/categories?post=154"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/zhishilib.com\/index.php\/wp-json\/wp\/v2\/tags?post=154"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}