4TCP编程

发表于 更新于 分类于 Waline： 本文字数： 6.3k 阅读时长 ≈ 6 分钟

按照前面的介绍，网络通讯的方式有TCP和UDP两种，其中TCP方式的网络通讯是指在通讯的过程中保持连接，有点类似于打电话，只需要拨打一次号码(建立一次网络连接)，就可以多次通话(多次传输数据)。这样方式在实际的网络编程中，由于传输可靠，类似于打电话，如果甲给乙打电话，乙说没有听清楚让甲重复一遍，直到乙听清楚为止，实际的网络传输也是这样，如果发送的一方发送的数据接收方觉得有问题，则网络底层会自动要求发送方重发，直到接收方收到为止。

在Java语言中，对于TCP方式的网络编程提供了良好的支持，在实际实现时，以java.net.Socket类代表客户端连接，以java.net.ServerSocket类代表服务器端连接。在进行网络编程时，底层网络通讯的细节已经实现了比较高的封装，所以在程序员实际编程时，只需要指定IP地址和端口号码就可以建立连接了。正是由于这种高度的封装，一方面简化了Java语言网络编程的难度，另外也使得使用Java语言进行网络编程时无法深入到网络的底层，所以使用Java语言进行网络底层系统编程很困难，具体点说，Java语言无法实现底层的网络嗅探以及获得IP包结构等信息。但是由于Java语言的网络编程比较简单，所以还是获得了广泛的使用。

在使用TCP方式进行网络编程时，需要按照前面介绍的网络编程的步骤进行，下面分别介绍一下在Java语言中客户端和服务器端的实现步骤。

客户端网络编程

第一步：建立连接

在客户端网络编程中，首先需要建立连接，在Java API中以java.net.Socket类的对象代表网络连接，所以建立客户端网络连接，也就是创建Socket类型的对象，该对象代表网络连接，示例如下：

1
2
Socket socket1 = new Socket(“192.168.1.103”,10000);
Socket socket2 = new Socket(“github.com”,80);

上面的代码中，socket1实现的是连接到IP地址是192.168.1.103的计算机的10000号端口，而socket2实现的是连接到域名是www.sohu.com的计算机的80号端口，至于底层网络如何实现建立连接，对于程序员来说是完全透明的。如果建立连接时，本机网络不通，或服务器端程序未开启，则会抛出异常。

第二步: 交换数据

连接一旦建立，则完成了客户端编程的第一步，紧接着的步骤就是按照“请求-响应”模型进行网络数据交换，在Java语言中，数据传输功能由Java IO实现，也就是说只需要从连接中获得输入流和输出流即可，然后将需要发送的数据写入连接对象的输出流中，在发送完成以后从输入流中读取数据即可。示例代码如下：

1
2
OutputStream os = socket1.getOutputStream(); //获得输出流，用来想服务发送请求
InputStream is = socket1.getInputStream();     //获得输入流,用来读取服务器的响应

上面的代码中，分别从socket1这个连接对象获得了输出流和输入流对象，在整个网络编程中，后续的数据交换就变成了IO操作，也就是遵循“请求-响应”模型的规定，先向输出流中写入数据，这些数据会被系统发送出去，然后再从输入流中读取服务器端的反馈信息，这样就完成了一次数据交换过程，当然这个数据交换过程可以多次进行。

这里获得的只是最基本的输出流和输入流对象，还可以根据前面学习到的IO知识，使用流的嵌套将这些获得到的基本流对象转换成需要的装饰流对象，从而方便数据的操作。

第三步：关闭网络连接

最后当数据交换完成以后，关闭网络连接，释放网络连接占用的系统端口和内存等资源，完成网络操作，示例代码如下：

1
socket1.close();

实例

这就是最基本的网络编程功能介绍。下面是一个简单的网络客户端程序示例，该程序的作用是向服务器端发送一个字符串“Hello”，并将服务器端的响应显示到控制台，数据交换只进行一次，当数据交换进行完成以后关闭网络连接，程序结束。实现的代码如下：
实例：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
package tcp;

import java.io.*;
import java.net.*;

/**
 * 简单的Socket客户端
 * 功能为：发送字符串“Hello”到服务器端，并打印出服务器端的响应
 */
public class SimpleSocketClient
{
    public static void main(String[] args)
    {
        Socket socket = null;
        InputStream is = null;
        OutputStream os = null;
        // 服务器端IP地址
        String serverIP = "127.0.0.1";
        // 服务器端端口号
        int serverPort = 10000;
        // 发送内容
        String request = "Hello";
        try
        {
            // 第一步:建立连接
            socket = new Socket(serverIP, serverPort);
            
            // 第二步:交换数据
            // 获取输出流
            os = socket.getOutputStream();
            // 发送数据给服务器
            os.write(request.getBytes());
            // 接收服务器的数据
            is = socket.getInputStream();
            byte[] response = new byte[1024];
            int size = is.read(response);
            // 输出反馈数据
            System.out.println("服务器响应：" + new String(response, 0, size));
        } catch (Exception e)
        {
            e.printStackTrace(); // 打印异常信息
        } finally
        {
            if(os!=null)
            {
                try
                {
                    os.close();
                } catch (IOException e)
                {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            if(is!=null)
            {
                try
                {
                    is.close();
                } catch (IOException e)
                {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            if(socket!=null)
            {
                try
                {
                    socket.close();
                } catch (IOException e)
                {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }
}

在该示例代码中建立了一个连接到IP地址为127.0.0.1，端口号码为10000的TCP类型的网络连接，然后获得连接的输出流对象，将需要发送的字符串“Hello”转换为byte数组写入到输出流中，由系统自动完成将输出流中的数据发送出去，如果需要强制发送，可以调用输出流对象中的flush方法实现。在数据发送出去以后，从连接对象的输入流中读取服务器端的反馈信息，读取时可以使用IO中的各种读取方法进行读取，这里使用最简单的方法进行读取，从输入流中读取到的内容就是服务器端的响应，并将读取到的内容在客户端的控制台进行输出，最后依次关闭打开的流对象和网络连接对象。

这是一个简单的功能示例，在该示例中演示了TCP类型的网络客户端基本方法的使用，该代码只起演示目的，还无法达到实用的级别。

TCP客户端编程

介绍完一个简单的客户端编程的示例，下面接着介绍一下TCP类型的服务器端的编写。首先需要说明的是，客户端的步骤和服务器端的编写步骤不同，所以在学习服务器端编程时注意不要和客户端混淆起来。

第一步：监听窗口

在服务器端程序编程中，由于服务器端实现的是被动等待连接，所以服务器端编程的第一个步骤是监听端口，也就是监听是否有客户端连接到达。实现服务器端监听的代码为：

1
ServerSocket ss = new ServerSocket(10000);

该代码实现的功能是监听当前计算机的10000号端口，如果在执行该代码时，10000号端口已经被别的程序占用，那么将抛出异常。否则将实现监听。

第二步：建立连接

服务器端编程的第二个步骤是获得连接。该步骤的作用是当有客户端连接到达时，建立一个和客户端连接对应的Socket连 接对象，从而释放客户端连接对于服务器端端口的占用。实现功能就像公司的前台一样，当一个客户到达公司时，会告诉前台我找某某某，然后前台就通知某某某， 然后就可以继续接待其它客户了。通过获得连接，使得客户端的连接在服务器端获得了保持，另外使得服务器端的端口释放出来，可以继续等待其它的客户端连接。 实现获得连接的代码是：

1
Socket socket = ss.accept();

该代码实现的功能是获得当前连接到服务器端的客户端连接。需要说明的是**accept和IO部分介绍的read方法一样，都是一个阻塞方法，也就是当无连接时，该方法将阻塞程序的执行，直到连接到达时才执行该行代码。**另外获得的连接会在服务器端的该端口注册，这样以后就可以通过在服务器端的注册信息直接通信，而注册以后服务器端的端口就被释放出来，又可以继续接受其它的连接了。

第三步：交换数据

连接获得以后，后续的编程就和客户端的网络编程类似了，这里获得的Socket类型的连接就和客户端的网络连接一样了，只是服务器端需要首先读取发送过来的数据，然后进行逻辑处理以后再发送给客户端，也就是交换数据的顺序和客户端交换数据的步骤刚好相反。这部分的内容和客户端很类似，所以就不重复了，如果还不熟悉，可以参看下面的示例代码。

关闭连接

最后，在服务器端通信完成以后，关闭服务器端连接。实现的代码为：

1
ss.close();

这就是基本的TCP类型的服务器端编程步骤。下面以一个简单的echo服务实现为例子，介绍综合使用示例。echo的意思就是“回声”，**echo服务器端实现的功能就是将客户端发送的内容再原封不动的反馈给客户端。**实现的代码如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
package tcp;
import java.io.*;
import java.net.*;
/**
 * echo服务器 功能：将客户端发送的内容反馈给客户端
 */
public class SimpleSocketServer
{
    public static void main(String[] args)
    {
        ServerSocket serverSocket = null;
        Socket socket = null;
        OutputStream out = null;
        InputStream in = null;
        // 监听端口号
        int port = 10000;
        try
        {
            // 建立连接
            serverSocket = new ServerSocket(port);
            // 获得连接
            socket = serverSocket.accept();
            // 接收客户端发送内容
            in = socket.getInputStream();
            byte[] recive = new byte[1024];
            int size = in.read(recive);
            // 输出
            System.out.println("客户端发送内容为：" + new String(recive, 0, size));
            // 向客户端发送反馈内容
            out = socket.getOutputStream();
            out.write(recive, 0, size);
        } catch (Exception e)
        {
            e.printStackTrace();
        } finally
        {
            try
            {
                // 关闭流和连接
                out.close();
                in.close();
                socket.close();
                serverSocket.close();
            } catch (Exception e)
            {
            }
        }
    }
}

在该示例代码中建立了一个监听当前计算机10000号端口的服务器端Socket连接，然后获得客户端发送过来的连接，如果有连接到达时，读取连接中发送过来的内容，并将发送的内容在控制台进行输出，输出完成以后将客户端发送的内容再反馈给客户端。最后关闭流和连接对象，结束程序。

运行客户端和服务端 ###：

因为在IDE中只有一个控制台窗口，所以运行效果不明显，所以这里再cmd命令行中编译运行简单点。

  • 编译运行服务器
    在cmd中编译服务器
    1
    javac -d . SimpleSocketServer.java
    在cmd中运行服务器
    1
    java tcp.SimpleSocketServer
    此时，服务器端将阻塞，等待客户端的连接。
    服务器等待客户端的连接
  • 编译运行客户端
    在cmd中编译客户端
    1
    javac -d . SimpleSocketClient.java
    在cmd中运行客户端
    1
    java tcp.SimpleSocketClient
    编译运行客户端
    运行结果：

这样，就以一个很简单的示例演示了TCP类型的网络编程在Java语言中的基本实现，这个示例只是演示了网络编程的基本步骤以及各个功能方法的基本使用，只是为网络编程打下了一个基础，下面将就几个问题来深入介绍网络编程深层次的一些知识。
为了一步一步的掌握网络编程，下面再研究网络编程中的两个基本问题，通过解决这两个问题将对网络编程的认识深入一层。

原文链接: 4TCP编程