首页 > 编程语言 >【JavaEE】——回显服务器的实现

【JavaEE】——回显服务器的实现

时间:2024-10-10 21:17:31浏览次数:13  
标签:DatagramPacket socket 回显 JavaEE requestPacket new 服务器 String

 8e19eee2be5648b78d93fbff2488137b.png

阿华代码,不是逆风,就是我疯

你们的点赞收藏是我前进最大的动力!!

希望本文内容能够帮助到你!!

目录

一:引入

1:基本概念

二:UDP socket API使用

1:socket文件

2:DatagramSocket类

(1)构造方法

(2)方法

3:DatagramPacket类

三:回显服务器——服务器

1:引入(必看)

2:服务器响应代码

(1)注释版本

(2)无注释版本

3:细节补充

4:特点

四:回显服务器——客户端

1:代码

(1)注释版本

(2)无注释版本

2:注意点

五:回显服务器过程文字梳理

六:知识补充


前引:本文代码建议反复敲打至少3遍!!!!

一:引入

1:网络编程的基本概念

网络编程就是通过写代码来完成基于网络的跨主机通信

本质上是学习传输层给应用层提供的一系列的API,通过API把数据交给传输层,在经过层层封装之后,通过网卡,把数据发送出去。

这里使用的API是传输层提供的,传输层涉及到的主要协议有两个:TCP和UDP

后面通过代码详细理解这些特点

①有/无连接:这里的“连接”是虚拟的,抽象的连接

例:打电话——打过去对方接才能通话;微信发消息不管对面在不在线,消息都发出去了

②可/不可靠传输:可以知道数据到没到达对方

③面向字节流:传输数据的基本单位就是字节

④面向数据报:传输的的基本单位是一个“数据报”——由一系列字节构成的特定结构UDP

⑤全双工:可以双向通信

⑥半双工:只能单向通信

客户端:发送请求的一方,发送的数据叫做“请求”

服务器:被动接受请求的一方,给客户端返回的数据叫做“响应”

客户端和服务器之间的交互有这几种模式:“一问一答”,“一问多答”,“多问一答”,“多问多答”,

二:UDP socket API使用

引入:UDP核心类有两个DatagramSocket,DatagramPacket

1:socket文件

操作系统中有一类文件就叫做socket文件,区别于放在硬盘上的普通文件,socket文件是放在“网卡”这样的硬件设备上——通过网卡发送数据,就是写socket文件;接受数据,就是读socket文件

2:DatagramSocket类

(1)构造方法

(2)方法

3:DatagramPacket类

UDP面向数据报,每次发送和接收数据的基本单位就是一个UDP数据报

(1)构造方法

(2)方法

三:回显服务器——服务器

1:引入(必看)

以下代码是实现一个“回显服务器”——是网络编程中的“hello world”,但是对新手小白并不友好

大致流程为:客户端发出请求,服务器收到客户端的请求,完成业务并返回响应,客户端接受响应

先附赠上服务器的代码,(按照步骤去边理解边敲)(重在理解,重在理解)

2:服务器响应代码

(1)注释版本

package network;

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

/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: Hua YY
 * Date: 2024-10-07
 * Time: 17:20
 */
public class UdpEchoServer {
    //1:创建DatagramSocket对象
    private DatagramSocket socket = null;//socket:插槽插座
    //2:构造方法,服务器一启动,就要关联/绑定上一个操作系统中的端口号(服务器的端口号哦啊通常由程序员指定)
    //抛出的异常通常为scoket创建失败
    public UdpEchoServer(int port) throws SocketException {
        socket = new DatagramSocket(port);//端口号port
    }
    //3:服务器启动逻辑
    //5:抛异常,网络编程socket本质上也是IO
    public void start() throws IOException {
        System.out.println("服务器启动");
        while(true){
            //3:创建一个数据报,它是每次发送数据和接收数据的一个基本单位
            // 参数为输出型参数,字节数组,对应UDP的载荷部分,一开始是空的
            DatagramPacket requestPacket = new DatagramPacket(new byte[4096],4096);
            //4;socket读网卡能读到一个UDP数据报(里面会包含数据源IP,源端口),放到requestPacket(数据报)对象中
            //如果没有接受到请求那么就会阻塞等待,此处收到的数据是先存到socket文件的内存缓冲区中。非硬盘
            socket.receive(requestPacket);
            //5:基于字节数组构造String对象,数组中的数据可能是文本数据(给String刚好)也可能是二进制数据(Java也能保存)
            //这里的长度是有效长度
            String request = new String(requestPacket.getData(),0,requestPacket.getLength());
            //6:根据请求计算响应
            String response = process(request);
            //7:把响应(String)字节给拎出来,构造成一个DatagramPacket数据报,在传入socket对象(因为4中我们说过收到请求时,socket能读到源IP和源端口)
            //这时我们把这个源IP和源端口,作为响应的目的IP和目的端口(确认客户端的发出请求的位置),返回回去
            //注:response.length()单位是字符,此处单位是字节
            DatagramPacket responsePacket = new DatagramPacket(response.getBytes() , response.getBytes().length , requestPacket.getSocketAddress());
            socket.send(responsePacket);

        }
    }
    //7:构造响应,这里是回显服务器,所以就是单纯的return

    private String process(String request) {
        return request;
    }

}

(2)无注释版本

package repeat2;

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

/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: Hua YY
 * Date: 2024-10-10
 * Time: 18:28
 */
public class UdpServer {
    private DatagramSocket socket = null;
    public UdpServer(int port) throws SocketException {
        socket = new DatagramSocket(port);
    }
    public void start() throws IOException {
        System.out.println("服务器启动");
        while(true){
            DatagramPacket requestPacket = new DatagramPacket(new byte[4096],4096);
            socket.receive(requestPacket);
            //转化为字符串
            String request = new String(requestPacket.getData(),0,requestPacket.getLength());
            String response = process(request);
            DatagramPacket responsePacket = new DatagramPacket(response.getBytes(),response.getBytes().length,
                    requestPacket.getSocketAddress());
            socket.send(responsePacket);
            System.out.printf("[%s,%d]  request: %s  response: %s\n ",
                    requestPacket.getAddress().toString(),requestPacket.getPort(),request,response);
        }
    }
    public String process(String request){
        return request;
    }

    public static void main(String[] args) throws IOException {
        UdpServer server = new UdpServer(9096);
        server.start();
    }
}

3:细节补充

这里在补充一些细节:

①创建完socket对象后,可以通过socket对象来操作网卡(具体:因为socket对象是在内存中的,针对这个内存对象进行操作就可以影响到网卡)

②构造方法(还有无参的上面有写)中的参数,是我们指定的,进程一启动就要绑定上操作系统中的端口号,这个端口号是一个整数,用来区分一个主机上的进行网络通信的不同程序

一个端口号只能被一个进程绑定,但是一个进程可以绑定多个端口号(像极了爱情~~,爱情中宁死不做端口号~~)

③SocketException,类似端口号被别的进程占用就会报异常

④因为服务器需要不停的运作,所以while一直循环

⑤数据报中的数组就是载荷部分

⑥receive有阻塞等待功能

⑧数据报的位置在socket对象的内存缓冲区中

⑨构造响应数据报

4:特点

上述代码可以体现出UDP是——

(1)无连接通信

UDP的DAtagramSocket自身并不需要保存对端的IP和端口,对端IP和端口在数据报中就已经包含,另外代码中也没有“建立连接”和“接受连接”这种操作

(2)不可靠数据——代码没体现(略)

(3)面向数据报

send方法和receive方法都是以DatagramPacket为基本单位的

(4)全双工

一个socket既可以发送数据报又可以接受数据报(属于是自力更生了)

四:回显服务器——客户端

1:代码

(1)注释版本

package network;

import java.io.IOException;
import java.net.*;
import java.util.Scanner;

/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: Hua YY
 * Date: 2024-10-07
 * Time: 17:20
 */
public class UdpEchoClient {
    private DatagramSocket socket = null;
    private String serverIp;
    private int serverPort;
    public UdpEchoClient(String serverIp , int serverPort) throws SocketException {
        this.serverIp = serverIp;
        this.serverPort = serverPort;
        socket = new DatagramSocket();//传入参数为请求的目的ip和目的端口,源ip为本机ip源端口为系统分配的端口


    }
    public void start() throws IOException {
        System.out.println("客户端启动");
        Scanner scanner = new Scanner(System.in);
        while(true){
            System.out.print("->");
            if (!scanner.hasNext()){//如果没有输入的话就结束循环
                break;
            }
            String request = scanner.next();//人为输入请求
            DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),request.getBytes().length,
                    InetAddress.getByName(serverIp),serverPort);//指定服务器的ip和端口,分开的
            socket.send(requestPacket);
            DatagramPacket responsePacket = new DatagramPacket(new byte[4096] , 4096);
            socket.receive(responsePacket);
            //转化为字符串
            String response = new String(responsePacket.getData(),0,responsePacket.getLength());//内置getLength()获取length成员变量
            System.out.println(response);



        }
    }

    public static void main(String[] args) throws IOException {
        UdpEchoClient client = new UdpEchoClient("127.0.0.1",9090);
        client.start();
    }
}

(2)无注释版本

package repeat2;

import java.io.IOException;
import java.net.*;
import java.util.Scanner;

/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: Hua YY
 * Date: 2024-10-10
 * Time: 18:29
 */
public class UdpEchoClient {
    private DatagramSocket socket = null;
    private String serverIp;
    private int serverPort;
    public UdpEchoClient(String serverIp , int serverPort) throws SocketException {
        this.serverIp = serverIp;
        this.serverPort = serverPort;
        socket = new DatagramSocket();
    }
    public void start() throws IOException {
        System.out.println("客户端启动");
        Scanner scanner = new Scanner(System.in);
        while(true){
            System.out.print("->");
            if(!scanner.hasNext()){
                break;
            }
            String request = scanner.next();
            DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),
                    request.getBytes().length, InetAddress.getByName(serverIp),serverPort);
            socket.send(requestPacket);
            //接收响应
            DatagramPacket responsePacket = new DatagramPacket(new byte[4096] , 4096);
            socket.receive(responsePacket);
            String response = new String(responsePacket.getData(),0,responsePacket.getLength());
            System.out.println(response);//

        }
    }

    public static void main(String[] args) throws IOException {
        UdpEchoClient client = new UdpEchoClient("127.0.0.1",9096);
        client.start();
    }
}

2:注意点

(1)服务器端口号需要手动指定是确保,客户端可以找到服务器,客户端的端口号是操作系统的内核随机分配的 (确保分配的端口号是空闲可用的)

(2)Scanner从控制台读取字符串最好使用next非nextLine

(如果是从文件读取就无所谓了)

①next读取

②nextLine读取

(3).length和.length()方法的区别

五:回显服务器过程文字梳理

六:知识补充

1:.length和.length()的区别

引用文章java中length和length()的区别_length变量与length函数 java-CSDN博客

2:字符串转数组

标签:DatagramPacket,socket,回显,JavaEE,requestPacket,new,服务器,String
From: https://blog.csdn.net/2301_80133875/article/details/142744707

相关文章

  • 获取pytdx行情服务器ip和port
    之前一直用的api.connect('124.71.187.122',7709)突然不能用了,调查了一下,给出如下解决方案打开通达信客户端,选项->通讯设置。勾掉"登录时查找最快的主站",手动选择"行情主站",点确定。点击"选项"中的"断开行情主站",再点"连接行情主站"。打开windows任务管理器,找到通达信进程......
  • 如何将React项目,部署到Web服务器的Tomcat 上
    将React应用部署到Tomcat服务器上通常需要将其构建为静态文件,然后将这些文件放入Tomcat的webapps目录。以下是具体步骤:步骤指南1.构建React应用首先,你需要在本地构建你的React应用。npmrunbuild这会在项目根目录下生成一个build文件夹,里面包含了优化......
  • 浏览器报错 | 代理服务器可能有问题,或地址不正确
    问题描述Windows连网情况下,浏览器访问地址显示“你尚未连接,代理服务器可能有问题,或地址不正确。”解决方法电脑右下侧的WiFi图标右键,打开网络和Internet设置打开代理打开自动设置代理的“自动检测设置”关闭手动设置代理的“使用代理服务器”这样就可以正......
  • 什么是专业高防服务器?
    专业高防服务器是一种专门设计用于应对大规模网络攻击的服务器,尤其是DDoS(分布式拒绝服务)攻击。它通过高性能的硬件配置和强大的防御系统,能够有效保障网络服务的稳定性和安全性。对于那些易遭受恶意攻击的行业,例如游戏、电商、金融、政府等领域,专业高防服务器是确保网络稳定和用户......
  • 中国移动宽带 IPv6 连接到公网,家庭宽带设置服务器(2024年10月)
    摘要:1、中国移动的宽带,已经支持IPv6,需要宽带光猫上做好设置。2、需要从中国移动的服务器上获取公网IPv6地址。 操作:1、确保宽带WAN连接的前缀获取方式:PrefixDelegation网关的默认登录用户名(user)、密码,在设备的背面有写着。 如果不是,就联系客服,询问宽带终端的超级......
  • sqlserver建立与Oracle的链接服务器
    1.下载轻量级的ODAC安装包https://www.oracle.com/database/technologies/odac-downloads.html2.解压ODAC112030Xcopy_x64.zip(我解压到了C盘下):  3.在命令行界面进入解压文件夹后运行“install.batoledbc:\oracle odac”安装:4.在系统环境变量中,为Path添加“C:\ora......
  • Python 文件发送到对方服务器文件夹内
    为了将Python文件发送到服务器的文件夹内,你可以使用paramiko库来实现SSH连接,并进行文件传输。以下是一个简单的例子:首先,安装paramiko库(如果你还没有安装的话): pipinstallparamiko 然后,使用以下Python代码将文件发送到远程服务器:  importparamiko#设置SSH......
  • Oracle11g服务器linux 安装
    一.安装前准备1.检查硬件(内存,交换分区,tmp分区,cpu信息,内核版本)  #grepMemTotal/proc/meminfo  #grepSwapTotal/proc/meminfo  #df-k/tmp(>400M)  #grep"modelname"/proc/cpuinfo  #uname –r(-a,-m)查看Linux系统版本2.检查所需软件包(两种安......
  • Triton Inference Server: 高性能AI推理服务器
    serverTritonInferenceServer简介TritonInferenceServer是NVIDIA开发的开源AI推理服务器,旨在为企业级AI部署提供高性能、灵活和可扩展的解决方案。它支持多种深度学习和机器学习框架,可以在云端、数据中心、边缘设备和嵌入式系统上进行推理。TritonInferenceServer的主......
  • 自定义tomcat的服务器名称和版本号
    要修改Tomcat的服务器名称和版本号,你需要编辑Tomcat的server.xml配置文件。这个文件通常位于Tomcat安装目录的conf文件夹下。打开server.xml文件。找到以下部分:<Connectorport="8080"protocol="HTTP/1.1"connectionTimeout="20000"redirect......