JAVA之旅(三十二)——JAVA网络请求,IP地址,TCP/UDP通讯协议概述,Socket,UDP传输,多线程UDP聊天应用

简介: JAVA之旅(三十二)——JAVA网络请求,IP地址,TCP/UDP通讯协议概述,Socket,UDP传输,多线程UDP聊天应用 GUI写到一半电脑系统挂了,也就算了,最多GUI还有一个提示框和实例,我们暂时不讲了,我们直接来重点吧,关于JAVA的网络请求是怎么实现的...

JAVA之旅(三十二)——JAVA网络请求,IP地址,TCP/UDP通讯协议概述,Socket,UDP传输,多线程UDP聊天应用


GUI写到一半电脑系统挂了,也就算了,最多GUI还有一个提示框和实例,我们暂时不讲了,我们直接来重点吧,关于JAVA的网络请求是怎么实现的?当然是HTTP协议,但是不可否认,他的概念和思想都是我们必须去涉及的,包括后面的tcp和socket等,好吧,我们开车吧!

一.JAVA网络请求概述

关于JAVA的网络请求,我们大致的可以分为以下几个分类

  • 网络模式
    • OSI
    • TCP/IP
  • 网络通讯
    • IP地址
    • 端口号
    • 传输协议

拿这些都是干嘛的呢?我们接下来都会讲到

首先我们应该思考的是他们通信的一个过程的步骤

  • 1.找到对方IP
  • 2.数据发送到指定应用程序上,为了识别,就有了端口的概念
  • 3.定义通信协议(也就是后来的传输协议)国际协议/TCP/IP
  • 4.三要素:IP,端口,协议

OK,那我们就研究下网络模型,OSI和TCP/IP的区别
其实理解起来也不难,我们看一下他的逻辑结构就知道了

  • OSI

    • 应用层
    • 表示层
    • 会话层
    • 传输层
    • 网络层
    • 数据链路层
    • 物理层
  • TCP/IP

    • 应用层
    • 传输层
    • 网络层
    • 主机-网络层

应用层,我们就在这里玩,TCP封装了就比较好用,他们都有使用规则,而我们常用的大概就是HTTP协议了

二.IP地址

通讯要素大致的就是这些,我们来说一下我们耳熟能详的IP地址,他是什么概念呢?

  • IP地址

    • 网络中设备的标识
    • 可用主机名
    • 本地回环地址:127.0.0.1,主机名:location
  • 端口号

    • 用于标识进程的逻辑地址,不同进程的标识
    • 有效端口:0-65535,其中0-1024系统使用或者保留,我们熟知的8080
  • 通讯协议

    • 通讯的规则
    • 常见的TCP,UDP

我们可用用代码获得哦,先看API文档,会发现JAVA给我们提供了一个类InetAddress

我们可用直接去用代码使用

try {
    InetAddress localHost = InetAddress.getLocalHost();
    System.out.println(localHost.toString());
} catch (UnknownHostException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
}

可以得到

这里写图片描述

得到的本机的主机名和IP地址
当然,你要单独获取也是没问题的

        try {
            InetAddress localHost = InetAddress.getLocalHost();
            String hostAddress = localHost.getHostAddress();
            String hostName = localHost.getHostName();
            System.out.println(localHost.toString());
        } catch (UnknownHostException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

三.TCP/UDP通讯协议概述

端口我们没什么可说的,我们直接说通讯协议,目前常见的就是TCP/UDP了,我们先来简单的说下他们的概念

  • TCP

    • 建立连接,形成传输数据的通道
    • 在连接中进行大数据量传输
    • 通过三次握手完成连接,是可靠协议
    • 必须建立连接,效率稍微低点
  • UDP

    • 将数据及源和目的封装在数据包中,不需要建立连接
    • 每个数据包的大小限制在64K内
    • 因无连接,是不可靠协议
    • 不需要建立连接,速度快

这些这么多,java肯定会给我们封装对象的,这个是毋庸置疑的,那我们接着往下看

四.Socket

Socket就厉害了,我们先来看看他的概念

  • Socket就是为网络服务提供的一种机制
  • 通信的两端都有socket
  • 网络通信其实就是socket通信
  • 数据在两个socket通过IO传输

我们现在先说概念,后期再实战

五.UDP传输

UDP传输的socket服务该怎么建立?

  • DatagramSocket和DatagramPacket
  • 建立发送端和接收端
  • 建立数据包
  • 调用socket的发送和接收方法
  • 关闭socket

客户端和服务端是两个单独的服务,我们可用来用代码讲解下,用到的就是DatagramSocket和DatagramPacket

所以这里应该是有两个,一个传输端,一个接收端

传输端


/**
 * 需求: 通过UDP传输方式将一段文字数据发送出去 
 * 思路: 
 * 1.建立UDP的socket服务 
 * 2.建立数据包 
 * 3.发送数据 
 * 4.关闭资源
 * 
 * @author LGL
 *
 */
public class UdpSend {
    public static void main(String[] args) {
        try {
            // 1.建立UDP的socket服务,通过DatagramSocket对象
            DatagramSocket dSocket = new DatagramSocket();
            // 2.确定数据,封装成数据包
            byte[] data = "udp".getBytes();
            DatagramPacket dp = new DatagramPacket(data, data.length,
                    InetAddress.getByName("192.168.1.102"), 8080);
            // 3.发送数据
            dSocket.send(dp);
            // 4.关闭资源
            dSocket.close();
        } catch (SocketException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (UnknownHostException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

接收端

/**
 * 需求:接收指定端口发送过来的数据 
 * 思路: 
 * 1.定义socket服务
 * 2.定义数据包,存储接收到的字节数据,因为数据包对象中有更多功能可以提取字节数据中的不同数据信息
 * 3.通过socket的receive方法收到的数据存储到数据包中 
 * 4.将这些不同的数据取出,打印 
 * 5.关闭资源
 * 
 * @author LGL
 *
 */
class UdpRece {
    public static void main(String[] args) {
        try {
            // 1.创建服务,建立端点
            DatagramSocket dSocket = new DatagramSocket(8080);
            // 2.定义数据包,存储数据
            byte[] buf = new byte[1024];
            DatagramPacket dp = new DatagramPacket(buf, buf.length);
            // 3.存储
            dSocket.receive(dp);
            // 4.获取其中的数据
            String ip = dp.getAddress().getHostAddress();
            String data = new String(dp.getData(), 0, dp.getLength());
            int port = dp.getPort();
            System.out.println(ip+":" + data + ":" + port);
            //5.关闭资源
            dSocket.close();
        } catch (SocketException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

这样就可以通信了

六.多线程UDP聊天应用

既然上面有模有样的写出来了,那我们可以动手写一个应用了,我们继续来看,我不开多个进程,我写一个进程,两个线程来实现聊天

package com.lgl.hellojava;

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;

/**
 * 编写一个聊天应用程序 有收数据和发数据的部分,所以用到多线程的技术,一个接一个发 收和发的动作不一致,所以有两个Runnable
 * 
 * @author LGL
 *
 */
public class UdpSpeak {

    public static void main(String[] args) {

        try {
            DatagramSocket sendSocket = new DatagramSocket();
            DatagramSocket receSocket = new DatagramSocket(10000);

            new Thread(new send(sendSocket)).start();
            new Thread(new rece(receSocket)).start();

        } catch (SocketException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

/**
 * 发送
 * 
 * @author LGL
 *
 */
class send implements Runnable {

    private DatagramSocket socket;

    public send(DatagramSocket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            BufferedReader bufr = new BufferedReader(new InputStreamReader(
                    System.in));
            String line = null;
            while ((line = bufr.readLine()) != null) {
                if ("close".equals(line)) {
                    break;
                }
                byte[] buf = line.getBytes();
                DatagramPacket dp = new DatagramPacket(buf, buf.length,
                        InetAddress.getByName("192.168.1.102"), 10000);
                socket.send(dp);
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

}

/**
 * 接收
 * 
 * @author LGL
 *
 */
class rece implements Runnable {

    private DatagramSocket socket;

    public rece(DatagramSocket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        while (true) {
            try {
                byte[] buf = new byte[1024];
                DatagramPacket dp = new DatagramPacket(buf, buf.length);
                socket.receive(dp);

                String ip = dp.getAddress().getHostAddress();
                String data = new String(dp.getData(), 0, dp.getLength());
                int port = dp.getPort();
                System.out.println(ip + ":" + data + ":" + port);

            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }

}

OK,搞定,其实主要还是要了解他的思想,编码什么的不重要的

好了,本篇主要是以UDP和概念为起点,而且UDP用的较少,我们一般不是常接触,真正要用的是TCP,所以会重点掌握,那本篇,我们先到这里就好了

目录
相关文章
|
17天前
|
负载均衡 容灾 Cloud Native
云原生应用网关进阶:阿里云网络ALB Ingress 全能增强
在过去半年,ALB Ingress Controller推出了多项高级特性,包括支持AScript自定义脚本、慢启动、连接优雅中断等功能,增强了产品的灵活性和用户体验。此外,还推出了ingress2Albconfig工具,方便用户从Nginx Ingress迁移到ALB Ingress,以及通过Webhook服务实现更智能的配置校验,减少错误配置带来的影响。在容灾部署方面,支持了多集群网关,提高了系统的高可用性和容灾能力。这些改进旨在为用户提供更强大、更安全的云原生网关解决方案。
294 14
|
16天前
|
容灾 网络协议 数据库
云卓越架构:云上网络稳定性建设和应用稳定性治理最佳实践
本文介绍了云上网络稳定性体系建设的关键内容,包括面向失败的架构设计、可观测性与应急恢复、客户案例及阿里巴巴的核心电商架构演进。首先强调了网络稳定性的挑战及其应对策略,如责任共担模型和冗余设计。接着详细探讨了多可用区部署、弹性架构规划及跨地域容灾设计的最佳实践,特别是阿里云的产品和技术如何助力实现高可用性和快速故障恢复。最后通过具体案例展示了秒级故障转移的效果,以及同城多活架构下的实际应用。这些措施共同确保了业务在面对网络故障时的持续稳定运行。
|
1月前
|
Kubernetes 安全 Devops
有效抵御网络应用及API威胁,聊聊F5 BIG-IP Next Web应用防火墙
有效抵御网络应用及API威胁,聊聊F5 BIG-IP Next Web应用防火墙
72 10
有效抵御网络应用及API威胁,聊聊F5 BIG-IP Next Web应用防火墙
|
19天前
|
数据采集 JavaScript 前端开发
异步请求在TypeScript网络爬虫中的应用
异步请求在TypeScript网络爬虫中的应用
|
27天前
|
安全 算法 Java
Java CAS原理和应用场景大揭秘:你掌握了吗?
CAS(Compare and Swap)是一种乐观锁机制,通过硬件指令实现原子操作,确保多线程环境下对共享变量的安全访问。它避免了传统互斥锁的性能开销和线程阻塞问题。CAS操作包含三个步骤:获取期望值、比较当前值与期望值是否相等、若相等则更新为新值。CAS广泛应用于高并发场景,如数据库事务、分布式锁、无锁数据结构等,但需注意ABA问题。Java中常用`java.util.concurrent.atomic`包下的类支持CAS操作。
63 2
|
1月前
|
SQL 安全 网络安全
网络安全与信息安全:知识分享####
【10月更文挑战第21天】 随着数字化时代的快速发展,网络安全和信息安全已成为个人和企业不可忽视的关键问题。本文将探讨网络安全漏洞、加密技术以及安全意识的重要性,并提供一些实用的建议,帮助读者提高自身的网络安全防护能力。 ####
71 17
|
1月前
|
存储 SQL 安全
网络安全与信息安全:关于网络安全漏洞、加密技术、安全意识等方面的知识分享
随着互联网的普及,网络安全问题日益突出。本文将介绍网络安全的重要性,分析常见的网络安全漏洞及其危害,探讨加密技术在保障网络安全中的作用,并强调提高安全意识的必要性。通过本文的学习,读者将了解网络安全的基本概念和应对策略,提升个人和组织的网络安全防护能力。
|
1月前
|
SQL 安全 网络安全
网络安全与信息安全:关于网络安全漏洞、加密技术、安全意识等方面的知识分享
随着互联网的普及,网络安全问题日益突出。本文将从网络安全漏洞、加密技术和安全意识三个方面进行探讨,旨在提高读者对网络安全的认识和防范能力。通过分析常见的网络安全漏洞,介绍加密技术的基本原理和应用,以及强调安全意识的重要性,帮助读者更好地保护自己的网络信息安全。
59 10
|
1月前
|
SQL 安全 网络安全
网络安全与信息安全:关于网络安全漏洞、加密技术、安全意识等方面的知识分享
在数字化时代,网络安全和信息安全已成为我们生活中不可或缺的一部分。本文将介绍网络安全漏洞、加密技术和安全意识等方面的内容,并提供一些实用的代码示例。通过阅读本文,您将了解到如何保护自己的网络安全,以及如何提高自己的信息安全意识。
66 10
|
1月前
|
存储 监控 安全
云计算与网络安全:云服务、网络安全、信息安全等技术领域的融合与挑战
本文将探讨云计算与网络安全之间的关系,以及它们在云服务、网络安全和信息安全等技术领域中的融合与挑战。我们将分析云计算的优势和风险,以及如何通过网络安全措施来保护数据和应用程序。我们还将讨论如何确保云服务的可用性和可靠性,以及如何处理网络攻击和数据泄露等问题。最后,我们将提供一些关于如何在云计算环境中实现网络安全的建议和最佳实践。