Java中的TCP通信（网络编程 二）

简介

TCP（传输控制协议）是一种在计算机网络中常用的协议，它提供了可靠的、面向连接的通信（协议信息链接：TCP协议）。在Java中，我们可以使用Socket和ServerSocket类来实现TCP通信。

Java TCP通信关键方法

客户端套接字(Socket)方法：

- Socket(String host, int port)：使用指定的主机和端口创建一个客户端套接字。

- Socket(InetAddress address,int port)：创建流套接字并将其连接到指定IP指定端口号

- void connect(SocketAddress endpoint)：连接到指定的远程套接字地址。

- void setSoTimeout(int timeout)：设置套接字的读取超时时间。

- boolean isConnected()：检查套接字是否已连接。

- void close()：关闭套接字连接。

服务器套接字(ServerSocket)方法：

- ServerSocket(int port)：创建一个服务器套接字，绑定到指定的端口。

- Socket accept()：侦听客户端的连接请求，并返回与客户端连接的套接字。

- void setSoTimeout(int timeout)：设置服务器套接字的超时时间。

- boolean isBound()：检查服务器套接字是否已绑定到特定端口。

- void close()：关闭服务器套接字。

输入输出流方法（数据处理）：

- InputStream getInputStream()：返回与套接字关联的输入流。

- OutputStream getOutputStream()：返回与套接字关联的输出流。

- void write(byte[] b)：将字节数组中的数据写入输出流。

- int read(byte[] b)：从输入流中读取数据并存储到字节数组中。

- void flush()：刷新输出流，确保数据被发送。

- String readLine()：从输入流中读取一行数据。

- void writeBytes(String s)：将字符串以字节的形式写入输出流。

- void writeInt(int value)：将整数写入输出流。

- int readInt()：从输入流中读取整数。

- void writeObject(Object obj)：将对象写入输出流。

程序简单设计

客户端设计（后启动）

public class TCPClient {
    public static void main(String[] args) throws IOException {
        //创建嵌套字并连接服务端
        Socket socket=new Socket("127.0.0.1",10000);
        //获取嵌套字中的输出流，并发送数据
        OutputStream os = socket.getOutputStream();
        String message="hello tcp server";
        byte[] data=message.getBytes();
        //因为连接已经建立成功，直到往该连接(socket)的输出流里面写数据，服务端就能收到
        os.write(data,0,data.length);
 
        //获取嵌套字中的输入流，处理响应数据
        InputStream is = socket.getInputStream();
        byte[] buffer=new byte[1024];
        //堵塞当前进程，直到IO完成读取数据
        int length=is.read(buffer);
        String response=new String(buffer,0,length);
        System.out.println("服务端响应: "+response);
 
        //关闭连接
        socket.close();
    }
}

服务端设计（先启动）

public class TCPServer {
    public static void main(String[] args) throws IOException {
        //创建服务端嵌套字并监听指定端口
        ServerSocket serverSocket=new ServerSocket(10000);
        System.out.println("服务器已启动，等待客户端连接...");
 
        //监听客户端的链接(直接堵塞当前进程，知道完成与客户端的连接)
        Socket clientSocket = serverSocket.accept();
 
        //处理客户端请求
        System.out.println("客户端已连接");
        InputStream is = clientSocket.getInputStream();
        byte[] buffer=new byte[1024];
        int len=is.read(buffer);//读取缓存中的数据并返回数据长度
        String request=new String(buffer,0,len);
        System.out.println("客户端请求: "+request);
 
        //发送数据到客户端
        OutputStream os = clientSocket.getOutputStream();
        String message="Hello tcp Client";
        byte[] data = message.getBytes();
        os.write(data,0,data.length);
 
        //关闭连接
        clientSocket.close();
        serverSocket.close();
    }
}