单击此处编辑母版标题样式,单击此处编辑母版文本样式,第二级,第三级,第四级,第五级,*,*,Windows,环境下的分布式并行计算平台搭建,MATLAB,并行平台底层架构,MATLAB,并行平台搭建,并行程序的编写与实例,实验室,MATLAB,并行集群,1,MATLAB,并行平台底层架构（一）,并行平台上的三种角色,“警察”：维护整个平台mdce,：底层维护和通信进程,),“老板”：接任务，雇佣工人并分配任务jobmanager,：负责对计算机资源的管理，,接收用户发过来的并行计算任务工人”：努力工作worker,：工作进程）,我负责维护整个并行平台,接生意咯，客户要什么我就叫工人搞定它听老板的话，,努力干活！,2,MATLAB,并行平台底层架构（二）,MATLAB,并行平台底层架构图,3,MATLAB R2009b,的安装及启动（一）,安装时注意，,MDCS,，,License Manager,，并行计算工具箱,Parallel Computing Toolbox,等,为,必,装,的产品和工具箱,，（子节点机可不用装,License Manager,）如下图所示4,MATLAB R2009b,的安装及启动（二）,装好软件在启动之前，,双击主节点机的,matlabrootflexlm,文件夹下的,lmtool.exe,（,matlabroot,表示,matlab,软件的安装目录），开启,Matlab License Server,，如下图。
5,关闭防火墙,为方便平台搭建，将目录,matlabroottoolboxdistcompbin,添加到环境变量中的,path,里边，如右图设置6,MATLAB,并行平台搭建（一）,MATLAB,并行平台搭建（二）,安装和开启,mdce,（分布式计算引擎）,运行,-cmd,安装,mdce:mdce install,开启,mdce:mdce start,注意：,mdce,安装后会下次开机自动启动,警察来了！,7,MATLAB,并行平台搭建（三）,配置,jobmanager,打开,matlab,软件，菜单选,ParallelManage Configurations,，弹出对话框；,Filenewjobmanager,，弹出对话框：,Scheduler,项，,LookupURL,处填写所用计算机的名称，如,node5,；,Name,项为自拟的,jobmanager,的名称，如,myjobmanager,Jobs,项，,Number of Workers,处表示该,jobmanager,运行并行程序时需要最小,worker,数目（即最小,worker,数目才执行），以及该,jobmanager,可拥有的最大,worker,数目；,3.,点击,OK,，完成配置。
完善资料，合法经营8,MATLAB,并行平台搭建（三）,打开,jobmanager,命令行下输入：,startjobmanager name,myjobmanager,即前面配置时的名字,附：关闭,jobmanager,stopjobmanager name myjobmanager,正式登场！,9,MATLAB,并行平台搭建（四）,创建,worker,进程,(,雇佣工人,),同样在命令行下输入：,startworker jobmanagerhost,node5,jobmanager,myjobmanager,name,worker1,remotehost,node1,node5:,本地计算机名字,myjobmanager,：,jobmanager,的名字,worker1:worker,进程的名字,node1:,远程计算机的名字,注意：可开启多个不同名字的,worker,进程；,若在本地上创建则不需后面的,-remotehost node1,附：关闭,worker,进程：,stopworkername worker1 remotehost node1,我聘请你平台搭建完毕！可用,nodestatus,指令查看。
10,MATLAB,并行程序编写,资源查找，创建对象；,创建工作（,job,）；指定工作任务（,task,）；提交工作；等待；返回计算任务结果findResource(),createJob(),createTask(),submit(),getAllOutputArguments(),waitForState(),程序结构和相关函数调用,11,MATLAB,并行程序示例,%,程序功能，并行计算求,2+4,，,5+8,，,1+7,的和资源查找，创建对象jm=findResource(scheduler,type,jobmanager,name,myjobmanager,LookupURL,node5,);,需要修改的是红色划线参数，第一个即前面,jobmanager,的名字，第二个,即本地主机的名字,创建工作，并将该工作所需的数据、程序发到各个,worker,处job1=createJob(jm);%,工作名为,job1,%set(job1,FileDependencies,bb1.m,bb2.m,bb3.m,W_FDJ1.mat,W_FDJ2.mat,W_FDJ3.mat);,注：,set(),函数就是将该工作所需的数据、程序发到各个,worker,处,本程序不需要用到。
创建任务,createTask(job1,sum,1,2,4,);,createTask(job1,sum,1,5,8,);,createTask(job1,sum,1,1,7,);,为,job1,创建了,3,个任务，,sum,代表函数头，,1,代表返回参数个数，此处为,1,个，,2,4,代表函数,sum,的输入参数12,提交工作,submit(job1);,等待,waitForState(job1,finished);,返回结果,results=getAllOutputArguments(job1);,其中,results1,代表任务,1,的结果，本程序则为,6,2+4),results2,代表任务,2,的结果，本程序则为,13,5+8),results3,代表任务,3,的结果，本程序则为,8,1+7),完整程序如下,MATLAB,并行程序示例,13,实验室,MATLAB,集群平台,主机,node5,node1 4,node2 4,node3 4,node4 4,4,实验室,MATLAB,集群平台示意图,15,The end,16,。
