- 论坛徽章:
- 0
|
package wangluo.file;
import java.net.*;
import java.io.*;
public class GetFile extends Thread {
byte byteBuffer[] = new byte[1024];
Socket tempSocket;
RandomAccessFile inFile;
InputStream inSocket;
public static void main(String args[]) {
GetFile gf = new GetFile();
gf.start();
System.out.println("get it...");
}
public GetFile() {
try {
inFile = new RandomAccessFile("test/33.zip", "rw");
tempSocket = new Socket("127.0.0.1", 9090);
inSocket = tempSocket.getInputStream();
} catch (Exception e) {
}
}
public void run() {
int amount;
try {
while ((amount = inSocket.read(byteBuffer)) != -1) {
inFile.write(byteBuffer, 0, amount);
}
inSocket.close();
System.out.println("Get OK");
inFile.close();
tempSocket.close();
} catch (IOException e) {
}
}
}
package wangluo.file;
import java.net.*;
import java.io.*;
public class SendFile extends Thread {
byte byteBuffer[] = new byte[1024];
RandomAccessFile outFile;
ServerSocket serSocket;
OutputStream outputstream;
Socket tempSocket;
public static void main(String args[]) {
SendFile sf = new SendFile();
sf.start();
System.out.println("wait for...");
}
public SendFile() {
try {
outFile = new RandomAccessFile("33.zip", "r");
serSocket = new ServerSocket(9090);
} catch (Exception e) {
}
}
public void run() {
try {
tempSocket = serSocket.accept();
outputstream = tempSocket.getOutputStream();
int amount;
while ((amount = outFile.read(byteBuffer)) != -1) {
outputstream.write(byteBuffer, 0, amount);
}
System.out.println("Send File complete");
outFile.close();
tempSocket.close();
serSocket.close();
} catch (IOException e) {
}
}
} |
|