开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 网络协议 -> Java网络编程(详细TCP/UDP) -> 正文阅读

[网络协议]Java网络编程(详细TCP/UDP)

网络编程

1.1 概述

地球村：

简单点说，就是：地球村是说地球虽然很大，但是由于信息传递越来越方便，大家交流就像在一个小村子里面一样便利，就称地球这个大家庭为“地球村”了。

计算机网络：

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

网络编程的目的：

无线电台、传播交流信息、数据交换、通信

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

如何准确定位网络上的一台主机 192.168.31.59：端口，定位到这个计算机的资源
找到了这个主机。如何传输数据呢

javaweb : 网页编程 B/S

网络编程 : TCP/IP C/S

1.2 网络通信的要素

如何实现网络的通信？

通信双方地址：

ip
端口号

规则:网络通信的协议：

TCP/IP参考模型:

小结：

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

如何准确定位到网络上的一台或多台主机 cmd中 Ping + 域名
找到主机之后如何进行通信

2.网络编程中的要素

IP和端口号 ip
网络通信协议 udp/Tcp

3.万物皆对象

1.3 IP

ip地址：InetAddress

唯一定位一台网络上计算机
127.0.0.1：本机 localhost
ip地址的分类：
- ipv4/ipv6
  - IPV4 127.0.0.1 ,4个字节组成。 0-255 ，42亿；30亿都在北美，亚洲4亿。2011年就用尽
  - IPV6 128位。8个无符号整数！
域名：记忆IP问题
- IP： www.vip.com

package Thread;

import java.net.InetAddress;
import java.net.UnknownHostException;

public class TestInetAddress {
    public static void main(String[] args) {
        try {
            //查询本机地址
            InetAddress address1 = InetAddress.getByName("127.0.0.1");
            System.out.println(address1);
            InetAddress address3 = InetAddress.getByName("localhost");
            System.out.println(address3);
            InetAddress address4 = InetAddress.getLocalHost();
            System.out.println(address4);
            //查询网站ip地址
            InetAddress address2 = InetAddress.getByName("www.baidu.com");
            System.out.println(address2);
            //常用方法
           // System.out.println(address2.getAddress());
            System.out.println(address2.getCanonicalHostName());//规范的名字
            System.out.println(address2.getHostAddress());//ip
            System.out.println(address2.getHostName());//域名 或者自己电脑的名字
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
    }
}



//运行结果
/127.0.0.1
localhost/127.0.0.1
PC-202003271358/192.168.31.59
www.baidu.com/36.152.44.95
[B@74a14482
36.152.44.95
36.152.44.95
www.baidu.com

1.4 端口Port

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

不同的进程有不同的端口号！用来区分软件
被规定 0—65535
分为TCP和UDP两种端口 65535*2 单个协议下，端口号不能冲突
端口分类：
- 共有端口：
  - HTTP：80
  - HTTPS：443
  - FTP：21
  - Telent：23
- 程序注册端口：2014—49151，分配用户或者程序
  - Tomcat：8080
  - MySql：3306
  - Oracle：1521
- 动态，私有：49152—65535
```
netstat -ano  #查看所有的端口
netstat -ano|findstr "5900"  #查看指定端口
tasklist|findstr "8696"  #查看指定的端口的进程
```

package net;

import java.net.InetSocketAddress;

public class TestInetSocketAddress {
    public static void main(String[] args) {
        InetSocketAddress socketAddress = new InetSocketAddress("127.0.0.1",53331);
        InetSocketAddress socketAddress1 = new InetSocketAddress("localhsot",53331);
        System.out.println(socketAddress);
        System.out.println(socketAddress1);

        System.out.println(socketAddress.getAddress());
        System.out.println(socketAddress.getHostName());//地址
        System.out.println(socketAddress.getPort());//端口
    }
}


//运行结果
/127.0.0.1:53331
localhsot:53331
/127.0.0.1
ieonline.microsoft.com
53331

1.5 通信协议

协议：约定，就好比我们说的是普通话

网络通信协议：速率，传输码率，代码结构，传输控制…

问题：非常的复杂？

大事化了：分层！

TCP/IP协议簇：实际上是一组协议

重要：

TCP：用户传输协议
UDP：用户数据报协议

出名的协议：

TCP
IP：网络连接协议

TCP UDP对比：

TCP：打电话

连接，稳定
‘三次握手’’四次挥手‘
客户端，服务端
传输完成，断开连接，效率低

UDP：发短信

不连接，不稳定
客户端，服务端：没有明确的界限
不管有没有准备好，都可以发给你

1.6 TCP

客户端：

连接服务器Socket
发送消息

package net;

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


//客户端
public class TCPClientDemo01 {
    public static void main(String[] args) {
        Socket socket = null;
        OutputStream os = null;

        //要知道服务端的地址，端口号
        try {
            //地址
            InetAddress address = InetAddress.getByName("127.0.0.1");
            //端口号
            int port = 9999;
            //创建一个Socket连接
            socket = new Socket(address,port);
            //发送消息， IO流
            os = socket.getOutputStream();
            os.write("阿马喜欢学习".getBytes());
        } catch (Exception 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();
                }
            }
        }
    }
}

服务端：

建立服务的端口ServerSocket
等待用户的连接 accept
接收用的消息

package net;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

//服务端
public class TCPServerDemo01 {
    public static void main(String[] args) {
        ServerSocket serverSocket = null;
        Socket accept = null;
        InputStream is = null;
        ByteArrayOutputStream baos = null;
        try {
            //我得有一个地址
            serverSocket = new ServerSocket(9999);
            //等待客户端连接过来
            while (true){
                accept = serverSocket.accept();
                //读取客户端的消息
                is = accept.getInputStream();
                //管道流
                baos = new ByteArrayOutputStream();
                byte[] buffer = new byte[1024];
                int len;
                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 (accept != null){
                try {
                    accept.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

            if (serverSocket != null){
                try {
                    serverSocket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

        }
    }
}

文件上传

客户端

package net;

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


//客户端
public class TCPClientDemo01 {
    public static void main(String[] args) {
        Socket socket = null;
        OutputStream os = null;

        //要知道服务端的地址，端口号
        try {
            //地址
            InetAddress address = InetAddress.getByName("127.0.0.1");
            //端口号
            int port = 9999;
            //创建一个Socket连接
            socket = new Socket(address,port);
            //发送消息， IO流
            os = socket.getOutputStream();
            os.write("阿马喜欢学习".getBytes());
        } catch (Exception 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();
                }
            }
        }
    }
}

服务端

package net;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

//服务端
public class TCPServerDemo01 {
    public static void main(String[] args) {
        ServerSocket serverSocket = null;
        Socket accept = null;
        InputStream is = null;
        ByteArrayOutputStream baos = null;
        try {
            //我得有一个地址
            serverSocket = new ServerSocket(9999);
            //等待客户端连接过来
            while (true){
                accept = serverSocket.accept();
                //读取客户端的消息
                is = accept.getInputStream();
                //管道流
                baos = new ByteArrayOutputStream();
                byte[] buffer = new byte[1024];
                int len;
                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 (accept != null){
                try {
                    accept.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

            if (serverSocket != null){
                try {
                    serverSocket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

        }
    }
}

Tomcat

服务端

自定义 S
Tomcat服务器 S

客户端

自定义 C
浏览器 B

1.7 UDP

发短信，不用连接，只需要知道对方地址！

发送消息

发送端

package net;

import java.net.*;

//不需要连接服务器
public class UDPClientDemo01 {
    public static void main(String[] args) throws Exception {
        //1.建立一个Socket
        DatagramSocket socket = new DatagramSocket();

        //2.建个包
        String msg = "你好阿，服务器!";
        //发送给谁
        InetAddress address = InetAddress.getByName("localhost");
        int port = 9999;
        //数据，数据的长度起始，发送给谁
        DatagramPacket packet = new DatagramPacket(msg.getBytes(),msg.getBytes().length,address,port);


        //3.发送包
        socket.send(packet);

        //4。关闭连接
        socket.close();
    }
}

接收端

package net;

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(9999);
        //接收数据包
        byte[] buffer = new byte[1024];
        DatagramPacket packet = new DatagramPacket(buffer,0,buffer.length);//接收


        socket.receive(packet);//阻塞接收

        String msg = new String(packet.getData(),0,packet.getLength());

        System.out.println(packet.getAddress().getHostAddress());
        System.out.println(msg);

        //关闭连接
        socket.close();

    }
}

循环发送消息

package net;

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;

public class UdpSenderDemo01 {
    public static void main(String[] args) throws Exception {
        DatagramSocket socket = new DatagramSocket();

        InetAddress address = InetAddress.getByName("localhost");
        int port = 9999;

        while (true){
            //准备数据，控制台获取System.in
            InputStreamReader inputStreamReader = new InputStreamReader(System.in);
            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);

            String data = bufferedReader.readLine();

            byte[] buffer = data.getBytes();
            DatagramPacket packet = new DatagramPacket(buffer,0,buffer.length,address,port);

            socket.send(packet);
            if (data.equals("bye")){
                break;
            }
        }

        socket.close();
    }
}

循环接收消息

package net;

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

public class UdpReceviceDemo01 {
    public static void main(String[] args) throws Exception {
        DatagramSocket socket = new DatagramSocket(9999);

        while (true){

            //准备接收包裹
            byte[] container = new byte[1024];
            DatagramPacket packet = new DatagramPacket(container,0,container.length);
            socket.receive(packet);//阻塞时接收
            //断开连接 bye
            byte[] data = packet.getData();
            String receiveData = new String(data,0,data.length);

            System.out.println(receiveData);
            if (receiveData.equals("bye")){
                break;
            }
        }
        socket.close();
    }
}

多线程在线咨询

两个人都可以时发送方，也可以是接收方

package net;
public class TalkStudent {
    public static void main(String[] args) {
        new Thread(new TalkSend(3333,6666,"localhost")).start();
        new Thread(new TalkReceive(8888,"老师")).start();
    }

}

package net;
public class TalkTeacher {
    public static void main(String[] args) {
        new Thread(new TalkSend(4444,8888,"localhost")).start();
        new Thread(new TalkReceive(6666,"学生")).start();
    }
}

发送信息类

package net;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;

public class TalkSend implements Runnable{
    DatagramSocket socket = null;
    BufferedReader bufferedReader = null;
    InputStreamReader inputStreamReader = null;

    private int fromPort;
    private int toPort;
    private String toIP;

    public TalkSend(int fromPort,int toPort,String toIP){
        this.fromPort = fromPort;
        this.toPort = toPort;
        this.toIP = toIP;
    try{
        socket = new DatagramSocket();
        inputStreamReader = new InputStreamReader(System.in);
        //准备数据，控制台获取System.in
        bufferedReader = new BufferedReader(inputStreamReader);
    } catch (Exception e){
        e.printStackTrace();
    }
    }

    @Override
    public void run() {
        try {
            while (true){
                String data = bufferedReader.readLine();
                byte[] buffer = data.getBytes();
                DatagramPacket packet = new DatagramPacket(buffer,0,buffer.length,InetAddress.getByName(this.toIP),toPort);
                socket.send(packet);
                if (data.equals("bye")){
                    break;
                }
            }
            socket.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

接收信息类

package net;

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

public class TalkReceive implements Runnable{
    DatagramSocket socket = null;

    int port;
    String msgFrom;

    public TalkReceive(int port,String msgFrom){
        this.msgFrom = msgFrom;
        this.port = port;
        try {
            socket = new DatagramSocket(port);
        } catch (SocketException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        while (true){
            try{
                //准备接收包裹
                byte[] container = new byte[1024];
                DatagramPacket packet = new DatagramPacket(container,0,container.length);
                socket.receive(packet);//阻塞时接收
                //断开连接 bye
                byte[] data = packet.getData();
                String receiveData = new String(data,0,data.length);

                System.out.println(msgFrom+":"+receiveData);
                if (receiveData.equals("bye")){
                    break;
                }
            }catch (Exception e){
                e.printStackTrace();
            }
        }
        socket.close();
    }
}

网络协议最新文章

使用Easyswoole 搭建简单的Websoket服务

常见的数据通信方式有哪些？

Openssl 1024bit RSA算法---公私钥获取和处

加:2021-11-10 12:45:58 更:2021-11-10 12:46:12

360图书馆购物三丰科技阅读网日历万年历 2024年7日历

-2024/7/1 21:08:11-

图片自动播放器
↓图片自动播放器↓

TxT小说阅读器
↓语音阅读,小说下载,古典文学↓

一键清除垃圾
↓轻轻一点,清除系统垃圾↓

图片批量下载器
↓批量下载图片,美女图库↓

网站联系: qq:121756557 email:121756557@qq.com IT数码