狂神说 网络编程实战讲解

1.1、概述

计算机网络:

计算机网络是指将地理位置不同的具有独立功能的多台过算机及其外部设备,通过通信线路连接起来,在网络操作系统，网络管理软件及网络通信协议的管理和协调下，实现资源共享和信息传递的计算机系统。

网络编程的目的:

无线电台...传播交流信息，数据交换。通信

想要达到这个效果需要什么:

1.如何准确的定位网络.上的一台主机192.168.16.124: 端口，定位到这个计算机上的某个资源

2.找到了这个主机，如何传输数据呢?

javaweb:网页编程 B/S 网络编程: TCP/IP C/S

1.2、网络通信的要素

如何实现网络的通信?

通信双方地址:

• ip
• 端口号
• 192.168.16,124:5900

规则:网络通信的协议

http， ftp，smtp，tcp， udp。。。

小结:

1.网络编程中有两个主要的问题

• 如何准确的定位到网络.上的一台或者多台主机
• 找到主机之后如何进行通信
  2.网络编程中的要素

• IP和端口号ip
• 网络通信写协议tcp udp
• 3.万物皆对象

1.3、IP

ABCD类地址

1.4、端口

端口表示计算机上的一个程序的进程

• 不同的进程有不同的端口号！用来区分软件！
• 被规定0！65535
• TCP，UDP：65535*2 单个协议下 端口不能冲突
• 端口分类

• 公有端口0~1023

• HTTP：80
• HTTPS：443
• FTP：21
• Telent：23

• 程序注册端口：1014~49151，分配给用户或者程序

• Tomcat：8080
• MySQL：3306
• Oracle：1521

• 动态、私有：46152~65535

netstat -ano  #查看所有端口
netstat -ano|findstr "5900"  #查看指定端口
tasklist|findstr "8696" #查看指定端口的进程

## 1.5、通信协议

网络通信协议:速率，传输码率，代码结构，传输控制...
问题:非常的复杂?
大事化小:分层!
TCP/IP协议簇:实际上是一组协议
**重要**:****
●TCP :用户传输协议
●UDP:用户数据报协议
出名的协议:****
●TCP:
●IP:网络互连协议



#### TCP UDP 对比

TCP：打电话

- 连接。稳定

- 三次握手，四次挥手

  1. ```
     A:你瞅啥？
     B：瞅你咋地？
     A：干一场！


     A:我要断开了
     B:你真的要走了么
     A:你真的真的要走了么
     A：我真的要走了

• 客户端，服务端
• 传输完成，释放连接，效率低

UDP 发短信

• 不连接，不稳定
• 客户端、服务端：没有明显的界限
• 不管有没有准备好，都可以发给你
• 导弹
• DDOS：洪水攻击（饱和攻击）

1.6、TCP

客户端

1. 连接服务器
2. 发送消息

package com.network.lesson02;

import java.io.IOException;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

public class TcpCilentDemo01 {
    public static void main(String[] args) {
        //1.要知道服务器的地址 端口号
        Socket socket=null;
        OutputStream os=null;
        try {
            InetAddress byName = InetAddress.getByName("127.0.0.1");
            int port=9999;
            //2.创建一个socket连接
            socket = new Socket(byName,port);
            //3.发送IO消息流
            os = socket.getOutputStream();
            os.write("大家一起学Java".getBytes());
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            if (os!=null){
                try {
                    os.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (socket!=null){
                try {
                    socket.close ();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

服务器

1. 建立服务器的端口ServerSocket
2. 等待用户的连接 accpet
3. 接收用的消息

package com.network.lesson02;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class TcpServerDemo01 {
    public static void main(String[] args) {
        //1.有一个地址
        ServerSocket serverSocket =null;
        Socket socket=null;
        InputStream is=null;
        ByteArrayOutputStream baos=null;
        try {
             serverSocket = new ServerSocket(9999);
            //2.等待客户端连接过来
            socket = serverSocket.accept();
            //3.读取客户端的消息
            is = socket.getInputStream();

            /*bug写法
            byte[] buffer = new byte[1024];
            int len;
            while ((len=is.read(buffer))!=-1){
                String msg = new String(buffer, 0, len);
                System.out.println(msg);
             */
            //管道流
            baos = new ByteArrayOutputStream();
            int len;
            byte[] buffer = new byte[1024];
            while ((len= is.read(buffer))!=-1){
                baos.write(buffer,0,len);
            }
            System.out.println(baos.toString());

            //先开后关

        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            //关闭资源
            if (baos!=null){
                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 (serverSocket!=null){
                    try {
                        serverSocket.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }
}

文件上传

服务器端

package com.network.lesson02;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class TcpServerDemo02 {
    public static void main(String[] args) throws Exception {

//        1.创建服务
        ServerSocket serverSocket = new ServerSocket(9000);
//        Socket socket = new Socket();

//2.监听客户端链接
        Socket socket = serverSocket.accept();//阻塞式监听，会一直等待客户端输入


//        3.获得输入流
        InputStream is = socket.getInputStream();


//        4.文件输出
        FileOutputStream fos = new FileOutputStream(new File("hhhh.jpg"));
        byte[] buffer = new byte[1024];
        int len;
        while ((len=is.read(buffer))!=-1){
            is.read(buffer,0,len);
        }
//通知客户端接收完毕
        OutputStream os = socket.getOutputStream();
        os.write("我接收完毕了，你可以断开了".getBytes());

//        5.关闭资源
        fos.close();
        is.close();
        socket.close();
        serverSocket.close();

    }
}

客户端

package com.network.lesson02;

import java.io.*;
import java.net.InetAddress;
import java.net.Socket;

public class TcpCilentDemo02 {
    public static void main(String[] args) throws Exception {
        //1.创建一个socket连接
        Socket socket = new Socket(InetAddress.getByName("127.0.0.1"),9000);

//        2.创建一个输出流
        OutputStream os = socket.getOutputStream();

//        3.读取文件     把文件变成流   再把流输出
        FileInputStream fis = new FileInputStream(new File("1.jpg"));

//        4.写出文件
        byte[] buffer = new byte[1024];//缓冲区 ·1
        int len;
        while ((len= fis.read(buffer))!=-1){
            os.write(buffer,0,len);
        }
        //通知服务器 输出完了
        socket.shutdownOutput();

        //确定服务器接收完毕才能断开链接
        InputStream inputStream = socket.getInputStream();
        ByteArrayOutputStream baos = new ByteArrayOutputStream();

        byte[] buffer2 = new byte[1024];
        int len2;
        while ((len2=inputStream.read(buffer2))!=-1){
            baos.write(buffer2,0,len2);
        }
        System.out.println(baos.toString());
//        确定服务


//        5.关闭资源
        baos.close();
        fis.close();
        os.close();
        socket.close();
    }
}

Tomcat

服务端

• 自定义
• Tomcat服务器

客户端

• 自定义 C
• 浏览器 B

1.7、UDP

发消息：不用连接，需要知道对方的地址！

发送消息

package com.network.lesson03;

import java.net.*;

//不需要连接服务器
public class UdpCelientDemo01 {
    public static void main(String[] args) throws Exception {
        //1.建立一个Socket
        DatagramSocket socket = new DatagramSocket();
        //2.建个包
        String msg="你好啊，服务器!!";
        //发给谁
        InetAddress localhost = InetAddress.getByName("localhost");
        int port = 9090;
        //数据，数据的长度起始，要发送给谁
        DatagramPacket packet = new DatagramPacket(msg.getBytes(),0,msg.getBytes().length,localhost,port);
        socket.send(packet);

        //关闭
        socket.close();

    }
}

接收端

package com.network.lesson03;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

public class UdpServerDemo01 {
    //还是要等待客户端的连接
    public static void main(String[] args) throws Exception {
        //开放端口
        DatagramSocket socket = new DatagramSocket(9090);
        //接收数据
        byte[] buffer = new byte[1024];
        DatagramPacket packet = new DatagramPacket(buffer,0,buffer.length);

        socket.receive(packet);//阻塞接受
        System.out.println(packet.getAddress().getHostAddress());
        System.out.println(new String(packet.getData(),0,packet.getLength()));
        socket.close();

    }
}

咨询

循环发送消息

package com.network.chat;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.*;

public class UdpSender01 {
    public static void main(String[] args) throws Exception {
        DatagramSocket socket = new DatagramSocket(8888);
        BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));

        while (true){

            String data = reader.readLine();
            byte[] datas = data.getBytes();
            String sendData=new String(datas,0,datas.length);
            if (sendData.equals("bye")){
                break;
            }

            DatagramPacket packet = new DatagramPacket(datas,0,datas.length,new InetSocketAddress("localhost",6666));
            socket.send(packet);

        }

        socket.close();


    }
}

循环接收消息

package com.network.chat;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

public class UdpReceive01 {
    public static void main(String[] args) throws Exception {
        DatagramSocket socket = new DatagramSocket(6666);
        while (true){
            byte[] container = new byte[1024];
            DatagramPacket packet = new DatagramPacket(container,0,container.length);
            socket.receive(packet);//阻塞式接受包裹


            byte[] data = packet.getData();
            String receiveData=new String(data,0,data.length);
            System.out.println(receiveData);
            if (receiveData.equals("bye")){
                break;
            }
        }
        socket.close();
    }
}

1.8、URL

统一资源定位符

DNS域名解析 ip 域名

协议：//IP地址：端口/项目名/资源

爬取

package com.network.lesson04;

import java.io.*;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;

public class URLDown {
    public static void main(String[] args) throws IOException {
//        https://m701.music.126.net/20220215002141/95215abe6a0cacbbac7f4386691694cd/jdyyaac/obj/w5rDlsOJwrLDjj7CmsOj/11624482968/5b8b/9912/7c40/3877aa1c480cedeb274dae1b816efbb6.m4a
//        漠河舞厅
        URL url = new URL("https://m701.music.126.net/20220215002141/95215abe6a0cacbbac7f4386691694cd/jdyyaac/obj/w5rDlsOJwrLDjj7CmsOj/11624482968/5b8b/9912/7c40/3877aa1c480cedeb274dae1b816efbb6.m4a");
        System.out.println(url.getHost());
        System.out.println(url.getPort());
        System.out.println(url.getUserInfo());

        HttpURLConnection urlConnection = (HttpURLConnection) url.openConnection();

        InputStream inputStream = urlConnection.getInputStream();

        FileOutputStream fos = new FileOutputStream("亲爱的漠河舞厅.m4a");

        byte[] buffer = new byte[1024];
        int len;
        while ((len=inputStream.read(buffer))!=-1){
            fos.write(buffer,0,len);
        }


        fos.close();
        inputStream.close();
        urlConnection.disconnect();
    }
}