下面的代码实现一个多个客户端往同一个服务端上传图片的功能，我的疑问是，服务端在使用serverSocket提供服务的时候必须要明确端口号,比如serverSocket ss=new serverSocket(10006);
然后在通过accept获取Socket对象。和指定的客户端进行交互，问题是每个客户端的端口号可能不一样，那么serverSocket ss=new serverSocket(10006)这样指定端口后不是只能为一个客户端服务了吗？
是吗，如何解决这个问题？
这里使用多线程封装了处理客户端请求的任务。

1. package cn.itcast.net.p1.uploadpic;
   
2. 
   
3. import java.io.File;
   
4. import java.io.FileOutputStream;
   
5. import java.io.IOException;
   
6. import java.io.InputStream;
   
7. import java.io.OutputStream;
   
8. import java.net.Socket;
   
9. 
   
10. public class UploadTask implements Runnable {
    
11. 
    
12.         private static final int SIZE = 1024*1024*2;
    
13.         private Socket s;
    
14. 
    
15.         public  UploadTask(Socket s) {
    
16.                 this.s = s;
    
17.         }
    
18. 
    
19.         @Override
    
20.         public void run() {
    
21. 
    
22.                 int count = 0;
    
23.                 String ip = s.getInetAddress().getHostAddress();
    
24.                 System.out.println( ip + ".....connected");
    
25.                
    
26.                 try{
    
27. 
    
28.                 // 读取客户端发来的数据。
    
29.                 InputStream in = s.getInputStream();
    
30. 
    
31.                 // 将读取到数据存储到一个文件中。
    
32.                 File dir = new File("c:\\pic");
    
33.                 if (!dir.exists()) {
    
34.                         dir.mkdirs();
    
35.                 }
    
36.                 File file = new File(dir, ip + ".jpg");
    
37.                 //如果文件已经存在于服务端
    
38.                 while(file.exists()){
    
39.                         file = new File(dir,ip+"("+(++count)+").jpg");
    
40.                 }
    
41.                
    
42.                
    
43.                 FileOutputStream fos = new FileOutputStream(file);
    
44. 
    
45.                 byte[] buf = new byte[1024];
    
46. 
    
47.                 int len = 0;
    
48. 
    
49.                 while ((len = in.read(buf)) != -1) {
    
50.                         
    
51.                         
    
52.                         
    
53.                         fos.write(buf, 0, len);
    
54.                         
    
55.                         if(file.length()>SIZE){
    
56.                                 System.out.println(ip+"文件体积过大");
    
57.                                 
    
58.                                 fos.close();
    
59.                                 s.close();
    
60.                                 
    
61.                                 
    
62.                                 System.out.println(ip+"...."+file.delete());
    
63.                                 
    
64.                                 return ;
    
65.                         }
    
66.                 }
    
67. 
    
68.                 // 获取socket输出流，将上传成功字样发给客户端。
    
69.                 OutputStream out = s.getOutputStream();
    
70.                 out.write("上传成功".getBytes());
    
71. 
    
72.                 fos.close();
    
73.                 s.close();
    
74.                 }catch(IOException e){
    
75.                         
    
76.                 }
    
77. 
    
78.         }
    
79. 
    
80. }
    

复制代码

这里是服务端。

1. package cn.itcast.net.p1.uploadpic;
   
2. 
   
3. import java.io.File;
   
4. import java.io.FileOutputStream;
   
5. import java.io.IOException;
   
6. import java.io.InputStream;
   
7. import java.io.OutputStream;
   
8. import java.net.ServerSocket;
   
9. import java.net.Socket;
   
10. 
    
11. public class UploadPicServer {
    
12. 
    
13.         /**
    
14.          * @param args
    
15.          * @throws IOException
    
16.          */
    
17.         public static void main(String[] args) throws IOException {
    
18.                         
    
19.                 //创建tcp的socket服务端。
    
20.                ServerSocket ss = new ServerSocket(10006);
    
21.                
    
22.                 while(true){
    
23.                         Socket s = ss.accept();                     
    
24.                         
    
25.                         new Thread(new UploadTask(s)).start();               
    
26.                         
    
27.                 }
    
28.                 //获取客户端。
    
29.                
    
30.                
    
31. //                ss.close();
    
32.                
    
33.                
    
34.         }
    
35. 
    
36. }
    

复制代码

这里是客户端

1. package cn.itcast.net.p1.uploadpic;
   
2. 
   
3. import java.io.FileInputStream;
   
4. import java.io.IOException;
   
5. import java.io.InputStream;
   
6. import java.io.OutputStream;
   
7. import java.net.Socket;
   
8. import java.net.UnknownHostException;
   
9. 
   
10. public class UploadPicClient {
    
11. 
    
12.         /**
    
13.          * @param args
    
14.          * @throws IOException
    
15.          * @throws UnknownHostException
    
16.          */
    
17.         public static void main(String[] args) throws UnknownHostException, IOException {
    
18. 
    
19.                
    
20.                 //1,创建客户端socket。
    
21.                 Socket s = new Socket("192.168.1.100",10006);
    
22.                
    
23.                 //2,读取客户端要上传的图片文件。
    
24.                 FileInputStream fis = new FileInputStream("c:\\0.bmp");
    
25.                
    
26.                 //3,获取socket输出流，将读到图片数据发送给服务端。
    
27.                 OutputStream out = s.getOutputStream();
    
28.                
    
29.                 byte[] buf = new byte[1024];
    
30.                
    
31.                 int len = 0;
    
32.                
    
33.                 while((len=fis.read(buf))!=-1){
    
34.                         out.write(buf,0,len);
    
35.                 }
    
36.                
    
37.                 //告诉服务端说：这边的数据发送完毕。让服务端停止读取。
    
38.                 s.shutdownOutput();
    
39.                
    
40.                
    
41.                 //读取服务端发回的内容。                 
    
42.                 InputStream in  = s.getInputStream();
    
43.                 byte[] bufIn = new byte[1024];
    
44.                
    
45.                 int lenIn = in.read(buf);
    
46.                 String text = new String(buf,0,lenIn);
    
47.                 System.out.println(text);
    
48.                
    
49.                 fis.close();
    
50.                 s.close();
    
51.                
    
52.                
    
53.                
    
54.                
    
55.         }
    
56. 
    
57. }
    

复制代码

代码贴的有点多，请原谅！！！

下面的代码实现一个多个客户端往同一个服务端上传图片的功能，我的疑问是，服务端在使用serverSocket提供服务的时候必须要明确端口号,比如serverSocket ss=new serverSocket(10006);
然后在通过accept获取Socket对象。和指定的客户端进行交互，问题是每个客户端的端口号可能不一样，那么serverSocket ss=new serverSocket(10006)这样指定端口后不是只能为一个客户端服务了吗？
是吗，如何解决这个问题？
这里使用多线程封装了处理客户端请求的任务。

1. package cn.itcast.net.p1.uploadpic;
   
2. 
   
3. import java.io.File;
   
4. import java.io.FileOutputStream;
   
5. import java.io.IOException;
   
6. import java.io.InputStream;
   
7. import java.io.OutputStream;
   
8. import java.net.Socket;
   
9. 
   
10. public class UploadTask implements Runnable {
    
11. 
    
12.         private static final int SIZE = 1024*1024*2;
    
13.         private Socket s;
    
14. 
    
15.         public  UploadTask(Socket s) {
    
16.                 this.s = s;
    
17.         }
    
18. 
    
19.         @Override
    
20.         public void run() {
    
21. 
    
22.                 int count = 0;
    
23.                 String ip = s.getInetAddress().getHostAddress();
    
24.                 System.out.println( ip + ".....connected");
    
25.                
    
26.                 try{
    
27. 
    
28.                 // 读取客户端发来的数据。
    
29.                 InputStream in = s.getInputStream();
    
30. 
    
31.                 // 将读取到数据存储到一个文件中。
    
32.                 File dir = new File("c:\\pic");
    
33.                 if (!dir.exists()) {
    
34.                         dir.mkdirs();
    
35.                 }
    
36.                 File file = new File(dir, ip + ".jpg");
    
37.                 //如果文件已经存在于服务端
    
38.                 while(file.exists()){
    
39.                         file = new File(dir,ip+"("+(++count)+").jpg");
    
40.                 }
    
41.                
    
42.                
    
43.                 FileOutputStream fos = new FileOutputStream(file);
    
44. 
    
45.                 byte[] buf = new byte[1024];
    
46. 
    
47.                 int len = 0;
    
48. 
    
49.                 while ((len = in.read(buf)) != -1) {
    
50.                         
    
51.                         
    
52.                         
    
53.                         fos.write(buf, 0, len);
    
54.                         
    
55.                         if(file.length()>SIZE){
    
56.                                 System.out.println(ip+"文件体积过大");
    
57.                                 
    
58.                                 fos.close();
    
59.                                 s.close();
    
60.                                 
    
61.                                 
    
62.                                 System.out.println(ip+"...."+file.delete());
    
63.                                 
    
64.                                 return ;
    
65.                         }
    
66.                 }
    
67. 
    
68.                 // 获取socket输出流，将上传成功字样发给客户端。
    
69.                 OutputStream out = s.getOutputStream();
    
70.                 out.write("上传成功".getBytes());
    
71. 
    
72.                 fos.close();
    
73.                 s.close();
    
74.                 }catch(IOException e){
    
75.                         
    
76.                 }
    
77. 
    
78.         }
    
79. 
    
80. }
    

复制代码

这里是服务端。

1. package cn.itcast.net.p1.uploadpic;
   
2. 
   
3. import java.io.File;
   
4. import java.io.FileOutputStream;
   
5. import java.io.IOException;
   
6. import java.io.InputStream;
   
7. import java.io.OutputStream;
   
8. import java.net.ServerSocket;
   
9. import java.net.Socket;
   
10. 
    
11. public class UploadPicServer {
    
12. 
    
13.         /**
    
14.          * @param args
    
15.          * @throws IOException
    
16.          */
    
17.         public static void main(String[] args) throws IOException {
    
18.                         
    
19.                 //创建tcp的socket服务端。
    
20.                ServerSocket ss = new ServerSocket(10006);
    
21.                
    
22.                 while(true){
    
23.                         Socket s = ss.accept();                     
    
24.                         
    
25.                         new Thread(new UploadTask(s)).start();               
    
26.                         
    
27.                 }
    
28.                 //获取客户端。
    
29.                
    
30.                
    
31. //                ss.close();
    
32.                
    
33.                
    
34.         }
    
35. 
    
36. }
    

复制代码

这里是客户端

1. package cn.itcast.net.p1.uploadpic;
   
2. 
   
3. import java.io.FileInputStream;
   
4. import java.io.IOException;
   
5. import java.io.InputStream;
   
6. import java.io.OutputStream;
   
7. import java.net.Socket;
   
8. import java.net.UnknownHostException;
   
9. 
   
10. public class UploadPicClient {
    
11. 
    
12.         /**
    
13.          * @param args
    
14.          * @throws IOException
    
15.          * @throws UnknownHostException
    
16.          */
    
17.         public static void main(String[] args) throws UnknownHostException, IOException {
    
18. 
    
19.                
    
20.                 //1,创建客户端socket。
    
21.                 Socket s = new Socket("192.168.1.100",10006);
    
22.                
    
23.                 //2,读取客户端要上传的图片文件。
    
24.                 FileInputStream fis = new FileInputStream("c:\\0.bmp");
    
25.                
    
26.                 //3,获取socket输出流，将读到图片数据发送给服务端。
    
27.                 OutputStream out = s.getOutputStream();
    
28.                
    
29.                 byte[] buf = new byte[1024];
    
30.                
    
31.                 int len = 0;
    
32.                
    
33.                 while((len=fis.read(buf))!=-1){
    
34.                         out.write(buf,0,len);
    
35.                 }
    
36.                
    
37.                 //告诉服务端说：这边的数据发送完毕。让服务端停止读取。
    
38.                 s.shutdownOutput();
    
39.                
    
40.                
    
41.                 //读取服务端发回的内容。                 
    
42.                 InputStream in  = s.getInputStream();
    
43.                 byte[] bufIn = new byte[1024];
    
44.                
    
45.                 int lenIn = in.read(buf);
    
46.                 String text = new String(buf,0,lenIn);
    
47.                 System.out.println(text);
    
48.                
    
49.                 fis.close();
    
50.                 s.close();
    
51.                
    
52.                
    
53.                
    
54.                
    
55.         }
    
56. 
    
57. }
    

复制代码

代码贴的有点多，请原谅！！！