附录五城轨线网非结构化数据接入系统

1、123概123概4 函函函 函21 台近2 接入服务 系统详细设计3.1 系统实现31 台近2 接入服务 系统详细设计3.1 系统实现3接入客户接入客户接入服务器：接入服务器位于城轨线网指，通过与接系接入客户端：城通过接入客户端，将城轨线路控其中，接入系统服务器包括四个功能模块1)接入服务器：接入服务器位于城轨线网指，通过与接系接入客户端：城通过接入客户端，将城轨线路控其中，接入系统服务器包括四个功能模块1) 接入服务器与接入客户端的通信模服务器主线程通过IO 多路复 2) 接入服务器与线网分布式文 数据 除时间超过三个月的文件。接入服务器使fork()函数生成子进程，专 主接入服务器serv

2、er，备接入服务nt。接入系统初始启动时，指43.2接入服务器除3.2.1 工作流接入服务器主线程通过IO多路复用接口接收到接入客户端通过ftp协议发送 接入服务接入客户元数封装成请求报事件上传事3.2接入服务器除3.2.1 工作流接入服务器主线程通过IO多路复用接口接收到接入客户端通过ftp协议发送 接入服务接入客户元数封装成请求报事件上传事件上传主线输文件封装成数据报 5打开写文件数主线文件 socket epoll socket epoll_wait 写事件放入请求队列。睡眠在请求队列上的某个工作线程被唤醒，它往 socket线 3.2.2 socket epoll socket epo

3、ll_wait 写事件放入请求队列。睡眠在请求队列上的某个工作线程被唤醒，它往 socket线 3.2.2 1令buf 6 4接入服务器与线网分布式文件系统的通信模块系IP 7 4接入服务器与线网分布式文件系统的通信模块系IP 7003.2.4 文件的文件夹，使用 3.2.5 主接入服务器和备接入服务器之间采用 通信3.2.4 文件的文件夹，使用 3.2.5 主接入服务器和备接入服务器之间采用 通信模式，主接入服务器server，备接入服务器为 sever。接入系统初始启动时，指定某台服务器为主接入4主接入备接入定时发无有3.3接入客户端8主接入心心3.3.1 TCP 3.3.2 63.3.1

4、 TCP 3.3.2 6 9系统主要代码文件接入服务器主要代码文件线类4.2接入客户端主要代码文件系统主要代码文件接入服务器主要代码文件线类4.2接入客户端主要代码文件附函数与数据结构说明文成员： type：类型 数据结构2. 文函2.1 参数： s_fd：文件描述符返回值：若成功将文件描述符设为非阻塞，则返回0，否则附函数与数据结构说明文成员： type：类型 数据结构2. 文函2.1 参数： s_fd：文件描述符返回值：若成功将文件描述符设为非阻塞，则返回0，否则返回-2.2epoll_fd,Connection*说明：在epoll_fd对应的文件监测表中添加conn对应的文件epoll_

5、fd：epoll文件描述符，conn：连接指针，event_mask码返回值：若成功操作，则返回0，否则返回-2.3 epoll_fd,Connection*参数： 码返回值：若成功操作，则返回0，否则返回-2.4 epoll_fd,Connection*说明：在epoll_fd对应的文件监测表中删除conn对应的文件epoll_fd：epoll文件描述符，conn：连接指针，event_mask码返回值：若成功操作，则返回0，否则返回-文数据结构成员： NEW：新的任务文数据结构成员： NEW：新的任务 s_jobs：任务队文原型：void函32_t_event4.2 原型：voidunre

6、gister_epoll32_t参数： _event文数据结构和函数5.2 成员： thread_num_：线terminate_： 是否终止 文数据结构和函数5.2 成员： thread_num_：线terminate_： 是否终止 文函原型：voidput_task(tp_task*参数： task：线程任务原型：voidtake_task(tp_task*参数： task： 线程任务6.4 原型：bool 说明：判断是否终返回值：是否终止的布6.5原型：void 说明：等待各线6.6 原型：void*thread_main(void*文函原型：boolrecv_file_server(c

7、onstchar*local_filename,Connection*packet*hp,FILE*& & 说明：6.6 原型：void*thread_main(void*文函原型：boolrecv_file_server(constchar*local_filename,Connection*packet*hp,FILE*& & 说明：写文件到接入服务器，件到线网分布式文系返回值：若成功操作则返回真，否则返回假。文mutex_capacity_数据结构和函文数据结构9.2 listen_sock ：用于侦听conn_sock t 文原型：void 说明：初始化接入服务原型：void 说明：接入服务器主t 文原型：void 说明：初始化接入服务原型：void 说明：接入服务器主函函10.3原型：void 说明：接受客户端的连10.4原型：Connection*原型：voidhandle_write(void*返回值：网络连接的指原型：voidhandle_read(void* 原型：voidhandle_write(void*11文数据结11.1e 文原型参数：无函说明：11文数据结11.1e 文原型参数：无函说明：心跳包模块的