基于稳定婚姻算法和cloudsim框架的云计算任务调度模拟Java源码(本科毕设).zip

package examples.container; import cloudsim.*; import cloudsim.container.containerProvisioners.ContainerBwProvisionerSimple; import cloudsim.container.containerProvisioners.ContainerPe; import cloudsim.container.containerProvisioners.ContainerRamProvisionerSimple; import cloudsim.container.containerProvisioners.CotainerPeProvisionerSimple; import cloudsim.container.containerVmProvisioners.ContainerVmBwProvisionerSimple; import cloudsim.container.containerVmProvisioners.ContainerVmPe; import cloudsim.container.containerVmProvisioners.ContainerVmPeProvisionerSimple; import cloudsim.container.containerVmProvisioners.ContainerVmRamProvisionerSimple; import cloudsim.container.core.*; import cloudsim.container.resourceAllocatorMigrationEnabled.PowerContainerVmAllocationPolicyMigrationAbstract; import cloudsim.container.resourceAllocators.ContainerAllocationPolicy; import cloudsim.container.resourceAllocators.ContainerVmAllocationPolicy; import cloudsim.container.schedulers.ContainerCloudletSchedulerDynamicWorkload; import cloudsim.container.schedulers.ContainerSchedulerTimeSharedOverSubscription; import cloudsim.container.schedulers.ContainerVmSchedulerTimeSharedOverSubscription; import cloudsim.container.utils.IDs; import cloudsim.util.MathUtil; import com.opencsv.CSVWriter; import java.io.*; import java.io.File; import java.util.*; /** * This is the modified version of {@link examples.power.Helper} class in cloudsim. * Created by sareh on 15/07/15. */ public class HelperEx { public HelperEx() { // System.out.print(); } public static List<ContainerCloudlet> createContainerCloudletList(int brokerId, String inputFolderName, int numberOfCloudlets) throws FileNotFoundException { ArrayList cloudletList = new ArrayList(); long fileSize = 300L; long outputSize = 300L; UtilizationModelNull utilizationModelNull = new UtilizationModelNull(); File inputFolder1 = new File(inputFolderName); File[] files1 = inputFolder1.listFiles(); int createdCloudlets = 0; for (File aFiles1 : files1) { File inputFolder = new File(aFiles1.toString()); File[] files = inputFolder.listFiles(); for (int i = 0; i < files.length; ++i) { if (createdCloudlets < numberOfCloudlets) { ContainerCloudlet cloudlet = null; try { cloudlet = new ContainerCloudlet(IDs.pollId(ContainerCloudlet.class), 216000000L * 1000, 1, fileSize, outputSize, new UtilizationModelPlanetLabInMemoryExtended(files[i].getAbsolutePath(), 300.0D), utilizationModelNull, utilizationModelNull); } catch (Exception var13) { var13.printStackTrace(); System.exit(0); } cloudlet.setUserId(brokerId); // cloudlet.setVmId(i); cloudletList.add(cloudlet); createdCloudlets += 1; } else { return cloudletList; } } } return cloudletList; } // create the containers for hosting the cloudlets and binding them together. public static List<Container> createContainerList(int brokerId, int containersNumber) { ArrayList containers = new ArrayList(); for (int i = 0; i < containersNumber; ++i) { // int containerType = new RandomGen().getNum(ConstantsExamples.CONTAINER_TYPES); int containerType = i / (int) Math.ceil((double) containersNumber / 3.0D); // int containerType = 0; containers.add(new PowerContainer(IDs.pollId(Container.class), brokerId, (double) ConstantsExamples.CONTAINER_MIPS[containerType], ConstantsExamples. CONTAINER_PES[containerType], ConstantsExamples.CONTAINER_RAM[containerType], ConstantsExamples.CONTAINER_BW, 0L, "Xen", new ContainerCloudletSchedulerDynamicWorkload(ConstantsExamples.CONTAINER_MIPS[containerType], ConstantsExamples.CONTAINER_PES[containerType]), ConstantsExamples.SCHEDULING_INTERVAL)); } return containers; } // create the containers for hosting the cloudlets and binding them together. public static List<ContainerVm> createVmList(int brokerId, int containerVmsNumber) { ArrayList containerVms = new ArrayList(); for (int i = 0; i < containerVmsNumber; ++i) { ArrayList peList = new ArrayList(); // int vmType = new RandomGen().getNum(ConstantsExamples.VM_TYPES); // Log.print(vmType); // Log.print("\n"); int vmType = i / (int) Math.ceil((double) containerVmsNumber / 4.0D); // int vmType = 1; // int vmType = 1; for (int j = 0; j < ConstantsExamples.VM_PES[vmType]; ++j) { peList.add(new ContainerPe(j, new CotainerPeProvisionerSimple((double) ConstantsExamples.VM_MIPS[vmType]))); } containerVms.add(new PowerContainerVm(IDs.pollId(ContainerVm.class), brokerId, (double) ConstantsExamples.VM_MIPS[vmType], (float) ConstantsExamples.VM_RAM[vmType], ConstantsExamples.VM_BW, ConstantsExamples.VM_SIZE, "Xen", new ContainerSchedulerTimeSharedOverSubscription(peList), new ContainerRamProvisionerSimple(ConstantsExamples.VM_RAM[vmType]), new ContainerBwProvisionerSimple(ConstantsExamples.VM_BW), peList, ConstantsExamples.SCHEDULING_INTERVAL)); } return containerVms; } public static List<ContainerHost> createHostList(int hostsNumber) { ArrayList hostList = new ArrayList(); for (int i = 0; i < hostsNumber; ++i) { // int hostType = new RandomGen().getNum(ConstantsExamples.HOST_TYPES); int hostType = i / (int) Math.ceil((double) hostsNumber / 3.0D); // int hostType = i % 2; // int hostType = 2; ArrayList peList = new ArrayList(); for (int j = 0; j < ConstantsExamples.HOST_PES[hostType]; ++j) { peList.add(new ContainerVmPe(j, new ContainerVmPeProvisionerSimple((double) ConstantsExamples.HOST_MIPS[hostType]))); } // hostList.add(new PowerContainerHost(i, new ContainerVmRamProvisionerSimple(ConstantsExamples.HOST_RAM[hostType]), // new ContainerVmBwProvisionerSimple(1000000L), 1000000L, peList, new ContainerVmSchedulerTimeSharedOverSubscription(peList), ConstantsExamples.HOST_POWER[hostType])); hostList.add(new PowerContainerHostUtilizationHistory(IDs.pollId(ContainerHost.class), new ContainerVmRamProvisionerSimple(ConstantsExamples.HOST_RAM[hostType]), new ContainerVmBwProvisionerSimple(1000000L), 1000000L, peList, new ContainerVmSchedulerTimeSharedOverSubscription(peList), ConstantsExamples.HOST_POWER[hostType])); } return hostList; } // Broker public static ContainerDatacenterBroker createBroker(double overBookingFactor) { ContainerDatacenterBroker broker = null; try { broker = new ContainerDatacenterBroker("Broker", overBookingFactor); } catch (Exception var2) { var2.printStackTrace(); System.exit(0); } return broker; } // // Data Center // public static PowerContainerDatacenter createDatacenter(String name, List<ContainerHost> hostList, ContainerVmAllocationPolicy vmAllocationPolicy, ContainerAllocationPolicy containerAllocationPolicy) throws Exception { // String arch = "x86"; // String os = "Linux"; // String vmm = "Xen"; // double time_zone = 10.0D; // double cost = 3.0D; // double costPerMem = 0.05D; // double costPerStorage = 0.001D