TCP网络通信编程(字符流)-Socket应用

Posted 二师弟&

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了TCP网络通信编程(字符流)-Socket应用相关的知识,希望对你有一定的参考价值。

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("客户端退出!");

    



输出结果:

服务端显示结果:

客户端显示结果:

以上是关于TCP网络通信编程(字符流)-Socket应用的主要内容,如果未能解决你的问题,请参考以下文章

TCP编程(字节读写)- Socket 网络应用

TCP编程(字节读写)- Socket 网络应用

通过 Socket 实现 TCP 编程

基于 TCP/IP 协议的网络编程

63 网络编程——TCP编程

java 网络编程---TCP的基础级示例