Socket 传送文件

1.传送文本文件

1.1服务端

package com;

import java.io.BufferedWriter;
import java.io.DataInputStream;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class FileServerSocket {
	public static void main(String[] args) {
		try {
			File file = new File("F:\Test\129.mp3");
			
			ServerSocket server = new ServerSocket(8008);
			DataInputStream dataInput;
			String fileMessage = "";
			
			FileWriter fileWriter = new FileWriter(file,true);
			BufferedWriter bw = new BufferedWriter(fileWriter);
			
			Socket socket;
			System.out.println("服务器已启动~~~");
			socket = server.accept();
			System.out.println("捕获到连接");
			while(true){
				dataInput = new DataInputStream(socket.getInputStream());
				fileMessage = dataInput.readUTF();
				
				bw.write(fileMessage);
				bw.flush();
				System.out.println(fileMessage);
				if(fileMessage.equals("exit")){
					System.out.println("传输完成~~~");
					break;
				}
			}
			
			bw.close();
			dataInput.close();
			server.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

1.2 ### 客户端

package com;

import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class FileSocket {
	public static void main(String[] args) {
		try {
			File file = new File("F:\Test\12.mp3");
			Socket socket = new Socket("127.0.0.1",8008);
			OutputStream output = socket.getOutputStream();
			
			FileReader fileReader = new FileReader(file);
			BufferedReader br = new BufferedReader(fileReader);
			
			DataOutputStream dataOutput = new DataOutputStream(output);
			dataOutput.writeUTF(file.getName());
			
			String sb = "";
			System.out.println("客户端已启动");
			while((sb = br.readLine()) != null){
				dataOutput.writeUTF(sb);
				dataOutput.flush();
			}
			System.out.println("客户端文件已经传送完成");
			dataOutput.close();
			br.close();
			socket.close();
			
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

2.传送其他文件

2.1 服务端

package fileSocket;

import java.io.DataInputStream;
import java.io.EOFException;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
	public static void main(String[] args) throws EOFException {
		try {
			ServerSocket server = new ServerSocket(8008);
			DataInputStream dataInput;
			
			File file = new File("F:\Test\12_3.mp3");
			FileOutputStream fileOutput = new FileOutputStream(file);
			
			Socket socket;
			System.out.println("服务器已启动~~~");
			
			byte byte_[] = new byte[1024 * 4];
			int length;
			
			socket = server.accept();
			System.out.println("捕获到连接");
			dataInput = new DataInputStream(socket.getInputStream());
			while((length = dataInput.read(byte_,0,byte_.length)) > 0){
				fileOutput.write(byte_,0,length);
				fileOutput.flush();
			}
			fileOutput.close();
			dataInput.close();
			server.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
		System.out.println("接收完成");
		
	}
}

2.2 客户端

package fileSocket;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {
	public static void main(String[] args) {
		try {
			File file = new File("F:\Test\12.mp3");
			FileInputStream fileStream = new FileInputStream(file);
			
			Socket socket = new Socket("127.0.0.1",8008);
			OutputStream output = socket.getOutputStream();
			DataOutputStream dataOutput = new DataOutputStream(output);
			
			byte[] b = new byte[1024 * 4];
			System.out.println("客户端已启动");
			int length;
			while((length = fileStream.read(b,0,b.length)) > 0){
				dataOutput.write(b,0,length);
				dataOutput.flush();
			}
			System.out.println("客户端文件已经传送完成");
			dataOutput.close();
			fileStream.close();
			socket.close();
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}