TCP网络通信编程（字符流）-Socket应用

Posted 2023-02-15 二师弟&

TCP网络通信编程

应用案例（使用字符流）：
1.编写一个服务端和一个客户端
2.服务端在 9999 端口监听
3.客户端连接到服务端，发送 “hello,server”，并接收服务端发回消息“hello,client”,再退出
4.服务端接收到客户端发送的信息，输出信息；并发送“hello,client”,再退出
    

思路：
客户端：
1.Socket.getOutputStream()
2.将OutputStream -> Writer
3.这里需要使用转换流
OutputStreamWriter(字节流)

服务端：
要求使用字符流
1.socket.getInputStream()
2.将InputStream -> Reader
3.使用转换流 InputStreamReader()

设置写入结束标志：
writer.newLine()//换行符，注意需要使用readLine()
    

案例代码

服务端：

package com.zfy.socket;

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

/**
 * @author zfy
 * @version 1.0
 * @date 2022/12/9 10:28
 * @Description:服务器端(字符流)：接收到客户端发送的信息输出，并发送 “hello,client”，再退出
 */
@SuppressWarnings("all")
public class SocketTCP03Server 
    public static void main(String[] args) throws IOException 
        // 思路：
        // 1.在本机的9999的端口监听，等待连接
        //细节：要求在本机没有其他服务在监听 9999
        //细节：这个 ServerSocket 可以通过 accept() 返回多个Socket[多个客户端连接服务器的并发]
        ServerSocket serverSocket = new ServerSocket(9999);
        System.out.println("服务端在 9999 端口监听，等待连接......");

        // 2，当没有客户端连接9999端口时，程序会阻塞，等待连接
        //如果有客户端连接，则会返回Socket对象，程序继续
        Socket socket = serverSocket.accept();
        System.out.println("socket = " + socket.getClass());

        // 3.通过socket.getInputStream()读取客户端写入数据通道的数据，显示
        InputStream inputStream = socket.getInputStream();

        //4.IO读取.使用字符流,使用InputStreamReader()转换流 将 inputStream 转成字符流
        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
        String s = bufferedReader.readLine();
        System.out.println(s);

        // 5.获取socket相关联的输出流
        OutputStream outputStream = socket.getOutputStream();
        // 使用字符输出流的方式回复消息
        BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream));
        bufferedWriter.write("hello client 字符流");
        // 插入一个换行符，表示回复内容的结束
        bufferedWriter.newLine();
        // 注意手动flush
        bufferedWriter.flush();
        // 6.设置结束标记
        socket.shutdownOutput();

        // 7.关闭流和socket
        bufferedWriter.close();
        bufferedReader.close();
        socket.close();
        serverSocket.close();

    

客户端：

package com.zfy.socket;

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

/**
 * @author zfy
 * @version 1.0
 * @date 2022/12/9 10:38
 * @Description: 客户端:连接服务端（字符流），发送 “hello,server”，并接收服务端发回的 “hello,client”，再退出
 */
@SuppressWarnings("all")
public class SocketTCP03Client 
    public static void main(String[] args) throws IOException 
        // 思路：
        // 1.连接服务端（ip，端口）
        //解读：连接本机的 9999 端口，如果连接成功，返回socket对象
        Socket socket = new Socket(InetAddress.getLocalHost(),9999);
        System.out.println("客户端socket返回= " + socket);

        // 2.连接上后，生成Socket，通过Socket.getOutputStream()
        //得到和socket对象关联的输出流对象
        OutputStream outputStream = socket.getOutputStream();

        // 3.通过输出流，写入数据到数据通道。使用字符流
        BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(outputStream));
        bufferedWriter.write("hello,server 字符流");
        //插入一个换行符，表示写入的内容结束，注意：要求对方使用readLine()
        bufferedWriter.newLine();
        //如果使用的字符流，需要手动刷新，否则数据不会写入数据通道
        bufferedWriter.flush();

        // 4.获取和socket相关联的输入流，读取数据（字符）并显示
        InputStream inputStream = socket.getInputStream();
        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
        String s = bufferedReader.readLine();
        System.out.println(s);

        // 5.关闭流对象和socket，必须关闭
        bufferedReader.close();
        bufferedWriter.close();
        socket.close();
        System.out.println("客户端退出！");

    

输出结果：

服务端显示结果：

客户端显示结果：