网络编程(1)写一个简单的UDP网络通信程序【回显服务器】,并且实现一个简单的翻译功能

使用 JAVA 自带的api

目录

一、回显服务器 UdpEchoServer

服务器代码

客户端代码

二、翻译功能 UdpDictServer

在UdpDictServer里重写process方法


一、回显服务器 UdpEchoServer

/*** 回显服务器* 写一个简单的UDP的客户端/服务器 通信的程序* 这个程序没有啥业务逻辑,只是单纯的调用socket api* 让客户端给服务器发送一个请求,从控制台输入的字符串* 服务器收到字符串后,会把这个字符串原封不动的返回给客户端,客户端再显示出来运行过程* 1.先启动服务器 ,程序会进入while循环,执行到receive()阻塞,等待客户端的请求* 2.再启动客户端,程序也会进入while循环,执行到scanner 等待用户输入*      当用户输入字符串之后,next就会返回,构造请求数据,并发送给服务器* 3.客户端发送数据之后*      服务器就会从receive中返回,进一步执行解析请求UDP报,执行process计算响应操作,最后执行send操作,发送响应结果*      客户端接着执行到receive,等待服务器的响应* 4.客户端接收到服务器响应的数据之后,从receive中返回,执行打印操作,把响应的内容显示出来了* 5. 服务器执行完后,重新进入while循环,又执行到receive这里阻塞*    客户端执行完后,也重新进入while循环,执行到scanner这里阻塞**/

服务器代码

package network;import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;public class UdpEchoServer {//创建一个DatagramSocket对象,后续操作网卡的基础//socket 就是把网卡抽象成了文件//往socket文件中 写数据 ,就相当于通过网卡 发送数据//从socket文件中 读数据 ,就相当于通过网卡 接收数据//把网络通信和文件操作给统一了//在Java中就使用这个类,来表示系统内部的 socket 文件了//常用的socket的方法:receive(DatagramPacket P) ,send(DatagramPacket P), close//DatagramPacket 这个类,用来表示一个UDP数据报//UDP是面向数据报的//每次进行传输,都要以UDP数据包为基本单位private DatagramSocket socket = null;//构造方法//服务器需要手动 显示指定端口号,可以避免端口号冲突//客户端的socket 一般不能显示指定(系统会随机分配一个端口)//传入参数为 int portpublic UdpEchoServer(int port) throws SocketException {//手动指定端口号socket = new DatagramSocket(port);//不带参数就是系统自动分配端口号
//        socket = new DatagramSocket();}//服务器启动方法//通过这个方法来启动服务器public void start() throws IOException {//服务器启动提示System.out.println("服务器启动!");//服务器一般开了就不关了,7*24小时不停歇运转,所以是while(true)形式while(true){//1.读取请求并解析//创建UDP数据报 DatagramPacket对象 接收 客户端的数据//收到的数据需要用内存空间保存,而DatagramPacket 内部不能自行分配内存空间//于是需要程序员手动把空间创建好,交给DatagramPacket 进行处理,使用字节数组创建DatagramPacket requestPacket = new DatagramPacket(new byte[4096],4096);//保存请求信息socket.receive(requestPacket);//接收请求信息。数据没来的时候,会先阻塞,直到客户端把请求发来为止//接收到的数据,是以二进制的形式存储到DatagramPacket中了//要想显示出来,需要将这个二进制数据转换成字符串String request = new String(requestPacket.getData(),0,requestPacket.getLength());//参数为 二进制数据,偏移量从0开始到requestPacket.getLength()这个数据结尾//2.根据请求计算响应//实际开发项目中,服务器中最核心的步骤,绝大数程序都是在完成这一部分String response = process(request);//3.把响应写回到客户端// 创建响应对象,DatagramPacket// 往这个对象里构造刚才的数据,再通过send返回DatagramPacket responsePacket = new DatagramPacket(response.getBytes(),response.getBytes().length,requestPacket.getSocketAddress());//传入的参数 获取 数据的起始地址response.getBytes(),数据的字节长度response.getBytes().length,响应给 客户端的ip地址requestPacket.getSocketAddress()//指定字节数组缓冲区,同时指定 客户端UDP请求报中的网卡信息requestPacket.getSocketAddress()(其中包含了ip和端口号)//网络传输,使用字节,以字节为单位socket.send(responsePacket);//4.打印一个日志,把这次数据交互的详情打印出来System.out.printf("[%s:%d] request=%s response=%s\n",requestPacket.getAddress().toString(),requestPacket.getPort(),request,response);//打印的内容:客户端的ip:客户端的端口号 请求内容 响应内容}}//响应程序//这里只是简单回显
//这里写public才能被重写public String process(String request) {return request;}public static void main(String[] args) throws IOException {UdpEchoServer server = new UdpEchoServer(9090);server.start();}
}

客户端代码

package network;import java.io.IOException;
import java.net.*;
import java.util.Scanner;public class UdpEchoClient {private DatagramSocket socket = null;//对网卡进行操作,接收或发送数据报,或者关闭//因为UDP报不会建立链接,也不会存储对端的信息//所以在应用程序里把它存储起来private  String serverIp = "";private int serverPort = 0;public UdpEchoClient(String ip , int port) throws SocketException {//客户端不能指定端口号码,会端口冲突socket = new DatagramSocket();//客户端 系统随机分配端口,不写参数就是系统随机分配//因为UDP报不会建立链接,也不会存储对端的信息//所以在应用程序里把它存储起来//这里主要记录对端的 ip 和 端口serverIp = ip;serverPort = port;}//启动客户端程序public void start() throws IOException {//启动客户端提示System.out.println("客户端启动!");//用户输入字符串Scanner scanner = new Scanner(System.in);while(true){//1.从控制台读取数据,作为请求System.out.print("->");//输入提示符String request = scanner.next();//请求信息的内容//2.把请求内容构造成一个DatagramPacket对象,发送给服务器DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),request.getBytes().length,InetAddress.getByName(serverIp),serverPort);//request.getBytes(),request.getBytes().length指定字节数组缓冲区,同时指定 ip 和 端口号 InetAddress.getByName(serverIp),serverPortsocket.send(requestPacket);//发送UDP数据报//3.尝试读取客户端的响应DatagramPacket responsePacket = new DatagramPacket(new byte[4096],4096);//创建一个空的UDP数据报来接收服务器的响应数据socket.receive(responsePacket);//4.把接收的响应数据 由二进制 转换成 字符串 显示出来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",9090);//该参数为对端(服务器)的ip和端口client.start();}
}

运行结果:

* 1.先启动服务器 ,程序会进入while循环,执行到receive()阻塞,等待客户端的请求

* 2.再启动客户端,程序也会进入while循环,执行到scanner 等待用户输入

* 当用户输入字符串之后,next就会返回,构造请求数据,并发送给服务器

* 3.客户端发送数据之后

* 服务器就会从receive中返回,进一步执行解析请求UDP报,执行process计算响应操作,最后执行send操作,发送响应结果

* 客户端接着执行到receive,等待服务器的响应

* 4.客户端接收到服务器响应的数据之后,从receive中返回,执行打印操作,把响应的内容显示出来了

* 5. 服务器执行完后,重新进入while循环,又执行到receive这里阻塞 * 客户端执行完后,也重新进入while循环,执行到scanner这里阻塞 * */ 

二、翻译功能 UdpDictServer

在回显服务器的基础上,创建一个新的类,继承回显服务器

在UdpDictServer里重写process方法

package network;import java.io.IOException;
import java.net.SocketException;
import java.util.HashMap;
import java.util.Map;public class UdpDictServer extends UdpEchoServer{private Map<String,String> dict = new HashMap<>();
//重写构造方法public UdpDictServer(int port) throws SocketException {super(port);dict.put("猫","cat");dict.put("狗","dog");dict.put("今天","today");dict.put("cat","猫");dict.put("dog","狗");dict.put("today","今天");}//重写父类 UdpEchoServer 的process方法//完成翻译逻辑,翻译本质上是“查表”//刚才再dict哈希表里添加了一些键值对元素//刚才在重写的地方报错//原因是 父类的process方法之前用的是private//而private封装特性,不能被重写//改成public之后就可以了@Overridepublic String process(String request) {
//        return dict.get(request);return dict.getOrDefault(request,"该单词目前不在表中,无法查看!!");//差不到表中信息,可以给默认值}public static void main(String[] args) throws IOException {//如果端口号也是9090就与父类的端口号冲突了UdpDictServer dictServer = new UdpDictServer(6666);//指定这个翻译功能 的端口是6666dictServer.start();//此时,这里调用start的是子类UdpDictServer,所以后面调用的process也是子类重写的方法//这里就是之前学到的多态}
}

 注意:

翻译服务器里main方法里的端口要与父类不一样,避免端口号冲突

同时客户端开启的时候,要把端口号修改过来6060,不然服务器就连错了

运行结果

 

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

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

相关文章

C++中,判断某个自定义结构体是否在该结构体的vector中

demo1源码&#xff1a; #include <iostream> #include <vector> #include <algorithm> using namespace std;struct PushStreamIpAndPort {std::string ip"";int port0;// 重载相等运算符 &#xff1a;可不用bool operator(cons…

TSINGSEE青犀智慧工厂视频汇聚与安全风险智能识别和预警方案

在智慧工厂的建设中&#xff0c;智能视频监控方案扮演着至关重要的角色。它不仅能够实现全方位、无死角的监控&#xff0c;还能够通过人工智能技术&#xff0c;实现智能识别、预警和分析&#xff0c;为工厂的安全生产和高效运营提供有力保障。 TSINGSEE青犀智慧工厂智能视频监…

PaddleGAN快速让你的照片动起来

一个不知名大学生&#xff0c;江湖人称菜狗 original author: Jacky Li Email : 3435673055qq.com Time of completion&#xff1a;2024.03.30 Last edited: 2024.03.30 目录 PaddleGAN快速让你的照片动起来 两个方案让照片动起来 方案一&#xff1a;FirstOrder 下载Paddle…

CAPL实现关闭TCP连接的几种方式以及它们的区别

在讲正文前,我们有必要复习下关闭TCP连接的过程:四次挥手。 假设A和B建立TCP连接并进行数据传输,当A的数据发送完后,需要主动发起断开连接的请求: A发送FIN报文,发起断开连接的请求B收到FIN报文后,首先回复ACK确认报文B把自己的数据发送完,发送FIN报文,发起断开连接的…

uniapp中安装vant2

1.uniapp项目搭建 因为是安装vant2所以项目选择vue2&#xff0c;如果vue3项目的话安装vant3 2.安装vant npm i vantlatest-v2 3.在main.js文件引入挂载vant 说明&#xff1a;// #ifndef VUE3这里是vue2模板用来挂载注册组件的地方&#xff1b;// #ifdef VUE3这里是vue3模板…

服务器操作系统有几种?

众所周知&#xff0c;电脑上的一切正常运作都不可缺电脑操作系统的使用&#xff0c;网络服务器做为这种出示服务项目的服务器&#xff0c;或许都是不可 或缺的电脑操作系统。常用的网络服务器电脑操作系统有许多&#xff0c;比如&#xff1a;Windows、Linux、Unix等等&#xff…

Spring Boot简介及案例

文章目录 Spring Boot简介以下是一个简单的 Spring Boot Web 应用实例**步骤 1&#xff1a;创建 Spring Boot 项目****步骤 2&#xff1a;编写 RESTful 控制器****步骤 3&#xff1a;配置主类****步骤 4&#xff1a;运行并测试应用** Spring Boot简介 Spring Boot 是一个用于简…

Linux服务器进程自动停止/终结

记录一个现场问题&#xff1a;Linux服务器中的服务进程莫名被杀死&#xff0c;或者启动失败 情况说明&#xff1a;现场是一台Linux的suse系统服务器&#xff0c;前一天客户反应服务有异常&#xff0c;登录查看发现所有的服务进程都没有启动&#xff0c;以为是客户重启服务器了&…

K8S Pod 水平自动扩缩容 HPA

介绍 HPA&#xff08;Horizontal Pod Autoscaler&#xff09;水平扩缩意味着可根据观察到的CPU、内存使用率或自定义度量标准来自动扩展或缩容Pod的数量&#xff08;Deployment、StatefulSet 或其他类似资源&#xff09;。与“垂直”扩缩不同&#xff0c;对于 K8S&#xff0c;…

canvas跟随鼠标画有透明度的矩形边框

提示&#xff1a;canvas跟随鼠标画有透明度的矩形边框 文章目录 前言一、跟随鼠标画有透明度的矩形边框总结 前言 一、跟随鼠标画有透明度的矩形边框 test.html <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8">&…

【动手学深度学习-pytorch】9.2长短期记忆网络(LSTM)

长期以来&#xff0c;隐变量模型存在着长期信息保存和短期输入缺失的问题。 解决这一问题的最早方法之一是长短期存储器&#xff08;long short-term memory&#xff0c;LSTM&#xff09; (Hochreiter and Schmidhuber, 1997)。 它有许多与门控循环单元&#xff08; 9.1节&…

HTX Ventures:为什么BounceBit可能成为新的BTC生态解决方案?

随着BTC现货ETF的通过&#xff0c;全球各大机构和个人都在不断加码对BTC的持仓&#xff0c;BTC价格也随之上升&#xff0c;目前已上升至全球市值排名前十的资产。在本轮市场周期中&#xff0c;BTC铭文和BTC扩容是两个被市场高度关注的细分赛道。BTC生态资产的多元化收益探索正在…

mydumper和myloader对MySQL数据备份和恢复

安装教程省略 一、mydumper数据备份 mydumper -u root -p 123456 -P 3306 -B db1 -o /data/20240329root&#xff1a;数据库用户名 123456&#xff1a;密码 3306&#xff1a;端口 db1&#xff1a;数据库库名 /data/20240329&#xff1a;导出的备份文件存放位置 导出的数据文…

Django详细教程(一)

文章目录 一、安装Django二、创建项目1.终端创建项目2.Pycharm创建项目&#xff08;专业版才可以&#xff09;3.默认文件介绍 三、创建app1.app介绍2.默认文件介绍 四、快速上手1.写一个网页步骤1&#xff1a;注册app 【settings.py】步骤2&#xff1a;编写URL和视图函数对应关…

mysql权限相关操作

创建mysql用户并开通某数据库的特定权限 CREATE USER username% IDENTIFIED BY 123456; GRANT INSERT,DELETE,UPDATE,SELECT ON xxxdb.* TO username%; GRANT ALL PRIVILEGES ON caieinstitute.* TO caie%;//给全部管理权限 修改某用户登录所需使用的IP select * from user w…

面试题:@Component, @Service, @Repository, @Controller 注解的区别与用途

在Spring框架中&#xff0c;Component, Service, Repository, 和 Controller 都是用来标记Bean并将其纳入Spring IoC容器管理的注解&#xff0c;它们的主要区别在于用途和语义上的强调&#xff0c;旨在提高代码的可读性和更好的组织架构。 1. Component - 用途这是Spring中定…

基于微信小程序的校园服务平台设计与实现(程序+论文)

本文以校园服务平台为研究对象&#xff0c;首先分析了当前校园服务平台的研究现状&#xff0c;阐述了本系统设计的意义和背景&#xff0c;运用微信小程序开发工具和云开发技术&#xff0c;研究和设计了一个校园服务平台&#xff0c;以满足学生在校园生活中的多样化需求。通过引…

最优算法100例之13-输出第n个丑数

专栏主页:计算机专业基础知识总结(适用于期末复习考研刷题求职面试)系列文章https://blog.csdn.net/seeker1994/category_12585732.html 题目描述 把只包含因子2、3和5的数称作丑数(Ugly Number)。例如6、8都是丑数,但14不是,因为它包含因子7。 习惯上我们把1当…

使用Hive对HDFS中数据查询的优点

目录 摘要一、Hive是什么二、HDFS是什么三、Hive与HDFS的关系四、什么是HiveQL五、什么是mapreduce六、Hive如何将查询转为mapreduce任务七、Hadoop生态系统中的高性能引擎八、使用Hadoop的优点 摘要 Hadoop生态系统中包含了多个关键组件&#xff0c;如Hive、HDFS、MapReduce等…

Typora:一款值得尝试的Markdown编辑器

引言&#xff1a; 随着博客的兴起&#xff0c;越来越多的人开始写博客。而Markdown作为一种轻量级标记语言&#xff0c;因其简洁、易读、易写、易转换等特点而被广泛使用。Markdown的语法简单易学&#xff0c;使用起来也比较方便。但是&#xff0c;为了更好地使用Markdown&…