1. import java.io.*;
   
2. import java.net.*;
   
3. class UploadPicDemo
   
4. {
   
5.         public static void main(String[] args) throws Exception
   
6.         {
   
7.                 Socket s=new Socket("127.0.0.1",10001);//创建客户端通信套接字，端口号为10001
   
8.                 File f=new File("D:\\Documents\\Pictures\\me.jpg");//把客户端选择的文件封装成file对象
   
9.                 //判断客户选择的文件是否合法
   
10.                 if (!f.exists()&&!f.isFile())
    
11.                 {
    
12.                         System.out.println("选择的文件不存在或不是文件，请重新选择");
    
13.                         return;
    
14.                 }
    
15.                 if (f.length()>1024*1024*2)
    
16.                 {
    
17.                         System.out.println("选择的文件太大");
    
18.                         return;
    
19.                 }
    
20.                 FileInputStream in=new FileInputStream(f);//创建文件流
    
21.                 OutputStream out=s.getOutputStream(); //获取套接字输出流
    
22.                
    
23.                 byte [] buf=new byte[1024*1024*2];
    
24.                 int len=0;
    
25.                 while ((len=in.read(buf))!=-1)
    
26.                 {
    
27.                         System.out.println(new Integer(len).toString());//获取文件的实际长度
    
28.                         out.write(buf,0,len);//向服务端输出数据
    
29.                 }
    
30.                 s.shutdownInput() ;//告诉服务端文件已经到了结尾
    
31.                 byte [] buff=new byte[1024];
    
32.                 InputStream br=s.getInputStream();
    
33.                 int num=br.read(buff);//获取服务端返回的信息
    
34.                 System.out.println(new String(buff,0,num));
    
35.                 in.close();
    
36.                 s.close();
    
37.         }
    
38. }
    

复制代码

客户端代码，读取本地的一张图片发送给服务端

1. import java.io.*;
   
2. import java.net.*;
   
3. class UploadPicServerDemo
   
4. {
   
5.         public static void main(String[] args) throws Exception
   
6.         {
   
7.                 ServerSocket ss=new ServerSocket(10001);//创建服务端通信套接字，侦听10001端口号
   
8. 
   
9.                         Socket s=ss.accept();//接收客户端套接字
   
10.                         System.out.println(s.getInetAddress().getHostName());
    
11.                         byte [] buf=new byte[1024*1024*2];//定义缓冲区
    
12.                         InputStream in=s.getInputStream();//获取客户端套接字输入流
    
13.                         FileOutputStream out =new FileOutputStream("server.jpg");
    
14.                         int len;
    
15.                         while ((len=in.read(buf))!=-1)//把客户端传过来的数据存到缓冲区里
    
16.                         {
    
17.                                 out.write(buf,0,len);//写出
    
18.                         }
    
19.                         System.out.println(new Integer(len).toString());
    
20.                         OutputStream bw=s.getOutputStream();
    
21.                         bw.write("上传成功".getBytes());
    
22.                         out.close();
    
23.                         s.close();
    
24.                         
    
25.                 }
    
26.         
    
27. }
    

复制代码

运行之后报了个图1的错，但是服务端的文件却创建了，大小和客户端上传的一样大，但是打开还原补了

import java.io.*;
import java.net.*;
class UploadPicServerDemo
{
        public static void main(String[] args) throws Exception
        {
                ServerSocket ss=new ServerSocket(10001);//创建服务端通信套接字，侦听10001端口号

                        Socket s=ss.accept();//接收客户端套接字
                        System.out.println(s.getInetAddress().getHostName());
                        byte [] buf=new byte[1024*1024*2];//定义缓冲区
                        InputStream in=s.getInputStream();//获取客户端套接字输入流
                        FileOutputStream out =new FileOutputStream("server.jpg");
                        int len;
                        while ((len=in.read(buf))!=-1)//把客户端传过来的数据存到缓冲区里
                        {
                                out.write(buf,0,len);//写出
                        }
                        System.out.println(new Integer(len).toString());   //这句代码貌似有问题~~~可以考虑去掉
                        OutputStream bw=s.getOutputStream();
                        bw.write("上传成功".getBytes());
                        out.close();
                        s.close();
                        
                }
        
}

       s.shutdownIntput() ;//告诉服务端文件已经到了结尾 这里写错了,应该是s.shutdownOutput() ;

31.                byte [] buff=new byte[1024];

32.                InputStream br=s.getInputStream();

33.                int num=br.read(buff);//获取服务端返回的信息

34.                System.out.println(new String(buff,0,num));

35.                in.close();

36.                s.close();