如何使用 TCP/IP 开发网络程序

关注

发布于: 4 小时前

摘要：进行 TCP 协议网络程序的编写，关键在于 ServerSocket 套接字的熟练使用，TCP 通信中所有的信息传输都是依托 ServerSocket 类的输入输出流进行的。

本文分享自华为云社区《Java利用TCP协议实现客户端与服务器通信【附通信源码】》，作者：灰小猿。

TCP 协议概念

我们知道 TCP 是可靠而非安全的网络协议。它可以保证数据在从一端送至另一端的时候可以准确的送达，并且抵达的数据的排列顺序和送出时的顺序是相同的。因此在进行 TCP 协议通信的时候，我们首先应该保证客户端和服务器之间的连接通畅。

而 TCP 协议程序的编写，仍然是依靠套接字 Socket 类来实现的，并且利用 TCP 协议进行通信的两个程序之间是有主次之分的，即一个是服务器的程序，另一个是客户端的程序。因此两者的功能和编写上也略有不同。如下图是服务器与客户端之间进行通信的示意图：

以上就是在 TCP 协议中客户端与服务器建立连接的过程示意图。而在这其中起到关键作用的就是服务器端套接字 ServerSocket 和客户端套接字 Socket。通过这两个套接字来建立服务器和客户端，从而利用其中的函数进行数据的通信。

在 ServerSocket 类中有很多需要注意的地方，接下来大灰狼和大家分享一下 ServerSocket 类的具体用法：

ServerSocket 类

ServerSocket 类存在于http://Java.net包中，表示服务器端的套接字，在使用时需要首先导入这个类，我们也知道 ServerSocket 类的主要功能就是通过指定的端口等待来自于网络中客户端的请求并且进行连接。

值得注意的是：服务器套接字一次只能与一个客户端套接字进行连接，因此如果存在多台客户端同时发送连接请求，则服务器套接字就会将请求的客户端存放到队列中去，然后从中取出一个套接字与服务器建立的套接字进行连接，但是服务器端能够容纳的客户端套接字也不是无限的，当请求连接的数量大于最大容纳量时，那么多出来的请求就会被拒接，一般来说队列的默认大小是 50。

ServerSocket 类的构造方法通常会抛出 IOException 异常，具体有以下几种形式：

ServerSocket()：创建非绑定服务器套接字
ServerSocket(inr port)：创建绑定到特定端口的服务器套接字
ServerSocket(int port, int backlog)：利用指定的 backlog 创建服务器套接字，并将其绑定到指定的服务器端口上，
ServerSocket(int port, int backlog, InetAddress bindAddress)：使用指定的端口，侦听 backlog 和要绑定到本地的 IP 地址创建服务器。这种情况适用于计算机上有多个网卡和多个 IP 地址的情况，用户可以明确的规定 ServerSocket 在哪块网卡或哪个 IP 地址上等待用户的连接请求。

以下是 ServerSocket 类中一些常用的方法：

了解了 ServerSocket 类的基本方法之后，就是如何进行客户端和服务器进行连接的问题了。

在服务器端我们可以调用 ServerSocket 类的 accpet()方法与请求连接的客户机建立连接，这时会返回一个和客户端相连接的 Socket 对象，这个时候其实已经连接成功了，使用 getInetAddress()方法就可以获取到进行请求的客户机的 IP 地址。

对于如何进行客户端和服务器端数据的通信，就要用到数据的输入流和输出流了，服务器端的 Socket 对象使用 getOutputStream()方法获取到的输出流，将指向客户端的 Socket 对象使用 getInputStream()方法获取到的输入流。由此就实现在服务器向客户端发送数据的一个过程，同样的道理，客户端端的 Socket 对象使用 getOutputStream()方法获取到的输出流，将指向服务器端的 Socket 对象使用 getInputStream()方法获取到的输入流。从而实现由客户端向服务器发送数据的过程。

注意：accpet()方法会阻塞线程的继续执行，如果在对应的接口没有收到客户端的呼叫，则程序会停留在此处，直到获取到客户端的呼叫才会继续向下执行，但是如果服务器没有收到来自客户端的呼叫请求，并且 accpet()方法没有发生阻塞，那么通常情况下就是程序出了问题，一般来说可能是使用了一个已经被其他程序占用了的端口号，导致 ServerSocket 没有绑定成功！遇到这种情况可以尝试更换新的端口号。

了解了 TCP 协议的通信过程，接下来就是进行 TCP 通信程序的书写啦！

在网络通信中，如果只要求客户机向服务器发送信息，不要求服务器向客户端反馈信息的行为称为“单向通信”，要求客户机和服务器双方互相通信的过程称为“双向通信”，双向通信只不过是比单向通信多了一个服务器向客户端发送消息的过程

接下来分别是服务器端和客户端程序的编写：

服务器端程序

package server_1;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.net.ServerSocket;import java.net.Socket;public class MyTcp {
	private ServerSocket server;	//设置服务器套接字	private Socket client;		//设置客户端套接字		//连接客户端函数	void getServer()	{		try {			server = new ServerSocket(1100);	//建立服务器 端口为1100			System.out.println("服务器建立成功！正在等待连接......");			client = server.accept();	//调用服务器函数对客户端进行连接						System.out.println("客户端连接成功！ip为：" + client.getInetAddress());	//返回客户端IP					getClientMessage();		//调用信息传输和接收函数					} catch (IOException e) {			// TODO Auto-generated catch block			e.printStackTrace();		}			}		void getClientMessage()	{		try {			while (true) {				InputStream is = client.getInputStream();	//获取到客户端的输入流				byte[] b = new byte[1024];	//定义字节数组				int len = is.read(b);	//由于信息的传输是以二进制的形式，所以要以二进制的形式进行数据的读取				String data = new String(b, 0,len);				System.out.println("客户端发来消息：" + data);								//定义发送给客户端的输出流				OutputStream put = client.getOutputStream();				String putText = "我已经收到！欢迎你！";				put.write(putText.getBytes());	//将输出流信息以二进制的形式进行写入			}		} catch (Exception e) {			// TODO: handle exception		}		try {			//判断客户端字节流不是空，则关闭客户端			if (server != null) {				server.close();			}		} catch (Exception e) {			// TODO: handle exception		}	}		public static void main(String[] args) {		// TODO Auto-generated method stub		MyTcp myTcp = new MyTcp();	//调用该类生成对象		myTcp.getServer();	//调用方法	}
}

复制代码

客户端程序

package client_1;
import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.io.PrintWriter;import java.net.Socket;import java.net.UnknownHostException;
public class MyClient {	private Socket client;	//定义客户端套接字		//建立客户端函数	void getClient()	{		try {			client = new Socket("127.0.0.1", 1100);	//建立客户端，使用的IP为127.0.0.1，端口和服务器一样为1100			System.out.println("客户端建立成功！");						setClientMessage();		//调用客户端信息写入函数		} catch (UnknownHostException e) {			// TODO Auto-generated catch block			e.printStackTrace();		} catch (IOException e) {			// TODO Auto-generated catch block			e.printStackTrace();		}	}		//定义客户端信息写入函数	void setClientMessage()	{		try {					OutputStream pt = client.getOutputStream();		//建立客户端信息输出流			String printText = "服务器你好！我是客户端！";				pt.write(printText.getBytes());		//以二进制的形式将信息进行输出						InputStream input = client.getInputStream();	//建立客户端信息输入流			byte [] b = new byte[1024];		//定义字节数组			int len = input.read(b);	//读取接收的二进制信息流			String data = new String(b, 0,len);			System.out.println("收到服务器消息：" + data);					} catch (IOException e) {			// TODO Auto-generated catch block			e.printStackTrace();		}
		try {			//如果客户端信息流不为空，则说明客户端已经建立连接，关闭客户端			if (client != null) {				client.close();			}		} catch (Exception e) {			// TODO: handle exception		}	}		public static void main(String[] args) {		// TODO Auto-generated method stub		//生成客户端类对象		MyClient myClient  = new MyClient();		myClient.getClient();	}
}