黑马程序员技术交流社区

标题: Tcp 服务端多线程 [打印本页]
作者: fmi110    时间: 2015-10-7 17:19
标题: Tcp 服务端多线程
Tcp协议传输文件时，传输完成一定要记得关闭输出流     new Socket().shutdownOutput();
以便将文件结尾标志传至服务器端，让程序正常终止。
  1. import java.io.File;
  2. import java.io.FileInputStream;
  3. import java.io.FileOutputStream;
  4. import java.io.IOException;
  5. import java.io.InputStream;
  6. import java.io.OutputStream;
  7. import java.net.ServerSocket;
  8. import java.net.Socket;


  11. public class TcpDemo4 {

  13.         /**
  14.          * TCP协议服务端多线程技术
  15.          * @throws Exception
  16.          */
  17.         public static void main(String[] args) throws Exception {
  18.                 ServerSocket ss = new ServerSocket(10888);
  19.                 while(true){
  20.                         Socket s = new Socket();
  21.                         s = ss.accept();
  22.                         new Thread(new Upload(s)).start();
  23.                 }
  24.         }

  26. }
  27. class Client{
  28.         public static void main(String[] args) throws Exception, IOException {
  29.                 Socket s = new Socket("192.168.220.1",10888);
  30.                 File src = new File("F:\\深色壁纸\\1 (2).jpg");
  31.                 FileInputStream fin = new FileInputStream(src);
  32.                 byte[] buf = new byte[1024];
  33.                 int len = 0;
  34.                 OutputStream os = s.getOutputStream();
  35.                 System.out.println("客户端开始传输...");
  36.                 while ((len = fin.read(buf)) != -1) {
  37.                         os.write(buf, 0, len);
  38.                 }
  39.                 s.shutdownOutput();
  40.                 InputStream in = s.getInputStream();
  41.                 len = in.read(buf);
  42.                 System.out.println(new String(buf, 0, len));
  43.                 fin.close();
  44.                 s.close();
  45.         }
  46. }
  47. class Upload implements Runnable{
  48.         private Socket s;
  49.         private int count = 0;
  50.         public Upload(Socket s) {
  51.                 super();
  52.                 this.s = s;
  53.         }

  55.         @Override
  56.         public void run() {
  57.                 System.out.println("服务器启动");
  58.                 String ip = s.getInetAddress().getHostAddress();
  59.                 File dir = new File("f:\\tcp多线程");
  60.                 dir.mkdirs();
  61.                 File des = new File(dir,ip+".jpg");
  62.                 while (des.exists())
  63.                         des = new File(dir, ip + "(" + ++count + ")" + ".jpg");
  64.                 FileOutputStream fos = null;
  65.                 try {
  66.                          fos = new FileOutputStream(des);
  67.                         InputStream in = s.getInputStream();
  68.                         byte[] buf = new byte[1024];
  69.                         int len = 0;
  70.                         System.out.println("开始上传...");
  71.                         while ((len = in.read(buf)) != -1) {
  72.                                 fos.write(buf, 0, len);
  73.                         }
  74.                         System.out.println("done");
  75.                         OutputStream os = s.getOutputStream();
  76.                         os.write("上传成功".getBytes());
  77.                 } catch (Exception e) {
  78.                         // TODO Auto-generated catch block
  79.                         e.printStackTrace();
  80.                 }finally{
  81.                         if(null!=fos)
  82.                                 try {
  83.                                         fos.close();
  84.                                 } catch (IOException e) {
  85.                                         e.printStackTrace();
  86.                                 }
  87.                         try {
  88.                                 s.close();
  89.                         } catch (IOException e) {
  90.                                 e.printStackTrace();
  91.                         }
  92.                 }
  93.         }
  94. }
复制代码






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