【Java EE 初阶】网络编程套接字UDP

news2024/12/28 5:16:18

目录

1.为什么需要网络编程?

2.什么是网络编程?

3.发送端和接收端

4.请求和响应

 5.客户端和服务端

6.如何进行网络编程(Socket套接字)

1.如何进行网络编程

2.TCP与UDP的区别

1.流套接字:使用传输层TCP协议

2.数据报套接字:使用传输层UDP协议

3.举例对比TCP与UDP

7.Java中使用UDP数据报套接字编程

1.类和方法

1.DatagramSocket 构造方法

2.DatagramSocket普通方法

         3.DatagramPacket API

1.DatagramPacket 构造方法

 2.DatagramPacket 方法普通

8.实现一个简单的UDP回显服务器于客户端

服务端步骤:

服务端代码:

2.客户端步骤

客户端代码:

代码如下:

结果展示:


1.为什么需要网络编程?

  • 所谓的网络资源,其实就是在网络中可以获取的各种数据资源。
  • 而所有的网络资源,都是通过网络编程来进行数据传输的

2.什么是网络编程?

网络编程,指网络上的主机,通过不同的进程,以编程的方式实现网络通信(或称为网络数据传输)

我们只需要满足进程不同即可,即便是同一个主机的不同进程,基于网络来传输数据,也称作网络编程

  • 进程A:编程来获取网络资源
  • 进程B:编程来提供网络资源

3.发送端和接收端

在一次网络数据传输时:
  • 发送端:数据的发送方进程,称为发送端。发送端主机即网络通信中的源主机。
  • 接收端:数据的接收方进程,称为接收端。接收端主机即网络通信中的目的主机。

4.请求和响应

一般来说,获取一个网络资源,涉及到两次网络数据传输:
  • 第一次:请求数据的发送
  • 第二次:响应数据的发送。

 5.客户端和服务端

  • 服务端:在常见的网络数据传输场景下,把提供服务的一方进程,称为服务端,可以提供对外服务。
  • 客户端获取服务的一方进程,称为客户端。

6.如何进行网络编程(Socket套接字)

1.如何进行网络编程

 

2.TCP与UDP的区别

1.流套接字:使用传输层TCP协议

TCP,即Transmission Control Protocol(传输控制协议),传输层协议
以下为TCP的特点:
  • 有连接(比如打电话接通后双方才可以通信)
  • 可靠传输(若丢包,会有重传机制)
  • 面向字节流(打电话说一个字对方就能听到一个字)
  • 有接收缓冲区,也有发送缓冲区
  • 大小不限(想说多少说多少)
对于字节流来说,可以简单的理解为,传输数据是基于IO流,流式数据的特征就是在IO流没有关闭的情况下,是无边界的数据,可以多次发送,也可以分开多次接收。

2.数据报套接字:使用传输层UDP协议

UDP,即User Datagram Protocol(用户数据报协议),传输层协议。
以下为UDP的特点:
  • 无连接(对方有没有开机并不影响)
  • 不可靠传输(丢包就丢了)
  • 面向数据报(发短信一整条发出去对方才可以阅读)
  • 有接收缓冲区,无发送缓冲区
  • 大小受限:一次最多传输64k(短信大小会有限制)
对于数据报来说,可以简单的理解为,传输数据是一块一块的,发送一块数据假如100个字节,必须一次发送,接收也必须一次接收100个字节,而不能分100次,每次接收1个字节

3.举例对比TCP与UDP

7.Java中使用UDP数据报套接字编程

1.类和方法

DatagramSocket API 中DatagramSocket 是UDP Socket ,用于发送和接收UDP数据报

1.DatagramSocket 构造方法

2.DatagramSocket普通方法

 

 3.DatagramPacket API

DatagramPacket 是UDP Socket 发送和接收的数据报

1.DatagramPacket 构造方法

 2.DatagramPacket 方法普通

8.实现一个简单的UDP回显服务器于客户端

服务端步骤:

  1.  定义一个用于服务器端的DatagramSocket
  2. 对外提供服务
  3. 循环接收用户的请求
    1. 创建一个用于接收请求数据的DatagramPacket
    2. 接收请求, 把真实的内容填充到requestPacket
    3. 从requestPacket获取数据
    4. 根据请求获取响应
    5. 把响应封装到DatagramPacket
    6. 发送数据
    7. 打印日志

服务端代码:

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.nio.charset.StandardCharsets;

public class UDPsever {

    private DatagramSocket sever;

    //初始化,端口号
    public UDPsever (int port) throws Exception {
        if (port < 1024 || port > 65535) {
            throw new Exception("端口号必须在1024~65535之间");
        }
        this.sever = new DatagramSocket(port);
    }

    //对外提供服务
    public void start () throws IOException {
        System.out.println("服务端已启动~~");
        while (true) {
            //用户接收请求的DatagramPacket
            DatagramPacket requestPacket = new DatagramPacket(new byte[1024],1024);
            //接受请求
            sever.receive(requestPacket);
            //从请求中获取并解析数据
            String request = new String(requestPacket.getData(),0,requestPacket.getLength());
            //根据真实请求获取响应
            String response = processor (request);
            //封装响应
            DatagramPacket responsePacket = new DatagramPacket(response.getBytes(StandardCharsets.UTF_8),response.getBytes().length,requestPacket.getSocketAddress());
            //发送数据
            sever.send(responsePacket);
            //打印日志
            System.out.printf("[%s:%d] request: %s, response: %s.\n", requestPacket.getAddress().toString(),
                    requestPacket.getPort(), request, response);
        }
    }

    private String processor(String request) {
        return "小锦鲤 " + request;
    }

    public static void main(String[] args) throws Exception {
        UDPsever sever = new UDPsever(8888);
        sever.start();
    }

}

2.客户端步骤

1.定义一个用于客户端的DatagramSocket
2.定义服务器的IP地址,定义服务器的端口号
3.循环接收用户的输入

1. 把请求内容包装成DatagramPacket
2. 发送数据
3. 接收响应
4. 在receive方法中填充响应数据
5. 解析响应数据
6. 打印日志

客户端代码:

import java.io.IOException;
import java.net.*;
import java.nio.charset.StandardCharsets;
import java.util.Scanner;

public class UDPclient {

    private DatagramSocket client;

    private String severIp;
    private int port;
    private SocketAddress address;

    public UDPclient (String severIp, int port) throws SocketException {
        this.client = new DatagramSocket();
        this.severIp = severIp;
        this.port = port;
        this.address = new InetSocketAddress(severIp, port);
    }

    public void start () throws IOException {
        System.out.println("客户端已启动~~");
        // 循环接收用户的输入
        Scanner sc = new Scanner(System.in);
        while (true) {
            System.out.println("请输入请求");
            String request = sc.next();
            // 1. 把请求内容包装成DatagramPacket
            DatagramPacket requestPacket = new DatagramPacket(request.getBytes(StandardCharsets.UTF_8),request.getBytes().length,address);
            //2. 发送数据
            client.send(requestPacket);
            //3. 接收响应
            DatagramPacket responsePacket = new DatagramPacket(new byte[1024],1024);
            //4. 在receive方法中填充响应数据
            client.receive(responsePacket);
            //5. 解析响应数据
            String response = new String(responsePacket.getData(),0,responsePacket.getLength(),"UTF-8");
            //6. 打印日志
            System.out.printf("request:%s, response : %s.\n",request,response);


        }
    }

    public static void main(String[] args) throws IOException {
        UDPclient pclient = new UDPclient("127.0.0.1",8888);
        pclient.start();
    }
}

上述我们只是简单地将原请求返回回去,其实我们还可以使用map通过键值对返回其对应的值

代码如下:

import java.io.IOException;
import java.net.*;
import java.nio.charset.StandardCharsets;
import java.util.Scanner;

public class UDPclient {

    private DatagramSocket client;

    private String severIp;
    private int port;
    private SocketAddress address;

    public UDPclient (String severIp, int port) throws SocketException {
        this.client = new DatagramSocket();
        this.severIp = severIp;
        this.port = port;
        this.address = new InetSocketAddress(severIp, port);
    }

    public void start () throws IOException {
        System.out.println("客户端已启动~~");
        // 循环接收用户的输入
        Scanner sc = new Scanner(System.in);
        while (true) {
            System.out.println("请输入请求");
            String request = sc.next();
            // 1. 把请求内容包装成DatagramPacket
            DatagramPacket requestPacket = new DatagramPacket(request.getBytes(StandardCharsets.UTF_8),request.getBytes().length,address);
            //2. 发送数据
            client.send(requestPacket);
            //3. 接收响应
            DatagramPacket responsePacket = new DatagramPacket(new byte[1024],1024);
            //4. 在receive方法中填充响应数据
            client.receive(responsePacket);
            //5. 解析响应数据
            String response = new String(responsePacket.getData(),0,responsePacket.getLength(),"UTF-8");
            //6. 打印日志
            System.out.printf("request:%s, response : %s.\n",request,response);


        }
    }

    public static void main(String[] args) throws IOException {
        UDPclient pclient = new UDPclient("127.0.0.1",8888);
        pclient.start();
    }
}

结果展示:

 

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

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

相关文章

5月跳槽会有风险,不跳也会有?

今天讲讲跳槽。 说实话跳槽是为了寻求更好的发展&#xff0c;但在跳槽前我们也不能确定下家就是更好的归宿&#xff0c;这就更加需要我们审慎地去对待&#xff0c;不能盲目跳槽。 其次&#xff0c;我们离职和跳槽&#xff0c;其中的原因很大一部分是目前薪资不符合预期。 那…

Kyligence 客户案例招商银行批发业务分析平台获评金融数字化最佳实践案例

近日&#xff0c;“2023 爱分析金融数字化最佳实践案例”评选结果正式揭晓。Kyligence 携手招商银行申报的“招商银行‘火眼’批发业务分析平台”项目经过领先性、案例创新性、应用成熟度、价值创造等维度综合评选&#xff0c;最终获评“金融数字化最佳实践案例”。 招商银行“…

阿里 P9 推荐的 Spring 领域巅峰之作,直接颠覆了我对 Spring 的认知

写在前面 你第一次接触 spring 框架是在什么时候&#xff1f;相信很多人和我一样&#xff0c;第一次了解 spring 都不是做项目的时候用到&#xff0c;而是在网上看到或者是听到过一个叫做 spring 的框架&#xff0c;这个框架号称完爆之前的 structs 和 structs2&#xff0c;吸…

Jupyter设置指定的python环境

Jupyter设置指定的python环境 Jupyter在虚拟环境中启动 按理说在命令行执行如下命令 conda activate 环境名称激活一个conda环境&#xff0c;再打开jupyter&#xff0c;输入如下命令 jupyter notebook默认的python环境应该是刚刚激活的那个&#xff0c;但是我发现在window上…

git代码回滚是使用reset还是revert

时光不能回退&#xff0c;Git却允许我们改变历史。 想要让Git回退历史&#xff0c;有以下步骤&#xff1a; 使用git log命令&#xff0c;查看分支提交历史&#xff0c;确认需要回退的版本 使用git reset --hard commit_id命令&#xff0c;进行版本回退 使用git push origin命…

不需要策略模式也能避免满屏if/else

满屏if/else java 复制代码 public static void main(String[] args) { int a 1; if(a 1){ System.out.println("执行a1的逻辑"); }else if (a 2){ System.out.println("执行a2的逻辑"); }else if (a 3){ System.out.println("执行a3的逻辑&quo…

基于apache paimon实时数仓全增量一体实时入湖

用例简介 Apache Paimon&#xff08;以下简称 Paimon&#xff09;作为支持实时更新的高性能湖存储&#xff0c;本用例展示了在千万数据规模下使用全量 增量一体化同步 MySQL 订单表到 Paimon明细表、下游计算聚合及持续消费更新的能力。整体流程如下图所示&#xff0c;其中 …

R语言实践——rWCVP:世界维管植物名录的R包

rWCVP&#xff1a;世界维管植物名录的R包 介绍1. 参照github安装与简单例子1.1 安装rWCVP1.2 安装rWCVPdata1.3 github的例子 2. rWCVP原始文献阅读2.1 前言&#xff08;背景&#xff09;2.2 功能概要2.2.1 名称匹配&#xff08;wcvp_match_names(), wcvp_match_exact(), wcvp …

ChatGPT:你真的了解网络安全吗?浅谈攻击防御进行时之网络安全新定义

ChatGPT&#xff1a;你真的了解网络安全吗&#xff1f;浅谈网络安全攻击防御进行时 网络安全新定义总结 ChatGPT&#xff08;全名&#xff1a;Chat Generative Pre-trained Transformer&#xff09;&#xff0c;美国OpenAI 研发的聊天机器人程序&#xff0c;是人工智能技术驱动…

在字节跳动做了6年测试,5月无情被辞,想给划水的兄弟提个醒

先简单交代一下背景吧&#xff0c;某不知名 985 的本硕&#xff0c;17 年毕业加入字节&#xff0c;以“人员优化”的名义无情被裁员&#xff0c;之后跳槽到了有赞&#xff0c;一直从事软件测试的工作。之前没有实习经历&#xff0c;算是6年的工作经验吧。 这6年之间完成了一次…

API接口测试—详情版(拼多多根据ID取商品详情)

一、为什么要做接口测试 做接口测试的原因主要有以下几个方面&#xff1a; 1. 确保接口功能正确性&#xff1a;接口是不同软件系统或者不同模块之间的数据传输和交互的通道&#xff0c;通过接口测试能够确保不同系统或者模块之间传递的信息准确无误&#xff0c;从而保证了整个…

微信小程序点击icon实现分享功能

1.小程序分享功能实现方式 小程序分享功能有两种方式&#xff0c;监听用户点击页面内转发按钮&#xff08; 组件 open-type“share”&#xff09;或右上角菜单“转发”按钮的行为&#xff0c;并自定义转发内容。 使用微信小程序的分享功能需要定义onShareAppMessage(Object obj…

Java基础 变量与数据类型

变量 为什么需要变量 一花一世界&#xff0c;如果把一个程序看做一个世界或一个社会的话&#xff0c;那么变量就是程 序世界的花花草草、万事万物。即&#xff0c;变量是程序中不可或缺的组成单位&#xff0c;最基 本的存储单元。 初识变量 变量的概念 内存中的一个存储区域…

工作几年,涨薪4K遭拒,后一天我就裸辞走了···

19年7月大学毕业&#xff0c;当时学的计算机科学专业。因为考研之后&#xff0c;秋招结束了。也没什么更多的岗位选择&#xff0c;就想着找个工作先干着&#xff0c;刚好有个亲戚在一家大厂公司上班说要招测试&#xff0c;所以就来做测试了。 虽然都是属于计算机大类&#xff0…

chatgpt赋能Python-python_nor

了解Python NOR 在Python编程语言中&#xff0c;NOR运算是一种逻辑运算符&#xff0c;用于反转两个变量的逻辑值。它是布尔运算中的一种&#xff0c;通常用于检查两个条件是否都不成立。 NOR运算有两个输入和一个输出&#xff0c;当输入为空或两个输入都为False时&#xff0c…

nuxt视频播放(踩坑)

展示效果&#xff1a; nuxt样例视频 1.安装vue-video-player插件 ①执行命令 npm i vue-video-player 或者 npm i vue-video-player5.0.2 后者直接安装对应版本号的插件 ②安装完之后 执行npm i ③安装不对应的版本会报错 ④注意安装版本 不是vue3.0的 请安装&#xff08;“v…

【nginx】同一接口有时返回500(client_body_temp)

问题描述&#xff1a; 同一个接口&#xff0c;有能正常访问并返回的&#xff0c;有的访问未到服务器直接返回500。 查看nginx日志&#xff08;error.log&#xff09;&#xff0c;发现open() "/nginx/client_body_temp/0000476534" failed (13: Permission denied)报…

java的URL类

文章目录 1. 简介2. 创建URL3. 从URL获取数据4. 分解URL5. 相等性和比较 1. 简介 java.net.URL类是对统一资源定位符的抽象。它扩展了Object类&#xff0c;是一个final类&#xff0c;不能对其派生子类。它不依赖于继承来配置不同的URL实例&#xff0c;而使用了策略设计模式&am…

VivadoIO约束

VivadoIO约束 FPGA开发离不开IO约束和时序约束&#xff0c;IO约束用于确定输入/输出端口的物理端口和电气特性&#xff0c;与芯片和电路设计有关。而时序约束则用于设定FPGA设计中的时序特性&#xff0c;以确保系统能够在预期时钟频率下正常运行。本文将介绍vivado中常见的设置…

编码踩坑——Redis Pipeline中调用Lua脚本报错JedisMoveDataException的问题 / Lua脚本常遇到的问题

本篇记录使用Redis Pipeline时&#xff0c;调用redis.clients.jedis.PipelineBase#eval时&#xff0c;报错JedisMoveDataException的问题&#xff1b;通过查看源码发现问题的原因&#xff0c;通过jedis在Github的issue了解了解决方案&#xff1b;涉及知识&#xff1a;Redis slo…