簡(jiǎn)介面向三菱CNC數(shù)采開(kāi)發(fā)與自動(dòng)化調(diào)試場(chǎng)景的C#示例工程適合具備一定C#基礎(chǔ)、希望將機(jī)床數(shù)據(jù)接入上位機(jī)或業(yè)務(wù)系統(tǒng)的工程師參考也可作為自動(dòng)化技術(shù)愛(ài)好者學(xué)習(xí)數(shù)控通訊流程的入門材料。內(nèi)容圍繞與三菱數(shù)控系統(tǒng)建立連接、采集加工參數(shù)與設(shè)備狀態(tài)、處理錯(cuò)誤日志等需求展開(kāi)并說(shuō)明配合安裝A2.exe的作用幫助理解Demo運(yùn)行前提、通訊接口調(diào)用與數(shù)據(jù)交換方式。壓縮包約3.52MB文件總數(shù)暫無(wú)有效值類型明細(xì)上游未給出預(yù)覽顯示含參考手冊(cè)PDF與SimCNC-master仿真源碼目錄可用于對(duì)照通訊協(xié)議、搭建無(wú)實(shí)機(jī)測(cè)試環(huán)境并驗(yàn)證采集邏輯。已有626人學(xué)習(xí)適合借此梳理連接建立、數(shù)據(jù)解析、異常處理與調(diào)試排錯(cuò)思路為后續(xù)上位機(jī)集成提供參考。1. 從一臺(tái) M800 的網(wǎng)口說(shuō)起這份 Demo 能省掉哪一半工作量很多人以為三菱CNC數(shù)采最難的是連不上實(shí)際在現(xiàn)場(chǎng)把線插好、IP 配好ping 通了真正耗時(shí)間的是后面那一段坐標(biāo)怎么讀、報(bào)警號(hào)怎么對(duì)上文本、采集跑一夜內(nèi)存漲到幾個(gè) G、換一臺(tái)系統(tǒng)版本不一樣的機(jī)臺(tái)又得重調(diào)。這份帶 C# 源碼的三菱CNC數(shù)據(jù)采集 Demo價(jià)值不在演示能讀到數(shù)而在它把會(huì)話建立、周期采集、數(shù)據(jù)落地、斷線重連這幾段骨架先搭好了你拿到手是把字段換成自己車間的不是從零畫架構(gòu)圖。適合兩類人手上有一批 M70/M80 系列機(jī)臺(tái)、想自己做一套輕量數(shù)采的自動(dòng)化工程師以及接了小項(xiàng)目、需要一份能跑通的 C# 三菱CNC數(shù)采參考實(shí)現(xiàn)的外包開(kāi)發(fā)者。它不解決跨品牌統(tǒng)一建模也不替你做 MES 對(duì)接邊界先講清楚后面才好判斷哪部分能直接用、哪部分必須自己補(bǔ)。2. 采集鏈路選型EZSocket、MC 協(xié)議與 MTConnect 三條路怎么選動(dòng)手寫第一行代碼之前最該花時(shí)間的是把數(shù)據(jù)從哪個(gè)口子出來(lái)定下來(lái)。三菱CNC的數(shù)據(jù)出口不止一個(gè)選錯(cuò)了后面寫多少代碼都是白搭。這一章把 CNC 側(cè)數(shù)據(jù)和 PLC 側(cè)數(shù)據(jù)的邊界劃清再把三條常見(jiàn)接入路線擺到一張表里對(duì)比最后給出這份 Demo 的工程分層方便你判斷它是能直接改還是只能當(dāng)參考。2.1 CNC 數(shù)據(jù)與 PLC 數(shù)據(jù)先劃清邊界三菱CNC系統(tǒng)里其實(shí)住著兩個(gè)世界。一個(gè)是 NC 世界軸機(jī)械坐標(biāo)、絕對(duì)坐標(biāo)、相對(duì)坐標(biāo)、主軸實(shí)際轉(zhuǎn)速、進(jìn)給速度、當(dāng)前執(zhí)行的程序號(hào)、刀具補(bǔ)償號(hào)、報(bào)警號(hào)與報(bào)警文本、伺服負(fù)載。這些數(shù)據(jù)由 NC 內(nèi)核維護(hù)走廠商提供的 NC 數(shù)據(jù)訪問(wèn)接口最直接字段語(yǔ)義明確不用你去猜某個(gè)寄存器是第幾軸。另一個(gè)是 PLC 世界卡盤夾緊/松開(kāi)、防護(hù)門開(kāi)關(guān)、三色燈狀態(tài)、加工計(jì)數(shù)、外部急停鏈路、上下料機(jī)構(gòu)的握手信號(hào)。這些本質(zhì)上是梯形圖里的軟元件走 MC 協(xié)議讀 D/M/X/Y 更合適。把這兩個(gè)世界混在一個(gè)采集周期里是新手最常見(jiàn)的結(jié)構(gòu)性問(wèn)題。NC 接口一次調(diào)用返回的是結(jié)構(gòu)化對(duì)象PLC 側(cè)返回的是一段連續(xù)的字節(jié)數(shù)組兩者的失敗模式、超時(shí)特征、刷新頻率都不一樣。我一般的做法是在采集層就分成兩個(gè)獨(dú)立的采集器各自有獨(dú)立的周期和獨(dú)立的健康狀態(tài)只在數(shù)據(jù)落地時(shí)按machine_id timestamp對(duì)齊。這樣某一側(cè)卡住了另一側(cè)還能繼續(xù)跑不會(huì)整條鏈路一起啞掉。還有一處容易忽略NC 側(cè)的坐標(biāo)數(shù)據(jù)是有生命周期概念的。程序運(yùn)行中、程序停止、急停、復(fù)位同名字段的可用性不一樣。有些實(shí)現(xiàn)在急停狀態(tài)下讀絕對(duì)坐標(biāo)會(huì)返回上一次的緩存值看著像正常數(shù)據(jù)其實(shí)已經(jīng)失真。所以采集器里必須同時(shí)抓一個(gè)運(yùn)行狀態(tài)字段落地時(shí)一起寫進(jìn)去后面做數(shù)據(jù)分析的人才知道這條記錄該不該信。2.2 三條接入路線的成本對(duì)照下面這張表是我自己在幾個(gè)模擬項(xiàng)目里反復(fù)對(duì)比后沉淀下來(lái)的參數(shù)取值來(lái)自實(shí)際調(diào)試經(jīng)驗(yàn)具體到你的機(jī)臺(tái)型號(hào)和選件配置會(huì)有出入看趨勢(shì)就行。維度EZSocket / NC 數(shù)據(jù)訪問(wèn)庫(kù)MC 協(xié)議裸寫3E 幀MTConnect接入形態(tài)廠商提供的 .NET/COM 組件C# 直接引用自己拼二進(jìn)制幀走 TCP/UDPHTTP XML輪詢 Agent數(shù)據(jù)粒度軸、主軸、報(bào)警、程序號(hào)等語(yǔ)義字段軟元件級(jí)D/M/X/Y 任意地址按設(shè)備模型定義的 DataItem單機(jī)接入工作量低半天能讀到第一條坐標(biāo)中幀格式和響應(yīng)解析要自己寫高需要部署 Agent 并做映射跨品牌能力無(wú)綁定單一品牌無(wú)各品牌協(xié)議不同強(qiáng)標(biāo)準(zhǔn)模型額外授權(quán)通常需要官方運(yùn)行庫(kù)/選件無(wú)只要網(wǎng)口開(kāi)放Agent 側(cè)一般開(kāi)源典型故障版本不匹配、位寬不匹配端口不通、字節(jié)序搞反Agent 掉線、映射字段缺失適合場(chǎng)景單品牌車間、快速出結(jié)果補(bǔ)采 PLC 側(cè)信號(hào)、機(jī)床無(wú) NC 接口多品牌混線、要對(duì)接上層平臺(tái)選型判斷其實(shí)很簡(jiǎn)單車間里只有一個(gè)品牌的機(jī)臺(tái)優(yōu)先走 NC 數(shù)據(jù)訪問(wèn)庫(kù)因?yàn)樗训趲纵S的第幾個(gè)坐標(biāo)這種語(yǔ)義問(wèn)題替你解決了如果還要采門、燈、卡盤這些外圍信號(hào)再疊一層 MC 協(xié)議補(bǔ)采只有當(dāng)車間里同時(shí)存在多個(gè)品牌、上層平臺(tái)又要求統(tǒng)一模型時(shí)才值得為 MTConnect 付出那份額外的部署和映射成本。別為了架構(gòu)先進(jìn)在一臺(tái)機(jī)臺(tái)上堆三套協(xié)議維護(hù)成本會(huì)把省下來(lái)的時(shí)間全吃掉。提示MC 協(xié)議是否開(kāi)放、走 TCP 還是 UDP、端口號(hào)是多少取決于機(jī)臺(tái)的網(wǎng)絡(luò)參數(shù)設(shè)定不同選件配置下默認(rèn)值可能不同。動(dòng)手前先在機(jī)臺(tái)側(cè)確認(rèn)一遍別拿網(wǎng)上抄來(lái)的端口硬試。2.3 Demo 工程結(jié)構(gòu)與依賴清單這份 Demo 的源碼結(jié)構(gòu)是典型的三層適配層、采集層、落地層。適配層把廠商 API 關(guān)在門內(nèi)對(duì)外只暴露一個(gè)自定義接口采集層負(fù)責(zé)周期調(diào)度和狀態(tài)機(jī)落地層負(fù)責(zé)緩沖和批量寫入。這個(gè)分法不新鮮但對(duì)數(shù)采這種廠商 API 隨時(shí)可能換版本的場(chǎng)景特別管用——哪天換了一臺(tái)系統(tǒng)版本不同的機(jī)臺(tái)你只需要再寫一個(gè)適配器實(shí)現(xiàn)采集層一行不用動(dòng)。依賴清單不長(zhǎng)但要一次配齊.NET Framework 4.7.2 或以上走 COM 互操作時(shí)我更傾向 Framework踩的坑少、廠商的通信運(yùn)行庫(kù)、一個(gè)數(shù)據(jù)庫(kù)驅(qū)動(dòng)、一個(gè)日志庫(kù)。工程里建議單獨(dú)建一個(gè)Libs目錄放廠商 DLL并且把復(fù)制到輸出目錄設(shè)成 true否則調(diào)試時(shí)經(jīng)常出現(xiàn)設(shè)計(jì)器里能引用、運(yùn)行時(shí)報(bào)找不到模塊的玄學(xué)問(wèn)題。下面是最小可跑的分層骨架把接口先立住后面所有代碼都往里填。// 適配層對(duì)外契約所有廠商差異都在實(shí)現(xiàn)類里消化 public interface ICncChannel : IDisposable { bool IsOpen { get; } void Open(); // 建立會(huì)話內(nèi)部做重試 CncSnapshot ReadSnapshot(); // 一次讀全量避免多次往返 } // 采集層只認(rèn)這個(gè)結(jié)構(gòu)體不認(rèn)廠商類型 public sealed class CncSnapshot { public DateTime TimestampUtc { get; set; } public string MachineId { get; set; } public double[] AxisPositions { get; set; } // 按軸號(hào)順序單位 mm public double SpindleSpeed { get; set; } // rpm public double FeedRate { get; set; } // mm/min public int ProgramNo { get; set; } public int AlarmNo { get; set; } // 0 表示無(wú)報(bào)警 public int RunState { get; set; } // 1 運(yùn)行 2 暫停 3 急停 4 復(fù)位 }ICncChannel里刻意把Open和讀取分開(kāi)是為了讓采集層能自己控制重連節(jié)奏——如果Open寫在構(gòu)造函數(shù)里一旦網(wǎng)絡(luò)抖動(dòng)你連重試的入口都沒(méi)有。ReadSnapshot一次性返回全量而不是提供GetAxis(i)這種細(xì)粒度方法是因?yàn)樽呔W(wǎng)絡(luò)協(xié)議的接口每次調(diào)用都是一次往返十個(gè)字段調(diào)十次周期直接被拖垮。TimestampUtc用 UTC 存展示層再轉(zhuǎn)本地時(shí)區(qū)這一條后面第 5 章還會(huì)專門講它是時(shí)區(qū)問(wèn)題的后悔藥。3. 把 Demo 跑起來(lái)從運(yùn)行庫(kù)注冊(cè)到第一條軸坐標(biāo)環(huán)境這一關(guān)勸退過(guò)不少人不是因?yàn)殡y是因?yàn)閳?bào)錯(cuò)信息太含糊。這一章按環(huán)境準(zhǔn)備 → 會(huì)話建立 → 采集循環(huán)的順序走一遍每步給出可執(zhí)行的命令或代碼并說(shuō)明失敗時(shí)該看哪里。跟著走完你應(yīng)該能在自己的機(jī)臺(tái)上看到第一條真實(shí)的軸坐標(biāo)。3.1 環(huán)境準(zhǔn)備與網(wǎng)絡(luò)連通性驗(yàn)證第一步是把運(yùn)行庫(kù)裝對(duì)。廠商的通信組件通常是 32 位和 64 位兩套你的宿主進(jìn)程是哪個(gè)位數(shù)就必須裝對(duì)應(yīng)那一套混裝的表現(xiàn)是編譯通過(guò)、運(yùn)行時(shí)拋類型加載異常。工程屬性里把目標(biāo)平臺(tái)從Any CPU改成明確的x64或x86別留默認(rèn)值這是最常見(jiàn)的翻車點(diǎn)之一。裝完之后用管理員權(quán)限注冊(cè)一次路徑按你實(shí)際安裝位置改。# 以管理員身份運(yùn)行32 位進(jìn)程用 SysWOW64 下的 regsvr32 regsvr32 C:\Program Files (x86)\Common Files\Vendor\Comm\EzSocket.dll # 確認(rèn)注冊(cè)成功查注冊(cè)表里有沒(méi)有對(duì)應(yīng)的 ProgID reg query HKCR\EzSocketLib.EzSocket /s # 確認(rèn)進(jìn)程位數(shù)與庫(kù)位數(shù)一致 corflags C:\YourApp\bin\Debug\YourApp.exe三條命令各管一件事第一條把 COM 組件寫進(jìn)注冊(cè)表第二條驗(yàn)證寫入成功查不到就說(shuō)明路徑不對(duì)或者權(quán)限不夠第三條確認(rèn)宿主進(jìn)程的位數(shù)標(biāo)記32BITREQ表示必須跑在 32 位下。第三條規(guī)定經(jīng)常被跳過(guò)結(jié)果就是排查半天發(fā)現(xiàn)是位數(shù)問(wèn)題白白浪費(fèi)一個(gè)下午。網(wǎng)絡(luò)側(cè)先做最樸素的驗(yàn)證別一上來(lái)就開(kāi)程序。機(jī)臺(tái)側(cè)的 IP、子網(wǎng)掩碼、網(wǎng)關(guān)要和采集機(jī)在同一網(wǎng)段防火墻把采集程序放行。用 PowerShell 探端口比 telnet 穩(wěn)因?yàn)?Windows 默認(rèn)經(jīng)常沒(méi)裝 telnet 客戶端。# 1. 先確認(rèn)三層可達(dá) Test-Connection -ComputerName 192.168.1.20 -Count 4 # 2. 再確認(rèn)端口通5007 只是常見(jiàn)默認(rèn)值務(wù)必以機(jī)臺(tái)側(cè)設(shè)定為準(zhǔn) Test-NetConnection -ComputerName 192.168.1.20 -Port 5007 -InformationLevel Detailed # 3. 看本機(jī)是不是有多張網(wǎng)卡搶路由 Get-NetIPConfiguration | Where-Object { $_.IPv4DefaultGateway -ne $null }第二步返回TcpTestSucceeded : True才算通。如果 ping 通但端口不通八成是機(jī)臺(tái)側(cè)沒(méi)開(kāi)對(duì)應(yīng)服務(wù)、端口號(hào)填錯(cuò)、或者中間有設(shè)備做了端口過(guò)濾。第三步容易被忽略采集機(jī)如果同時(shí)接了辦公網(wǎng)和車間網(wǎng)默認(rèn)路由可能把發(fā)往機(jī)臺(tái)的包甩到辦公網(wǎng)卡上表現(xiàn)是偶爾能通、大部分超時(shí)這種間歇性故障最難查先把路由理清楚。3.2 會(huì)話建立與句柄生命周期管理會(huì)話這層的核心原則只有一條一個(gè)采集實(shí)例對(duì)應(yīng)一個(gè)會(huì)話句柄且句柄的生命周期必須由狀態(tài)機(jī)管不能散落在業(yè)務(wù)代碼里。我見(jiàn)過(guò)最典型的錯(cuò)誤寫法是在每次讀取時(shí)new一個(gè)通信對(duì)象讀一百次就泄漏一百個(gè)句柄跑兩小時(shí)機(jī)臺(tái)側(cè)直接拒絕新連接。正確做法是把通道包成一個(gè)單例式的、帶重連能力的對(duì)象。public sealed class EzCncChannel : ICncChannel { private readonly string _host; private readonly int _port; private readonly object _gate new object(); private dynamic _session; // 廠商對(duì)象具體類型按引用庫(kù)版本改 private DateTime _lastOpenFail DateTime.MinValue; public bool IsOpen { get; private set; } public EzCncChannel(string host, int port) { _host host; _port port; } public void Open() { lock (_gate) { // 失敗退避連續(xù)失敗時(shí)不要立刻重試避免把機(jī)臺(tái)側(cè)連接池打滿 if (DateTime.UtcNow - _lastOpenFail TimeSpan.FromSeconds(5)) return; try { _session Activator.CreateInstance(Type.GetTypeFromProgID(EzSocketLib.EzSocket)); _session.Open(_host, _port, 3000); // 第三個(gè)參數(shù)是超時(shí)單位 ms IsOpen true; } catch (Exception ex) { _lastOpenFail DateTime.UtcNow; IsOpen false; Log.Warn($open failed host{_host} err{ex.Message}); } } } public void Dispose() { lock (_gate) { try { _session?.Close(); } catch { /* 關(guān)閉失敗不拋避免拖垮退出流程 */ } _session null; IsOpen false; } } }這段代碼有三處值得說(shuō)。_gate鎖保證同一時(shí)刻只有一個(gè)線程在建會(huì)話多線程并發(fā)Open是句柄泄漏的頭號(hào)來(lái)源。_lastOpenFail做的是失敗退避間隔設(shè) 5 秒機(jī)臺(tái)側(cè)網(wǎng)絡(luò)斷開(kāi)時(shí)如果每 100ms 重試一次一分鐘就是 600 次無(wú)效連接有些實(shí)現(xiàn)會(huì)直接把源 IP 拉黑。Open的第三個(gè)參數(shù)是超時(shí)3000ms 是個(gè)折中值設(shè)太短機(jī)臺(tái)忙的時(shí)候誤判為斷線設(shè)太長(zhǎng)采集線程被阻塞整個(gè)周期被拖垮。dynamic加ProgID的寫法是為了讓你不用在編譯期綁定具體類型庫(kù)換一個(gè)版本的運(yùn)行庫(kù)時(shí)改個(gè)字符串就行。代價(jià)是沒(méi)有編譯期檢查方法名拼錯(cuò)要運(yùn)行到才知道。所以我會(huì)在Open成功后立刻做一次探針讀取讀一個(gè)必然存在的字段比如軸數(shù)讀不到就認(rèn)為這次會(huì)話是假的主動(dòng)關(guān)掉重來(lái)。ICncChannel的注釋里寫了「一次讀全量」實(shí)現(xiàn)時(shí)要注意廠商接口通常不支持真正的批量那就把多次讀取壓縮在一次會(huì)話內(nèi)完成別在兩次讀取之間做任何 IO 或數(shù)據(jù)庫(kù)操作。采集線程的黃金法則是會(huì)話期間只做內(nèi)存操作出了會(huì)話再談落庫(kù)。3.3 采集循環(huán)軸坐標(biāo)、主軸轉(zhuǎn)速與報(bào)警號(hào)采集循環(huán)要解決三個(gè)具體問(wèn)題周期怎么定、值怎么判重、異常怎么不中斷。周期不是越短越好NC 側(cè)的坐標(biāo)刷新本身有內(nèi)部節(jié)拍你 10ms 讀一次讀到的可能還是同一個(gè)值白白占帶寬。我的經(jīng)驗(yàn)值是坐標(biāo)和轉(zhuǎn)速 100ms 到 200ms報(bào)警和程序號(hào) 500msPLC 側(cè)的開(kāi)關(guān)量 50ms 到 100ms。這個(gè)粒度對(duì)絕大多數(shù)加工過(guò)程分析夠用對(duì)真正的插補(bǔ)級(jí)分析不夠但那就不是數(shù)采該干的事了。判重同樣重要。一臺(tái)機(jī)臺(tái)一天產(chǎn)生幾十萬(wàn)條記錄其中大部分坐標(biāo)是重復(fù)的?？梢灾淮孀兓c(diǎn) 每 N 秒的心跳點(diǎn)存儲(chǔ)量能降一個(gè)數(shù)量級(jí)。下面這個(gè)循環(huán)把采集、判重、異常隔離串在一起。public sealed class Collector { private readonly ICncChannel _ch; private readonly IBlockingSink _sink; private readonly int _intervalMs; private CncSnapshot _last; public async Task RunAsync(CancellationToken ct) { var sw new Stopwatch(); while (!ct.IsCancellationRequested) { sw.Restart(); try { if (!_ch.IsOpen) _ch.Open(); if (_ch.IsOpen) { var snap _ch.ReadSnapshot(); snap.TimestampUtc DateTime.UtcNow; // 判重坐標(biāo)變化超過(guò) 0.001mm 或距上次落庫(kù)超過(guò) 5s 才寫 if (IsChanged(snap) || (snap.TimestampUtc - _last.TimestampUtc).TotalSeconds 5) { _sink.Put(snap); // 只入內(nèi)存隊(duì)列絕不在采集線程里寫庫(kù) _last snap; } } } catch (Exception ex) { Log.Error($collect error machine{_last?.MachineId} err{ex.Message}); _ch.Dispose(); // 出錯(cuò)先拆會(huì)話下一輪重建 } var wait _intervalMs - (int)sw.ElapsedMilliseconds; if (wait 0) await Task.Delay(wait, ct); } } private bool IsChanged(CncSnapshot cur) { if (_last null) return true; if (cur.AlarmNo ! _last.AlarmNo) return true; if (cur.ProgramNo ! _last.ProgramNo) return true; for (int i 0; i cur.AxisPositions.Length; i) if (Math.Abs(cur.AxisPositions[i] - _last.AxisPositions[i]) 0.001) return true; return false; } }Stopwatch配合減去已耗時(shí)再 Delay的寫法是為了讓周期穩(wěn)定在設(shè)定值附近而不是設(shè)定值 執(zhí)行耗時(shí)逐輪累積漂移。這一點(diǎn)在長(zhǎng)時(shí)間運(yùn)行里差別很大不修正的話設(shè)定 100ms 實(shí)際跑成 130ms一天的樣本量少 23%做節(jié)拍分析時(shí)數(shù)據(jù)對(duì)不上。catch里直接Dispose而不是只記日志是因?yàn)橥ㄐ女惓Ｖ髸?huì)話對(duì)象的狀態(tài)往往已經(jīng)不可信繼續(xù)用它會(huì)讀到臟數(shù)據(jù)。拆掉重建的成本是幾十毫秒比讀一整天假數(shù)據(jù)劃算。_sink.Put只做內(nèi)存入隊(duì)這個(gè)約束必須硬性守住。一旦有人在采集線程里寫了一次數(shù)據(jù)庫(kù)數(shù)據(jù)庫(kù)抖動(dòng)就會(huì)傳導(dǎo)成采集超時(shí)進(jìn)而觸發(fā)重連進(jìn)而雪崩。落地的事放到第 4 章單獨(dú)講。設(shè)備型號(hào)、軸數(shù)、程序號(hào)格式這些信息不同機(jī)型和系統(tǒng)版本差異不小代碼里凡是硬編碼的地方都建議提成配置項(xiàng)。4. 讓數(shù)據(jù)真正落下來(lái)時(shí)間戳、緩沖隊(duì)列與斷線重連能讀到數(shù)只是半程另一半在讀到的數(shù)怎么不丟、不亂、不把數(shù)據(jù)庫(kù)壓死。這一章講三件事為什么采集頻率必須和入庫(kù)頻率解耦、環(huán)形緩沖怎么設(shè)計(jì)、斷線重連的狀態(tài)機(jī)怎么寫才不會(huì)抖動(dòng)。4.1 采集頻率不能跟著數(shù)據(jù)庫(kù)走新手最常見(jiàn)的架構(gòu)是采一條、寫一條代碼短邏輯直觀在單機(jī)臺(tái)、低頻率下確實(shí)能跑。但它有三個(gè)致命傷第一數(shù)據(jù)庫(kù)的寫入延遲會(huì)直接疊加到采集周期上一次慢查詢就能讓采集周期從 100ms 變成 2 秒第二網(wǎng)絡(luò)抖動(dòng)時(shí)采集線程阻塞在 IO 上機(jī)臺(tái)側(cè)數(shù)據(jù)在緩沖區(qū)里堆積恢復(fù)后一次性涌進(jìn)來(lái)形成尖峰第三采集和存儲(chǔ)的責(zé)任混在一起后面想換存儲(chǔ)介質(zhì)時(shí)序庫(kù)、消息隊(duì)列、文件就得動(dòng)采集代碼。解耦的做法是在中間加一層有界隊(duì)列。采集線程只負(fù)責(zé)Put獨(dú)立的落地線程按批Take兩邊頻率互不影響。隊(duì)列要有界滿了之后采取丟最舊或阻塞采集的策略我一般選丟最舊并計(jì)數(shù)——數(shù)采場(chǎng)景里最新的數(shù)據(jù)永遠(yuǎn)比歷史數(shù)據(jù)重要而丟了多少條本身就是一個(gè)應(yīng)該被監(jiān)控的健康指標(biāo)。public sealed class BoundedSnapshotQueue : IBlockingSink { private readonly BlockingCollectionCncSnapshot _queue; private long _dropped; public BoundedSnapshotQueue(int capacity 20000) { // 有界隊(duì)列容量按最長(zhǎng)斷線時(shí)間 × 采集頻率 × 機(jī)臺(tái)數(shù)估算 _queue new BlockingCollectionCncSnapshot(capacity); } public void Put(CncSnapshot snap) { if (!_queue.TryAdd(snap)) { // 隊(duì)列滿丟最舊保證最新數(shù)據(jù)一定進(jìn)得去 if (_queue.TryTake(out _)) Interlocked.Increment(ref _dropped); _queue.TryAdd(snap); } } public IEnumerableCncSnapshot TakeBatch(int max, int timeoutMs) { var batch new ListCncSnapshot(max); if (_queue.TryTake(out var first, timeoutMs)) batch.Add(first); while (batch.Count max _queue.TryTake(out var more)) batch.Add(more); return batch; } public long DroppedCount Interlocked.Read(ref _dropped); }容量 20000 不是拍腦袋按 20 臺(tái)機(jī)臺(tái)、每臺(tái) 10 條/秒、允許 100 秒的數(shù)據(jù)庫(kù)不可用來(lái)估算正好兩萬(wàn)。這個(gè)數(shù)應(yīng)該寫進(jìn)配置而不是常量。TakeBatch先帶超時(shí)取第一條再非阻塞地把剩下的撈干凈這樣既不會(huì)空轉(zhuǎn)燒 CPU又能在有數(shù)據(jù)時(shí)一次取滿減少數(shù)據(jù)庫(kù)往返次數(shù)。DroppedCount暴露出來(lái)給監(jiān)控用這個(gè)值一旦持續(xù)增長(zhǎng)說(shuō)明落地側(cè)跟不上該加索引或者換存儲(chǔ)了。4.2 批量落庫(kù)與表結(jié)構(gòu)批量寫入的關(guān)鍵是批次大小和事務(wù)粒度的平衡。批次太小數(shù)據(jù)庫(kù)往返次數(shù)多批次太大一次失敗重放代價(jià)高而且長(zhǎng)事務(wù)會(huì)鎖表。我一般取 500 到 2000 條一批配合SqlBulkCopy或者多值INSERT單批耗時(shí)控制在 200ms 以內(nèi)。表結(jié)構(gòu)上有個(gè)小設(shè)計(jì)能省很多事把變化點(diǎn)和心跳點(diǎn)用同一個(gè)表存加一個(gè)is_heartbeat標(biāo)記。做過(guò)程分析時(shí)過(guò)濾掉心跳點(diǎn)做設(shè)備在線率統(tǒng)計(jì)時(shí)只看心跳點(diǎn)一張表兩用。CREATE TABLE cnc_snapshot ( id BIGINT IDENTITY(1,1) PRIMARY KEY, machine_id VARCHAR(32) NOT NULL, ts_utc DATETIME2(3) NOT NULL, -- 統(tǒng)一存 UTC展示層再轉(zhuǎn) axis_json NVARCHAR(512) NULL, -- 軸坐標(biāo)數(shù)組序列化后存 spindle_speed DECIMAL(10,2) NULL, feed_rate DECIMAL(10,2) NULL, program_no INT NULL, alarm_no INT NULL, run_state TINYINT NULL, is_heartbeat BIT NOT NULL DEFAULT 0 ); -- 查詢模式基本固定為某臺(tái)機(jī)某段時(shí)間復(fù)合索引按這個(gè)建 CREATE INDEX ix_snapshot_machine_ts ON cnc_snapshot (machine_id, ts_utc) INCLUDE (alarm_no, run_state);ts_utc用DATETIME2(3)而不是DATETIME毫秒精度對(duì)判重和節(jié)拍分析是必要的DATETIME的 3.33ms 精度在 100ms 周期下會(huì)產(chǎn)生肉眼可見(jiàn)的對(duì)齊誤差。索引把a(bǔ)larm_no和run_state放進(jìn) INCLUDE是因?yàn)閳?bào)表查詢幾乎總要帶上這兩個(gè)字段覆蓋索引能避免回表。axis_json這招在小規(guī)模場(chǎng)景下很好用省掉一張軸明細(xì)表。但如果后面要做任意軸的任意時(shí)間段曲線就得拆成cnc_axis_value(machine_id, ts_utc, axis_no, value)的窄表。這個(gè)改造越晚做代價(jià)越大如果一開(kāi)始就知道要做軸級(jí)分析直接上窄表。4.3 斷線重連的狀態(tài)機(jī)重連邏輯寫不好會(huì)出現(xiàn)抖動(dòng)放大網(wǎng)絡(luò)短暫抖動(dòng) 1 秒程序瘋狂重連 100 次每次都失敗機(jī)臺(tái)側(cè)認(rèn)為是攻擊行為。正確做法是用一個(gè)顯式狀態(tài)機(jī)把失敗次數(shù)變成退避時(shí)間的輸入。public enum LinkState { Disconnected, Connecting, Online, Degraded } public sealed class LinkStateMachine { private int _failCount; private DateTime _nextRetryUtc DateTime.MinValue; public LinkState State { get; private set; } LinkState.Disconnected; // 返回 true 表示本次允許嘗試連接 public bool ShouldTryConnect(DateTime nowUtc) { if (State LinkState.Online) return false; return nowUtc _nextRetryUtc; } public void OnSuccess() { _failCount 0; _nextRetryUtc DateTime.MinValue; State LinkState.Online; } public void OnFailure(DateTime nowUtc) { _failCount; // 指數(shù)退避1s, 2s, 4s, 8s ... 上限 60s var delaySec Math.Min(60, Math.Pow(2, Math.Min(_failCount - 1, 6))); _nextRetryUtc nowUtc.AddSeconds(delaySec); // 連續(xù)失敗 3 次以上進(jìn)入 Degraded只告警不放棄 State _failCount 3 ? LinkState.Degraded : LinkState.Disconnected; } }退避上限設(shè) 60 秒是權(quán)衡的結(jié)果設(shè)太小起不到保護(hù)作用設(shè)太大比如 10 分鐘會(huì)讓一次短暫的網(wǎng)絡(luò)閃斷變成長(zhǎng)時(shí)間的數(shù)據(jù)缺口。Degraded這個(gè)狀態(tài)很多人不設(shè)全用Disconnected表示結(jié)果就是剛斷 1 秒和斷了半小時(shí)在監(jiān)控上看起來(lái)一樣運(yùn)維沒(méi)法判斷優(yōu)先級(jí)。狀態(tài)機(jī)的調(diào)用點(diǎn)必須在采集循環(huán)內(nèi)部而不是搞一個(gè)獨(dú)立的定時(shí)器去探活兩套節(jié)奏容易打架。采集循環(huán)每輪先問(wèn)ShouldTryConnect返回 true 才真正去Open這樣重連節(jié)奏和采集節(jié)奏天然同步。5. 避坑與排查五個(gè)把我按在機(jī)臺(tái)旁邊的現(xiàn)場(chǎng)問(wèn)題這一章的每一條都是真實(shí)踩過(guò)的按現(xiàn)象 → 原因 → 解決寫方便你對(duì)著癥狀查。5.1 連得上、讀得到但坐標(biāo)全是 0現(xiàn)象會(huì)話建立成功Open沒(méi)報(bào)錯(cuò)讀取也返回了對(duì)象但所有軸坐標(biāo)都是 0主軸轉(zhuǎn)速也是 0唯獨(dú)報(bào)警號(hào)能讀到。原因多數(shù)是讀錯(cuò)了數(shù)據(jù)區(qū)。NC 側(cè)的坐標(biāo)分機(jī)械坐標(biāo)、絕對(duì)坐標(biāo)、相對(duì)坐標(biāo)、剩余量等多個(gè)區(qū)有些實(shí)現(xiàn)需要顯式指定區(qū)號(hào)或者先切換到某個(gè)坐標(biāo)系才返回有效值。另一個(gè)可能是軸號(hào)映射錯(cuò)了讀的是不存在的軸實(shí)現(xiàn)層默默返回 0 而不是報(bào)錯(cuò)。解決先用機(jī)臺(tái)的操作面板對(duì)照一次——把面板上顯示的機(jī)械坐標(biāo)抄下來(lái)再和程序讀到的值逐個(gè)比對(duì)能立刻判斷是區(qū)錯(cuò)了還是軸號(hào)錯(cuò)了。代碼里加一個(gè)斷言如果所有軸同時(shí)為 0 且運(yùn)行狀態(tài)為運(yùn)行中視為異常打警告日志別讓它靜默寫庫(kù)。5.2 采集跑幾小時(shí)內(nèi)存漲到幾個(gè) G現(xiàn)象程序啟動(dòng)時(shí)內(nèi)存 80MB跑 8 小時(shí)后漲到 3GB最終 OOM 退出重啟后又慢慢漲。原因九成是隊(duì)列無(wú)界或者落庫(kù)線程因?yàn)楫惓Ｍ顺隽说珱](méi)人發(fā)現(xiàn)采集端一直往里塞。剩下的一成是 COM 對(duì)象沒(méi)釋放——每次讀取都new一個(gè)對(duì)象GC 又回收不了 COM 引用形成泄漏。解決隊(duì)列強(qiáng)制有界第 4 章那個(gè)實(shí)現(xiàn)落地線程用try/catch包住整個(gè)循環(huán)體出錯(cuò)后延遲重啟而不是直接退出同時(shí)把隊(duì)列長(zhǎng)度和落地線程是否存活打點(diǎn)到監(jiān)控。COM 對(duì)象嚴(yán)格按一個(gè)采集實(shí)例一個(gè)會(huì)話管理Dispose里顯式Close并置 null。上線前跑一次 24 小時(shí)浸泡用任務(wù)管理器看內(nèi)存曲線平穩(wěn)才算過(guò)。5.3 多機(jī)臺(tái)并發(fā)時(shí)隨機(jī)幾臺(tái)讀不到現(xiàn)象單臺(tái)調(diào)試一切正常一上到 10 臺(tái)并發(fā)總有 2 到 3 臺(tái)隨機(jī)超時(shí)重啟程序又能好一陣。原因線程數(shù)開(kāi)太多每臺(tái)機(jī)臺(tái)一個(gè)線程加上定時(shí)器和日志線程池被占滿或者所有機(jī)臺(tái)共用同一個(gè)通信組件實(shí)例內(nèi)部鎖競(jìng)爭(zhēng)導(dǎo)致排隊(duì)。還有一種隱蔽情況是采集機(jī)的網(wǎng)卡或交換機(jī)端口在突發(fā)并發(fā)下丟包。解決機(jī)臺(tái)數(shù)超過(guò) 8 臺(tái)時(shí)改用少量線程 異步輪詢的模型不要一臺(tái)一線程。通信組件按機(jī)臺(tái)實(shí)例化絕不共享。先把并發(fā)降到 3 臺(tái)看是否穩(wěn)定再逐步加找出臨界點(diǎn)。網(wǎng)絡(luò)側(cè)用ping -t長(zhǎng)時(shí)間跑看有沒(méi)有規(guī)律性的丟包。5.4 報(bào)警號(hào)能讀到文本對(duì)不上現(xiàn)象alarm_no讀到 1024但程序里查表得到的文本和機(jī)臺(tái)面板顯示的完全不是一回事。原因報(bào)警文本不是 NC 標(biāo)準(zhǔn)數(shù)據(jù)的一部分它來(lái)自機(jī)臺(tái)廠商或者最終用戶自定義的報(bào)警表不同項(xiàng)目、不同系統(tǒng)版本差別很大。指望一套硬編碼的映射表通吃所有機(jī)臺(tái)必然翻車。解決把報(bào)警文本做成外部可配置的映射表按machine_model system_version alarm_no三鍵查找查不到就顯示原始編號(hào)并記錄一條未映射報(bào)警日志。跑一段時(shí)間后把這些未映射的編號(hào)導(dǎo)出來(lái)交給機(jī)臺(tái)側(cè)確認(rèn)逐步補(bǔ)全。這樣即使映射不全數(shù)據(jù)也不會(huì)錯(cuò)只是文本暫時(shí)缺失。5.5 時(shí)間戳差 8 小時(shí)報(bào)表全錯(cuò)位現(xiàn)象數(shù)據(jù)庫(kù)里的時(shí)間和機(jī)臺(tái)面板顯示的時(shí)間差了整整 8 小時(shí)跨天統(tǒng)計(jì)全部錯(cuò)位。原因采集機(jī)、數(shù)據(jù)庫(kù)、機(jī)臺(tái)三方的時(shí)區(qū)設(shè)置不一致有的存本地時(shí)間有的存 UTC匯總時(shí)又按本地時(shí)間截?cái)唷＝鉀Q全鏈路統(tǒng)一存 UTC只在展示層轉(zhuǎn)本地時(shí)區(qū)。機(jī)臺(tái)側(cè)如果只能提供本地時(shí)間采集時(shí)立刻轉(zhuǎn)成 UTC 并記錄原始時(shí)區(qū)偏移。數(shù)據(jù)庫(kù)字段名明確寫ts_utc讓后來(lái)的人沒(méi)有歧義空間。這一條改起來(lái)最便宜但漏掉的代價(jià)最大——時(shí)區(qū)錯(cuò)了所有基于時(shí)間的分析全部作廢而且很難發(fā)現(xiàn)。6. 從 Demo 到產(chǎn)線用 72 小時(shí)浸泡和一張健康度表把穩(wěn)定性釘死Demo 能跑通和能上線之間隔著一段叫長(zhǎng)時(shí)間穩(wěn)定性的距離。我的做法很笨但有效任何一套采集程序不管多簡(jiǎn)單上線前必須跑滿 72 小時(shí)浸泡測(cè)試期間人為制造三次網(wǎng)絡(luò)中斷拔網(wǎng)線 30 秒、兩次機(jī)臺(tái)斷電重啟、一次數(shù)據(jù)庫(kù)重啟。測(cè)試期間只做一件事——盯著健康度指標(biāo)看曲線不看日志里的成功字樣。健康度我只看五個(gè)指標(biāo)多一個(gè)都是負(fù)擔(dān)指標(biāo)采集方式合格線異常時(shí)的第一反應(yīng)采集周期偏差每輪記錄實(shí)際耗時(shí)算 P95P95 設(shè)定值 × 1.5查線程池和 GC 停頓隊(duì)列積壓深度定時(shí)采樣隊(duì)列長(zhǎng)度穩(wěn)態(tài) 容量 20%查落地線程是否卡在慢 SQL丟棄條數(shù)隊(duì)列的 DroppedCount 增量24 小時(shí)為 0同上優(yōu)先擴(kuò)批次而非擴(kuò)容量重連次數(shù)狀態(tài)機(jī) OnFailure 計(jì)數(shù)24 小時(shí) 3 次查網(wǎng)絡(luò)和機(jī)臺(tái)側(cè)連接數(shù)上限數(shù)據(jù)缺口時(shí)長(zhǎng)相鄰兩條記錄的最大間隔 3 倍采集周期對(duì)照機(jī)臺(tái)運(yùn)行狀態(tài)排除正常停機(jī)這五個(gè)指標(biāo)里我最看重?cái)?shù)據(jù)缺口時(shí)長(zhǎng)因?yàn)樗且粋€(gè)結(jié)果性指標(biāo)前四個(gè)出問(wèn)題最終都會(huì)體現(xiàn)在它身上。實(shí)現(xiàn)上很簡(jiǎn)單落地時(shí)記錄上一條記錄的時(shí)間戳超過(guò)閾值就打一條告警帶上機(jī)臺(tái)號(hào)和缺口時(shí)長(zhǎng)。浸泡測(cè)試還有一個(gè)小技巧不要只測(cè)正常生產(chǎn)要專門測(cè)邊界。讓機(jī)臺(tái)在程序運(yùn)行中途急停、在換刀時(shí)斷電、在報(bào)警狀態(tài)下保持兩小時(shí)。這些場(chǎng)景下讀出來(lái)的字段才是真正考驗(yàn)解析邏輯的地方——正常加工時(shí)所有字段都有值邊界狀態(tài)下才會(huì)暴露某個(gè)字段其實(shí)一直返回緩存值這種問(wèn)題。// 缺口檢測(cè)落地線程里順手做不需要額外定時(shí)器 private DateTime _lastTsUtc DateTime.MinValue; private void CheckGap(CncSnapshot snap, int intervalMs) { if (_lastTsUtc ! DateTime.MinValue) { var gapMs (snap.TimestampUtc - _lastTsUtc).TotalMilliseconds; // 閾值取 3 倍采集周期超過(guò)就告警但正常停機(jī)也會(huì)觸發(fā)需結(jié)合 run_state 判斷 if (gapMs intervalMs * 3) { Log.Warn($gap machine{snap.MachineId} gapMs{gapMs:F0} state{snap.RunState}); } } _lastTsUtc snap.TimestampUtc; }這段代碼的閾值取 3 倍周期是因?yàn)閱未?GC 或者一次慢查詢?cè)斐?1 到 2 個(gè)周期的抖動(dòng)是正常的追著這個(gè)告警會(huì)被淹沒(méi)。帶RunState一起打日志是為了區(qū)分真丟數(shù)據(jù)和機(jī)臺(tái)正常停機(jī)——后者在夜班和午休時(shí)段大量出現(xiàn)不區(qū)分的話告警沒(méi)有可讀性。還有一件事值得在 Demo 基礎(chǔ)上補(bǔ)把配置外置。機(jī)臺(tái)列表、IP、端口、采集周期、隊(duì)列容量、告警閾值全部從配置文件讀改一次參數(shù)不用重新編譯。我在一個(gè)模擬項(xiàng)目里就是因?yàn)榘讯丝趯懰涝诖a里換機(jī)臺(tái)時(shí)不得不重新發(fā)布凌晨?jī)牲c(diǎn)在車間里抱著筆記本編譯那種體驗(yàn)一次就夠了。從那以后我每次接數(shù)采項(xiàng)目第一件事就是把配置文件骨架立起來(lái)哪怕只有三臺(tái)機(jī)臺(tái)也不例外。希望幫到你。本文還有配套的精品資源點(diǎn)擊獲取