RFID中間件處理模塊是 RFID中間件的核心模塊。主要作用是負(fù)責(zé)數(shù)據(jù)接收、數(shù)據(jù)處理和數(shù)據(jù)轉(zhuǎn)換, 具有對(duì)讀寫器的工作狀態(tài)進(jìn)行監(jiān)控的功能, 同時(shí)還具有讀寫器的注冊、刪除和群組等功能。RFID 中間件處模塊由 RFID事件過濾系統(tǒng)、實(shí)時(shí)內(nèi)存事件數(shù)據(jù)庫和任務(wù)管理系統(tǒng)3部分組成,
下面對(duì)這3部分的功能分別加以介紹。
1. RFID事件過濾系統(tǒng)
   RFID事件過濾系統(tǒng)(RFID Event Management System, RFID EMS)可以與讀寫器應(yīng)用程序進(jìn)行通信, 過濾讀寫器發(fā)送的事件流。在中間件系統(tǒng)中, RFID EMS是最重要的組件, 它為用戶在滿足中間件要求的基礎(chǔ)上被過濾。提供了集成其他應(yīng)用程序的平臺(tái)。RFID EMS 支持多種讀寫器協(xié)議, RFID EMS 可以采集、緩沖、平滑和組織從讀寫器獲得的信息, 讀寫器每秒可以上傳數(shù)百個(gè)事件, 每個(gè)事件都能在處理中間件請(qǐng)求的基礎(chǔ)上被恰當(dāng)?shù)鼐彌_過濾和記錄。

(1)事件過濾的方式。
①平滑。
   有時(shí)讀寫器會(huì)讀錯(cuò)或丟失標(biāo)簽。如果標(biāo)簽數(shù)據(jù)被讀錯(cuò), 則稱為積極閱讀錯(cuò)誤; 如果覆蓋區(qū)內(nèi)的標(biāo)簽數(shù)據(jù)被漏讀, 則被稱為消極閱讀錯(cuò)誤。平滑算法就是要清除那些被懷疑有積極或消極錯(cuò)誤的閱讀。
② 協(xié)調(diào)。
    當(dāng)多個(gè)讀寫器相互之間離得很近時(shí), 它們會(huì)讀到相同的標(biāo)簽數(shù)據(jù)。如果一個(gè)標(biāo)簽數(shù)據(jù)被不同的讀寫器上傳兩次, 中間件流程邏輯就會(huì)產(chǎn)生錯(cuò)誤。協(xié)同工作可以采用不同的運(yùn)算規(guī)則, 清除“不屬于”的那個(gè)讀寫器的閱讀。如果在幾毫秒中, 一個(gè)解讀事件涉及不同的讀寫器閱讀同一個(gè)標(biāo)簽數(shù)據(jù), 協(xié)同運(yùn)算規(guī)則就可以刪除這一事件。如果當(dāng)前讀寫器距離標(biāo)簽比該標(biāo)簽應(yīng)該“歸屬”的讀寫器近, 那么附加的邏輯應(yīng)該允許當(dāng)前讀寫器的數(shù)據(jù)通過。
③轉(zhuǎn)發(fā)。
   一個(gè)時(shí)間轉(zhuǎn)發(fā)器應(yīng)該有一個(gè)或多個(gè)輸出。根據(jù)事件類型的不同, 轉(zhuǎn)發(fā)器可以將事件傳送為一個(gè)或多個(gè)輸出。例如, 時(shí)間轉(zhuǎn)發(fā)器可選擇只轉(zhuǎn)發(fā)讀寫器上傳的非標(biāo)簽數(shù)據(jù)閱讀事件, 如閱讀時(shí)的溫度。因此, RFID EMS支持具有一個(gè)輸入事件流, 一個(gè)或多個(gè)輸出事件流的“事件過濾器”。
(2)事件記錄的方式。
    經(jīng)過采集和平滑的事件, 最終會(huì)被恰當(dāng)?shù)匾允录涗浀姆绞教幚怼３Ｓ玫氖录涗浄绞接幸韵?種:
①保存在像數(shù)據(jù)庫這樣永遠(yuǎn)的存儲(chǔ)器中;
② 保存在倉儲(chǔ)數(shù)據(jù)結(jié)構(gòu)中, 如實(shí)時(shí)內(nèi)存數(shù)據(jù)庫;
③ 通過HTTP、JMS 或 SOAP 協(xié)議傳輸?shù)竭h(yuǎn)程服務(wù)器;
④RFID EMS 支持多種“事件記錄器”。
(3)事件過濾的作用。
① RFID EMS是具有采集、過濾和記錄功能的“程序模塊”, 工作在獨(dú)立的線程中, 不相互妨礙。RFID EMS能在不同的線程中啟動(dòng)處理單元, 而且能夠在單元間緩沖事件流;
② RFID EMS能夠?qū)嵗瓦B接上面提到的事件處理單元;
③ RFID EMS 允許遠(yuǎn)方機(jī)器登錄和注銷到動(dòng)態(tài)事件流中。
(4)事件過濾的功能。
① 允許不同種類的讀寫器寫入適配器;
② 讀寫器以標(biāo)準(zhǔn)格式采集數(shù)據(jù);
③允許設(shè)置過濾器, 清除冗余的數(shù)據(jù), 上傳有效的數(shù)據(jù);
④允許寫各種記錄文件, 如記錄數(shù)據(jù)庫日志, 記錄數(shù)據(jù)廣播到遠(yuǎn)程服務(wù)器事件中的HTTP/JMS/SOAP 網(wǎng)絡(luò)日志;
⑤ 對(duì)記錄器、過濾器和適配器進(jìn)行事件緩沖, 使它們在不相互妨礙的情況下運(yùn)行。
2. 實(shí)時(shí)內(nèi)存事件數(shù)據(jù)庫
    實(shí)時(shí)內(nèi)存事件數(shù)據(jù)庫(Real-time In-memory Event Database, RIED)是一個(gè)用來保存 RFID邊緣中間件信息的內(nèi)存數(shù)據(jù)庫。RFID邊緣中間件保存和組織讀寫器發(fā)送的事件。RFID事件管理系統(tǒng)通過過濾和記錄事件的框架, 可以將事件保存在數(shù)據(jù)庫中。但是, 數(shù)據(jù)庫不能在一秒內(nèi)處理兒百次以上的交易。實(shí)時(shí)內(nèi)存事件數(shù)據(jù)庫提供了與數(shù)據(jù)庫一樣的接口。但其性能要好得多。

    應(yīng)用程序可以通過JDBC或本地 Java 接口訪問實(shí)時(shí)內(nèi)存事件數(shù)據(jù)庫。RIED 支持常用的SQL 操作, 還支持一部分SQL92 中定義的數(shù)據(jù)操作方法。RIED也可以保存不同事件點(diǎn)上數(shù)據(jù)庫的“快照。

     RIED是一個(gè)高性能的內(nèi)存數(shù)據(jù)庫, 假如讀寫器每秒閱讀并發(fā)送10000個(gè)數(shù)據(jù)信息,據(jù)庫每秒必須能夠完成10000個(gè)數(shù)據(jù)處理, 而且這此數(shù)據(jù)是保守估計(jì)的, 內(nèi)存數(shù)據(jù)庫必須高效地  內(nèi)存效處理讀取的大量數(shù)據(jù)。

     RIED 是一個(gè)多版本的數(shù)據(jù)庫, 即能夠保存多種快照的數(shù)據(jù)庫。此外, 并不是讀寫器發(fā)送的每個(gè)事件都能存儲(chǔ)到內(nèi)存數(shù)據(jù)庫中。保存監(jiān)視器的過期快照是為了滿足監(jiān)視和備份的要求, RIED可以為過期信息保存多個(gè)閱讀快照。例如, 數(shù)據(jù)庫中可以保存監(jiān)視器的兩個(gè)過期快照, 一個(gè)是一天的開始, 另一個(gè)是每一秒的開頭, 但現(xiàn)有的內(nèi)存數(shù)據(jù)庫系統(tǒng)不支持對(duì)永久信息的有效管理。
3. 任務(wù)管理系統(tǒng)
    任務(wù)管理系統(tǒng)(Task Management System, TMS)負(fù)責(zé)管理由上級(jí)中間件或企業(yè)應(yīng)用程序發(fā) 送到本級(jí)中間件的任務(wù)。一般情況下, 任務(wù)可以等價(jià)為多任務(wù)系統(tǒng)中的進(jìn)程, TMS管理任務(wù)類似于操作系統(tǒng)管理進(jìn)程。
(1)任務(wù)管理系統(tǒng)的特點(diǎn)。
    TMS具有許多一般線程管理器和操作系統(tǒng)不具有的特點(diǎn), TMS的特點(diǎn)如下。0
①任務(wù)進(jìn)度表的外部接口;
② 獨(dú)立的虛擬機(jī)平臺(tái), 包含從冗余類服務(wù)器中根據(jù)需要加載的統(tǒng)一庫;
③用來維護(hù)永久任務(wù)信息的健壯性進(jìn)度表, 具有在中間件碎片或任務(wù)碎片中重啟任務(wù)的能力。TMS使分布式中間件的維護(hù)變得簡單, 企業(yè)可以僅僅通過在一組類服務(wù)中保存最新的任務(wù)和中間件中恰當(dāng)?shù)匕才湃蝿?wù)進(jìn)度來維護(hù)中間件。然而, 硬件和核心軟件, 如操作系統(tǒng)和Java虛擬機(jī), 必須定期升級(jí)。
(2)任務(wù)管理系統(tǒng)的功能。
  傳輸?shù)絋MS的任務(wù)可以獲得中間件的所有便利條件, TMS 可以完成企業(yè)的多種操作。TMS的功能如下。
① 數(shù)據(jù)交互, 即向其他中間件發(fā)送產(chǎn)品信息或從其他中間件中獲取產(chǎn)品信息;
② PML 查詢, 即查詢 ONS/PML 服務(wù)器獲得產(chǎn)品實(shí)例的靜態(tài)或動(dòng)態(tài)信息;
③ 刪除任務(wù)進(jìn)度, 即確定和刪除其他中間件上的任務(wù);
④值班報(bào)警, 即當(dāng)某些事件發(fā)生時(shí), 警告值班人員, 如需向貨架補(bǔ)貨、丟失或產(chǎn)品到期;
⑤遠(yuǎn)程數(shù)據(jù)上傳, 即向遠(yuǎn)處供應(yīng)鏈管理服務(wù)器發(fā)送產(chǎn)品信息。
(3)任務(wù)管理系統(tǒng)的性能。
①從 TMS的各種需求可以看到, TMS應(yīng)該是一個(gè)有較小存儲(chǔ)注腳, 建立在開放、獨(dú)立平臺(tái)標(biāo)準(zhǔn)上的健壯性的系統(tǒng)。
② TMS 是具有較小存儲(chǔ)處理能力的獨(dú)立系統(tǒng)平臺(tái)。不同的中間件選擇不同的工作平臺(tái), 一此工作平臺(tái), 尤其是那些需要大量中間件的工作平臺(tái), 可以是進(jìn)行低級(jí)存儲(chǔ)和處理的低價(jià)的嵌入式系統(tǒng)。
③ 對(duì)網(wǎng)絡(luò)上所有中間件進(jìn)行定期升級(jí)是一項(xiàng)艱巨的任務(wù), 如果中間件基于簡單維護(hù)的原則對(duì)代碼解析自動(dòng)升級(jí)則是比較理想的。因此要求 TMS 能夠?qū)?zhí)行的任務(wù)進(jìn)行自動(dòng)升級(jí)。中間件需要為任務(wù)時(shí)序提供外部接口, 為了滿足公開和協(xié)同工作的系統(tǒng)要求, 為了將 TMS 設(shè)計(jì)從任務(wù)設(shè)計(jì)中分離出來, 需要在一個(gè)獨(dú)立的語言平臺(tái)上, 用簡單、定義完美的軟件開發(fā)工具包(SDK)來描述任務(wù)。