黑马程序员技术交流社区

标题: 分享代码 [打印本页]

---

作者: 刘德坤    时间: 2015-10-15 22:26
标题: 分享代码
package com.itheima;

import java.net.*;

import java.io.*;

/**
* 9、 使用TCP协议写一个可以上传文件的服务器和客户端。
*
* @author 张家洛
*                         思路：
*                                 1.网络编程与IO流相拼命;
*                                 2.客户端通过socket向其输出流中写入本地文件，用到FileInputStream读取文件，也可加上缓冲BufferedInputStream;
*                                 3.通过socket的输入流读取服务器端的反馈信息;
*                                 4.服务端通过socket从其输入流中读取文件，存入到服务器端，并返回文件复制情况信息;
*                                 5.关闭资源.
*/

public class Test9 {

        public static void main(String[] args) {

        }

}

// 客户端
class client {
        public static void main(String[] args) throws Exception {
                // 建立Socket服务
                Socket fileLoaderSocket = new Socket("127.0.0.1", 10005);
                // 从客户端本地读取文件,并写入socket的输出流中
                OutputStream out = fileLoaderSocket.getOutputStream();
                InputStream fileRead = new FileInputStream("D:\\Demo.mp3");

                byte[] buf = new byte[1024];
                int len = 0;
                while ((len = fileRead.read(buf)) != -1) {
                        out.write(buf, 0, len);
                }
                // 告诉服务端，文件已传输完毕
                fileLoaderSocket.shutdownOutput();

                // 获取从服务端反馈的信息
                BufferedReader in = new BufferedReader(new InputStreamReader(
                                fileLoaderSocket.getInputStream()));
                String serverBack = in.readLine();
                System.out.println(serverBack);

                // 资源关闭
                fileLoaderSocket.close();
                fileRead.close();
        }
}

// 服务端
class Server {
        public static void main(String[] args) throws Exception {
                // 建立服务端Socket
                ServerSocket ss = new ServerSocket(10005);
                // 接收客户端Socket
                Socket fileLoaderSocket = ss.accept();

                // 打印连接信息
                String ip = fileLoaderSocket.getInetAddress().getHostAddress();
                System.out.println(ip + "...conncected");

                // 接收文件，并保存
                InputStream in = fileLoaderSocket.getInputStream();
                OutputStream fileSave = new FileOutputStream("E:\\server.mp3");
                byte[] buf = new byte[1024];
                int len = 0;
                while ((len = in.read(buf)) != -1) {
                        fileSave.write(buf, 0, len);
                        fileSave.flush();
                }
                // 返回文件复制情况信息
                BufferedWriter out = new BufferedWriter(new OutputStreamWriter(
                                fileLoaderSocket.getOutputStream()));
                out.write("文件上传成功");
                out.flush();

                // 资源关闭
                ss.close();
                fileLoaderSocket.close();
                fileSave.close();
        }
}
       

---

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

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