Java高级编程-----网络编程

网络通信协议

通过计算机网络可以实现多台计算机连接,但是不同计算机的操作系统和硬件体系结构不同,为了提供通信支持,位于同一个网络中的计算机在进行连接和通信时必须要遵守一定的规则,这就好比在道路中行驶的汽车一定要遵守交通规则一样。在计算机网络中,这些连接和通信的规则被称为网络通信协议,它对数据的传输格式、传输速率、传输步骤等做了统一规定,通信双方必须同时遵守才能完成数据交互。
网络通信协议有很多种,目前应用最广泛的是TCP/IP协议(Transmission Control Protocol/Internet Protocol,传输控制协议/英特网互联协议)、UDP协议(User Datagram Protocol,用户数据报协议)、ICMP协议(Internet Control Message Protocol,Internet 控制报文协议)和其他一些协议的协议组。
在学习具体的内容之前,首先来了解一下TCP/IP 协议。TCP/IP(又称TCP/IP协议簇)是一组用于实现网络互连的通信协议,其名称来源于该协议簇中两个重要的协议(TCP协议和IP协议)。

基于TCP/IP的参考模型将协议分成四个层次。
在这里插入图片描述

CP/IP协议中的四层分别是链路层、网络层、传输层和应用层,每层分别负责不同的通信功能,接下来针对这四层进行详细地讲解。

  • 链路层:
    也称为网络接口层,该层负责监视数据在主机和网络之间的交互。事实上,TCP/IP本身并未定义该层的协议,而由参与互连的各网络使用自己的物理层和数据链路层协议与TCP/IP的网络互联层进行连接。(传出的数据基本上是0101的二进制数据)
  • 网络层:
    也称网络互联层,是整个TCP/IP协议的核心,它主要用于将传输的数据进行分组,将分组数据发送到目标计算机或者网络。
    (IP协议、ICMP协议等)
  • 传输层:
    主要使网络程序进行通信,在进行网络通信时,可以采用TCP协议,也可以采用UDP协议。(Java网络编程就是基于该层进行数据传输)
  • 应用层:
    主要负责应用程序的协议,如HTTP协议(浏览器)、FTP协议(文件)等。

IP地址和端口号

要想使网络中的计算机能够进行通信,必须为每台计算机指定一个标识号,通过这个标识号指定接收数据的计算机或者发送数据的计算机。在TCP/IP协议中,这个标识号就是IP地址,它可以唯一标识一台计算机。目前,IP地址广泛使用的版本是IPv4,它由4个字节大小的二进制数来表示,如:00001010000000000000000000000001。由于二进制形式表示的IP地址非常不便记忆和处理,因此通常会将IP地址写成十进制的形式,每个字节用一个十进制数字(0-255)表示,数字间用符号“.”分开,如 “10.0.0.1”。(常被称为点分十进制)

随着计算机网络规模的不断扩大,对IP地址的需求也越来越多,IPv4这种用4个字节表示的IP地址将面临使用枯竭的局面(2的32次方)。为解决此问题,IPv6 便应运而生。IPv6使用16个字节表示IP地址,它所拥有的地址容量约是IPv4的8×1028倍,达到2128个(算上全零的),这样就解决了网络地址资源数量不足的问题。

IP地址由两部分组成,即“网络地址.主机地址”的形式,其中网络部分表示其属于互联网的哪一个网络,是网络的地址编码,主机部分表示其属于该网络中的哪一台主机,是网络中一个主机的地址编码,二者是主从关系。

接下来通过一个图例描述IP地址和端口号的作用。
在这里插入图片描述

InetAddress

在Java中,提供了一个与IP地址相关的InetAddress类,该类用于封装一个IP地址,并提供了一系列与IP地址相关的方法,InetAddress类的一些常用方法如下表。
在这里插入图片描述
上表列举了InetAddress的五个常用方法。其中,前两个方法用于获得该类的实例对象,第一个方法用于获得表示指定主机的InetAddress对象,第二个方法用于获得表示本地的InetAddress对象。通过InetAddress对象便可获取指定主机名,IP地址等。
接下来通过一个案例来演示InetAddress常用方法的使用。

1 import java.net.InetAddress;
2 public class Example01 {
3  public static void main(String[] args) throws Exception {
4   InetAddress localAddress = InetAddress.getLocalHost();
5   InetAddress remoteAddress = InetAddress. getByName("www.itcast.cn");
6   System.out.println("本机的IP地址:" + localAddress.getHostAddress());
7   System.out.println("itcast的IP地址:" + remoteAddress.getHostAddress());
8   System.out.println("3秒是否可达:" + remoteAddress.isReachable(3000));
9   System.out.println("itcast的主机名为:" + remoteAddress.getHostName());
10	}
11 }

上述代码中,第4行代码获取本机的IP地址并打印,第5~6行代码获取主机名为“www.itcast.cn的IP”地址,第7行代码获取itcast的主机地址。第8行代码判断3秒是否可到达主机。第9行代码用于获取itcast的主机名。

UDP与TCP协议

协议是定义的通信规则,一般有TCP协议和UDP协议。通过TCP/IP结构,我们知道传输层的两个重要的高级协议分别是UDP和TCP,其中,UDP是User Datagram Protocol的简称,称为用户数据报协议;TCP是Transmission Control Protocol的简称,称为传输控制协议

UDP

UDP是无连接通信协议,即在数据传输时,数据的发送端和接收端不建立逻辑连接。简单来说,当一台计算机向另外一台计算机发送数据时,发送端不会确认接收端是否存在,就会发出数据,同样接收端在收到数据时,也不会向发送端反馈是否收到数据。由于使用UDP协议消耗资源小,通信效率高,所以通常都会用于音频、视频和普通数据的传输,例如视频会议使用UDP协议,因为这种情况即使偶尔丢失一两个数据包,也不会对接收结果产生太大影响。但是在使用UDP协议传送数据时,由于UDP的面向无连接性,不能保证数据的完整性,因此在传输重要数据时不建议使用UDP协议。

UDP的交互过程如下图
在这里插入图片描述

TCP

TCP协议是面向连接的通信协议,即在传输数据前先在发送端和接收端建立逻辑连接,然后再传输数据,它提供了两台计算机之间可靠无差错的数据传输。在TCP连接中必须要明确客户端与服务器端,由客户端向服务器端发出连接请求,每次连接的创建都需要经过“三次握手”。第一次握手,客户端向服务器端发出连接请求,等待服务器确认;第二次握手,服务器端向客户端回送一个响应,通知客户端收到了连接请求;第三次握手,客户端再次向服务器端发送确认信息,确认连接。

TCP连接的整个交互过程如下图:
在这里插入图片描述
由于TCP协议的面向连接特性,它可以保证传输数据的安全性,是一个被广泛采用的协议。例如,在下载文件时,如果数据接收不完整,将会导致文件数据丢失而不能被打开,因此,下载文件时必须采用TCP协议

UDP通信

前面介绍了UDP是一种面向无连接的协议,因此,在通信时发送端和接收端不用建立连接。UDP通信的过程就像是货运公司在两个码头间发送货物一样,在码头发送和接收货物时都需要使用集装箱来装载货物。UDP通信也是一样,发送和接收的数据也需要使用“集装箱”进行打包,为此Java提供了一个DatagramPacket类(封装数据)。然而运输货物只有“集装箱”是不够的,还需要有“码头”。同理,在程序中,要实现通信只有DatagramPacket数据包也是不行的,它也需要一个“码头”。为此,Java还提供了一个DatagramSocket类(发送数据/接收数据)。

通过DatagramPacket类和DatagramSocket类发送数据的过程如下图。
在这里插入图片描述

DatagramPacket

DatagramPacket类用于封装UDP通信中发送或者接收的数据。想要创建一个DatagramPacket对象,首先需要了解一下它的构造方法。在创建发送端和接收端的DatagramPacket对象时,使用的构造方法有所不同,接收端的构造方法只需要接收一个字节数组来存放接收到的数据,而发送端的构造方法不但要接收存放了发送数据的字节数组,还需要指定发送端IP地址和端口号。
DatagramPacket类用于封装UDP通信中发送或者接收的数据。想要创建一个DatagramPacket对象

  • DatagramPacket(byte[] buf,int length)
    使用该构造方法在创建DatagramPacket对象时,指定了封装数据的字节数组和数据的大小,没有指定IP地址和端口号。很明显,这样的对象只能用于接收端,不能用于发送端。因为发送端一定要明确指出数据的目的地(IP地址和端口号),而接收端不需要明确知道数据的来源,只需要接收到数据即可。

  • DatagramPacket(byte[] buf,int length,InetAddress addr,int port)
    使用该构造方法在创建DatagramPacket对象时,不仅指定了封装数据的字节数组和数据的大小,还指定了数据包的目标IP地址(addr)和端口号(port)。该对象通常用于发送端,因为在发送数据时必须指定接收端的IP地址和端口号,就好像发送货物的集装箱上面必须标明接收人的地址一样。

  • DatagramPacket(byte[] buf,int offset,int length)
    该构造方法与第一个构造方法类似,同样用于接收端,只不过在第一个构造方法的基础上,增加了一个offset参数(偏移量),该参数用于指定接收到的数据在放入buf缓冲数组时是从offset处开始的。

  • DatagramPacket(byte[] buf,int offset,int length,InetAddress addr,int port)
    该构造方法与第二个构造方法类似,同样用于发送端,只不过在第二个构造方法的基础上,增加了一个offset参数,该参数用于指定一个数组中发送数据的偏移量为offset,即从offset位置开始发送数据。

上面已经讲解了DatagramPacket的构造方法,接下来对DatagramPacket类中的常用方法进行详细的讲解。
在这里插入图片描述

UDP网络程序

使用DatagramSocket类的实例对象就可以发送和接收DatagramPacket数据包在创建发送端和接收端的DatagramSocket对象时,使用的构造方法也有所不同,下面对DatagramSocket类中常用的构造方法进行讲解

  • DatagramSocket()
    该构造方法用于创建发送端的DatagramSocket对象,在创建DatagramSocket对象时,并没有指定端口号,此时,系统会分配一个没有被其他网络程序所使用的端口号。
  • DatagramSocket(int port)
    该构造方法既可用于创建接收端的DatagramSocket对象,又可以创建发送端的DatagramSocket对象,在创建接收端的DatagramSocket对象时,必须要指定一个端口号,这样就可以监听指定的端口。
  • DatagramSocket(int port,InetAddress addr)
    使用该构造方法在创建DatagramSocket对象时,不仅指定了端口号,还指定了相关的IP地址。该对象的使用适用于计算机上有多块网卡的情况,在使用时可以明确规定数据通过哪块网卡向外发送和接收哪块网卡的数据。由于计算机中针对不同的网卡会分配不同的IP,因此在创建DatagramSocket对象时需要通过指定IP地址确定使用哪块网卡进行通信。

上面我们讲解了DatagramSocket的常用构造方法,接下来对DatagramSocket类中的常用方法进行详细的讲解
在这里插入图片描述
前面两个小节讲解了DatagramPacket和DatagramSocket的相关知识,接下来通过一个案例来学习一下它们在程序中的具体用法。要实现UDP通信需要创建一个发送端程序和一个接收端程序。很明显,在通信时只有接收端程序先运行,才能避免发送端发送数据时找不到接收端,而造成数据丢失的问题。因此,首先需要完成接收端程序的编写。接收端程序如下

1 import java.net.*;
2 // 接收端程序
3 public class Receiver {
4	public static void main(String[] args) throws Exception {
5		byte[] buf = new byte[1024]; // 创建一个字节数组,用于接收数据
6        // 定义一个DatagramSocket对象,监听的端口号为8954
7		DatagramSocket ds = new DatagramSocket(8954);
8         // 定义一个DatagramPacket对象,用于接收数据
9		DatagramPacket dp = new DatagramPacket(buf, buf.length);
10		System.out.println("等待接收数据");
11		ds.receive(dp); // 等待接收数据,如果没有数据则会阻塞
12 // 调用DatagramPacket的方法获得接收到的信息
13         //包括数据的内容、长度、发送的IP地址和端口号
14		String str = new String(dp.getData(), 0, dp.getLength()) +
15         "from "+ dp.getAddress().getHostAddress() + ":" + dp.getPort();
16		System.out.println(str); // 打印接收到的信息
17		ds.close();// 释放资源
18	}
19 }

创建了一个接收端程序,用来接收数据。其中,第6行代码创建了一个DatagramSocket对象,并指定其监听的端口号为8954,这样发送端就能通过这个端口号与接收端程序进行通信。第9行代码在创建DatagramPacket对象时传入一个大小为1024个字节的数组用来接收数据,第11行代码调用DatagramPacket对象的receive()方法接收到数据以后,数据会填充到DatagramPacket中,第14~15行代码是通过DatagramPacket的相关方法可以获取接收到的数据的内容、长度、发送的IP地址和端口号等信息,第17行代码是释放资源。

从运行结果可以看到,程序运行后,程序一直处于停滞状态,这是因为DatagramSocket的receive()方法在运行时会发生阻塞,只有接收到发送端程序发送的数据时,该方法才会结束这种阻塞状态,程序才能继续向下执行。
实现了接收端程序之后,接下来还需要编写一个发送端的程序。

1 import java.net.*;
2 //发送端程序
3 public class Sender {
4	public static void main(String[] args) throws Exception {
5		// 创建一个DatagramSocket对象
6		DatagramSocket ds = new DatagramSocket(3000);
7		String str = "hello world"; // 要发送的数据
8		byte[] arr = str.getBytes(); //将定义的字符串转为字节数组
9 //创建一个要发送的数据包,数据包包括发送的数据,
10         //数据的长度,接收端的IP地址以及端口号
11	     DatagramPacket dp = new DatagramPacket(arr, arr.length,
12         InetAddress.getByName("localhost"), 8954);
13		System.out.println("发送信息");
14		ds.send(dp); // 发送数据
15		ds.close(); // 释放资源
16	}
17 }

上述代码中,创建了一个发送端程序,用来发送数据。在创建DatagramPacket对象时需要指定目标IP地址和端口号,而且端口号必须要和接收端指定的端口号一致,这样调用DatagramSocket的send()方法才能将数据发送到对应的接收端。

脚下留心: UDP程序所使用的端口号被占用时运行异常

需要注意的是,运行接收端程序有时会出现一种异常,如下图。
在这里插入图片描述
上图所示异常是因为在一台计算机中,一个端口号上只能运行一个程序,而我们编写的UDP程序所使用的端口号已经被其他的程序占用。遇到这种情况时,可以在命令行窗口输入“netstat -ano”命令来查看当前计算机端口占用情况,netstat命令运行结果如下图。
在这里插入图片描述

上图显示了所有正在运行的应用程序及它们所占用的端口号。想要解决端口号占用的问题,只需关掉占用端口号的应用程序或者使用一个未被占用的端口号重新运行程序即可。

多线程的UDP网络程序

在上一节中,分别实现了发送端程序和接收端程序,当接收端程序阻塞的状态下,运行发送端程序,接收端程序就会收到发送端发送的数据而结束阻塞状态,完成程序运行。实际上,发送端可以无限发送数据,接收端也可以一直接收数据,例如,聊天程序发送端可以一直发消息,接收端也可以一直接收消息,因此发送端和客户端都是多线程的.
接下来通过一个案例演示使用UDP通信方式实现多线程的UDP网络程序。

1 import java.io.IOException;
2 import java.net.*;
3 import java.util.Scanner;
4 public class Example04 {
5    public static void main(String[] args) {
6        new Receive().start();
7        new Send().start();
8    }
9 }
10 class Receive extends Thread {
11    public void run() {
12        try {
13            //创建socket相当于创建码头
14            DatagramSocket socket = new DatagramSocket(6666);	
15           //创建packet相当于创建集装箱		
16            DatagramPacket packet = new DatagramPacket(new byte[1024], 1024);
17            while(true) {
18                socket.receive(packet);//接收货物
19                byte[] arr = packet.getData();
20               int len = packet.getLength();
21                String ip = packet.getAddress().getHostAddress();
22                System.out.println(ip + ":" + new String(arr,0,len));
23            }
24 } catch (IOException e) {
25            e.printStackTrace();
26        }
27    }
28 }
29 class Send extends Thread {
30    public void run() {
31        try {
32            //创建socket相当于创建码头
33            DatagramSocket socket = new DatagramSocket();		
34            Scanner sc = new Scanner(System.in);
35            while(true) {
36                String str = sc.nextLine();
37 if("quit".equals(str))
38                    break;
39                DatagramPacket packet = new DatagramPacket(str.getBytes(),
40                str.getBytes().length, InetAddress.getByName
41               ("127.0.0.1"), 6666);
42                socket.send(packet);//发货
43            }
44            socket.close();
45        }  catch (IOException e) {
46            e.printStackTrace();
47        }
48    }
49 }

上述代码中,第10-28行代码使用多线程的方法创建了一个接收端程序,第17-23行代码通过在接收端的while循环中调用receive()方法,不停地接收发送端发送的请求,当与发送端建立连接后,就会开启一个新的线程,该线程会去处理发送端发送的数据,而主线程仍处于继续等待状态;第29~49行代码使用多线程的方法创建的一个发送端程序,第35-43行代码通过在发送端的while循环中调用的send()方法,不停的发送数据。

TCP通信

TCP通信同UDP通信一样,也能实现两台计算机之间的通信,但TCP通信的两端需要创建socket对象。UDP通信与TCP通信的区别在于,UDP中只有发送端和接收端,不区分客户端与服务器端,计算机之间可以任意地发送数据;而TCP通信是严格区分客户端与服务器端的,在通信时,必须先由客户端去连接服务器端才能实现通信,服务器端不可以主动连接客户端,并且服务器端程序需要事先启动,等待客户端的连接
Java提供了两个用于实现TCP程序的类,一个是ServerSocket类,用于表示服务器端;一个是Socket类,用于表示客户端。通信时,首先要创建代表服务器端的ServerSocket对象,创建该对象相当于开启一个服务,此服务会等待客户端的连接;然后创建代表客户端的Socket对象,使用该对象向服务器端发出连接请求,服务器端响应请求后,两者才建立连接,开始通信。
整个通信过程如下图.
在这里插入图片描述

ServerSocket

在开发TCP程序时,首先需要创建服务器端程序。java.net包提供了一个ServerSocket类,该类的实例对象可以实现一个服务器端的程序。通过查阅API文档可知,ServerSocket类提供了多种构造方法。

  • ServerSocket()
    ServerSocket有一个不带参数的默认构造方法。通过该方法创建的ServerSocket对象不与任何端口绑定,这样的ServerSocket对象创建的服务器端没有监听任何端口,不能直接使用,还需要继续调用bind(SocketAddress endpoint)方法将其绑定到指定的端口号上,才可以正常使用。
  • ServerSocket(int port)
    使用该构造方法在创建ServerSocket对象时,可以将其绑定到一个指定的端口号上(参数port就是端口号)。端口号可以指定为0,此时系统就会分配一个还没有被其他网络程序所使用的端口号。由于客户端需要根据指定的端口号来访问服务器端程序,因此端口号随机分配的情况并不常用,通常都会让服务器端程序监听一个指定的端口号。
  • ServerSocket(int port, int backlog)
    该构造方法就是在第二个构造方法的基础上,增加了一个backlog参数。该参数用于指定在服务器忙时,可以与之保持连接请求的等待客户数量,如果没有指定这个参数,默认为50。
  • ServerSocket(int port, int backlog, InetAddress bindAddr)
    该构造方法就是在第三个构造方法的基础上,增加了一个bindAddr参数,该参数用于指定相关的IP地址。该构造方法的使用适用于计算机上有多块网卡和多个IP的情况,使用时可以明确规定ServerSocket在哪块网卡或IP地址上等待客户的连接请求。显然,对于一般只有一块网卡的情况,就不用专门的指定了。
    除了构造方法,ServerSocket还提供了其他常用方法,如下表。
    在这里插入图片描述
    ServerSocket对象负责监听某台计算机的某个端口号,在创建ServerSocket对象后,需要继续调用该对象的accept()方法,接收来自客户端的请求。当执行了accept()方法之后,服务器端程序会发生阻塞,直到客户端发出连接请求时,accept()方法才会返回一个Socket对象用于和客户端实现通信,程序才能继续向下执行。

Socket

ServerSocket对象可以实现服务器端程序,但只实现服务器端程序还不能完成通信,此时还需要一个客户端程序与之交互,为此Java提供了一个Socket类,用于实现TCP客户端程序。通过查阅API文档可知,Socket类同样提供了多种构造方法

  • Socket()
    使用该构造方法在创建Socket对象时,并没有指定IP地址和端口号,也就意味着只创建了客户端对象,并没有去连接任何服务器。通过该构造方法创建对象后还需调用connect(SocketAddress endpoint)方法,才能完成与指定服务器端的连接,其中参数endpoint用于封装IP地址和端口号。
  • Socket(String host, int port)
    使用该构造方法在创建Socket对象时,会根据参数去连接在指定地址和端口上运行的服务器程序,其中参数host接收的是一个字符串类型的IP地址。
  • Socket(InetAddress address, int port)
    该构造方法在使用上与第二个构造方法类似,参数address用于接收一个InetAddress类型的对象,该对象用于封装一个IP地址。

除了构造方法,Socket还提供了很多其他方法,如下表。
在这里插入图片描述
接下来通过一张图描述服务器端和客户端的数据传输。
在这里插入图片描述

简单的TCP网络程序

接下来通过一个TCP通信的案例来进一步学习ServerSocket、Socket类的用法。要实现TCP通信需要创建一个服务器端程序和一个客户端程序,为了保证数据传输的安全性,首先需要实现服务器端程序。服务器端程序实现如下。

1 import java.io.*;
2 import java.net.*;
3 public class Server {
4	public static void main(String[] args) throws Exception {
5		new TCPServer().listen(); // 创建TCPServer对象,并调用listen()方法
6	}
7 }
8 // TCP服务器端
9 class TCPServer {
10	private static final int PORT = 7788;   // 定义一个端口号
11	public void listen() throws Exception { // 定义一个listen()方法,抛出异常
12		ServerSocket serverSocket = new ServerSocket(PORT);
13 // 调用ServerSocket的accept()方法接收数据
14		Socket client = serverSocket.accept(); 
15		OutputStream os = client.getOutputStream();// 获取客户端的输出流
16		System.out.println("开始与客户端交互数据");
17         // 当客户端连接到服务器端时,向客户端输出数据
18		os.write(("传智播客欢迎你!").getBytes());   
19		Thread.sleep(5000);// 模拟执行其他功能占用的时间
20		System.out.println("结束与客户端交互数据");
21		os.close();
22		client.close();
23	}
24 }

上述代码中,第9-24行代码封装了一个TCP服务端的方法,第12行代码创建ServerSocket对象时指定了端口号(7788),第14代码调用ServerSocket对象的accept()方法用于接收数据,第15行代码使用OutputStream获取客户端的输出流,第19行代码使用线程的sleep()方法使线程休眠5000毫秒,用于模拟执行其他功能占用的时间,最后在第21~22行代码中分别使用OutputStream与Socket的close()方法关闭了OutputStream与Socket。

从运行结果可以看出,控制台中的光标一直在闪动,这是因为accept()方法发生阻塞***,程序暂时停止运行,直到有客户端来访问时才会结束这种阻塞状态***。这时该方法会返回一个Socket类型的对象用于表示客户端,通过该对象获取与客户端关联的输出流并向客户端发送信息,同时执行Thread.sleep(5000)语句模拟服务器执行其他功能占用的时间。最后,调用Socket对象的close()方法将通信结束。

客户端程序如下。

1 import java.io.*;
2 import java.net.*;
3 public class Client {
4	public static void main(String[] args) throws Exception {
5		new TCPClient().connect();// 创建TCPClient对象,并调用connect()方法
6	}
7 }
8 //TCP客户端
9 class TCPClient {
10	private static final int PORT = 7788; // 服务器端的端口号
11	public void connect() throws Exception {
12		//创建一个Socket并连接到给出地址和端口号的计算机
13		Socket client = new Socket(InetAddress.getLocalHost(), PORT);
14		InputStream is = client.getInputStream();   // 得到接收数据的流
15		byte[] buf = new byte[1024];   // 定义1024个字节数组的缓冲区
16		int len = is.read(buf);                        // 将数据读到缓冲区中
17		System.out.println(new String(buf, 0, len));// 将缓冲区中的数据输出
18		client.close();   // 关闭Socket对象,释放资源
19	}
20 }

上述代码中,第9~20行代码封装了一个TCP客户端的方法,第13行代码创建了一个Socket并连接到给出地址给端口号的计算机,第14行代码使用InputStream接收得到的数据流,第15行代码定义1024个字节数组的缓冲区,第16行代码将InputStream接收到的数据读到缓冲区中,最后在第18行代码中使用Socket的close()方法关闭Socket。

在客户端创建的Socket对象与服务器端建立连接后,通过Socket对象获得输入流读取服务器端发来的数据,并打印出如上图所示的结果。
同时服务器端程序会结束阻塞状态,并在控制台中打印出“开始与客户端交互数据”,然后向客户端发出数据“传智播客欢迎你!”,在休眠5秒钟后会在控制台打印出“结束与客户端交互数据”,此时,本次通信才结束。

多线程的TCP网络程序

实际上,很多服务器端程序都是允许被多个应用程序访问的,例如,门户网站可以被多个用户同时访问,因此服务器都是多线程的。下面就通过一个图例来表示多个用户访问同一个服务器。在这里插入图片描述
在上图中,服务器端为每个客户端创建一个对应的Socket,并且开启一个新的线程使两个Socket建立专线进行通信。

1 import java.io.*;
2 import java.net.*;
3 public class Server {
4	public static void main(String[] args) throws Exception {
5		new TCPServer().listen();   // 创建TCPServer对象,并调用listen()方法
6	}
7 }
8 // TCP服务器端
9 class TCPServer {
10	private static final int PORT = 7788; // 定义一个静态常量作为端口号
11	public void listen() throws Exception {
12          // 创建ServerSocket对象,监听指定的端口
13		ServerSocket serverSocket = new ServerSocket(PORT); 
14         // 使用while循环不停的接收客户端发送的请求
15		while (true) {
16              // 调用ServerSocket的accept()方法与客户端建立连接
17			final Socket client = serverSocket.accept();
18 // 下面的代码用来开启一个新的线程
19			new Thread() {              
20				public void run() {
21					OutputStream os;  // 定义一个输出流对象
22					try {
23						os = client.getOutputStream();// 获取客户端的输出流
24						System.out.println("开始与客户端交互数据");
25						os.write(("传智播客欢迎你!").getBytes());
26						Thread.sleep(5000);  // 使线程休眠5000毫秒
27						System.out.println("结束与客户端交互数据");
28						os.close();     // 关闭输出流
29						client.close(); // 关闭Socket对象
30					} catch (Exception e) {
31						e.printStackTrace();
32					}
33				};
34			}.start();
35		}
36	}
37 }

在上述代码中,第9-37行代码使用多线程的方式创建了一个服务器端程序。第15~35行代码通过在while循环中调用accept()方法,不停地接收客户端发送的请求,当与客户端建立连接后,就会开启一个新的线程,该线程会去处理客户端发送的数据,而主线程仍处于继续等待状态。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/154308.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

mricorn 手动勾画ROI并保存为模版的方法步骤

mricorn软件手动勾画ROI: 这里拿一个做了切除手术的癫痫病人举例子,我们需要把切除区域勾画出来并保存成切除的模版。 1、将图像导入到mricorn中 2、逐层勾画ROI并填充 比较方便的是从切除区域的起始层进行勾画,这里为了方便展示只勾画中间…

计算机网络的OSI七层模型

目录 1、OSI七层模型是什么 1.1 物理层(Physical Layer) 1.2 数据链路层(Data Link Layer) 1.3 网络层(Network Layer) 1.4 传输层(Transport Layer) 1.5 会话层(S…

5款免费BI数据可视化工具,2023年最新精选推荐!

BI可视化工具顾名思义是进行数据分析和可视化的软件,旨在将数据以表格、图表、仪表盘等形式展示出来,让用户能够更加直观了解其业务状况、发现问题,并在必要时进行决策。   市面上BI数据可视化工具很多,目前比较火的像国外的Tabl…

CTF/AWD竞赛标准参考书+实战指南

随着网络安全问题日益凸显,国家对网络安全人才的需求持续增长,其中,网络安全竞赛在国家以及企业的人才培养和选拔中扮演着至关重要的角色。 在数字化时代,企业为了应对日益增长的攻击威胁,一般都在大量部署安全产品、…

uview-plus u-picker的defaultIndexs修改后无效的问题

uniapp项目中使用了uview-plus组件库,在使用u-picker组件时,发现其默认的选中属性 defaultIndex是一次性的,修改后无法响应,解决办法就是在u-picker源码中修改这个属性的watch,源码位置在uni_modules/uview-plus/components/u-pi…

Hive 定义变量 变量赋值 引用变量

Hive 定义变量 变量赋值 引用变量 变量 hive 中变量和属性命名空间 命名空间权限描述hivevar读写用户自定义变量hiveconf读写hive相关配置属性system读写java定义额配置属性env只读shell环境定义的环境变量 语法 Java对这个除env命名空间内容具有可读可写权利; …

SQL零基础入门教程,贼拉详细!贼拉简单! 速通数据库期末考!(十一)

COUNT() 计数函数 COUNT() 函数返回匹配指定条件的行数。 语法: 1.返回指定列的字段值条数 SELECT COUNT(column_name) FROM table_name;2.返回整表数据行条数 SELECT COUNT(*) FROM table_name;3.返回指定列去重后的字段值条数 SELECT COUNT(DISTINCT column_…

Leetcode 第 372 场周赛题解

Leetcode 第 372 场周赛题解 Leetcode 第 372 场周赛题解题目1:2937. 使三个字符串相等思路代码复杂度分析 题目2:2938. 区分黑球与白球思路代码复杂度分析 题目3:2939. 最大异或乘积思路代码复杂度分析 题目4:2940. 找到 Alice 和…

vatee万腾的科技奇点:Vatee创新力引领数字未来

在数字时代的涌动潮流中,Vatee万腾显露出一颗科技的奇点之心,其创新力正引领着数字未来的前沿。随着科技不断演进,Vatee万腾敏锐地捕捉到了科技的契机,展现出独特的创新视野,为数字化未来勾勒出了一幅令人瞩目的画卷。…

使用frp搭建内网穿透服务

使用frp搭建内网穿透服务 frp 是一个专注于内网穿透的高性能的反向代理应用,支持 TCP、UDP、HTTP、HTTPS 等多种协议,且支持 P2P 通信。可以将内网服务以安全、便捷的方式通过具有公网 IP 节点的中转暴露到公网。 1.下载frp 下载地址 2.服务端安装 …

[Linux] shell脚本相关知识

一、shell脚本基础 1.1 shell脚本的作用 shell将人类使用的高级语言翻译成二进制,再将二进制翻译成高级语言。换句话就是人类写了一个命令集合,然后用bash去翻译给硬件执行。 linux中常见的shell: bash:基于gun的框架下发展的shell csh:类…

同为科技(TOWE)智能机柜PDU助力上海华为数据中心完善机房末端配电

智能时代加速而来,最大的需求是算力,最关键的基础设施是数据中心。作为一家在信息通信领域拥有多年经验和技术积累的公司,华为在全国多个地区都设有数据中心,如知名的贵州贵安华为云全球总部、内蒙古乌兰察布华为数据中心等&#…

pnpm 管理依赖包是如何节省磁盘空间的?

npm 存在的问题 我们经常使用 npm 来管理 node 项目中的包,从 package.json 中读取配置将依赖下载到本地,以保障项目的正常运行。 当项目数量多时,这样的包管理方式会非常的占用电脑内存。由于每个项目都有属于自己的依赖,每个项…

什么是多域名证书?

多域名证书是指同一个证书中包含多个域名,能够在多个站点之间共享一份证书,实现一个站点对应多个域名的情况。多域名证书非常适合需要跨多个站点部署的应用,例如企业的子站点、博客等。 特点 多域名证书的优点包括以下几个方面:…

【原创】为MybatisPlus增加一个逻辑删除插件,让XML中的SQL也能自动增加逻辑删除功能

前言 看到这个标题有人就要说了,D哥啊,MybatisPlus不是本来就有逻辑删除的配置吗,比如TableLogic注解,配置文件里也能添加如下配置设置逻辑删除。 mybatis-plus:mapper-locations: classpath*:mapper/*.xmlconfiguration:mapUnd…

品牌挑选控价服务商的标准参考

控价是一项需要投入时间精力的工作,品牌可以自主团队去做,但如果涉及数据量太大的时候,还需要开发系统,这样显然会增加非常多的成本,系统开发费用和运维费用都是一笔不小的开支,所以现在很多的品牌会选择找…

澳洲猫罐头到底怎么样呢?我自己亲自喂养过的优质猫罐头分享

猫罐头要符合三点:营养配方完整均衡、原料新鲜优质、生产工艺科学可靠。只有具备这些特点,才是品质上乘的猫罐头。 这三个要点缺一不可,配方不够均衡营养,便无法给猫提供充足的营养、会导致营养不良;原料不够新鲜、优质…

77基于matlab的蚁群优化路径算法,二维路径和三维路径优化

基于matlab的蚁群优化路径算法,二维路径和三维路径优化。输出可视化最优路径和距离迭代曲线。数据可更换自己的,程序已调通,可直接运行。 77三维和二维路径可视化 (xiaohongshu.com)

Python二级 每周练习题27

如果你感觉有收获,欢迎给我微信扫打赏码 ———— 以激励我输出更多优质内容 练习一: 用户输入一个半径r,求该半径下的圆的面积s与周长c。要求如下: (1)输出的面积与周长都保留俩位小数; (2&a…

Active Directory 和域名系统(DNS)的相互关系

什么是域名系统(DNS) 域名系统(DNS),从一般意义上讲是一种将主机名或域名解析为相应IP地址的手段。 在 AD 的中,DNS 服务维护 DNS 域和子域的工作命名空间,这些域和子域主要有助于查找过程&am…