Socket套接字模拟客户端，服务端，实现文件上传

• 服务端

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerTest {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(10001);
        Socket socket = serverSocket.accept();
        InputStream is = socket.getInputStream();
        byte[] buf = new byte[1024];
        int len =0;
        while ((len=is.read(buf))!=-1){
            System.out.println(new String(buf,0,len));
        }
        OutputStream os = socket.getOutputStream();
        os.write("www.taobao.com".getBytes());
        socket.close();
        serverSocket.close();
    }
}

• 客户端

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class ClientTest {
    public static void main(String[] args) throws IOException {
        Socket s = new Socket("127.0.0.1",10001);
        OutputStream os = s.getOutputStream();
        os.write("淘宝官网".getBytes());
        s.shutdownOutput();

        InputStream is = s.getInputStream();
        byte[] buf = new byte[1024];
        int len =0;
        while ((len=is.read(buf))!=-1){
            System.out.println(new String(buf,0,len));
        }
        s.close();
    }
}

"C:\Program Files\Java\jdk1.8.0_131\bin\java.exe" "-javaagent:K:\Intelli IDEA\IntelliJ IDEA 2020.1.1\lib\idea_rt.jar=8314:K:\Intelli IDEA\IntelliJ IDEA 2020.1.1\bin" -Dfile.encoding=UTF-8 -classpath "C:\Program Files\Java\jdk1.8.0_131\jre\lib\charsets.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\deploy.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\access-bridge-64.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\cldrdata.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\dnsns.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\jaccess.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\jfxrt.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\localedata.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\nashorn.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\sunec.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\sunjce_provider.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\sunmscapi.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\sunpkcs11.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\zipfs.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\javaws.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\jce.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\jfr.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\jfxswt.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\jsse.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\management-agent.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\plugin.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\resources.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\rt.jar;C:\Program Files\Apache Software Foundation\Tomcat 9.0\lib\servlet-api.jar;C:\Users\djy\IdeaProjects\TCPTest\out\production\TCPTest" ClientTest
www.taobao.com

Process finished with exit code 0

文件上传实现

客户端

/*
 * TCP的客户端 带反馈信息的文件的上传实现
 *  数据源：文件，FileReader。
 * 	目的地：通道，getOutputStream,所以也需要转为字符流，OutputStreamWriter,然后需要换行，所以用BufferedWriter。
 */
public class ClientDemo {
    public static void main(String[] args) throws Exception{
        // 创建客户端套接字对象
        Socket s = new Socket("127.0.0.1", 16888);
        //创建输入流关联数据源文件
        BufferedReader br = new BufferedReader(new FileReader("day11\\bw.txt"));//day11表示模块名
        //创建输出流关联通道
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        //读写数据
        String line=null;
        //这里是读取数据，读取到文件末尾，有结束标识null，读取完毕循环结束
        while((line=br.readLine())!=null)
        {
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        //关闭资源
        br.close();//由于输入流直接关联的是文件，所以要单独关闭资源
        s.close();
    }
}

服务器端

/*
 * TCP服务端代码：
 * 分析：
 * 	数据源：通道，getInputStream，需要转为字符流。
 * 	目的地：工程模块下面的一个文件 copy.txt
 */
public class ServerDemo {
    public static void main(String[] args) throws Exception{
        // 创建服务端套接字对象
        ServerSocket ss = new ServerSocket(16888);
        // 侦听并获取客户端套接字对象
        Socket s = ss.accept();
        // 获取输入流，关联通道
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        // 创建输出流关联目的地文件
        BufferedWriter bw = new BufferedWriter(new FileWriter("day11\\copy.txt"));
        // 读取数据
        String line = null;
        while ((line = br.readLine()) != null) {
            // 将从客户端获取的数据写到目的地文件中
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        // 关闭资源
        s.close();
        ss.close();
        bw.close();//由于输出流直接关联的是文件，所以要单独关闭资源
    }
}