資源簡(jiǎn)介
使用Java寫(xiě)的并行云計(jì)算簡(jiǎn)單使用的小程序,很久之前的東西因此不是很高大上,簡(jiǎn)單認(rèn)識(shí)入門(mén)應(yīng)該是可以的

代碼片段和文件信息
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(“簡(jiǎn)易云計(jì)算器“);
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[]*/;
//讀取子節(jié)點(diǎn)配置文件
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?自動(dòng)生成的?catch?塊
e1.printStackTrace();
}
try{
NumServers?=?Integer.parseInt(IntString);
}catch(NumberFormatException?e){
System.out.println(“r?servers?is?not?an?integer“);
System.exit(1);
}
//通過(guò)配置文件取得子節(jié)點(diǎn)數(shù)目后,實(shí)例化定義的各個(gè)數(shù)組
Servernames?=?new?String[NumServers];
sock?=?new?Socket[NumServers];
Serveraddr?=?new?InetAddress[NumServers];
datain?=?new?DataInputStream[NumServers];
dataout?=?new?DataOutputStream[NumServers];
for(i?=?0?;?i? try{
Servernames[i]?=?ServerConfigFile.readLine();
}catch(IOException?e){
System.out.println(“讀取子節(jié)點(diǎn)名稱(chēng)錯(cuò)誤“);
System.exit(1);
}
Servernames[i]?=?Servernames[i].trim();
}
try{
ServerConfigFile.close();
ServerConfigFile?=?null;
}catch(IOException?e){}
//建立套接字對(duì)象和建立輸入輸出流
try{
for(i?=?0?;?i? Serveraddr[i]?=?InetAddress.getByName(Servernames[i]); //獲取IP地址
txtServerIP.append(“連接到子節(jié)點(diǎn)?“+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錯(cuò)誤,建立套接字連接失敗“);
System.exit(1);
}
ClientBody();
try{
for(i?=?0;?i? dataout[i].
?屬性????????????大小?????日期????時(shí)間???名稱(chēng)
-----------?---------??----------?-----??----
?????文件????????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
評(píng)論
共有 條評(píng)論