基于socket的上传下载（Java）精简版

package server;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class AndroidServer implements Runnable {
private ServerSocket serverSocket = null;
private DataInputStream is;

public void run() {
if (serverSocket == null) {
try {
serverSocket = new ServerSocket(5926);
} catch (Exception e) {
e.printStackTrace();
}
}
try {
Socket socket = serverSocket.accept();
is = new DataInputStream(new BufferedInputStream(new FileInputStream("D:\\test.mp4"))); // 把需要上传的文件，放入InputStream
DataOutputStream os = new DataOutputStream(new BufferedOutputStream(socket.getOutputStream())); // 初始化socket的OutputStream
int count;
byte[] buffer = new byte[1024];
while ((count = is.read(buffer, 0, buffer.length)) != -1) { // 把文件放入socket的OutputStream中
os.write(buffer, 0, count);
}
os.flush();
serverSocket.close();
socket.close();
} catch (Exception e) {
e.printStackTrace();
}
}

public static void main(String[] args) {
Thread desktopServerThread = new Thread(new AndroidServer()); // 启动服务
desktopServerThread.start();
}
}

import java.io.BufferedOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.net.Socket;

public class test {

public static void main(String[] args) {
try {
Socket socket = new Socket("192.168.0.228", 5926);
DataInputStream dis = new DataInputStream(socket.getInputStream()); // 获取socket中的InputStream
DataOutputStream os = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(new File("D:\\fuck")))); // 初始化OutputStream
int count = 0;
byte[] buffer = new byte[1024];
while ((count = dis.read(buffer)) != -1) { // 把socket中的InputStream放入OutputStream
os.write(buffer, 0, count);
}
os.close();
socket.close(); // 上传完成，关闭socket
} catch (Exception e) {
e.printStackTrace();
} finally {
}
}
}