Java云计算简单

使用Java写的并行云计算简单使用的小程序，很久之前的东西因此不是很高大上，简单认识入门应该是可以的

import java.awt.FlowLayout;
import java.awt.TextArea;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.net.InetAddress;
import java.net.Socket;

import javax.swing.Jframe;

public class Netc extends Jframe {
	
	static Socket sock[];
	static InetAddress Serveraddr[];
	static DataInputStream datain[];
	static DataOutputStream dataout[];
	static int NumServers;
	static String Servernames[];
	static TextArea txtServerIP;
	static TextArea txtOutDatatxtInData;
	
	public Netc（）{
		super（“简易云计算器“）;
		setSize（320500）;
		setVisible（true）;
		setLayout（new FlowLayout（））;
		txtServerIP = new TextArea（230）;
		txtInData = new TextArea（1030）;
		txtOutData = new TextArea（1630）;
		add（txtServerIP）;
		add（txtOutData）;
		add（txtInData）;
		setDefaultCloseOperation（Jframe.EXIT_ON_CLOSE）;
		validate（）;
	}
	
	@SuppressWarnings（“deprecation“）
	public static void main（String[] args）{
		new Netc（）;
		
		int i;
		DataInputStream ServerConfigFile = null;
		String IntString = null/*Servernames[]*/;
		//读取子节点配置文件
		FileInputStream fileIn;
		try {
			fileIn = new FileInputStream（“node.txt“）;
			ServerConfigFile = new DataInputStream（fileIn）;
		} catch （FileNotFoundException e） {
			e.printStackTrace（）;
			System.exit（1）;
		}
		try {
			IntString = ServerConfigFile.readLine（）;
		} catch （IOException e1） {
			// TODO 自动生成的 catch 块
			e1.printStackTrace（）;
		}
		try{
			
			NumServers = Integer.parseInt（IntString）;
		}catch（NumberFormatException e）{
			System.out.println（“r servers is not an integer“）;
			System.exit（1）;
		}
		//通过配置文件取得子节点数目后，实例化定义的各个数组
		Servernames = new String[NumServers];
		sock = new Socket[NumServers];
		Serveraddr = new InetAddress[NumServers];
		datain = new DataInputStream[NumServers];
		dataout = new DataOutputStream[NumServers];
		
		for（i = 0 ; i < NumServers ; i++）{
			try{
				Servernames[i] = ServerConfigFile.readLine（）;
			}catch（IOException e）{
				System.out.println（“读取子节点名称错误“）;
				System.exit（1）;
			}
			Servernames[i] = Servernames[i].trim（）;
		}
		try{
			ServerConfigFile.close（）;
			ServerConfigFile = null;
		}catch（IOException e）{}
		//建立套接字对象和建立输入输出流
		try{
			for（i = 0 ; i < NumServers ; i++）{		//通过循环为所有子节点创建套接字
				Serveraddr[i] = InetAddress.getByName（Servernames[i]）;	//获取IP地址
				txtServerIP.append（“连接到子节点 “+Serveraddr[i]+“\n“）;
				sock[i] = new Socket（Serveraddr[i]1237）;		//约定端口为1237
				datain[i] = new DataInputStream（new BufferedInputStream（sock[i].getInputStream（）））;
				dataout[i] = new DataOutputStream（new BufferedOutputStream（sock[i].getOutputStream（）））;
			}
		}catch（IOException e）{
			System.out.println（“IO错误，建立套接字连接失败“）;
			System.exit（1）;
		}
		ClientBody（）;
		try{
			for（i = 0; i < NumServers ; i++）{
				dataout[i].

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件        301  2016-07-14 11:29  CloudComputing\.classpath

     文件        390  2016-07-14 11:29  CloudComputing\.project

     文件        598  2016-07-14 11:29  CloudComputing\.settings\org.eclipse.jdt.core.prefs

     文件       6144  2016-08-06 13:04  CloudComputing\bin\Netc.class

     文件       3355  2016-08-06 13:04  CloudComputing\bin\Nets.class

     文件         12  2016-07-14 20:26  CloudComputing\node.txt

     文件          1  2016-07-14 19:51  CloudComputing\root.txt

     文件       6077  2016-07-14 20:41  CloudComputing\src\Netc.java

     文件       3003  2016-07-14 20:40  CloudComputing\src\Nets.java

     目录          0  2016-07-14 11:29  CloudComputing\.settings

     目录          0  2016-08-06 13:04  CloudComputing\bin

     目录          0  2016-07-14 13:50  CloudComputing\src

     目录          0  2016-07-14 19:52  CloudComputing

----------- ---------  ---------- -----  ----

                19881                    13