import java.io.*;
import java.net.*;
/*
*發送端
*/
class picsend
{
  public static void main(String[] args) throws Exception
  {
    if(args.length!=1)
    {
      System.out.println("請選擇一張.jpg圖片");
      return;
    }
    File file = new File(args[0]);
    if (!(file.exists() && file.isFile()))
    {
      System.out.println("圖片有問題(不是文件或不存在)");
      return;
    }
    if(!file.getName().endsWith(".jpg"))
    {
      System.out.println("圖片格式不對，請重新選擇圖片");
      return;
    }
    if(file.length()>1024*1024*10)
    {
      System.out.println("圖片過大，無法上傳");
      return;
    }
    Socket s = new Socket("192.168.33.1",10006);//建立服務
    FileInputStream fis = new FileInputStream("d:\\美女.jpg");//讀取圖片
    OutputStream out = s.getOutputStream();//讀到的寫入
    byte [] b = new byte[1024];
    int len = 0;
    while((len = fis.read(b))!= -1)
    {
      out.write(b,0,len);
    }
    s.shutdownOutput();//標記結束
    InputStream in = s.getInputStream();//讀服務端返回數據
    byte [] bin = new byte[1024];
    int num = in.read(bin);
    System.out.println(new String(bin,0,num));
    fis.close();
    s.close();
  }
}
class picThread implements Runnable
{
  private Socket s;
  picThread(Socket s)
  {
    this.s = s;
  }
  public void run()
  {
    int count = 1;
    String ip = s.getInetAddress().getHostAddress();//得到ip
    try
    {
      System.out.println(ip+".............connect");
      InputStream in = s.getInputStream();//讀到流中數據
      File file = new File(ip+"("+(count)+")"+".jpg");
      while(file.exists())//判斷文件是否存在
        file = new File(ip+"("+(count++)+")"+".jpg");
      FileOutputStream fos = new FileOutputStream(file);//寫入
      byte [] b = new byte[1024];
      int len = 0;
      while((len = in.read(b))!=-1)
      {
        fos.write(b,0,len);
      }
      OutputStream out = s.getOutputStream();//寫入服務端傳過來數據
      out.write("上傳成功！".getBytes());
      fos.close();
      s.close();
    }
    catch (Exception e)
    {
      throw new RuntimeException("上傳失敗");
    }
  }
}
/*
*服務端
*/
class picrece
{
  public static void main(String[] args) throws Exception
  {
    ServerSocket ss = new ServerSocket(10006);
    while(true)
    {
      Socket s = ss.accept();//接收
      new Thread(new picThread(s)).start();
    }
  }
}