[网络协议]2-4网络编程-TCP通信练习

1.练习1：

• 客户端：发送数据，接收服务器反馈
• 服务器：接收数据，给出反馈

代码：

• 客户端

package Study12;

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


/*客户端：发送数据，接收服务器反馈*/
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //创建客户端Socket对象(Socket)
        Socket s = new Socket("10.6.9.0",10086);
        //获取输出流，写数据
        OutputStream ops = s.getOutputStream();
        ops.write("Hello,java,我来啦".getBytes());
        //接收服务器反馈
        InputStream is = s.getInputStream();
        byte[]bys = new byte[1024];
        int len = is.read(bys);
        String data = new String(bys,0,len);
        System.out.println("客户端："+data);

        //释放资源
        s.close();
    }
}

• 服务器端

package Study12;

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

/*服务器：接收数据，给出反馈*/
public class ServerDemo {
    public static void main(String[] args) throws IOException {
        //创建服务器端的`Socket`对象(`ServerSocket`)
        ServerSocket ss = new ServerSocket(10086);
        //监听客户端连接，返回一个Socket对象
        Socket sa = ss.accept();
        //获取输入流，读数据，并把数据显示在控制台
        InputStream is = sa.getInputStream();
        byte[] bys = new byte[1024];
        int len = is.read(bys);
        String data = new String(bys,0,len);
        System.out.println("服务器："+data);
        //给出反馈
        OutputStream os = sa.getOutputStream();
        os.write("接收到啦".getBytes());
        //释放资源
        sa.close();
        ss.close();
    }
}

2.练习2

• 客户端：数据来自于键盘录入，直到录入的数据是886，发送数据结束
• 服务器：接收到的数据在控制台输出

代码：

• 客户端

package Study13;

import java.io.*;
import java.net.Socket;


/*客户端：数据来自于键盘录入，直到录入的数据是886，发送数据结束*/
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //创建客户端Socket对象(Socket)
        Socket s = new Socket("10.6.9.0", 10087);
        //数据来自于键盘录入，直到录入的数据是886，发送数据结束
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        //封装输出流对象
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while ((line= br.readLine())!=null){
            if ("886".equals(line)){
                break;
            }
            //获取输入流对象
//            OutputStream os = s.getOutputStream();
//            os.write(line.getBytes());
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        //释放资源
        s.close();
    }
}

• 服务器端

package Study13;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

/*服务器：接收到的数据在控制台输出*/
public class ServerDemo {
    public static void main(String[] args) throws IOException {
       //创建服务器Socket对象
        ServerSocket ss = new ServerSocket(10087);

        //监听客户端连接，返回一个对应的Socket对象
        Socket s = ss.accept();

        //获取输入流
//        InputStream is = s.getInputStream();
//        InputStreamReader isr = new InputStreamReader(is);
//        BufferedReader br = new BufferedReader(isr);
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        String line;
        while ((line= br.readLine())!=null){
            System.out.println(line);
        }
        //释放资源
        ss.close();
    }
}

3.练习3

• 客户端：数据来自键盘录入，直到输入的数据是886，发送数据结束
• 服务器：接收到的数据写入文本文件

代码：

• 客户端：

package Study13;

import java.io.*;
import java.net.Socket;


/*客户端：数据来自于键盘录入，直到录入的数据是886，发送数据结束*/
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //创建客户端Socket对象(Socket)
        Socket s = new Socket("10.6.9.0", 10087);
        //数据来自于键盘录入，直到录入的数据是886，发送数据结束
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        //封装输出流对象
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while ((line= br.readLine())!=null){
            if ("886".equals(line)){
                break;
            }
            //获取输入流对象
//            OutputStream os = s.getOutputStream();
//            os.write(line.getBytes());
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        //释放资源
        s.close();
    }
}

• 服务器端

package Study13;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

/*服务器：接收到的数据写入文本文件*/
public class ServerDemo {
    public static void main(String[] args) throws IOException {
       //创建服务器Socket对象
        ServerSocket ss = new ServerSocket(10087);
        //监听客户端连接，返回一个对应的Socket对象
        Socket s = ss.accept();
        //接收数据
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //把数据写入文本文件
        BufferedWriter bw = new BufferedWriter(new FileWriter("Study\\tcp.txt"));
        String line;
        while ((line=br.readLine())!=null){
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        //释放资源
        bw.close();
        ss.close();
    }
}

4.练习4

• 客户端：数据来自于文本文件
• 服务器：接收到的数据写入文本文件

代码：

• 客户端

package Study13;

import java.io.*;
import java.net.Socket;


/*客户端：数据来自于文本文件*/
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //创建客户端Socket对象(Socket)
        Socket s = new Socket("10.6.9.0", 10087);
        //数据来自于文本文件
        BufferedReader br = new BufferedReader(new FileReader("Study\\tcp.txt"));
        //封装输出流对象
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while ((line= br.readLine())!=null){
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        //释放资源
        br.close();
        s.close();
    }
}

• 服务器端

package Study13;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

/*服务器：接收到的数据写入文本文件*/
public class ServerDemo {
    public static void main(String[] args) throws IOException {
       //创建服务器Socket对象
        ServerSocket ss = new ServerSocket(10087);
        //监听客户端连接，返回一个对应的Socket对象
        Socket s = ss.accept();
        //接收数据
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //把数据写入文本文件
        BufferedWriter bw = new BufferedWriter(new FileWriter("Study\\test.txt"));
        String line;
        while ((line=br.readLine())!=null){
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        //释放资源
        bw.close();
        ss.close();
    }
}

5.练习5

• 客户端：数据来自于文本文件，接收服务器反馈
• 服务器：接收到的数据写入文本文件，给出反馈

代码：

• 客户端

package Study13;

import java.io.*;
import java.net.Socket;


/*客户端：数据来自于文本文件，接收服务器反馈*/
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //创建客户端Socket对象(Socket)
        Socket s = new Socket("10.6.9.0", 10087);
        //数据来自于文本文件
        BufferedReader br = new BufferedReader(new FileReader("Study\\test.txt"));
        //封装输出流对象
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while ((line= br.readLine())!=null){
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
//        //自定义结束标记
//        bw.write("886");
//        bw.newLine();
//        bw.flush();
        //void shutdownOutput() 禁用此套接字的输出流。
        s.shutdownOutput();

        //接收反馈
        BufferedReader brClient = new BufferedReader(new InputStreamReader(s.getInputStream()));
        String data = brClient.readLine();
        System.out.println("服务器的反馈"+data);
        //释放资源
        br.close();
        s.close();
    }
}

• 服务器端

package Study13;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

/*服务器：接收到的数据写入文本文件，给出反馈*/
public class ServerDemo {
    public static void main(String[] args) throws IOException {
       //创建服务器Socket对象
        ServerSocket ss = new ServerSocket(10087);
        //监听客户端连接，返回一个对应的Socket对象
        Socket s = ss.accept();
        //接收数据
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //把数据写入文本文件
        BufferedWriter bw = new BufferedWriter(new FileWriter("Study\\tcp.txt"));
        String line;
        while ((line=br.readLine())!=null){//等待读取数据
//            if ("886".equals(line)){
//                break;
//            }
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        //给出反馈
        BufferedWriter bwServe = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        bwServe.write("文件上传成功");
        bwServe.newLine();
        bwServe.flush();
        //释放资源

        bw.close();
        ss.close();
    }
}

• 出现问题：程序一直等待
• 原因：读数据的方法时阻塞式的
• 解决办法：
  • 自定义结束标记------不够好
  • 使用shutdownOutput()方法（推荐）

6.练习6

• 客户端：数据来自于文本文件，接收服务器反馈
• 服务器：接收到的数据写入文本文件，给出反馈，代码用线程进行封装，为每一个客户端开启一个线程。

代码：

• 客户端

package Study13;

import java.io.*;
import java.net.Socket;


/*客户端：数据来自于键盘录入，直到录入的数据是886，发送数据结束*/
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //创建客户端Socket对象(Socket)
        Socket s = new Socket("10.6.9.0", 10087);
        //数据来自于文本文件
        BufferedReader br = new BufferedReader(new FileReader("Study\\MyThreadPriority.java"));
        //封装输出流对象
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line;
        while ((line= br.readLine())!=null){
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
//        //自定义结束标记
//        bw.write("886");
//        bw.newLine();
//        bw.flush();
        //void shutdownOutput() 禁用此套接字的输出流。
        s.shutdownOutput();

        //接收反馈
        BufferedReader brClient = new BufferedReader(new InputStreamReader(s.getInputStream()));
        String data = brClient.readLine();
        System.out.println("服务器的反馈"+data);
        //释放资源
        br.close();
        s.close();
    }
}

• 服务器

//ServerDemo类
package Study13;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

/*服务器：接收到的数据写入文本文件，给出反馈，代码用线程进行封装，为每一个客户端开启一个线程。*/
public class ServerDemo {
    public static void main(String[] args) throws IOException {
       //创建服务器Socket对象
        ServerSocket ss = new ServerSocket(10087);
        while (true) {
            //监听客户端连接，返回一个对应的Socket对象
            Socket s = ss.accept();
            //为每一个客户端开启一个线程
            new Thread(new ServerThread(s)).start();

        }
//        ss.close();
    }
}

//ServerThread类
package Study13;

import java.io.*;
import java.net.Socket;

public class ServerThread implements Runnable {
    private Socket s;
    public ServerThread(Socket s) {
        this.s = s;
    }

    @Override
    public void run() {
        //接收数据，写到文本文件
        try {
            BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
//            BufferedWriter bw = new BufferedWriter(new FileWriter("Study\\copy.java"));
            //解决名称冲突问题
            int count =0;
            File file = new File("Study\\copy["+count+"].java");
            while (file.exists()){
                count++;
                file = new File("Study\\copy["+count+"].java");
            }
            BufferedWriter bw = new BufferedWriter(new FileWriter(file));

            String line;
            while ((line=br.readLine())!=null){
                bw.write(line);
                bw.newLine();
                bw.flush();
            }
            //给出反馈
            BufferedWriter bwServer = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
            bwServer.write("文件上传成功");
            bwServer.newLine();
            bwServer.flush();
            //释放资源
            s.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}