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();}
}