資源簡介
使用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? 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? 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? 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
評論
共有 條評論