黑马程序员技术交流社区

标题: 【黑马云青年 胡浩】关于服务器使用多线程技术同时处理.... [打印本页]
作者: 胡浩    时间: 2013-6-2 15:52
标题: 【黑马云青年 胡浩】关于服务器使用多线程技术同时处理....
本帖最后由 胡浩 于 2013-6-2 15:55 编辑

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

  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;

  10. public class UploadTask implements Runnable {

  12.         private static final int SIZE = 1024*1024*2;
  13.         private Socket s;

  15.         public  UploadTask(Socket s) {
  16.                 this.s = s;
  17.         }

  19.         @Override
  20.         public void run() {

  22.                 int count = 0;
  23.                 String ip = s.getInetAddress().getHostAddress();
  24.                 System.out.println( ip + ".....connected");
  25.                
  26.                 try{

  28.                 // 读取客户端发来的数据。
  29.                 InputStream in = s.getInputStream();

  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);

  45.                 byte[] buf = new byte[1024];

  47.                 int len = 0;

  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.                 }

  68.                 // 获取socket输出流，将上传成功字样发给客户端。
  69.                 OutputStream out = s.getOutputStream();
  70.                 out.write("上传成功".getBytes());

  72.                 fos.close();
  73.                 s.close();
  74.                 }catch(IOException e){
  75.                         
  76.                 }

  78.         }

  80. }
复制代码
这里是服务端。
  1. package cn.itcast.net.p1.uploadpic;

  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;

  11. public class UploadPicServer {

  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.         }

  36. }
复制代码
这里是客户端
  1. package cn.itcast.net.p1.uploadpic;

  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;

  10. public class UploadPicClient {

  12.         /**
  13.          * @param args
  14.          * @throws IOException
  15.          * @throws UnknownHostException
  16.          */
  17.         public static void main(String[] args) throws UnknownHostException, IOException {

  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.         }

  57. }
复制代码
代码贴的有点多，请原谅！！！





欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2