云计算的关键技术与应用实例

云计算的关键技术与应用实例.txt世上有三种人：一是良心被狗吃了的人，二是良心没被狗吃的人，三是良心连狗都不吃的人。丶爱情是个梦，而我却睡过了头第一篇从并行计算到云计算第1章并行计算与云计算. 21.1 并行计算到云计算的演变. 21.2 云计算需要定义吗？. 41.3 云计算是否是新瓶装旧酒. 51.4 MPI与Hadoop，不同学科学者的选择. 61.5 云计算与浏览器. 8第2章MPI并行计算环境的建立. 102.1 配置前的准备工作. 102.2 挂载NFS文件系统. 112.3 配置ssh实现MPI节点间用户的无密码访问. 122.4 安装MPICH2. 122.5 建立并行计算环境时的注意事项. 14第3章并行计算时代的程序设计方法. 153.1 最简单的并行程序. 153.2 获取进程标志和机器名. 183.3 有消息传递功能的并行程序. 203.4 Monte Carlo法在并行程序设计中的应用. 233.5 并行计算中节点间的Reduce操作. 253.6 用MPI的6个基本函数实现Reduce函数功能. 283.7 计算与通信的并行. 303.8 节点间自定义复杂数据结构的传输. 343.9 MPI与MySQL数据库的结合应用. 373.10 设计MPI并行程序时的注意事项. 41第4章从MPI走向云计算. 434.1 MPI没有分布式文件系统支持. 434.2 MPI无法应对节点的失效. 444.3 假如用MPI来构建云计算系统. 44第二篇云计算的关键技术第5章Map/Reduce是云计算的选择吗. 485.1 Map/Reduce跨越50年的历史. 485.2 实现Map/Reduce的C语言实例. 495.3 采用MPI实现并行化的Map/Reduce功能. 51第6章Hadoop技术. 586.1 Hadoop与MPI在数据处理上的对比. 586.2 Hadoop的主从式结构. 596.2.1 主从式文件系统HDFS. 596.2.2 主从式计算系统Map/Reduce. 606.2.3 文件分块策略分析. 616.3 Hadoop文件系统HDFS的前辈GFS. 646.4 构建云文件系统需要解决的关键问题. 666.5 云计算不相信节点服务器. 676.6 揭密云计算架构下的典型服务器Google服务器. 686.6.1 Google服务器概述. 686.6.2 揭开Google服务器的神秘面纱. 696.6.3 Google服务器的配置情况. 696.6.4 Google服务器的性能评测. 73第7章Hadoop环境的建立. 757.1 Hadoop配置环境. 757.2 配置ssh实现Hadoop结点间用户的无密码访问. 767.3 JDK的安装配置. 767.4 Hadoop的安装配置. 777.5 Hadoop中的Hello World. 817.6 C语言程序在Hadoop上运行. 82第8章动手做自己的云计算V0.01系统. 868.1 系统总体分析. 868.1.1 系统架构. 868.1.2 文件分布式存储流程. 888.1.3 计算与存储的整合流程. 888.2 管理节点程序设计与分析. 898.2.1 管理节点服务器程序主函数. 908.2.2 管理节点各线程函数的设计. 938.2.3 主服务器中其他函数的设计. 958.3 子节点程序分析. 988.3.1 子节点主函数. 998.3.2 子节点各线程函数设计. 1028.4 客户端API设计. 1078.4.1 客户端文件的存储. 1088.4.2 客户端启动子节点计算. 1138.4.3 客户端应用的简单实例. 1148.5 客户端应用开发实例115第三篇云计算应用实例第9章基于不可信服务器节点的云计算基础架构. 1189.1 云计算基础架构的应用场景. 1189.2 云计算基础架构. 1209.3 基于单向指针目录映射的分层用户隔离. 1219.4 云文件系统的物理存储管理. 1239.5 云存储的安全级别划分. 1249.6 计算和存储的整合. 1259.7 计算和存储的迁移. 1269.8 任务的可并行性和分类分析. 1279.9 简化的服务器级粗粒度计算和存储资源分配方案. 1309.10 数据的云计算系统之旅. 133第10章云计算与智能. 13510.1 云计算的智能与人类智能的比较. 13510.2 云计算提升终端智能. 13610.3 云计算智能与Monte Carlo方法. 13810.4 云计算时代不确定性智能算法示例模拟谐振子算法. 13810.4.1 简谐振动的描述. 13910.4.2 模拟谐振子算法描述. 14110.4.3 模拟谐振子算法流程. 14410.4.4 模拟谐振子算法分析. 14610.4.5 模拟谐振子算法应用于旅行商问题. 14910.4.6 模拟谐振子算法在连续和非线性优化问题中的应用. 16110.4.7 模拟谐振子算法的隐含并行性. 16210.5 云计算中的人工智能. 162第11章云计算企业之间的竞争性分析. 16411.1 云计算技术流派分析. 16411.1.1 存储型数据密集云计算平台. 16411.1.2 计算型计算密集云计算平台. 16511.1.3 综合云计算平台. 16511.2 国际云计算公司分析. 16511.2.1 云计算技术的提出者Google. 16611.2.2 “端”的霸主微软. 16611.2.3 蓝色巨人IBM的蓝云. 16711.2.4 云计算的市场先行者Amazon公司. 16811.2.5 Salesforce从SaaS走入云中. 16811.2.6 热爱白皮书的Sun. 16911.2.7 EMC云计算的核心是虚拟化. 17011.2.8 渔翁得利的思科. 17011.3 国内云计算公司分析. 17111.3.1 拥有基础设施的世纪互联. 17111.3.2 阿里巴巴下决心入云. 17211.3.3 中国移动的BigCloud. 17211.3.4 国产旗帜友友云计算平台. 17311.3.5 曙光高性能与云计算. 17311.3.6 展览也要云. 17311.4 开源云计算平台分析. 17411.5 国际国内云计算平台提供商对比研究. 17511.6 产业综合分析. 17911.6.1 云计算与网络设备商的关系. 17911.6.2 云计算与移动通讯运营商的关系. 18011.6.3 云计算与服务器提供商的关系. 18011.6.4 云计算与应用程序开发商的关系. 181后记：未来的计算机不确定性和隐含并行计算. 182附录：计算力的标准Linpack测试详细指南. 186参考文献196面对云计算，有的人越来越糊涂，经常听到有人用云里雾里来形容现在的云计算。云计算系统确实是一个庞大和综合的系统，即使是国际大公司也不敢贸然进军云计算领域，大量的企业不是将自己的传统技术优势称为云计算，就是雷声大雨点小的观望。一般开发者更是不适应在机群的环境下工作，所以本章将用一个简单的例子来展现云计算的基本特点和技术开发方式，我们并不保证这个系统是一个完善的系统，但它具备了云计算的一些基本特点如计算和存储的整合、计算向存储的迁移、文件的分布式存储、计算的并行化等，我们对这些功能采用了最简单的实现方法以使大多数读者能从中体会到云计算技术的核心理念，所以我们命名这个系统为云计算V0.01，运行环境为Windows。8.1系统总体分析我们进行系统总体结构设计时主要着眼于云计算基本特征的实现，不考虑系统中很多细节性的要求和高级要求，并采用中等水平的读者能完成的难度设计。设计需要实现的基本功能如下。（1）向开发云应用的客户提供可以调用的API函数，利用API函数实现对云计算系统的访问。（2）实现分布式的文件存储。（3）实现计算向存储的迁移，使计算和存储在同一个节点完成，避免数据在网络中的传送。（4）向用户隔离计算的并行性和存储的分布性，用户无需关心系统具体的操作过程。（5）初步实现对数据求和及求最大值的处理，演示云计算的基本特点。读者可以通过增加处理函数实现更多的计算功能。8.1.1系统架构云计算V0.01系统是一个完全模型化的实验用系统，开发和运行环境为Windows系统，通过对该系统的学习使读者对云计算技术的基本要点有一定的了解，云计算V0.01将云计算设备分为3个角色：管理节点、子节点和客户端。管理节点和子节点构成了云计算的服务器端，客户端通过对API的调用实现对云计算系统的访问，并通过API整合为不同的应用程序。为了简化系统的设计难度，我们在做云计算V0.01时限定所做的计算任务包括对大数据量数组求和、求最大值等操作，读者可通过实际的系统体会存储的分布化与计算的并行化的关系，并理解计算向存储迁移的作用。云计算V0.01没有实现存储的副本策略，因此暂时不能处理节点失效的问题，这也是为了降低系统难度的需要。以下的系统架构方法仅供参考和学习，并且不代表我们赞成这一架构，不同的读者可以设计不同的系统架构。系统的整个架构如图8.1所示，这种架构方式是一个以客户端为核心的架构方法，系统中的所有操作指令均由客户端发出，管理节点不和任一子节点作数据和指令的通信，管理节点的作用主要是维护root.dat和node.dat两个系统文件。root.dat文件存储着现在系统中已注册的用户名及该用户所对应的文件分块描述文件所在节点的IP地址，系统利用这一文件可实现用户的注册、认证及用户登录后获得文件分块描述文件所在节点的IP地址。node.dat文件则维护着整个云计算系统所有子节点的IP地址、端口、最大空间、剩余空间等信息，客户端通过该文件能够获得整个机群的信息，从而实现向各子节点的直接连接。客户端从管理节点获得了相关的系统信息后将根据这一信息直接向各个子节点发起连接，完成文件存储及计算的功能，这大大提高了数据传输的速率，减轻了管理节点的负荷。各用户文件的具体分块和存储方式被系统用该用户的用户名（username）作为文件名的文件分块描述文件存储于其中的一个子节点，这一子节点的IP可在root.dat文件中找到。图8.1 云计算V0.01的系统结构在云计算V0.01系统中不同角色间存在两类数据的传送：一类是命令数据CMD，管理节点和子节点通过命令数据判断自己下一步所要完成的任务；一类是信息数据，这类数据是系统要完成相关任务所需要数据，如系统描述信息、文件信息等，这类数据的数据量相对较大。由于采用了计算向存储的迁移策略，系统中出现用户文件数据传输的情况很少，这大大提高了系统的运行效率。8.1.2文件分布式存储流程系统在进行文件存储时先通过客户端连接管理节点，读取root.dat文件数据，检验是否有该用户存在，并获取用户数据块文件所在节点的IP地址。通过读取node.dat文件从管理节点读取子节点的IP地址的列表，根据以上信息完成对数据的分割，启动多线程函数同时连接各子节点将数据分别保存在各个节点上，最后更新username表以备访问时重新找到文件的分布情况。uesername文件将被存储于某一节点上，管理节点会根据现有username文件的分布情况向用户分配一个节点的IP地址存放username文件，文件名就是该用户的用户名，由于用户名在系统中是惟一的，所以每个用户的username也是惟一的，不会造成混乱，如图8.2所示。图8.2 文件的分布式存储流程8.1.3计算与存储的整合流程如图8.3所示，在云计算V0.01系统中，我们利用获得的用户名、文件名、数据块号以及数据分块信息文件的IP地址信息，可以惟一地确定任一数据块的位置和文件名，客户端同时向各个子节点发送启动计算的命令，各节点就地读取数据块本地文件，并对其进行计算，计算完成后发送回客户端汇总得到最后的结果。图8.3 计算与存储的整合流程这一计算过程不用移动任何数据，对于数据的处理就在存储数据块的节点完成，系统根据客户端的指令，将计算迁移到节点上分布式的完成，大大提高了计算效率，避免了数据在网络中的大量流动所造成的效率下降，对于海量数据来说，这一做法的效果是相当明显的。对于不同的数据，我们可以定义不同的数据处理方法，从而扩展系统的应用领域。8.2管理节点程序设计与分析管理节点在云计算V0.01系统中只与客户端进行通信，存储系统中的节点信息和用户注册信息，并不负责任务的调度工作。在管理节点我们将保存root.dat和node.dat两个系统信息文件。root.dat文件保存用户名及该用户文件系统所在的子节点的IP地址，采用userInfo数据结构来描述。客户端程序只有获得了子节点IP地址才能和该子节点直接建立连接获取子节点上的用户存储情况文件，该文件的文件名就是用户的用户名，通过这一个文件可以知道数据的具体存储情况，从而由客户端直接与数据块存储节点建立连接。node.dat文件保存了云计算系统的所有子节点的IP地址、总空间和可用空间等信息，由nodeInfo数据结构来描述。管理节点各函数调用关系如图8.4所示。图8.4 管理节点函数调用结构8.2.1管理节点服务器程序主函数管理节点主程序为整个管理程序的主入口，通过4个线程函数来监听并完成客户端所提交的任务。程序8.1/*文件名mainsever.cpp*/ 定义管理节点服务器程序的入口点void test();int _tmain(int argc, _TCHAR* argv)openfile(); /获得root.dat、node.dat的文件指针test(); /该函数完成对主服务器的配置工作WSADATA wsa;int ret = 0;int PORT = 5100;SOCKET s_socket;SOCKET c_socket;struct sockaddr_in s_sockaddr;struct sockaddr_in c_sockaddr;int c_sockaddr_len = sizeof(c_sockaddr);ret = WSAStartup(MAKEWORD(2, 2), &wsa);if(ret != 0)cout Init WinSock failed: ret endl;return 0;if(s_socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP) = SOCKET_ERROR)cout Create Socket Failed: WSAGetLastError() endl;WSACleanup();return 0;s_sockaddr.sin_family = AF_INET;s_sockaddr.sin_port = htons(PORT);s_sockaddr.sin_addr.s_addr = htonl(INADDR_ANY);if(bind(s_socket, (SOCKADDR *)&s_sockaddr, sizeof(s_sockaddr) = SOCKET_ERROR)cout bind failed: WSAGetLastError() endl;closesocket(s_socket);WSACleanup();return 0;if(listen(s_socket, 5) = SOCKET_ERROR)cout Listen Failed: WSAGetLastError() endl;closesocket(s_socket);WSACleanup();return 0;CMD cmd;/进入循环接收来自客户端的操作命令cmdwhile(1)c_socket = accept(s_socket, (SOCKADDR *)&c_sockaddr, &c_sockaddr_len);recv(c_socket, (char *)&cmd, sizeof(CMD), 0);/从客户端获取操作命令SOCKET *tsock = (SOCKET *)malloc(sizeof(SOCKET);*tsock = c_socket;switch(cmd)case USERADD:_beginthreadex(NULL, 0, &useraddthread, tsock, 0, NULL);/进入增加用户线程break;case USERGET:_beginthreadex(NULL, 0, &usergetthread, tsock, 0, NULL);/进入获取用户信息线程case USERDEL:_beginthreadex(NULL, 0, &userdelthread, tsock, 0, NULL);/删除用户，暂未定义case GETNODE:_beginthreadex(NULL, 0, &getnodeaddrthread, tsock, 0, NULL);/进入获取节点信息线程default:break;cin.get();cin.get();return 0;/test()函数用于配置各子节点的IP、端口等信息，并将信息存储到管理节点的node.dat文件void test()cout 输入地址信息 endl;char ip16;int port = 5101;while(1)cout 输入IP endl;scanf(%s,ip);if(strcmp(ip,0) = 0)break;if(nodeadd(ip, port, 1024*10) = 0)cout 该记录已经存在 endl;cout 主服务器配置完成 endl;上面的管理服务器主程序在5100端口监听来自客户端的连接及操作命令，其命令由cmd定义，根据从客户端接收到的命令进入不同的处理线程，在本系统已实现的功能有添加用户功能、获取用户信息功能和获取节点信息功能。管理节点服务器在启动时就调用test()函数完成对子节点信息的添加及配置。节点信息被存到node.dat文件，用户信息被存到root.dat。在用户需要进行数据访问时将读取这两个文件获得当前云计算系统所有已接入系统的子节点，并判断当前用户是否存在，如存在则返回其文件分配信信息存储位置。我们要注意的是在现在这个系统中管理节点并不和任何的子节点进行通信，也不直接协调子节点的工作。用户在获取相关信息后将直接与子节点联系进行操作和数据访问，这样可以大大减轻主节点的负载。在管理节点程序中我们定义了一些常用的数据结构主要有userInfo，该数据结构与root.dat文件有关，包括用户名、用户数据配置文件所在节点的IP地址等信息，因为用户数据文件的信息没有存放在管理节点而是放在某一个子节点上的，客户端要访问文件数据首先要从管理节点的root.dat文件中获取该用户数据配置文件所在节点的IP地址，再通过该IP地址获取数据的存储信息。另一个数据结构是nodeInfo，该数据结构与node.dat文件有关，包括节点IP、端口、节点总容量、可用空间等，系统中所有节点的相关内容都采用这一数据结构存入node.dat文件。主节点服务器程序部分参数及数据结构的定义如程序8.2所示。程序8.2/*文件名melem.h*/#define USERADD 1 /添加用户#define USERGET 2 /获取用户信息#define USERDEL 3#define GETNODE 4 /获取节点信息#define BLOCKSIZE 1024/定义文件块大小typedef int CMD; /CMD为命令标识/*此结构体写入root.dat文件*/typedef structchar user20; /用户名char ip16; /用户数据配置文件所在节点的IP地址int port;userInfo;/*此结构体写入node.dat文件*/typedef structchar ip16; /存储节点的IP地址int port; /端口号int userNum; /用户数目_off_t totalsize; /节点的总容量_off_t freesize; /节点的可用空间nodeInfo;typedef structchar ip16;int port;nodeaddr;8.2.2管理节点各线程函数的设计管理节点程序的功能基本是由其定义的4个线程函数（其中删除用户未定义）提供的，这些函数的功能主要是完成用户信息的注册、服务器节点信息的管理和用户数据配置信息的管理。管理节点可以看作是一个信息的中转站，其自身并不完成任何的数据操作和处理工作。各线程的函数定义如下。1增加新用户线程函数程序8.3/*文件名mthread.cpp*/*增加新的用户，用于新用户注册功能*/unsigned _stdcall useraddthread(LPVOID p)SOCKET* tsock = (SOCKET *)p;struct sockaddr_in taddr;int len = 20;char* username = (char *) malloc (len * sizeof(char);recv(*tsock, username, len, 0);/从客户端接收用户名int result = useradd(username);send(*tsock, (char *)&result, sizeof(int), 0);closesocket(*tsock);free(username);free(tsock);return 1;函数useraddthread()接收来自于客户端的新注册用户名，调用useradd()函数将用户名及存储该用户文件信息的节点IP地址写入主节点的root.dat文件，客户端访问该文件可以获得某一用户的文件存储信息文件所在的子节点IP地址，该文件的文件名就是用户名。2获取用户信息线程函数程序8.4/*文件名mthread.cpp*/*客户端获取用户信息文件*/unsigned _stdcall usergetthread(LPVOID p)SOCKET* tsock = (SOCKET *)p;struct sockaddr_in taddr;int len = 20;char* username = (char *) malloc (len);userInfo *user = (userInfo *) malloc (sizeof(userInfo);recv(*tsock, username, len, 0);cout 接收到的用户名: username endl;/*根据用户名读取root.dat中的用户及对应存储文件描述信息的子节点IP*/if(userget(username, user) = 0)cout get false user, 0);strcpy(user-ip,0.0.0.0);user-port = 0;cout int_thread: user ip : port endl;send(*tsock, (char *)user, sizeof(userInfo), 0);closesocket(*tsock);free(username);free(user);return 1;函数usergetthread()接收来自客户端的用户名，并在root.dat文件中查找该用户名对应的userInfo数据结构，并传回给客户端。其中调用userget()函数从root.dat读取与username对应的userInfo信息。通过调用这一函数客户端可以知道对应用户的文件描述文件存储在哪个子节点上，通过连接该子节点获取文件的具体存储方式。客户端在调用一这函数后将通过返回的IP地址与存储了数据分块描述情况文件的子节点进行连接。3文件分块线程函数程序8.5/*文件名mthread.cpp*/*根据node.dat文件中的节点信息，将数据块分配到各节点*/unsigned _stdcall getnodeaddrthread(LPVOID p)SOCKET* tsock = (SOCKET *)p;int blocknum = 0;nodeInfo *node = (nodeInfo *) malloc (sizeof(nodeInfo);nodeaddr *naddr = (nodeaddr *) malloc (sizeof(nodeaddr);recv(*tsock, (char *)&blocknum, sizeof(int), 0); /获取数据块个数for(int i = 0; i port = node-port;strcpy(naddr-ip, node-ip);send(*tsock, (char *)naddr, sizeof(nodeaddr), 0); /该数据块的存储位置发送回客户端closesocket(*tsock);free(node);free(naddr);free(tsock);return 1;函数getnodeaddrthread()接收来自客户端的数据块个数，并为每个数据块分配一个存储节点，数据块的分配通过调用datagetnode()函数来完成，该函数按剩余空间最大的策略向各数据块分配存储节点，并将分配结果发送回客户端，由客户端根据接收到的子节点IP直接连接子节点来完成文件的存储工作，并将存储结果写入子节点中的数据分块描述文件中，以便系统在下次读取时获得数据的存储情况。8.2.3主服务器中其他函数的设计主服务器其他函数定义。程序8.6/*文件名mfile.cpp*/*向node.dat文件添加节点信息*/int nodeadd(char* ip, int port, _off_t totalsize)nodeInfo *temp = (nodeInfo *) malloc (sizeof(nodeInfo);fseek(fp_node, 0, 0);/*判断该节点是否已存在*/while( fread(temp, sizeof(nodeInfo), 1, fp_node) = 1)if(strcmp(temp-ip, ip) = 0 & temp-port = port)free(temp);return 0;strcpy(temp-ip, ip);temp-port = port;temp-userNum = 0;temp-totalsize = totalsize;temp-freesize = totalsize;/*写入node.dat文件*/fwrite(temp, sizeof(nodeInfo), 1, fp_node);fseek(fp_node, 0, 0);fflush(fp_node);free(temp);return 1;/*分配用户数据描述文件存储节点的IP*/int usergetnode(nodeInfo *node)nodeInfo *temp = (nodeInfo *) malloc (sizeof(nodeInfo);fseek(fp_node, 0, 0);int num = 0;int no = 0;/*寻找已分配uesername文件最少的节点IP*/if(fread(node, sizeof(nodeInfo), 1, fp_node) != 1)return 0;while( fread(temp, sizeof(nodeInfo), 1, fp_node) = 1)+num;if(temp-userNum userNum)*node = *temp;no = num;memset(temp, 0, sizeof(nodeInfo);*temp = *node;temp-userNum += 1;fseek(fp_node, no*sizeof(nodeInfo), 0);fwrite(temp, sizeof(nodeInfo), 1, fp_node);fseek(fp_node, 0, 0);fflush(fp_node);free(temp);return 1;/*将username及对应存储数据描述文件的节点IP写入root.dat文件*/int useradd(char* username)userInfo *temp = (userInfo *) malloc (sizeof(userInfo);nodeInfo *node = (nodeInfo *) malloc (sizeof(nodeInfo);fseek(fp_user, 0, 0);while( fread(temp, sizeof(userInfo), 1, fp_user) = 1)/*检测该用户名是否存在*/if(strcmp(temp-user, username) = 0)free(temp);free(node);return 0; /该用户名已经存在if(usergetnode(node) = 0)/获取该用户数据描述文件存储节点的IP，通过node参数传出return -1; /获取节点失败memset(temp, 0, sizeof(userInfo);strcpy(temp-user, username);strcpy(temp-ip, node-ip);temp-port = node-port;/*将userInfo信息写入root.dat文件，确认数据块描述文件的存储位置*/fwrite(temp, sizeof(userInfo), 1, fp_user) ;fseek(fp_user, 0, 0);fflush(fp_user);free(temp);free(node);return 1;/*根据用户名，读取root.dat文件中的userInfo数据*/int userget(char* username, userInfo *user)userInfo *temp = (userInfo *) malloc (sizeof(userInfo);fseek(fp_user, 0, 0);while( fread(temp, sizeof(userInfo), 1, fp_user) = 1)if(strcmp(temp-user, username) = 0)*user = *temp;return 1;return 0;/*根据node.dat文件获取系统中的节点信息nodeInfo，并按最大剩余空间优先策略分配给数据块*/*分配完成后更新node.dat文件的内容*/int datagetnode(nodeInfo *node)nodeInfo *temp = (nodeInfo *) malloc (sizeof(nodeInfo);fseek(fp_node, 0, 0);int num = 0;int no = 0;if(fread(node, sizeof(nodeInfo), 1, fp_node) != 1)return 0;/*首先向剩余空间最大的节点分配数据块*/while( fread(temp, sizeof(nodeInfo), 1, fp_node) = 1)+num;if(temp-freesize node-freesize)*node = *temp;no = num;memset(temp, 0, sizeof(nodeInfo);*temp = *node;temp-freesize -= BLOCKSIZE;fseek(fp_node, no*sizeof(nodeInfo), 0);/*将分配后的信息写回node.dat文件，更新文件信息*/fwrite(temp, sizeof(nodeInfo), 1, fp_node);fseek(fp_node, 0, 0);fflush(fp_node);free(temp);return 1;/*获得rood.dat和node.dat的文件指针*/*fp_user指向root.dat文件*/*fp_node指向node.dat文件*/void openfile()if( (fp_user = fopen(root.dat, rb+) = NULL)fp_user = fopen(root.dat, wb+);if( (fp_node = fopen(node.dat, rb+) = NULL)fp_node = fopen(node.dat, wb+);8.3子节点程序分析云计算V0.01中子节点主要完成数据的存储及用户文件存储信息的保存，各用户文件存储信息的文件名为该用户的用户名，子节点程序需要在所有的节点上同时运行。文件的存储和访问由客户端与子节点直接连接来完成，子节点和管理节点不进行任何的数据通信工作。各数据块存储的文件名为username_filename_blockNo，即用户名加文件名加数据块号，之间用下划线连接。子节点函数调用结构如图8.5所示。图8.5 子节点函数调用结构8.3.1子节点主函数子节点的主程序启动后监听来自于客户端发过来的命令cmd，根据不同的命令进入不同的线程进行处理。程序8.7/*文件名blocksever.cpp*/ blocksever.cpp : 定义控制台应用程序的入口点int _tmain(int argc, _TCHAR* argv)WSADATA wsa;int ret = 0;int PORT = 5101;SOCKET s_socket;SOCKET c_socket;struct sockaddr_in s_sockaddr;struct sockaddr_in c_sockaddr;int c_sockaddr_len = sizeof(c_sockaddr);ret = WSAStartup(MAKEWORD(2, 2), &wsa);if(ret != 0)cout Init WinSock failed: ret endl;return 0;if(s_socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP) = SOCKET_ERROR)cout Create Socket Failed: WSAGetLastError() endl;WSACleanup();return 0;s_sockaddr.sin_family = AF_INET;s_sockaddr.sin_port = htons(PORT);s_sockaddr.sin_addr.s_addr = htonl(INADDR_ANY);if(bind(s_socket, (SOCKADDR *)&s_sockaddr, sizeof(s_sockaddr) = SOCKET_ERROR)cout bind failed: WSAGetLastError() endl;closesocket(s_socket);WSACleanup();return 0;if(listen(s_socket, 5) = SOCKET_ERROR)cout Listen Failed: WSAGetLastError() endl;closesocket(s_socket);WSACleanup();return 0;CMD cmd;while(1)c_socket = accept(s_socket, (SOCKADDR *)&c_sockaddr, &c_sockaddr_len);recv(c_socket, (char *)&cmd, sizeof(CMD), 0);SOCKET *tsock = (SOCKET *)malloc(sizeof(SOCKET);*tsock = c_socket;/*获取用户文件存储信息，该文件存储于其中一个子节点*/*用户根据管理节点提供的IP，直接连接该子节点获取*/if(cmd = USERINFOGET)_beginthreadex(NULL, 0, &userinfogetthread, tsock, 0, NULL);else if(cmd = FILEINFOADD)_beginthreadex(NULL, 0, &fileinfoaddthread, tsock, 0, NULL);/添加文件存储信息else if(cmd = STOREBLOCK)_beginthreadex(NULL, 0, &storedatathread, tsock, 0, NULL); /存储数据块else if(cmd = GETDATA)_beginthreadex(NULL, 0, &getdatathread, tsock, 0, NULL); /完成计算工作elsecontinue;return 0;子节点的主函数的功能是启动对客户端发出命令的监听和执行，主要是完成4项工作，分别由4个不同的线程函数来完成。一是获取文件存储信息；二是在文件分块描述文件中添加信息；三是实现数据块的存储工作；四是在各节点启动计算，完成存储与计算的整合工作。子节点程序要用到的一些常用数据结构定义如下。程序8.8/*文件名belem.h*/#ifndef BELEM_H#define BELEM_H#include stdafx.h#define USERNAME_LEN 20#define FILENAME_LEN 64#define BLOCKNAME_LEN 128#define LISTLEN 5#define MAINIP 127.0.0.1#define USERADD 1#define USERGET 2#define USERDEL 3#define USERINFOGET 5#define FILEINFOADD 6#define STOREBLOCK 7#define GETDATA 8typedef int CMD;/*fileInfo数据结构为子节点上用户数据文件描述的内容*/typedef structchar filenameFILENAME_LEN; /文件名int blockNO; /数据块号char ip16; /数据块存放节点的IP地址int port;fileInfo;/*数据块描述数据结构*/typedef structint blockNO;char ip16;int port;blockInfo;typedef structfileInfo *e;int length;int size;fileInfoList;#endif8.3.2子节点各线程函数设计1获取文件存储信息线程函数程序8.9/*文件名bthread.cpp*/unsigned _stdcall userinfogetthread(LPVOID p) /获取用户信息文件线程SOCKET* tsock = (SOCKET *)p;char usernameUSERNAME_LEN;recv(*tsock, username, USERNAME_LEN, 0);FILE *fp;if(fp = fopen(username, rb) = NULL)fp = fopen(username, wb+); /打开用户存储信息描述表struct _stat info;_stat(username, &info);/获取文件信息_off_t filelen = info.st_size;sen