0引言

隨著光纖保護(hù)系統(tǒng)在通信領(lǐng)域的廣泛運(yùn)用，建立一整套軟、硬齊全的光層保護(hù)監(jiān)控系統(tǒng)尤其重要。系統(tǒng)通過(guò)數(shù)據(jù)采集服務(wù)可以實(shí)時(shí)快速地獲得各個(gè)光保護(hù)設(shè)備的及時(shí)數(shù)據(jù)，然后交給上層進(jìn)行相應(yīng)的處理。

數(shù)據(jù)采集服務(wù)是惟一面向光纖設(shè)備的接口服務(wù)層，每秒有相當(dāng)大的數(shù)據(jù)吞吐量，因此數(shù)據(jù)采集服務(wù)的設(shè)計(jì)尤為關(guān)鍵，必須兼顧考慮設(shè)計(jì)的合理性、高效性和一致性。面對(duì)大量的數(shù)據(jù)交流，采集服務(wù)分多個(gè)模塊，主要采用多點(diǎn)采集多線(xiàn)程的模式構(gòu)建方式。各個(gè)模塊分別完成不同的功能，通過(guò)由主線(xiàn)程創(chuàng)建許多與子模塊對(duì)應(yīng)的子線(xiàn)程，由單獨(dú)的一個(gè)線(xiàn)程來(lái)分發(fā)數(shù)據(jù)給各個(gè)子線(xiàn)程，實(shí)現(xiàn)數(shù)據(jù)的同步處理，提高系統(tǒng)的效率和網(wǎng)元容量。

1 TCP／IP，UDP協(xié)議

數(shù)據(jù)采集服務(wù)需要大量的數(shù)據(jù)處理工作，從光設(shè)備中采集數(shù)據(jù)以及將數(shù)據(jù)轉(zhuǎn)交給上層服務(wù)都需要一定的協(xié)議來(lái)完成。根據(jù)TCP和UDP不同的特點(diǎn)，選取可靠的TCP／IP通信方式連接采集服務(wù)與上層服務(wù)；選取效率較高的UDP通信方式連接采集服務(wù)及下層設(shè)備。以UDP為例，UDP通信模塊在發(fā)送的時(shí)候，只是需要從UDP發(fā)送隊(duì)列獲取數(shù)據(jù)發(fā)給設(shè)備，而在接收的時(shí)候，將設(shè)備數(shù)據(jù)存放到UDP接收隊(duì)列。

數(shù)據(jù)的發(fā)送和接收分別由兩個(gè)不同的線(xiàn)程來(lái)完成。此外，還有一個(gè)單獨(dú)的線(xiàn)程對(duì)接收隊(duì)列的數(shù)據(jù)進(jìn)行解包和分發(fā)，并根據(jù)返回的UDP命令代碼或索引（track）的不同將數(shù)據(jù)分別放置到數(shù)據(jù)輪詢(xún)返回隊(duì)列、閾值輪詢(xún)返回隊(duì)列和讀寫(xiě)設(shè)備返回隊(duì)列，其模塊結(jié)構(gòu)如圖1所示。

2數(shù)據(jù)輪詢(xún)

由于光保護(hù)設(shè)備都是非智能的設(shè)備，只能被動(dòng)地采集性能數(shù)據(jù)，不會(huì)主動(dòng)地上報(bào)性能變化給管理軟件，基于此，在軟件設(shè)計(jì)中采用了數(shù)據(jù)輪詢(xún)機(jī)制，獨(dú)立出一個(gè)輪詢(xún)模塊來(lái)捕捉網(wǎng)絡(luò)中的性能變化，彌補(bǔ)了設(shè)備的不足。在這個(gè)模塊中要進(jìn)行處理，去掉一些重復(fù)的數(shù)據(jù)，以減少與上層服務(wù)通信的數(shù)據(jù)量。在輪詢(xún)過(guò)程中，要進(jìn)行超時(shí)控制，對(duì)于超時(shí)的請(qǐng)求需要補(bǔ)叫。因此，對(duì)于所有的輪詢(xún)都需要有緩沖列表存儲(chǔ)，只有當(dāng)?shù)玫交貞?yīng)后才刪除請(qǐng)求。

數(shù)據(jù)輪詢(xún)模塊包括數(shù)據(jù)輪詢(xún)線(xiàn)程、數(shù)據(jù)輪詢(xún)返回處理線(xiàn)程、閾值輪詢(xún)返回處理線(xiàn)程和切換命令超時(shí)處理線(xiàn)程。數(shù)據(jù)輪詢(xún)模塊結(jié)構(gòu)圖如圖2所示。

2.1數(shù)據(jù)輪詢(xún)線(xiàn)程

數(shù)據(jù)輪詢(xún)線(xiàn)程是負(fù)責(zé)對(duì)設(shè)備進(jìn)行輪詢(xún)的線(xiàn)程。通過(guò)定時(shí)地發(fā)出讀數(shù)據(jù)和讀閾值命令來(lái)采集設(shè)備的性能、狀態(tài)、告警和閾值信息，因此，輪詢(xún)時(shí)間間隔必須很小，而且對(duì)性能和閾值輪詢(xún)的周期要求有所不同，因?yàn)殚撝档淖兓^少。該線(xiàn)程在輪詢(xún)模塊啟動(dòng)后，判斷是否獲得配置信息樹(shù)的初始信息，如果是就開(kāi)始輪詢(xún)。

2.2閾值輪詢(xún)返回處理線(xiàn)程

數(shù)據(jù)輪詢(xún)線(xiàn)程按照閾值輪詢(xún)的周期定期發(fā)送讀光保護(hù)設(shè)備閾值的命令，設(shè)備在收到命令包后定期返回設(shè)備的閾值，這些閾值通過(guò)UDP模塊的數(shù)據(jù)分發(fā)線(xiàn)程發(fā)送到閾值輪詢(xún)返回隊(duì)列，等待閾值輪詢(xún)返回處理線(xiàn)程來(lái)處理。

閾值輪詢(xún)返回處理線(xiàn)程則接收這些返回的閾值，通過(guò)比較全局配置信息樹(shù)的前次輪詢(xún)結(jié)果與當(dāng)前返回結(jié)果來(lái)捕捉閾值的變化，并將這些變化寫(xiě)入告警隊(duì)列，通過(guò)性能和告警模塊將閾值變化事件發(fā)送到上層服務(wù)器。

2.3數(shù)據(jù)輪詢(xún)返回處理線(xiàn)程

與閾值的輪詢(xún)相似，數(shù)據(jù)輪詢(xún)線(xiàn)程按照系統(tǒng)設(shè)定的輪詢(xún)周期定期發(fā)送讀光保護(hù)設(shè)備數(shù)據(jù)的命令，輪詢(xún)周期一般為500 ms或1 s。設(shè)備在收到讀數(shù)據(jù)的命令包后定期返回設(shè)備數(shù)據(jù)，這些數(shù)據(jù)通過(guò)UDP模塊的數(shù)據(jù)分發(fā)線(xiàn)程發(fā)送到數(shù)據(jù)輪詢(xún)返回隊(duì)列，等待數(shù)據(jù)輪詢(xún)返回處理線(xiàn)程來(lái)處理。數(shù)據(jù)輪詢(xún)返回處理線(xiàn)程在接收到這些返回的數(shù)據(jù)后，通過(guò)比較全局配置信息樹(shù)的前次輪詢(xún)結(jié)果與當(dāng)前返回結(jié)果來(lái)捕捉告警信息、狀態(tài)變化事件及其他信息，并將這些變化寫(xiě)入告警隊(duì)列，通過(guò)性能和告警模塊將告警和事件發(fā)送到上層服務(wù)器。

在該線(xiàn)程中，對(duì)線(xiàn)路切換的處理比較特殊，由于發(fā)生線(xiàn)路切換時(shí)用戶(hù)需要察看切換前整個(gè)過(guò)程中性能值的變化情況，并且需要該信息盡快返回到用戶(hù)界面，因此，當(dāng)發(fā)生線(xiàn)路切換時(shí)需要立即發(fā)送8個(gè)數(shù)據(jù)包讀取40幀切換過(guò)程的性能信息，通過(guò)數(shù)據(jù)分析后取出最近一次切換前的性能信息作為切換事件的附加數(shù)據(jù)添加到告警隊(duì)列。

2.4讀切換命令超時(shí)處理線(xiàn)程

在數(shù)據(jù)輪詢(xún)線(xiàn)程中讀切換信息命令發(fā)生工作模式改變（即發(fā)生線(xiàn)路切換）時(shí)，連續(xù)發(fā)送8個(gè)數(shù)據(jù)包（即8個(gè)讀切換命令）讀取40幀與線(xiàn)路切換相關(guān)的性能數(shù)據(jù)，每個(gè)命令讀取5幀數(shù)據(jù)。返回的40幀數(shù)據(jù)通過(guò)索引號(hào)來(lái)判別數(shù)據(jù)的先后關(guān)系，與數(shù)據(jù)幀的位置無(wú)關(guān)。在實(shí)際過(guò)程中可能還需要反復(fù)發(fā)送數(shù)據(jù)包才能完整地獲得40幀數(shù)據(jù)。因此，在讀切換命令超時(shí)處理線(xiàn)程中，在命令超時(shí)之前還要對(duì)未返回的數(shù)據(jù)包反復(fù)發(fā)送取切換命令，直到完全獲得全部40幀數(shù)據(jù)才能分析處理。

讀切換命令超時(shí)時(shí)間設(shè)置為5 s，5 s內(nèi)反復(fù)讀取切換信息直到全部40幀數(shù)據(jù)返回或者超時(shí)，如果超時(shí)則僅向告警隊(duì)列添加切換事件而不附帶性能數(shù)據(jù)。

在返回?cái)?shù)據(jù)的分析處理中，首先找到40幀數(shù)據(jù)中4個(gè)索引號(hào)的最大值，并在索引號(hào)最大的一組（共10個(gè)）數(shù)據(jù)中找到剛發(fā)生切換之前的性能數(shù)據(jù)——即找到這組數(shù)據(jù)中工作模式與切換后的當(dāng)前工作模式相同的一幀數(shù)據(jù)，這幀數(shù)據(jù)的前一幀數(shù)據(jù)就是剛剛發(fā)生切換之前的性能數(shù)據(jù)，將這些性能數(shù)據(jù)作為切換事件的附帶數(shù)據(jù)，和切換事件一起寫(xiě)入告警隊(duì)列，發(fā)往性能和告警模塊，等待處理并發(fā)送到上層服務(wù)器。

3多線(xiàn)程的應(yīng)用

數(shù)據(jù)輪詢(xún)模塊自身就屬于一個(gè)單獨(dú)的線(xiàn)程，用來(lái)完成數(shù)據(jù)采集模塊中的性能和告警數(shù)據(jù)主動(dòng)采集功能，為了保證對(duì)眾多網(wǎng)元設(shè)備的快速采集，數(shù)據(jù)輪詢(xún)模塊內(nèi)部又用了多個(gè)子線(xiàn)程分工協(xié)作。

雖然多個(gè)線(xiàn)程同時(shí)工作，可以在不占用大量CPU資源的情況下提高模塊的執(zhí)行效率，但是模塊也存在著一個(gè)隱患，它有一個(gè)潛在問(wèn)題，即數(shù)據(jù)采集服務(wù)中有許多共享資源，可能在某個(gè)時(shí)刻，某一個(gè)線(xiàn)程修改某一個(gè)信息，正好第二個(gè)線(xiàn)程的時(shí)間片也到了，也試圖去修改同一個(gè)信息，此刻就發(fā)生了數(shù)據(jù)沖突，那么后果比較嚴(yán)重。

上述問(wèn)題的出現(xiàn)主要是兩個(gè)線(xiàn)程同時(shí)訪問(wèn)了一個(gè)共享的變量，為了避免這種問(wèn)題的發(fā)生，要求在多個(gè)線(xiàn)程之間進(jìn)行同步處理，保證一個(gè)線(xiàn)程訪問(wèn)共享資源時(shí)，其他線(xiàn)程不能訪問(wèn)該資源。為了達(dá)到該目的，這里最初使用Sleep函數(shù)，讓線(xiàn)程睡眠片刻，避免多個(gè)線(xiàn)程同時(shí)訪問(wèn)同一資源，但經(jīng)過(guò)實(shí)踐發(fā)現(xiàn)，這樣不僅浪費(fèi)時(shí)間，依然沒(méi)有解決同步的問(wèn)題。

為了實(shí)現(xiàn)這種同步，系統(tǒng)采用了同步隊(duì)列技術(shù)，即構(gòu)造了一個(gè)隊(duì)列，讓多個(gè)線(xiàn)程分別向其中存人數(shù)據(jù)和取出數(shù)據(jù)。例如，通過(guò)數(shù)據(jù)輪詢(xún)從下層設(shè)備得到多種性能數(shù)據(jù)，這是UDP接收線(xiàn)程的工作。該線(xiàn)程將接收到的UDP包添加到同步隊(duì)列的隊(duì)尾，然后再去接收新的數(shù)據(jù)，反復(fù)做同樣的操作。存放在同步隊(duì)列中的數(shù)據(jù)等待命令處理線(xiàn)程將其一一取出并加以分析，然后分派到各個(gè)模塊類(lèi)。

命令處理線(xiàn)程每次從隊(duì)列頭部取出數(shù)據(jù)，一次只能取出一個(gè)數(shù)據(jù)。同一時(shí)刻，只能有一個(gè)線(xiàn)程對(duì)同步隊(duì)列進(jìn)行操作。否則會(huì)出現(xiàn)操作不同步的問(wèn)題，影響數(shù)據(jù)獲得的正確性。例如，當(dāng)接收線(xiàn)程向隊(duì)尾寫(xiě)數(shù)據(jù)時(shí)，處理線(xiàn)程也從隊(duì)頭取數(shù)據(jù)，可能取出的數(shù)據(jù)正好是接收線(xiàn)程當(dāng)前所寫(xiě)入的，這樣得到的數(shù)據(jù)不但不完整，也破壞了原始得到的性能數(shù)據(jù)。解決的方法就是給同步隊(duì)列設(shè)置一個(gè)互斥量（mutex），當(dāng)某個(gè)線(xiàn)程對(duì)同步隊(duì)列進(jìn)行操作時(shí)，就設(shè)置互斥。

這樣，其他線(xiàn)程想要使用隊(duì)列資源時(shí)就會(huì)因?yàn)榛コ饬恳驯辉O(shè)置而處于等待中，直到共享資源得到釋放。另外，同步隊(duì)列還采用了生產(chǎn)者一消費(fèi)者模型，保證向同步隊(duì)列添加新數(shù)據(jù)時(shí)，隊(duì)列有空間；向隊(duì)列取數(shù)據(jù)時(shí)，隊(duì)列中有數(shù)據(jù)，避免產(chǎn)生內(nèi)存泄露等問(wèn)題。實(shí)現(xiàn)方式是在隊(duì)列中添加信號(hào)量spProducer和spConsumer，每當(dāng)向隊(duì)列添加數(shù)據(jù)時(shí)，調(diào)用spConsumer-》post（）；取出數(shù)據(jù)的時(shí)候，調(diào)用spProducer-》post（）。

同步隊(duì)列定義了一個(gè)基類(lèi)CMosSynQueue，里面封裝了同步互斥的基本操作。在采集服務(wù)中各個(gè)模塊都運(yùn)用了多線(xiàn)程，所以每個(gè)模塊都定義了一個(gè)同步隊(duì)列，全部派生于CMosSynQueue。

4跨平臺(tái)的實(shí)現(xiàn)

為了加強(qiáng)系統(tǒng)的通用性，系統(tǒng)將平臺(tái)的相關(guān)性轉(zhuǎn)變?yōu)闊o(wú)關(guān)性。利用stlport庫(kù)的可移植性，封裝了普通類(lèi)，使所有類(lèi)都能夠跨平臺(tái)使用。這些類(lèi)包括CMosDirec-tory，CMosSynQueue，CMosEvent，CMosFile，CMos-MutexLock，CMosRunThread，CMosReadWriteLock，CMosSemaphore，CMosSimpleLock，CMosThread，CMosTimedMutex，CMosTryMurex。

每個(gè)類(lèi)中，通過(guò)宏來(lái)選擇程序運(yùn)行在哪個(gè)操作平臺(tái)，例如，#if defined（_MoS_WIN32_）則在Windows操作系統(tǒng)中使用，#elif defined（_MOS_POSIX_）則表示在Linux系統(tǒng)中使用。經(jīng)過(guò)封裝，系統(tǒng)中所有的類(lèi)都派生自這些類(lèi)，這樣就可以在多個(gè)平臺(tái)上使用了。

5結(jié)語(yǔ)

數(shù)據(jù)采集模塊在整個(gè)網(wǎng)絡(luò)管理系統(tǒng)中占據(jù)著十分重要的地位。這里主要介紹了采集模塊中一個(gè)很重要的模塊，即數(shù)據(jù)輪詢(xún)模塊。輪詢(xún)模塊采用了多線(xiàn)程，針對(duì)多線(xiàn)程，提出了一種同步的方式，采用同步隊(duì)列。為了使軟件更具有移植性，系統(tǒng)主要采用了stlport類(lèi)庫(kù)，實(shí)現(xiàn)了跨平臺(tái)。該模塊已在實(shí)際的網(wǎng)管系統(tǒng)中得到了應(yīng)用，取得了較好的效果。

編輯：jq