天天看点

Java——网络编程(TCP/IP三次握手、TCP编程、UDP编程)1. 概述2. 网络通信要素3. TCP网络编程3. UDP网络编程

1. 概述

①网络编程的目的:直接或间接地通过网络协议与其它计算机实现数据交换,进行通讯

②网络编程中有两个主要的问题:

  • 如何准确地定位网络的主机、定位主机上的特定的应用
  • 找到主机后如何可靠高效地进行数据传输

2. 网络通信要素

Java——网络编程(TCP/IP三次握手、TCP编程、UDP编程)1. 概述2. 网络通信要素3. TCP网络编程3. UDP网络编程

2.1 IP地址和端口号

2.1.1 IP地址

Java中用

InetAddress

代表IP:

  • 唯一的标识 Internet 上的计算机(通信实体)
  • 本地回环地址(hostAddress): 127.0.0.1 主机名(hostName): localhost
  • IP地址分类方式①: IPV4 和 IPV6
    • IPV4: 4个字节组成, 4个0-255。大概42亿,2011年初已经用尽。 以点分十进制表示,如192.168.0.1
    • IPV6: 128位(16个字节), 写成8个无符号整数,每个整数用四个十六进制位表示,数之间用冒号(:)分开,如:3ffe:3201:1401:1280:c8ff:fe4d:db39:1984
  • IP地址分类方式②: 公网地址(万维网使用)、私有地址(局域网使用);192.168. 开头的就是私有址址,范围即为192.168.0.0–192.168.255.255,专门为组织机构内部使用

InetAddress

类没有提供公共的构造器,而是提供了如下几个静态方法来获取实例

  • public static InetAddress getLocalHost()

  • public static InetAddress getByName(String host)

public static void main(String[] args) {
        try {
            InetAddress inet1 = InetAddress.getByName("192.168.56.1");
            System.out.println(inet1);

            InetAddress inet2 = InetAddress.getByName("www.baidu.com");
            System.out.println(inet2);

            InetAddress inet3 = InetAddress.getLocalHost();
            System.out.println(inet3);
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
    } 
           

2.1.2 域名

Internet上的主机有两种方式表示地址:

  • 域名(hostName): www.baidu.com
  • IP 地址(hostAddress): 202.108.35.210

域名解析:域名容易记忆,连网时 输入一个主机的域名后, 域名服务器 (DNS) 负责将域名转化成IP地址,这样才能和主机建立连接。

域名的层级

根域名 :

.root

或者

.

,通常是省略的

顶级域名,如

.com

.cn

次级域名,如 baidu.com 里的

baidu

,这个是用户可以进行注册购买的

主机域名,比如 baike.baidu.com 里的

baike

,这个是用户可分配的

2.1.2 端口号

端口号标识正在计算机上运行的进程(程序)

  • 不同的进程有不同的端口号
  • 被规定为一个 16 位的整数 0~65535
  • 端口分类:
    • 公认端口:0~1023。被预先定义的服务通信占用(如:HTTP占用端口80,FTP占用端口21,Telnet占用端口23)
    • 注册端口:1024~49151。分配给用户进程或应用程序。(如:Tomcat占用端口8080,MySQL占用端口3306,Oracle占用端口1521等)
    • 动态/私有端口:49152~65535。
  • 端口号与IP地址的组合得出一个网络套接字:Socket

2.2 网络协议

计算机网络中实现通信必须有一些约定,即通信协议,对速率、传输代码、代码结构、传输控制步骤、出错控制等制定标准。

最常用的复合方式是层次方式,即同层间可以通信、上一层可以调用下一层,而与再下一层不发生关系。各层互不影响,利于系统的开发和扩展。

2.2.1 TCP/IP协议簇

概述

① 传输层协议中有两个非常重要的协议:

  • 传输控制协议TCP(Transmission Control Protocol)
  • 用户数据报协议UDP(User Datagram Protocol)

② IP(Internet Protocol)协议是网络层的主要协议,支持网间互连的数据通信

③ TCP/IP以其两个主要协议:传输控制协议(TCP)和网络互联协议(IP)而得名,实际上是一组协议,包括多个具有不同功能且互为关联的协议

④ TCP/IP协议模型从更实用的角度出发,形成了高效的四层体系结构,即

物理链路层、IP层、传输层、应用层

TCP 和 UDP

TCP协议:

  • 使用TCP协议前,须先建立TCP连接,形成传输数据通道
  • 传输前,采用 “三次握手” 方式,点对点通信, 是可靠的
  • TCP协议进行通信的两个应用进程:客户端、 服务端
  • 在连接中可 进行大数据量的传输
  • 传输完毕,需 释放已建立的连接, 效率低

UDP协议:

  • 将数据、源、目的封装成数据包, 不需要建立连接
  • 每个数据报的大小限制在64K内
  • 发送不管对方是否准备好,接收方收到也不确认, 故是不可靠的
  • 可以广播发送
  • 发送数据结束时 无需释放资源,开销小,速度快

TCP三次握手

三次握手(Three-Way Handshake)即建立 TCP 连接,就是指建立一个TCP连接时,需要客户端和服务端总共发送3个包以确认连接的建立。整个流程如下图所示:

Java——网络编程(TCP/IP三次握手、TCP编程、UDP编程)1. 概述2. 网络通信要素3. TCP网络编程3. UDP网络编程

① 第一次握手:Client将标志位SYN置为1,随机产生一个值seq=J,并将该数据包发送给Server,Client进入SYN_SENT状态,等待Server确认。

② 第二次握手:Server收到数据包后由标志位SYN=1知道Client请求建立连接,Server将标志位SYN和ACK都置为1,ack=J+1,随机产生一个值seq=K,并将该数据包发送给Client以确认连接请求,Server进入SYN_RCVD状态。

③ 第三次握手:Client收到确认后,检查ack是否为J+1,ACK是否为1,如果正确则将标志位ACK置为1,ack=K+1,并将该数据包发送给Server,Server检查ack是否为K+1,ACK是否为1,如果正确则连接建立成功,Client和Server进入ESTABLISHED状态,完成三次握手,随后Client与Server之间可以开始传输数据了。

简单来说,就是:

① 建立连接时,客户端发送SYN包(SYN=i)到服务器,并进入到SYN-SEND状态,等待服务器确认

② 服务器收到SYN包,必须确认客户的SYN(ack=i+1),同时自己也发送一个SYN包(SYN=k),即SYN+ACK包,此时服务器进入SYN-RECV状态

③ 客户端收到服务器的SYN+ACK包,向服务器发送确认报ACK(ack=k+1),此包发送完毕,客户端和服务器进入ESTABLISHED状态,完成三次握手,客户端与服务器开始传送数据。

TCP四次挥手

四次挥手(Four-Way Wavehand)即终止TCP连接,就是指断开一个TCP连接时,需要客户端和服务端总共发送4个包以确认连接的断开。在socket编程中,这一过程可由客户端或服务端任一方发起,流程如下图所示:

Java——网络编程(TCP/IP三次握手、TCP编程、UDP编程)1. 概述2. 网络通信要素3. TCP网络编程3. UDP网络编程

由于TCP连接时全双工的,因此,每个方向都必须要单独进行关闭,这一原则是当一方完成数据发送任务后,发送一个FIN来终止这一方向的连接,收到一个FIN只是意味着这一方向上没有数据流动了,即不会再收到数据了,但是在这个TCP连接上仍然能够发送数据,直到这一方向也发送了FIN。首先进行关闭的一方将执行主动关闭,而另一方则执行被动关闭,上图描述的即是如此。

(1)第一次挥手:Client发送一个FIN,用来关闭Client到Server的数据传送,Client进入FIN_WAIT_1状态。

(2)第二次挥手:Server收到FIN后,发送一个ACK给Client,确认序号为收到序号+1(与SYN相同,一个FIN占用一个序号),Server进入CLOSE_WAIT状态。

(3)第三次挥手:Server发送一个FIN,用来关闭Server到Client的数据传送,Server进入LAST_ACK状态。

(4)第四次挥手:Client收到FIN后,Client进入TIME_WAIT状态,接着发送一个ACK给Server,确认序号为收到序号+1,Server进入CLOSED状态,完成四次挥手。

为什么挥手要比握手多一次?

关闭连接时,当Server端收到FIN报文时,很可能并不会立即关闭SOCKET,

所以只能先回复一个ACK报文,告诉Client端,“你发的FIN报文我收到了”。

只有等到我Server端所有的报文都发送完了,我才能发送FIN报文,因此不能一起发送。

故需要四步握手。

用我自己的话理解就是:

A给B发消息:“我打算关闭了!”

B给A回消息:“你的消息我收到了!但是我活还没干完,等我一会!”

B给A回消息:“好了,我活干完了!”

A给B发消息:“好的,我挂断了!”——同时等待一段时间后关闭

B收到消息后立即关闭

3. TCP网络编程

3.1 Socket

概述

  • 网络上具有唯一标识的IP地址和端口号组合在一起才能构成唯一能识别的标

    识符套接字。

  • 通信的两端都要有Socket,是两台机器间通信的端点。
  • 网络通信其实就是Socket间的通信。
  • Socket允许程序把网络连接当成一个流, 数据在两个Socket间通过IO传输。
  • 一般主动发起通信的应用程序属客户端,等待通信请求的为服务端。
  • Socket分类:
    • 流套接字(stream socket):使用TCP提供可依赖的字节流服务
    • 数据报套接字(datagram socket):使用UDP提供“尽力而为”的数据报服务

例子1:客户端发送内容给服务端,服务端将内容打印到控制台上

//客户端
    @Test
    public void client()  {
        Socket socket = null;
        OutputStream os = null;
        try {
            //1.创建Socket对象,指明服务器端的ip和端口号
            InetAddress inet = InetAddress.getByName("192.168.14.100");
            socket = new Socket(inet,8899);
            //2.获取一个输出流,用于输出数据
            os = socket.getOutputStream();
            //3.写出数据的操作
            os.write("你好,我是客户端mm".getBytes());
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            //4.资源的关闭
            if(os != null){
                try {
                    os.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if(socket != null){
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
           
}
    //服务端
    @Test
    public void server()  {

        ServerSocket ss = null;
        Socket socket = null;
        InputStream is = null;
        ByteArrayOutputStream baos = null;
        try {
            //1.创建服务器端的ServerSocket,指明自己的端口号
            ss = new ServerSocket(8899);
            //2.调用accept()表示接收来自于客户端的socket
            socket = ss.accept();
            //3.获取输入流
            is = socket.getInputStream();
            
            //4.读取输入流中的数据
            baos = new ByteArrayOutputStream();
            byte[] buffer = new byte[5];
            int len;
            while((len = is.read(buffer)) != -1){
                baos.write(buffer,0,len);
            }

            System.out.println(baos.toString());

            System.out.println("收到了来自于:" + socket.getInetAddress().getHostAddress() + "的数据");
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if(baos != null){
                //5.关闭资源
                try {
                    baos.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if(is != null){
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if(socket != null){
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if(ss != null){
                try {
                    ss.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
           

例子2:从客户端发送文件给服务端,服务端保存到本地,并返回“发送成功”给

客户端。并关闭相应的连接。

//客户端
	@Test
    public void client(){
        Socket socket = null;
        FileInputStream fis = null;
        BufferedInputStream bis = null;
        OutputStream os;
        InputStream is = null;
        ByteArrayOutputStream baos = null;
        try {
            socket = new Socket("127.0.0.1",9090);
            os = socket.getOutputStream();
            is = socket.getInputStream();
            baos = new ByteArrayOutputStream();
            fis = new FileInputStream(new File("薪资.png"));
            bis = new BufferedInputStream(fis);
            int len;

            byte[] buffer = new byte[5];

            while ((len = bis.read(buffer))!=-1){
                os.write(buffer,0,len);
            }
            socket.shutdownOutput();

            int len1;
            System.out.println("开始接受响应");
            byte[] buffer1 = new byte[5];
            while ((len1 = is.read(buffer1))!=-1){
                baos.write(buffer1,0,len1);
            }
            System.out.println(baos.toString());

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if(socket!=null) socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                if(bis!=null) bis.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                is.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                baos.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
           
//服务器端
	@Test
    public void server(){
        ServerSocket serverSocket = null;
        Socket socket = null;
        InputStream is = null;
        FileOutputStream fos = null;
        BufferedOutputStream bos = null;
        OutputStream os = null;

        try {
            serverSocket = new ServerSocket(9090);
            socket = serverSocket.accept();
            is = socket.getInputStream();
            os = socket.getOutputStream();
            fos = new FileOutputStream(new File("薪资1.png"));
            bos = new BufferedOutputStream(fos);

            int len;
            byte[] buffer = new byte[5];
            while ((len = is.read(buffer))!=-1){
                bos.write(buffer,0,len);
            }
            System.out.println("图片传输完成");

            os.write("已收到!!!!".getBytes());
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                serverSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                is.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                bos.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                os.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
           

3. UDP网络编程

3.1 概述

① 类

DatagramSocket

DatagramPacket

实现了基于 UDP 协议网络程序。

② UDP数据报通过数据报套接字

DatagramSocket

发送和接收, 系统不保证

UDP数据报一定能够安全送到目的地,也不能确定什么时候可以抵达。

③ DatagramPacket 对象封装了UDP数据报,在数据报中包含了发送端的IP

地址和端口号以及接收端的IP地址和端口号。

④ UDP协议中每个数据报都给出了完整的地址信息,因此无须建立发送方和

接收方的连接。 如同发快递包裹一样。

例子:

@Test
    public void sender() throws IOException {
        DatagramSocket socket = new DatagramSocket();

        String str = "hello,UPD!";
        byte[] data = str.getBytes();
        InetAddress inet = InetAddress.getByName("127.0.0.1");

        DatagramPacket datagramPacket = new DatagramPacket(data,data.length,inet,9090);
        socket.send(datagramPacket);

        socket.close();
    }

    @Test
    public void receiver() throws IOException {
        DatagramSocket socket = new DatagramSocket(9090);

        byte[] buffer = new byte[1024];
        DatagramPacket datagramPacket = new DatagramPacket(buffer,0,buffer.length);

        socket.receive(datagramPacket);

        System.out.println(new String(datagramPacket.getData(),0,datagramPacket.getLength()));

        socket.close();
    }