java 26

TCP练习：

1、客户端键盘录入，服务器输出文本文件

　　客户端代码：

public class ClientDemo {
    public static void main(String[] args) throws IOException {

        // 创建socket对象
        Socket s = new Socket("172.19.12.233", 10010);

        // 创建键盘输入流,用转换流包装成字符流
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));

        // 把通道中的字节流用转换流包装成字符流
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
                s.getOutputStream()));
        
        //读取键盘输入的数据，并传输到服务器端
        String line = null;
        while((line = br.readLine()) != null){
            //设定个关闭键盘的命令
            if(line.equals("esc")){
                break;
            }
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        //释放资源
        s.close();
        
    }
}

　　服务器代码：

public class ServerDemo {
    public static void main(String[] args) throws IOException {

        // 创建ServerSocket对象，监听
        ServerSocket ss = new ServerSocket(10010);

        // 创建socket对象
        Socket s = ss.accept();

        // 把通道中的字节流包装成字符流
        BufferedReader br = new BufferedReader(new InputStreamReader(
                s.getInputStream()));

        // 封装文件目录
        BufferedWriter bw = new BufferedWriter(new FileWriter("TCP.txt"));

        // 把读取到的数据写入到文件中
        String line = null;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();
        }

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

    }
}

2、客户端文本文件，服务器输出到控制台

　　

　　客户端代码：

public class ClientDemo {

    public static void main(String[] args) throws IOException, IOException {

        // 创建socket传送对象
        Socket s = new Socket("172.19.12.233", 10010);

        // 封装文本文件，字符流读取里面的数据
        BufferedReader br = new BufferedReader(new FileReader("InetAddressDemo.java"));
        // 封装通道里的字节流为字符流
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
                s.getOutputStream()));

        // 把读取到的数据输出到服务器端
        String line = null;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        
        //释放资源
        s.close();
        br.close();
    }
}

　　　　服务器代码：

public class ServerDemo {
    public static void main(String[] args) throws IOException {

        // 创建ServerSocket对象，监听
        ServerSocket ss = new ServerSocket(10010);

        // 创建socket对象
        Socket s = ss.accept();

        // 把通道中的字节流包装成字符流
        BufferedReader br = new BufferedReader(new InputStreamReader(
                s.getInputStream()));

        // 接收客户端发来都数据
        String line = null;
        while ((line = br.readLine()) != null) {
            System.out.println(line);
        }

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

    }
}

3、客户端读取文本文件，服务器输出文本文件

　　（可用来上传文件）

若是上传文件，那么我上传文件完毕后，客户端就要获得一个反馈。

但是，只单单给服务器添加发送反馈，客户端添加接收反馈不行。

因为：

　　读取文本文件是可以以null作为结束信息的，但是呢，通道内是不能这样结束信息的。

　　所以，服务器根本就不知道读取结束了。而如果还想服务器给客户端反馈。所以，两者都在相互等待。

如何解决呢?

 　　A:在多写一条数据，告诉服务器，读取到这条数据说明传输就结束，服务器的接收也结束吧。

　　　　这样做可以解决问题，但是不好。因为你这个数据如果文件中刚好就存在，那么就提前结束了。

　　B:Socket对象提供了一种解决方案

　　　　　　public void shutdownOutput()：

　　　　　　禁用此套接字的输出流。对于 TCP 套接字，任何以前写入的数据都将被发送，并且后跟 TCP 的正常连接终止序列。

　　客户端的代码

public class ClientDemo {
    public static void main(String[] args) throws IOException {

        // 创建Socket对象
        Socket s = new Socket("172.19.12.233", 10010);

        // 封装文件目录
        BufferedReader br = new BufferedReader(new FileReader(
                "InetAddressDemo.java"));

        // 把通道内的字节流包装成字符流
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
                s.getOutputStream()));

        // 获取文件中的数据，并输出给服务器
        String line = null;
        while ((line = br.readLine()) != null) {

            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        
        //给服务器一个信号，上面的文本中的数据已经传递完毕
        s.shutdownOutput();
        
        // 接收反馈
        BufferedReader brr = new BufferedReader(new InputStreamReader(
                s.getInputStream()));

        // 获取反馈，并输出到控制台
        String line1 = null;
        while ((line1 = brr.readLine()) != null) {
            System.out.println(line1);
        }
        
        brr.close();
        s.close();
        br.close();

    }
}

　　服务器的代码：

public class ServerDemo {
    public static void main(String[] args) throws IOException {

        // 创建ServerSocket对象，监听
        ServerSocket ss = new ServerSocket(10010);

        // 创建socket对象
        Socket s = ss.accept();

        // 把通道内的字节流包装成字符流
        BufferedReader br = new BufferedReader(new InputStreamReader(
                s.getInputStream()));

        // 封装文件目录
        BufferedWriter bw = new BufferedWriter(new FileWriter("TCPto.txt"));

        // 获取数据，并输出到文件中
        String line = null;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();
        }

        // 给出反馈
        BufferedWriter bwr = new BufferedWriter(new OutputStreamWriter(
                s.getOutputStream()));
        bwr.write("你的文件上传成功！");
        bwr.newLine();
        bwr.flush();
        
        // 释放资源
        s.close();
        bw.close();
        bwr.close();
    }
}