黑马程序员技术交流社区

标题: 文件上传案例--解决同步，并发等问题， [打印本页]

---

作者: yesnowoshiqiang    时间: 2016-6-3 11:20
标题: 文件上传案例--解决同步，并发等问题，
package 黑马面试编程;
//=================================客户端========================
import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;

public class Client {
        // 、使用TCP协议写一个可以上传文件的服务器和客户端。
        // 两个类 客户端类，，，服务器类，，用字节输流控制，所有的东西都可以传了，
        public static void main(String[] args) throws IOException {
                Socket socket = new Socket(InetAddress.getLocalHost(), 8888); // 需要指定ip和端口
                // 向服务器的输出流
                OutputStream os = socket.getOutputStream();
                // 从电脑需要上传的文件的输入流
                BufferedInputStream bis = new BufferedInputStream(new FileInputStream(
                                "gjp.jpg"));
                // 边度边写
                int len = 0;
                byte[] b = new byte[1024 * 8];
                while ((len = bis.read(b)) != -1) {
                        os.write(b, 0, len);
                }
                bis.close();
                // 暂时关闭输出流，不然不知道什么时候输入完成 了
                socket.shutdownOutput();
                InputStream is = socket.getInputStream();
                // 边度边写
                int len1 = 0;
                byte[] b2 = new byte[1024 * 8];
                len1 = is.read(b2);
                String string = new String(b2, 0, len1);
                // 获取数据后将数据读出到控制台
                System.out.println(string);

                is.close();
                os.close();
                socket.close();

        }

}


//================服务器端================================

package 黑马面试编程;

import java.io.BufferedOutputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
        public static void main(String[] args) throws IOException {
//                服务器
                final ServerSocket ss = new ServerSocket(8888);
//                循环接收，，因为服务器不会停
//                解决并发问题----匿名内部类  开   线程
                new Thread(){
                        public void run() {
                               
                               
                                while(true){
                                       
                                        try {
                                                Socket accept = ss.accept();
                                               
                                                InputStream is = accept.getInputStream();
//                向服务器硬盘输出的输出流，。还是字节流
                                                BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(System.currentTimeMillis()+"aaa.jpg"));
//                边度边写
                                                int len=0;
                                                byte[] b=new byte[1024*8];
                                                while((len=is.read(b))!=-1){
                                                        bos.write(b, 0, len);
                                                }
                                               
//                输出一句话
//                关闭向服务器硬盘输出的输出流bos
                                                bos.close();
//                ----------------------------------------->转战客户端
//                向客户端输出一句话
//                建立输出流
                                                OutputStream os = accept.getOutputStream();
                                                PrintStream ps = new PrintStream(os);
                                                ps.print("上传成功");
                                               
                                                ps.close();
                                        } catch (FileNotFoundException e) {
                                                //
                                                throw new RuntimeException("找不到文件");
                                               
                                        } catch (IOException e) {
                                               
                                        throw new RuntimeException("输入输出流出错");
                                        }
                                }
                        };
                       
                }.start();
               
//                os.close();
//                accept.close();
//                ss.close();
//               
               
       
        }

}

---

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

黑马程序员IT技术论坛 X3.2