附錄五城軌線網(wǎng)非結(jié)構(gòu)化數(shù)據(jù)接入系統(tǒng)

1、123概123概4 函函函 函21 臺(tái)近2 接入服務(wù) 系統(tǒng)詳細(xì)設(shè)計(jì)3.1 系統(tǒng)實(shí)現(xiàn)31 臺(tái)近2 接入服務(wù) 系統(tǒng)詳細(xì)設(shè)計(jì)3.1 系統(tǒng)實(shí)現(xiàn)3接入客戶接入客戶接入服務(wù)器：接入服務(wù)器位于城軌線網(wǎng)指，通過(guò)與接系接入客戶端：城通過(guò)接入客戶端，將城軌線路控其中，接入系統(tǒng)服務(wù)器包括四個(gè)功能模塊1)接入服務(wù)器：接入服務(wù)器位于城軌線網(wǎng)指，通過(guò)與接系接入客戶端：城通過(guò)接入客戶端，將城軌線路控其中，接入系統(tǒng)服務(wù)器包括四個(gè)功能模塊1) 接入服務(wù)器與接入客戶端的通信模服務(wù)器主線程通過(guò)IO 多路復(fù) 2) 接入服務(wù)器與線網(wǎng)分布式文 數(shù)據(jù) 除時(shí)間超過(guò)三個(gè)月的文件。接入服務(wù)器使fork()函數(shù)生成子進(jìn)程，專(zhuān) 主接入服務(wù)器serv

2、er，備接入服務(wù)nt。接入系統(tǒng)初始啟動(dòng)時(shí)，指43.2接入服務(wù)器除3.2.1 工作流接入服務(wù)器主線程通過(guò)IO多路復(fù)用接口接收到接入客戶端通過(guò)ftp協(xié)議發(fā)送 接入服務(wù)接入客戶元數(shù)封裝成請(qǐng)求報(bào)事件上傳事3.2接入服務(wù)器除3.2.1 工作流接入服務(wù)器主線程通過(guò)IO多路復(fù)用接口接收到接入客戶端通過(guò)ftp協(xié)議發(fā)送 接入服務(wù)接入客戶元數(shù)封裝成請(qǐng)求報(bào)事件上傳事件上傳主線輸文件封裝成數(shù)據(jù)報(bào) 5打開(kāi)寫(xiě)文件數(shù)主線文件 socket epoll socket epoll_wait 寫(xiě)事件放入請(qǐng)求隊(duì)列。睡眠在請(qǐng)求隊(duì)列上的某個(gè)工作線程被喚醒，它往 socket線 3.2.2 socket epoll socket epo

3、ll_wait 寫(xiě)事件放入請(qǐng)求隊(duì)列。睡眠在請(qǐng)求隊(duì)列上的某個(gè)工作線程被喚醒，它往 socket線 3.2.2 1令buf 6 4接入服務(wù)器與線網(wǎng)分布式文件系統(tǒng)的通信模塊系IP 7 4接入服務(wù)器與線網(wǎng)分布式文件系統(tǒng)的通信模塊系IP 7003.2.4 文件的文件夾，使用 3.2.5 主接入服務(wù)器和備接入服務(wù)器之間采用 通信3.2.4 文件的文件夾，使用 3.2.5 主接入服務(wù)器和備接入服務(wù)器之間采用 通信模式，主接入服務(wù)器server，備接入服務(wù)器為 sever。接入系統(tǒng)初始啟動(dòng)時(shí)，指定某臺(tái)服務(wù)器為主接入4主接入備接入定時(shí)發(fā)無(wú)有3.3接入客戶端8主接入心心3.3.1 TCP 3.3.2 63.3.1

4、 TCP 3.3.2 6 9系統(tǒng)主要代碼文件接入服務(wù)器主要代碼文件線類(lèi)4.2接入客戶端主要代碼文件系統(tǒng)主要代碼文件接入服務(wù)器主要代碼文件線類(lèi)4.2接入客戶端主要代碼文件附函數(shù)與數(shù)據(jù)結(jié)構(gòu)說(shuō)明文成員： type：類(lèi)型 數(shù)據(jù)結(jié)構(gòu)2. 文函2.1 參數(shù)： s_fd：文件描述符返回值：若成功將文件描述符設(shè)為非阻塞，則返回0，否則附函數(shù)與數(shù)據(jù)結(jié)構(gòu)說(shuō)明文成員： type：類(lèi)型 數(shù)據(jù)結(jié)構(gòu)2. 文函2.1 參數(shù)： s_fd：文件描述符返回值：若成功將文件描述符設(shè)為非阻塞，則返回0，否則返回-2.2epoll_fd,Connection*說(shuō)明：在epoll_fd對(duì)應(yīng)的文件監(jiān)測(cè)表中添加conn對(duì)應(yīng)的文件epoll_

5、fd：epoll文件描述符，conn：連接指針，event_mask碼返回值：若成功操作，則返回0，否則返回-2.3 epoll_fd,Connection*參數(shù)： 碼返回值：若成功操作，則返回0，否則返回-2.4 epoll_fd,Connection*說(shuō)明：在epoll_fd對(duì)應(yīng)的文件監(jiān)測(cè)表中刪除conn對(duì)應(yīng)的文件epoll_fd：epoll文件描述符，conn：連接指針，event_mask碼返回值：若成功操作，則返回0，否則返回-文數(shù)據(jù)結(jié)構(gòu)成員： NEW：新的任務(wù)文數(shù)據(jù)結(jié)構(gòu)成員： NEW：新的任務(wù) s_jobs：任務(wù)隊(duì)文原型：void函32_t_event4.2 原型：voidunre

6、gister_epoll32_t參數(shù)： _event文數(shù)據(jù)結(jié)構(gòu)和函數(shù)5.2 成員： thread_num_：線terminate_： 是否終止 文數(shù)據(jù)結(jié)構(gòu)和函數(shù)5.2 成員： thread_num_：線terminate_： 是否終止 文函原型：voidput_task(tp_task*參數(shù)： task：線程任務(wù)原型：voidtake_task(tp_task*參數(shù)： task： 線程任務(wù)6.4 原型：bool 說(shuō)明：判斷是否終返回值：是否終止的布6.5原型：void 說(shuō)明：等待各線6.6 原型：void*thread_main(void*文函原型：boolrecv_file_server(c

7、onstchar*local_filename,Connection*packet*hp,FILE*& & 說(shuō)明：6.6 原型：void*thread_main(void*文函原型：boolrecv_file_server(constchar*local_filename,Connection*packet*hp,FILE*& & 說(shuō)明：寫(xiě)文件到接入服務(wù)器，件到線網(wǎng)分布式文系返回值：若成功操作則返回真，否則返回假。文mutex_capacity_數(shù)據(jù)結(jié)構(gòu)和函文數(shù)據(jù)結(jié)構(gòu)9.2 listen_sock ：用于偵聽(tīng)conn_sock t 文原型：void 說(shuō)明：初始化接入服務(wù)原型：void 說(shuō)明：接入服務(wù)器主t 文原型：void 說(shuō)明：初始化接入服務(wù)原型：void 說(shuō)明：接入服務(wù)器主函函10.3原型：void 說(shuō)明：接受客戶端的連10.4原型：Connection*原型：voidhandle_write(void*返回值：網(wǎng)絡(luò)連接的指原型：voidhandle_read(void* 原型：voidhandle_write(void*11文數(shù)據(jù)結(jié)11.1e 文原型參數(shù)：無(wú)函說(shuō)明：11文數(shù)據(jù)結(jié)11.1e 文原型參數(shù)：無(wú)函說(shuō)明：心跳包模塊的