A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© 刘德坤 中级黑马   /  2015-10-20 21:27  /  488 人查看  /  0 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

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

0 个回复

您需要登录后才可以回帖 登录 | 加入黑马