//客戶端
import javax.imageio.IIOException;
import java.io.*;
import java.net.InetAddress;
import java.net.Socket;

public class Uploading1 {
? ?public static void main(String[] args) throws IIOException {
? ? ? ?try {
? ? ? ? ? ?//創(chuàng)建一個socket連接
? ? ? ? ? ?Socket socket = new Socket(InetAddress.getByName("127.0.0.1"), 1314);
? ? ? ? ? ?//創(chuàng)建一個輸出流
? ? ? ? ? ?OutputStream os=socket.getOutputStream();
? ? ? ? ? ?//讀取文件
? ? ? ? ? ?FileInputStream fis = new FileInputStream(new File("C:\\Users\\hfdn\\Desktop\\beauty.jpg"));
? ? ? ? ? ?//寫出文件
? ? ? ? ? ?byte[] buffer= new byte[1024];
? ? ? ? ? ?int len;
? ? ? ? ? ?while((len=fis.read(buffer))!=-1)
? ? ? ? ? ?{
? ? ? ? ? ? ? ?os.write(buffer,0,len);
? ? ? ? ? ?}
? ? ? ? ? ?//通知服務(wù)器，我已經(jīng)傳輸完了
? ? ? ? ? ?socket.shutdownOutput();

? ? ? ? ? ?//確定服務(wù)器接收完畢，才能斷開連接
? ? ? ? ? ?InputStream inputStream=socket.getInputStream();
? ? ? ? ? ?ByteArrayOutputStream tunnel = new ByteArrayOutputStream();
? ? ? ? ? ?byte[] buffer2= new byte[2014];
? ? ? ? ? ?int len2;
? ? ? ? ? ?while((len2=inputStream.read(buffer2))!=-1)
? ? ? ? ? ?{
? ? ? ? ? ? ? ?tunnel.write(buffer2,0,len2);
? ? ? ? ? ?}
? ? ? ? ? ?System.out.println(tunnel.toString());
? ? ? ? ? ?//關(guān)閉資源
? ? ? ? ? ?inputStream.close();
? ? ? ? ? ?tunnel.close();
? ? ? ? ? ?fis.close();
? ? ? ? ? ?os.close();
? ? ? ? ? ?socket.close();
? ? ? ?} catch (IOException e) {
? ? ? ? ? ?e.printStackTrace();
? ? ? ?}
? ?}
}

//服務(wù)端

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class Uplodaing2 {
? ?public static void main(String[] args) {
? ? ? ?try {
? ? ? ? ? ?//創(chuàng)建服務(wù)
? ? ? ? ? ?ServerSocket serverSocket = new ServerSocket(1314);
? ? ? ? ? ?//監(jiān)聽客戶端的連接
? ? ? ? ? ?Socket socket = serverSocket.accept();//阻塞式監(jiān)聽，會一直等待
? ? ? ? ? ?//獲取輸入流
? ? ? ? ? ?InputStream is=socket.getInputStream();
? ? ? ? ? ?//文件輸出
? ? ? ? ? ?FileOutputStream fos=new FileOutputStream(new File("receive.jpg"));
? ? ? ? ? ?byte[] buffer= new byte[1024];
? ? ? ? ? ?int len;
? ? ? ? ? ?while((len=is.read(buffer))!=-1)
? ? ? ? ? ?{
? ? ? ? ? ? ? ?fos.write(buffer,0,len);
? ? ? ? ? ?}
? ? ? ? ? ?//通知客戶端接收完畢了
? ? ? ? ? ?OutputStream over=socket.getOutputStream();
? ? ? ? ? ?over.write("我接收好了，你可以走了".getBytes());
? ? ? ? ? ?//關(guān)閉資源
? ? ? ? ? ?fos.close();
? ? ? ? ? ?is.close();
? ? ? ? ? ?socket.close();
? ? ? ? ? ?serverSocket.close();
? ? ? ?} catch (IOException e) {
? ? ? ? ? ?e.printStackTrace();
? ? ? ?}
? ?}

}