據(jù)協(xié)議解析實(shí)戰(zhàn):從NMEA語(yǔ)句到6-bit解碼)
簡(jiǎn)介AIS數(shù)據(jù)協(xié)議解析完整版是一份面向船舶通信研發(fā)、AIS設(shè)備調(diào)試與海事信息系統(tǒng)集成人員的doc技術(shù)文檔用于解決AIS VHF報(bào)文難讀、動(dòng)態(tài)/靜態(tài)信息字段定位繁瑣的問(wèn)題。文檔系統(tǒng)講解AIS報(bào)文的數(shù)據(jù)格式、VDM/VDO語(yǔ)句類型、A/B信道指示、填充位、8位CRC校驗(yàn)、多語(yǔ)句拆分重組及 結(jié)束標(biāo)志并給出C語(yǔ)言實(shí)現(xiàn)流程覆蓋字節(jié)流轉(zhuǎn)六位、報(bào)文頭提取、目標(biāo)信息解析可直接借鑒落地。除協(xié)議條款外文檔還梳理了1/2/3/4/5/18/19/21/24等報(bào)文類型的識(shí)別與解析要點(diǎn)以5號(hào)靜態(tài)信息報(bào)文為例展示電文合并后依次解析MMSI、船名、船型、船長(zhǎng)船寬、吃水、目的地等字段的位段劃分與代碼實(shí)現(xiàn)兼顧原理與實(shí)戰(zhàn)。壓縮包共1個(gè)doc文件大小678KB目前已有3749人學(xué)習(xí)下載適合作為AIS設(shè)備開(kāi)發(fā)、船舶監(jiān)控平臺(tái)搭建和協(xié)議二次開(kāi)發(fā)時(shí)的參考手冊(cè)。1. AIS數(shù)據(jù)協(xié)議解析從一串NMEA語(yǔ)句里還原一條船的實(shí)時(shí)動(dòng)態(tài)AISAutomatic Identification System船舶自動(dòng)識(shí)別系統(tǒng)是海事領(lǐng)域最基礎(chǔ)也最常用的數(shù)據(jù)協(xié)議之一岸基基站、船載終端、海事監(jiān)管平臺(tái)和航運(yùn)物流系統(tǒng)都在跑這東西。但真正拿到AIS數(shù)據(jù)你會(huì)發(fā)現(xiàn)它不像HTTP那樣有清晰的JSON結(jié)構(gòu)而是一串以“!AIVDM”開(kāi)頭、逗號(hào)分隔、看起來(lái)像亂碼的文本行。AIS數(shù)據(jù)協(xié)議解析的核心工作就是把這串文本按6-bit編碼規(guī)則拆開(kāi)還原出船名、MMSI、經(jīng)緯度、航速、航向、船長(zhǎng)船寬這些結(jié)構(gòu)化字段。這篇文章我會(huì)按我實(shí)際做過(guò)的方案來(lái)講先講清楚協(xié)議分層和報(bào)文格式再給一套可直接復(fù)現(xiàn)的Python解析實(shí)現(xiàn)最后把調(diào)試中踩過(guò)的坑和驗(yàn)證方法一并說(shuō)透。適合正在做AIS接入、船舶監(jiān)控系統(tǒng)開(kāi)發(fā)、海事數(shù)據(jù)清洗的工程師新手可以照步驟走熟手可以直接拿走避坑清單。2. 先把AIS報(bào)文鏈路理順從VHF數(shù)據(jù)鏈路到一行NMEA語(yǔ)句2.1 AIS在物理層跑的是VHF數(shù)據(jù)鏈路不是IP協(xié)議AIS工作在VHF頻段161.975MHz和162.025MHz兩個(gè)信道采用自組織的TDMA時(shí)分多址方式讓船只共享信道。每條船在自己的時(shí)隙里廣播消息不需要中心調(diào)度。這種設(shè)計(jì)對(duì)解析層意味著什么意味著你拿到手的不管是串口數(shù)據(jù)、UDP數(shù)據(jù)還是日志文件本質(zhì)上都是一段持續(xù)流里面每條消息彼此獨(dú)立沒(méi)有請(qǐng)求-響應(yīng)關(guān)系也沒(méi)有ACK機(jī)制。解析時(shí)不能假設(shè)“發(fā)了A就會(huì)回B”只能按語(yǔ)句一條條解。從數(shù)據(jù)鏈路往上協(xié)議棧大概是這樣的層次物理層是GMSK調(diào)制的VHF信號(hào)數(shù)據(jù)鏈路層是HDLC-like幀封裝網(wǎng)絡(luò)層以上才是我們常說(shuō)的高層消息——ITU-R M.1371定義的27種消息類型加上后來(lái)補(bǔ)充的28、29實(shí)際不超過(guò)29種。但這里要說(shuō)明一下我們實(shí)際開(kāi)發(fā)時(shí)99%的情況不會(huì)直接從HDLC幀開(kāi)始處理。市面上絕大多數(shù)AIS接收機(jī)比如Comar、SRT、或者普通的AIS接收模塊已經(jīng)完成了物理層和鏈路層解調(diào)把數(shù)據(jù)以NMEA 0183語(yǔ)句的形式從串口或網(wǎng)口吐出來(lái)。所以“AIS數(shù)據(jù)協(xié)議解析”這個(gè)標(biāo)題下的核心工作實(shí)際是在解析NMEA封裝層和高層消息層而不是去解射頻信號(hào)。如果你做的是類似“AIS基帶信號(hào)解調(diào)”的項(xiàng)目那就要去看GMSK解調(diào)和TDMA時(shí)隙同步那是另一個(gè)量級(jí)的工程。本文聚焦的是拿到接收機(jī)輸出之后的協(xié)議解析這也是絕大多數(shù)從業(yè)者的真實(shí)場(chǎng)景。2.2 NMEA語(yǔ)句格式VDO和VDM的六個(gè)字段必須記清AIS數(shù)據(jù)接入最常見(jiàn)的形式是NMEA 0183語(yǔ)句典型的一行長(zhǎng)這樣!AIVDM,1,1,,A,13u?etPv2;0n:dDPwUM1KV1L,0*5C拆開(kāi)來(lái)看這個(gè)語(yǔ)句以“!”開(kāi)頭后面是“AIVDM”或“AIVDO”然后是逗號(hào)分隔的字段。這里先記住一個(gè)關(guān)鍵點(diǎn)!AIVDM表示來(lái)自其他船的消息!AIVDO表示本船自己的消息。在接收機(jī)日志里兩者都會(huì)出現(xiàn)解析時(shí)一般不需要區(qū)分但如果做的是本船航跡記錄AIVDO就要單獨(dú)處理。六個(gè)字段的含義如下表字段序號(hào)示例值含義11語(yǔ)句條數(shù)一條完整消息可能被拆成多條語(yǔ)句發(fā)送21當(dāng)前語(yǔ)句序號(hào)3空順序消息ID多語(yǔ)句消息用用于關(guān)聯(lián)4A信道編碼A或B對(duì)應(yīng)VHF信道513u?etPv2;0n:dDPwUM1KV1L數(shù)據(jù)載荷payload6-bit ASCII編碼60填充位數(shù)數(shù)據(jù)載荷最后不足6位時(shí)補(bǔ)的0個(gè)數(shù)字段3在很多單語(yǔ)句消息里是空的這個(gè)不用管。字段5是真正的解碼對(duì)象字段6非常關(guān)鍵——它決定了載荷二進(jìn)制流的長(zhǎng)度是否準(zhǔn)確如果接收機(jī)填錯(cuò)了你解析出來(lái)的字段會(huì)整體錯(cuò)位。校驗(yàn)和是“”后面兩位十六進(jìn)制計(jì)算范圍是從“!”之后到“”之前的所有字符的異或和。這一行的校驗(yàn)和是0x5C可以用下面的代碼驗(yàn)證def nmea_checksum(sentence: str) - str: body sentence.split(*)[0].lstrip(!) cs 0 for ch in body: cs ^ ord(ch) return f{cs:02X}這個(gè)校驗(yàn)和的計(jì)算邏輯是逐字節(jié)異或不是累加和。很多人在這一步按CRC的思維去做算出來(lái)對(duì)不上其實(shí)AIS用的是最簡(jiǎn)單的異或代碼里兩行就完事。校驗(yàn)和的作用是在解碼之前先過(guò)濾掉損壞語(yǔ)句確保后面6-bit解碼不基于壞數(shù)據(jù)展開(kāi)。2.3 高層消息類型位置報(bào)告和靜態(tài)數(shù)據(jù)是解析主要目標(biāo)ITU-R M.1371定義了多種消息類型但實(shí)際在AIS數(shù)據(jù)流里出現(xiàn)頻率最高、業(yè)務(wù)價(jià)值最大的是這么幾類消息1、2、3位置報(bào)告Class A船包含MMSI、經(jīng)緯度、SOG、COG、真航向、航行狀態(tài)、ROT等一條1/2/3類消息就能知道一條船現(xiàn)在在哪、往哪開(kāi)、多快。消息5船舶靜態(tài)和航次數(shù)據(jù)Class A船包含船名、船舶類型、船長(zhǎng)船寬、吃水、目的地、ETA需要兩條NMEA語(yǔ)句拼接才能完整解析。消息18Class B位置報(bào)告對(duì)應(yīng)小型船只的B類設(shè)備字段比消息1/2/3少一些。消息24Class B靜態(tài)數(shù)據(jù)替代了B類船沒(méi)有消息5的問(wèn)題分為24A和24B兩段。消息4基站報(bào)告和消息21航標(biāo)報(bào)告在區(qū)域監(jiān)控和AIS基站網(wǎng)絡(luò)場(chǎng)景里會(huì)大量出現(xiàn)。這里有一個(gè)我們?cè)陧?xiàng)目中用到的消息類型過(guò)濾策略位置消息1/2/3/18直接進(jìn)實(shí)時(shí)軌跡鏈路靜態(tài)消息5/24進(jìn)船舶檔案表更新模塊其他消息4/11/21/27按需走旁路存儲(chǔ)。這個(gè)分流能省掉很多不必要的解碼時(shí)間在一路串口數(shù)據(jù)3000條/分鐘的場(chǎng)景下解碼性能的差距會(huì)被明顯放大。2.4 搞清楚AIS報(bào)文長(zhǎng)度和填充位的關(guān)系所有AIS消息的二進(jìn)制長(zhǎng)度是有固定區(qū)間的。Class A位置報(bào)告消息1/2/3不帶填充位時(shí)是168 bit用168除以6得到28個(gè)ASCII字符。這也是為什么很多位置報(bào)告語(yǔ)句的payload剛好是28個(gè)字符。消息5靜態(tài)數(shù)據(jù)是424 bit去掉填充位后是70到71個(gè)字符因?yàn)?24除以6等于70余4需要補(bǔ)2位填充。如果你在解析時(shí)發(fā)現(xiàn)消息5的payload字符數(shù)不是70或71就要警惕是不是語(yǔ)句拼接順序錯(cuò)亂或者是接收機(jī)輸出截?cái)?。填充位字段字?的取值范圍是0到5因?yàn)樗回?fù)責(zé)補(bǔ)齊最后不足6位的部分。解析時(shí)先把payload每個(gè)字符轉(zhuǎn)成6-bit二進(jìn)制然后把所有bit串起來(lái)再根據(jù)填充位字段去掉末尾的無(wú)效位得到真正有效的數(shù)據(jù)bit流。這個(gè)過(guò)程是整個(gè)AIS解析的地基地基歪了后面所有字段都會(huì)錯(cuò)位。下一章我會(huì)給出完整的Python實(shí)現(xiàn)。3. 核心解碼算法用Python把6-bit payload拆成經(jīng)緯度和航速3.1 6-bit ASCII編碼規(guī)則從字符到二進(jìn)制的映射表AIS的payload不是直接以ASCII碼傳輸數(shù)據(jù)而是用了一套自定義的6-bit字符表。這套表的字符順序是0123456789:;?ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_加上空格。為什么是從“0”開(kāi)始而不是從“A”開(kāi)始因?yàn)锳IS協(xié)議中第一個(gè)有效編碼字符對(duì)應(yīng)數(shù)值0第二個(gè)對(duì)應(yīng)1以此類推字符“0”的ASCII碼是48減去48就是0字符“A”的ASCII碼是65減去48等于17正好對(duì)應(yīng)表里的第18個(gè)位置。轉(zhuǎn)換為二進(jìn)制時(shí)規(guī)則是取該字符在表中的索引值轉(zhuǎn)成6-bit二進(jìn)制。比如前面的payload首字符“1”索引是1二進(jìn)制是000001“u”索引是45ASCII 117減48再偏移實(shí)際按順序算二進(jìn)制是101101。實(shí)現(xiàn)時(shí)不用維護(hù)映射表直接用兩個(gè)剪刀差轉(zhuǎn)換def char_to_bits(c: str) - str: # AIS 6-bit 字符轉(zhuǎn)二進(jìn)制輸入必須是payload字符 ascii_val ord(c) if 48 ascii_val 119: val ascii_val - 48 elif ascii_val 32: val 0 else: val ascii_val - 48 - 8 # 之后的特殊處理 return format(val, 06b)這段代碼的邏輯說(shuō)明AIS 6-bit字符表里“0”到“W”的索引就是ASCII減48其中“W”以后到空格之間的字符需要額外減8。實(shí)際項(xiàng)目里我建議直接用映射表查起來(lái)更快兩個(gè)方式性能差不多但映射表更不容易出錯(cuò)AIS_CHARS 0123456789:;?ABCDEFGHIJKLMNOPQRSTUVWXYZ[\\]^_ CHAR_MAP {c: i for i, c in enumerate(AIS_CHARS)} def char_to_bits_fast(c: str) - str: return format(CHAR_MAP[c], 06b)參數(shù)說(shuō)明AIS_CHARS這個(gè)字符串的順序就是協(xié)議的字符表順序不能調(diào)換最后一個(gè)字符是空格編碼值0x20。CHAR_MAP建好后整個(gè)payload轉(zhuǎn)換就是一次字符查表。3.2 按bit位精確提取字段位偏移表和字段解析函數(shù)當(dāng)payload轉(zhuǎn)換成一長(zhǎng)串二進(jìn)制bit流之后解碼的關(guān)鍵就是按消息類型去切分bit。以消息1/2/3Class A位置報(bào)告為例它的位偏移表是這樣的字段起始位長(zhǎng)度單位/說(shuō)明消息類型06固定值1/2/3重復(fù)指示器62一般填0MMSI830十進(jìn)制航行狀態(tài)3840在航1錨泊5受限等ROT428轉(zhuǎn)向率單位0.1度/分鐘SOG5010航速單位0.1節(jié)位置精度6011高精度10m0低精度經(jīng)度6128單位1/600000度有符號(hào)緯度8927單位1/600000度有符號(hào)COG11612航向單位0.1度真航向1289單位0.1度511不可用時(shí)間戳1376UTC秒填充位1432補(bǔ)0注意這里說(shuō)的“起始位”是0-based即從bit流的第0位開(kāi)始算。經(jīng)度占28位而緯度占27位是因?yàn)榻?jīng)度范圍是±180度乘以600000后需要的bit長(zhǎng)度和緯度不同。這個(gè)不對(duì)稱是小學(xué)算術(shù)就能推導(dǎo)的但實(shí)現(xiàn)時(shí)很容易把兩個(gè)長(zhǎng)度搞反建議把這段位偏移表寫(xiě)死成常量數(shù)組。def extract_bits(bits: str, start: int, length: int) - int: 從bit流中截取指定字段并轉(zhuǎn)成int chunk bits[start : start length] return int(chunk, 2) if chunk else 0 def decode_msg1(bits: str): msg_type extract_bits(bits, 0, 6) mmsi extract_bits(bits, 8, 30) sog extract_bits(bits, 50, 10) / 10.0 lon_raw extract_bits(bits, 61, 28) lat_raw extract_bits(bits, 89, 27) lon lon_raw / 600000.0 if lon_raw else None lat lat_raw / 600000.0 if lat_raw else None cog extract_bits(bits, 116, 12) / 10.0 true_heading extract_bits(bits, 128, 9) return { type: msg_type, mmsi: mmsi, sog_kn: sog, lon: lon, lat: lat, cog_deg: cog if cog 360 else None, heading_deg: true_heading if true_heading ! 511 else None, }邏輯說(shuō)明MMSI是30位的十進(jìn)制數(shù)直接轉(zhuǎn)int就行不用做符號(hào)處理。SOG是10位無(wú)符號(hào)數(shù)單位0.1節(jié)轉(zhuǎn)float后除以10。經(jīng)緯度因?yàn)橛胸?fù)數(shù)存在理論上需要處理二進(jìn)制補(bǔ)碼但實(shí)際中很少看到西經(jīng)或南緯的極端值簡(jiǎn)單按無(wú)符號(hào)數(shù)處理然后判斷是否超范圍再取負(fù)號(hào)也可以。COG的360度上限決定了一個(gè)特殊值當(dāng)COG原始值等于3600時(shí)表示不可用所以用cog 360做過(guò)濾。真航向的511即原始值511表示不可用在消息里通常是“無(wú)航向信息”如果不做過(guò)濾會(huì)把511當(dāng)511.1度解析出來(lái)出現(xiàn)一個(gè)幾乎不存在的航向。3.3 消息5靜態(tài)數(shù)據(jù)解析多語(yǔ)句拼接后再解碼消息5是AIS靜態(tài)數(shù)據(jù)報(bào)文里信息量最大的一條但它會(huì)被拆成兩條NMEA語(yǔ)句發(fā)送各攜帶168bit和256bit加起來(lái)正好是424bit。如果只解析其中一條語(yǔ)句拿到的就是半截?cái)?shù)據(jù)船名、目的地這些字段會(huì)錯(cuò)位。實(shí)現(xiàn)上要先按“語(yǔ)句條數(shù)”和“當(dāng)前語(yǔ)句序號(hào)”做拼接def assemble_static_report(parts: list[str]) - str: parts: 同一消息ID下的多個(gè)payload字符串按語(yǔ)句序號(hào)排列 返回拼接后的完整bit流 total_bits for payload in parts: total_bits .join(char_to_bits_fast(c) for c in payload) return total_bits拼接時(shí)要注意兩個(gè)邊界條件第一條語(yǔ)句和第二條語(yǔ)句的填充位不同第一條通常填充位是0第二條因?yàn)榭傞L(zhǎng)度424mod6的原因填充位是2分別去掉各自的填充位再拼還是先拼后去尾先拼后去尾更簡(jiǎn)單因?yàn)閮蓷l語(yǔ)句的payload拼接后只有最后一條語(yǔ)句末尾才有填充位中間不存在填充位問(wèn)題。但必須確認(rèn)第一條語(yǔ)句的payload長(zhǎng)度是28個(gè)字符第二條是42到43個(gè)字符如果接收機(jī)給的是別的長(zhǎng)度多半是數(shù)據(jù)鏈路層出了問(wèn)題。消息5的字段布局消息類型(6bit) MMSI(30bit) IMO(30bit) 呼號(hào)(42bit7個(gè)6-bit字符) 船名(120bit20個(gè)6-bit字符) 船舶類型(8bit) 船長(zhǎng)船寬(30bit) 吃水(12bit) 目的地(120bit20個(gè)6-bit字符) ETA(20bit)。船名和目的地這類字符串字段是直接用6-bit字符表反向映射的也就是把每個(gè)6-bit值查表轉(zhuǎn)回字符。def bits_to_text(bits: str) - str: text_chars [] for i in range(0, len(bits), 6): v int(bits[i : i 6], 2) text_chars.append(AIS_CHARS[v]) return .join(text_chars).strip( )這個(gè)函數(shù)最坑的地方是字符串末尾會(huì)帶空格填充和“”填充符。AIS協(xié)議規(guī)定文本字段不足長(zhǎng)度時(shí)用空格補(bǔ)位多余用符號(hào)填充。所以解析出的船名可能是“COSCO SHANGHAI”必須用strip( )把末尾的和空格清掉。但注意不能strip掉中間的空格否則“MAERSK LINE”會(huì)變成“MAERSKLINE”對(duì)船名匹配會(huì)出問(wèn)題。4. 把解析器接到真實(shí)數(shù)據(jù)流串口、TCP日志和消息分發(fā)的完整工程4.1 數(shù)據(jù)源接入方式serial讀取與socket接收的兩套模板AIS接收機(jī)常見(jiàn)輸出是串口RS232或USB轉(zhuǎn)串口和網(wǎng)絡(luò)TCP/UDP。串口場(chǎng)景下用pyserial核心參數(shù)是波特率38400、8位數(shù)據(jù)位、1位停止位、無(wú)校驗(yàn)。這是AIS接收機(jī)的默認(rèn)配置少數(shù)設(shè)備支持切換接不上時(shí)先檢查波特率再懷疑線序。import serial ser serial.Serial( port/dev/ttyUSB0, baudrate38400, bytesizeserial.EIGHTBITS, parityserial.PARITY_NONE, stopbitsserial.STOPBITS_ONE, timeout1, ) while True: line ser.readline().decode(ascii, errorsignore).strip() if line.startswith(!): process_sentence(line)這里有個(gè)性能陷阱串口readline在數(shù)據(jù)量大時(shí)會(huì)阻塞AIS數(shù)據(jù)密集時(shí)可能出現(xiàn)緩沖區(qū)溢出。建議把串口讀取放到獨(dú)立線程解析主線程用隊(duì)列接收避免IO阻塞影響解碼吞吐。timeout1保證即使沒(méi)有數(shù)據(jù)readline最多阻塞1秒不會(huì)把線程卡死。TCP場(chǎng)景更簡(jiǎn)單AIS TCP服務(wù)器通常直接輸出文本流用socket加readline循環(huán)即可但要做好斷線重連。很多岸基AIS設(shè)備用的是TCP 4001端口或者其他自定義端口接入時(shí)要先確認(rèn)設(shè)備的手冊(cè)不要想當(dāng)然用23。4.2 按消息類型分發(fā)從一句話到軌跡入庫(kù)的管線設(shè)計(jì)一條完整的AIS解析管線至少要有三層接入層負(fù)責(zé)讀取和校驗(yàn)解碼層負(fù)責(zé)把payload轉(zhuǎn)成結(jié)構(gòu)化對(duì)象業(yè)務(wù)層負(fù)責(zé)按消息類型分發(fā)到軌跡緩存、船舶檔案、告警模塊。分發(fā)邏輯有一個(gè)常見(jiàn)的坑消息1/2/3都是位置報(bào)告但消息類型字段在第0到第5位必須先解出消息類型再去分發(fā)不能直接用NMEA語(yǔ)句的前綴VDM/ VDO判斷。def process_sentence(sentence: str): if not sentence.startswith(!): return parts sentence[1:].split(*)[0].split(,) if len(parts) 7: return if nmea_checksum(sentence) ! sentence.split(*)[1][:2]: return payload parts[5] fill_bits int(parts[6]) bits .join(char_to_bits_fast(c) for c in payload) msg_type int(bits[0:6], 2) if msg_type in (1, 2, 3, 18): record decode_position_report(bits, fill_bits) route_tracker.update(record) elif msg_type 5: pending_static[parts[2]] pending_static.get(parts[2], []).append(payload) if len(pending_static[parts[2]]) 2: record decode_static_report(assemble_static_report(pending_static.pop(parts[2]))) ship_profile.update(record)邏輯說(shuō)明parts[2]是NMEA語(yǔ)句的消息ID字段用于關(guān)聯(lián)同一條消息5的兩個(gè)分片。如果接收機(jī)連續(xù)發(fā)送多條消息5用這個(gè)ID做key就能避免不同船的靜態(tài)數(shù)據(jù)拼錯(cuò)。fill_bits在這個(gè)分發(fā)層不直接參與解碼因?yàn)槲恢脠?bào)告類消息的fill_bits通常是0而消息5的fill_bits在拼接后統(tǒng)一處理更簡(jiǎn)單。分發(fā)的粒度建議按消息類型分表存儲(chǔ)而不是把所有消息灌進(jìn)一個(gè)大表。軌跡表通常只保留24小時(shí)內(nèi)的位置報(bào)告船舶檔案表則長(zhǎng)期保留靜態(tài)信息。這種設(shè)計(jì)在MySQL里加一個(gè)msg_type索引就能高效查詢?cè)诤A繑?shù)據(jù)場(chǎng)景下比一個(gè)“所有字段可空”的大寬表好維護(hù)得多。4.3 多語(yǔ)句消息的拼裝狀態(tài)管理過(guò)期清理不能少消息5需要兩條語(yǔ)句拼裝如果一個(gè)片段在傳輸中丟失另一片段就會(huì)一直掛在內(nèi)存里浪費(fèi)空間而且可能與下一條消息5的片段混淆。解決辦法是給每條待拼裝記錄加時(shí)間戳超過(guò)5秒沒(méi)湊齊全部片段就丟棄。這個(gè)5秒不是拍腦袋定的AIS的時(shí)隙分配保證一條消息的多個(gè)片段在同一個(gè)無(wú)線電時(shí)段內(nèi)到達(dá)正常情況下間隔不超過(guò)幾百毫秒。pending_static: dict[str, list[str]] {} def buffer_static(payload: str, msg_id: str): now time.time() item pending_static.get(msg_id) if item is None: pending_static[msg_id] {parts: [payload], ts: now} else: item[parts].append(payload) item[ts] now def cleanup_static(timeout5): for msg_id in list(pending_static): if time.time() - pending_static[msg_id][ts] timeout: del pending_static[msg_id]這里的cleanup_static要放在串口讀取循環(huán)里每輪調(diào)用一次或者用定時(shí)器每30秒跑一次否則內(nèi)存里堆積的失效消息會(huì)越來(lái)越多運(yùn)行一天后可能有幾千條垃圾數(shù)據(jù)占著內(nèi)存。5. AIS解析避坑五條會(huì)讓你深夜翻車(chē)的數(shù)據(jù)坑5.1 校驗(yàn)和明明能對(duì)上但解碼出來(lái)的緯度差了幾公里現(xiàn)象從串口讀到的AIS語(yǔ)句校驗(yàn)和全部通過(guò)解碼出的經(jīng)緯度在赤道附近偏差很大個(gè)別點(diǎn)跑到撒哈拉沙漠里去了。原因AIS的payload經(jīng)過(guò)6-bit編碼后如果接收機(jī)輸出的填充位字段第六個(gè)逗號(hào)后的數(shù)字填錯(cuò)了你按錯(cuò)誤填充位裁剪bit流尾部的bit錯(cuò)位會(huì)影響后面所有字段。更隱蔽的是另一種情況語(yǔ)句里帶有回車(chē)換行符如果不做strip最后一位的ASCII碼參與異或時(shí)會(huì)把0x0D也算進(jìn)去導(dǎo)致校驗(yàn)和計(jì)算表里錯(cuò)誤——但恰好某個(gè)接收機(jī)在發(fā)送時(shí)也把回車(chē)換行算進(jìn)了校驗(yàn)兩邊都錯(cuò)校驗(yàn)和反而能對(duì)上。解決解析前統(tǒng)一執(zhí)行strip()去掉\r\n然后強(qiáng)制校驗(yàn)位必須是兩位十六進(jìn)制且校驗(yàn)通過(guò)才繼續(xù)解析。如果發(fā)現(xiàn)填充位不在0到5之間這條語(yǔ)句直接丟棄不要試圖“修正”后再解。5.2 消息5拼裝一直湊不齊兩個(gè)片段但日志里明明有很多消息5現(xiàn)象日志文件里能看到大量!AIVDM,2,1,...和!AIVDM,2,2,...開(kāi)頭的語(yǔ)句但拼裝模塊永遠(yuǎn)只收到第一條第二條遲遲不出現(xiàn)。原因AIS消息5的第二種片段字段2等于2在某些接收機(jī)固件里可能因?yàn)榫彌_區(qū)太小被丟棄尤其是當(dāng)接收機(jī)同時(shí)處理消息1/2/3這種高頻位置報(bào)告時(shí)低優(yōu)先級(jí)的長(zhǎng)消息片段容易被擠掉。另一個(gè)常見(jiàn)原因是你的解析程序用了“按語(yǔ)句序號(hào)硬等”的邏輯如果一個(gè)片段到達(dá)順序顛倒先2后1你的代碼沒(méi)有處理。解決拼裝模塊不要依賴到達(dá)順序用消息ID做key兩個(gè)片段都到了就觸發(fā)拼接只到一條就進(jìn)入等待隊(duì)列。同時(shí)把等待超時(shí)設(shè)短一點(diǎn)3秒即可防止舊數(shù)據(jù)長(zhǎng)期占用內(nèi)存。對(duì)接收機(jī)緩沖區(qū)問(wèn)題可以考慮在配置層面把AIS接收機(jī)的輸出消息過(guò)濾掉消息8氣象、消息27長(zhǎng)距離等非關(guān)鍵類型給消息5騰出帶寬。5.3 船名解析出來(lái)是“COSCO”現(xiàn)象船名字段解碼后船名前面全是符號(hào)后面的名稱順序也亂了。原因AIS消息5的船名是固定120bit即20個(gè)字符協(xié)議規(guī)定船名靠左填寫(xiě)右邊用空格補(bǔ)位。但某些船載設(shè)備尤其是改裝的Class B終端會(huì)把船名靠右填寫(xiě)左邊用填充導(dǎo)致你按標(biāo)準(zhǔn)解析得到的字符串前半段是后半段才是船名。解決解析文本字段時(shí)先做strip( )再用strip()清理空格且不要只做一邊。正確順序是先按字符級(jí)過(guò)濾和空格再拼接成字符串這樣可以避免把“MAERSK EVERT”這種中間夾的字段拆錯(cuò)。更好的做法是保留內(nèi)部空格只去掉首尾無(wú)效字符然后用re.sub(r[\s]$, , name)只處理尾部填充。5.4 SOG出現(xiàn)99.9節(jié)COG出現(xiàn)360度現(xiàn)象解析出的船速經(jīng)常出現(xiàn)99.9航向顯示360但這是在長(zhǎng)江航道里不大可能的物理速度。原因AIS協(xié)議里SOG的可用范圍是0到102.2節(jié)超過(guò)102.2時(shí)用102.3表示“不可用”COG正好是0到359.9度用360表示“不可用”。如果解碼代碼把原始bit直接除以10輸出1023/10102.3和3600/10360就會(huì)被當(dāng)正常值放進(jìn)數(shù)據(jù)庫(kù)。業(yè)務(wù)統(tǒng)計(jì)時(shí)平均值全被這些值拉高了。解決在解碼函數(shù)中設(shè)置業(yè)務(wù)字段的可信范圍SOG超過(guò)102.2或等于102.3直接置NoneCOG大于等于360置None真航向等于511置None。注意是將字段置None還是置0置0會(huì)讓數(shù)據(jù)看起來(lái)像是“靜止在水面上”影響后續(xù)追跡判斷建議統(tǒng)一用None表示未知在數(shù)據(jù)庫(kù)里存NULL。5.5 時(shí)間戳字段解析出來(lái)全是垃圾數(shù)現(xiàn)象消息1/2/3的時(shí)間戳字段在解碼后是隨機(jī)數(shù)和真實(shí)UTC時(shí)間對(duì)不上。原因AIS消息里的時(shí)間戳字段位置報(bào)告里的第137到142位是UTC秒取值為0到59。但很多船載設(shè)備根本沒(méi)有GPS授時(shí)模塊或者GPS信號(hào)丟失這個(gè)字段要么是0要么是60表示時(shí)間不可用。如果你直接用這個(gè)時(shí)間戳作為軌跡點(diǎn)的時(shí)間會(huì)出現(xiàn)整點(diǎn)時(shí)間混亂、時(shí)間倒序等情況。解決業(yè)務(wù)系統(tǒng)里以接收機(jī)收到語(yǔ)句的系統(tǒng)時(shí)間作為軌跡主時(shí)間戳AIS時(shí)間戳只作為輔助參考。存儲(chǔ)時(shí)把AIS時(shí)間戳和接收時(shí)間分開(kāi)兩列方便后續(xù)排查信號(hào)源問(wèn)題。判斷時(shí)間戳是否可用的標(biāo)準(zhǔn)是值在0到59之間且接收時(shí)間與整點(diǎn)的分鐘數(shù)相差不超過(guò)1秒才認(rèn)為有效否則標(biāo)記時(shí)間源不可用。6. 進(jìn)階驗(yàn)證技巧用回放數(shù)據(jù)校準(zhǔn)解析器然后做消息類型擴(kuò)展解析器寫(xiě)完不等于能上線先拿歷史日志做回放驗(yàn)證。方法很簡(jiǎn)單從AIS接收機(jī)日志里截取一段原始數(shù)據(jù)保存為文本文件用支持回放的工具或腳本按原始時(shí)間間隔把每一行重新喂給解析函數(shù)然后把解碼結(jié)果和已知的船位信息做交叉比對(duì)。你沒(méi)有真實(shí)軌跡對(duì)照時(shí)可以抽幾個(gè)邏輯校驗(yàn)點(diǎn)MMSI是否落在合法的9位數(shù)字區(qū)間經(jīng)緯度是否在±180和±90以內(nèi)SOG是否在0到102.2范圍內(nèi)COG是否小于360。這些很容易寫(xiě)成一個(gè)批量校驗(yàn)函數(shù)跑完一輪后統(tǒng)計(jì)異常率。注意回放時(shí)要保留原始語(yǔ)句的順序和間隔不要一次性灌入內(nèi)存后并行處理——AIS的位置報(bào)告消息1/2/3之間是有時(shí)間關(guān)聯(lián)的你并行解出來(lái)的結(jié)果和真實(shí)時(shí)序不一致后續(xù)做軌跡擬合時(shí)會(huì)錯(cuò)亂。按行讀取、按行解析、按行入庫(kù)是最慢但最可靠的方式。消息類型擴(kuò)展方面除了消息5之外消息24Class B靜態(tài)數(shù)據(jù)也是必須補(bǔ)上的。它的結(jié)構(gòu)和消息5有部分相似但字段長(zhǎng)度和位置不同尤其24A和24B要區(qū)分處理——24A帶船名24B帶船舶類型和尺寸。如果你要接的是漁政、內(nèi)河船舶監(jiān)控項(xiàng)目Class B船的比例很高消息24比消息5更常見(jiàn)。具體位偏移參考ITU-R M.1371-5的Table 76和Table 77不要用網(wǎng)上流傳的舊版字段表舊版對(duì)24B的長(zhǎng)度定義和新版有差異。性能優(yōu)化的最后一招Python里直接用int切片再轉(zhuǎn)二進(jìn)制的做法在每秒鐘幾百條語(yǔ)句時(shí)沒(méi)問(wèn)題但到了每秒上千條一個(gè)繁忙港口可能同時(shí)有幾百條船每條船每2到10秒發(fā)一次位置報(bào)告應(yīng)該把6-bit解碼改成查表加位運(yùn)算的批量實(shí)現(xiàn)。具體做法是把payload字符串位置和bit偏移量拆成預(yù)計(jì)算的切片索引表一次循環(huán)里用ord查表替代字符串切片性能能提升3到5倍。如果你的系統(tǒng)目標(biāo)是單機(jī)支撐10000條船同時(shí)在線建議把那層解碼邏輯用Cython或Go重寫(xiě)Python只做業(yè)務(wù)分發(fā)。這套解析器的最后一個(gè)習(xí)慣性動(dòng)作是寫(xiě)監(jiān)控指標(biāo)每接收1000條語(yǔ)句記錄一次有效解碼率、校驗(yàn)失敗率、多語(yǔ)句拼裝成功率。這三個(gè)指標(biāo)能直接告訴你接收機(jī)信號(hào)質(zhì)量是否在惡化、協(xié)議層是否有兼容性問(wèn)題比看日志定位問(wèn)題快得多。我從第一次做AIS接入項(xiàng)目開(kāi)始就養(yǎng)成了這個(gè)習(xí)慣后來(lái)?yè)Q了幾種接收機(jī)、換了幾套傳輸鏈路都靠這套指標(biāo)快速排掉了接入層的疑難雜癥。希望幫到你。本文還有配套的精品資源點(diǎn)擊獲取