Java：网络编程之应用实例

//客户端

class PicClient

{
    public static void main(String[] args)throws Exception
    {
        
        if(args.length!=1)
        {
            System.out.println("请选择一个jpg类型的图片");
            return ;
        }
        
    
        File file = new File(args[0]);//"F:\\myfile\\1.jpg"
        if(!(file.exists()&& file.isFile()))
        {
            System.out.println("该文件有问题,要么不是文件,要么不存在");
            return ;
        }
        
        if(!(file.getName().endsWith(".jpg")))
        {
            System.out.println("图片格式错误,请重新选择!");
            return ;
        }
        
        if(file.length()>1024*1024*5)
        {
            System.out.println("文件过大!");
            return ;
        }

        Socket s = new Socket("192.168.1.105",10000);
        //图片读取流的源
        FileInputStream fis = new FileInputStream(file);

        //socket输出流的目的
        PrintStream ps = new PrintStream(s.getOutputStream(),true);
        
        byte[] buf = new byte[1024];
        int num = 0;
        while((num=fis.read(buf))!=-1)
        {
            ps.write(buf,0,num);
        }
        
        s.shutdownOutput();//关闭客户端的输出流，告诉服务端数据已经写完,相当于给流中加入一个结束标记-1
        
        //socket读取流的源(读取反馈信息)
        InputStream in = s.getInputStream();
        
        byte[] bufin = new byte[1024];
        int len = in.read(bufin);
        System.out.println(new String(bufin,0,len));
        
        fis.close();
        s.close();
    }
}

/*
服务端：
这个服务端有个局限性，当A客服端连上以后，被服务端收到。服务端执行具体流程。
这时，B客服端连接只有等待。因为服务端还没有处理完A客服端的请求，还没有循环
回来执行accept方法。所以，暂时获取不到B客户端对象。那么，为了能让多个客服端并发
访问服务端，服务端最好就是将每个客服端封装到一个单独的线程中，这样，可以同时处理
多个客服端的请求。

如何定义线程呢？
只要明确了每一个客户端要在服务端执行的代码即可，将该代码存入到run方法中。
*/
class PicThread implements Runnable
{
    private Socket s;
    PicThread(Socket s)
    {
        this.s = s;
    }
    public void run()
    {
      int count=1;    
      String ip = s.getInetAddress().getHostAddress();
      try
      {
        System.out.println(ip+"......connected!");
        //图片输出流的目的
        
        
        File file = new File(ip+"("+count+")"+".jpg");
        
        while(file.exists())    
            file = new File(ip+"("+(count++)+")"+".jpg");
        
        FileOutputStream fos = new FileOutputStream(file);
        //SocketServer读取流的源
        InputStream in = s.getInputStream();
    
        byte[] buf = new byte[1024];
        int len = 0;
        while((len=in.read(buf))!=-1)
        {
            fos.write(buf,0,len);
        }
        
        //SocketServer输出流的目的（输出反馈信息）
        PrintStream ps = new PrintStream(s.getOutputStream(),true);        
        ps.write("图片上传成功!".getBytes());
        
        fos.close();
        s.close();                  
      }      
      catch(Exception e)
      {
          throw new RuntimeException(ip+"上传失败!");
      }
    }
}

//测试类
class PicServer
{
    public static void main(String[] args)throws Exception
    {
        ServerSocket ss = new ServerSocket(10000);
        
        while(true)
        {
          Socket s = ss.accept();
          
          new Thread(new PicThread(s)).start();
        }
        //ss.close();
    }
}