当前位置： 首页 > news >正文

Java--网络编程(二)

news 2025/10/14 12:17:49

Udp 服务器和客户端

一.回显服务器

import java.io.IOException;
import java.net.*;public class EdpChoServe {private DatagramSocket socket = null;public EdpChoServe(int port) throws SocketException {socket = new DatagramSocket(port);}public void start() throws IOException {System.out.println("服务器启动");while (true){//创建接收缓冲区DatagramPacketDatagramPacket requestparcket = new DatagramPacket(new byte[1024],1024);//接收客户端数据socket.receive(requestparcket);//将数据转化为字符串类型String request = new String(requestparcket.getData(),0, requestparcket.getLength());//将转化后的数据通过process方法进行处理（此处直接返回，如果要进行相关数据的处理直接修改process方法）String response = process(request);//再次创建DatagramPacket套接字，将加工的数据给客户端发送DatagramPacket responsePacket = new DatagramPacket(response.getBytes(),response.getBytes().length,requestparcket.getSocketAddress());//发送数据socket.send(responsePacket);//打印客户端地址,端口,请求和相应信息System.out.printf("[%s:%d] req:%s,resp:%s\n",requestparcket.getAddress().toString(),requestparcket.getPort(),request,response);}}private String process(String request){String response = "服务端返回的消息："+request;return response;}public static void main(String[] args) throws IOException {EdpChoServe serve = new EdpChoServe(1010);serve.start();}
}

import java.io.IOException;
import java.net.*;
import java.util.Scanner;public class EdpChoClient {private DatagramSocket socket = null;private String IP;private int Port;public EdpChoClient(String ip,int port) throws SocketException {socket = new DatagramSocket();this.IP = ip;this.Port = port;}public void start() throws IOException {System.out.println("客户端启动");Scanner scanner = new Scanner(System.in);while (true){//输入要传输的内容String request = scanner.next();//创建DatagramPacket来储存数据 字节数组，数组长度,IP地址和端口号DatagramPacket requestpacket = new DatagramPacket(request.getBytes(),request.getBytes().length, InetAddress.getByName(this.IP),this.Port);//发送数据socket.send(requestpacket);DatagramPacket responsePacket = new DatagramPacket(new byte[1024],1024);//接收客户端处理后的消息socket.receive(responsePacket);//转化为 String 类型String response = new String(responsePacket.getData(),0,responsePacket.getLength());//打印System.out.println(response);}}public static void main(String[] args) throws IOException {EdpChoClient client = new EdpChoClient("127.0.0.1",1010);client.start();}
}

二.翻译服务器

翻译服务器跟我们上个文章做的回显服务器相似：

我们用 HashMap 来模拟字典，当我们输入单词的时候，返回相对应的意思

翻译服务器和回显服务器的区别就是对收到的信息进行处理的方式不同，回显服务器我们直接返回的字符串，翻译服务器我们通过 HashMap 来获取翻译后的结果并返回，

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.Socket;
import java.net.SocketException;
import java.util.HashMap;public class UdpServe {private HashMap<String,String> dic = new HashMap<String,String>();private DatagramSocket socket= null;public UdpServe(int port) throws SocketException {socket = new DatagramSocket(port);//创建词典，实际应用的话，数据要比这些多的多dic.put("hello","你好");dic.put("world","世界");}public void start() throws IOException {System.out.println("服务器启动");while (true){//创建数据缓存区，准备接收数据DatagramPacket resquestpacket = new DatagramPacket(new byte[1024],1024);//接收数据，将数据存入缓存区socket.receive(resquestpacket);//将数据转化为字符串String request = new String(resquestpacket.getData(),0, resquestpacket.getLength());//对内容进行处理String newrequest = process(request);//创建数据缓存区，准备发送处理后的数据DatagramPacket response = new DatagramPacket(newrequest.getBytes(),newrequest.getBytes().length,resquestpacket.getSocketAddress());//发送数据socket.send(response);//打印相关内容System.out.printf("[%s:%d] req:%s,resq:%s\n",resquestpacket.getAddress().toString(),resquestpacket.getPort(),resquestpacket,response);}}private String process(String request) {return dic.getOrDefault(request,"未找到单词");}public static void main(String[] args) throws IOException {UdpServe serve = new UdpServe(9090);serve.start();}
}

import java.io.IOException;
import java.net.*;
import java.util.Scanner;public class UdpClient {private DatagramSocket socket = null;private String IP;private int Port;public UdpClient(String IP,int Port) throws SocketException {//实例化对象并且添加属性socket = new DatagramSocket();this.IP = IP;//IP地址this.Port = Port;//端口号}public void start() throws IOException {System.out.println("客户端启动");Scanner scanner = new Scanner(System.in);while (true){//读取输入内容String request = scanner.next();//创建数据缓存区，准备发送数据DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),request.getBytes().length, InetAddress.getByName(this.IP),this.Port);//发送数据socket.send(requestPacket);//再次创建数据缓存区，准备接收数据DatagramPacket responsePacket = new DatagramPacket(new byte[1024],1024);//接收数据socket.receive(responsePacket);//转化为字符串类型String response = new String(responsePacket.getData(),0, responsePacket.getLength());//打印接收到的内容System.out.println(response);}}public static void main(String[] args) throws IOException {UdpClient Client = new UdpClient("127.0.0.1",9090);Client.start();}
}

Tcp 服务器和客户端

一.回显服务器

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;public class TcpServe {private ServerSocket serversocket = null;public TcpServe(int Port) throws IOException {serversocket = new ServerSocket(Port);}public void start() throws IOException {System.out.println("服务器启动");while (true){Socket socket = serversocket.accept();ProcessNection(socket);}}private void ProcessNection(Socket socket) throws IOException {System.out.printf("[%s:$d]","客户端上线",socket.getInetAddress(),socket.getPort());//创建输入流和输出流分别用来读取和输出数据try(InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream()) {//创建 scanner 来读取数据Scanner scanner = new Scanner(inputStream);//将字符串直接写入到socket的输出流中发送给客户端。PrintWriter writer = new PrintWriter(outputStream);while(true){//检查客户端是否下线if (!scanner.hasNext()){System.out.printf("[%s:%d] 客户端下线\n",socket.getInetAddress(),socket.getPort());}//读取数据String request = scanner.next();//处理数据String resoponse = process(request);//输出数据给客户端writer.println(resoponse);//冲刷缓冲区writer.flush();//打印客户端信息System.out.printf("[%s:%d] req:%s resp:%s\n",socket.getInetAddress(),socket.getPort(),request,resoponse);}} catch (IOException e) {throw new RuntimeException(e);}finally {try {//关闭与客户端的socket连接socket.close();}catch (IOException e){e.printStackTrace();}}}private String process(String request) {return request;}public static void main(String[] args) throws IOException {TcpServe server = new TcpServe(1010);server.start();}
}

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;public class TcpClient {private Socket socket = null;public TcpClient(String IP,int Port) throws IOException {socket = new Socket(IP,Port);//socket.connect(new InetSocketAddress(InetAddress.getByName(IP),Port));}public void start(){System.out.println("客户端启动");//创建输入流和输出流分别用来读取和输出数据try(InputStream inputStream = socket.getInputStream();OutputStream outputStream = socket.getOutputStream()){System.out.println("->");//输入要发送给服务器的数据Scanner scanner = new Scanner(System.in);//用于获取数据和输出数据Scanner newScanner = new Scanner(inputStream);PrintWriter writer = new PrintWriter(outputStream);while (true){//读取输入内容String request = scanner.next();//发送数据writer.println(request);//缓存区冲刷writer.flush();//检查从服务器接收的数据流是否还有下一个数据项if (!newScanner.hasNext()){break;}//将数据转化为字符串类型String response = newScanner.next();System.out.println(response);}} catch (IOException e) {e.printStackTrace();}}public static void main(String[] args) throws IOException {TcpClient client = new TcpClient("127.0.0.1",1010);client.start();}
}

二.翻译服务器

为了方便，此处我们直接继承回显服务器（记得改变客户端端口号）

import java.io.IOException;
import java.util.HashMap;public class DicTcpServe extends TcpServe{HashMap<String,String> dic = new HashMap<String,String>();public DicTcpServe(int Port) throws IOException {super(Port);dic.put("hello","你好");dic.put("world","世界");}@Overridepublic String process(String request) {return dic.getOrDefault(request,"未找到单词");}public static void main(String[] args) throws IOException {DicTcpServe server = new DicTcpServe(2020);server.start();}
}

http://www.dtcms.com/a/479260.html

相关文章：

  • 如何将网站转成小程序网站 微信 app
  • 若依框架下的接口测试
  • Unity网络开发--第三方协议工具Protobuf
  • 城阳网站建设公司wordpress首页文章缩略图插件
  • 兼职招聘网站中国最新军事新闻
  • MATLAB做一个简单的元胞自动机：森林火灾模拟
  • 嵌入式开发培训机构排名seo自动推广工具
  • 百度网盘公益解析网站下载限速一边去
  • 站酷网首页蛋糕店微网站
  • 2025年--Lc183--198. 打家劫舍(菲波那契数列类型）--Java版
  • linux系统中命令基础
  • 站酷网站建设合肥网建公司
  • 湖南旅游网站开发做毕业设计的网站
  • 安卓上谷歌35版本
  • 《架构设计精讲》学习笔记
  • Uvicorn在多核CPU上启动的参数workers
  • 宁波网站建设免费咨询手表
  • DDD架构——充血模型、领域模型
  • 【Linux系列】Vim 中删除当前光标到行尾
  • 建设银行手机网站首页域名访问过程会不会影响网站访问
  • 【1017】浮点型数据类型存储空间大小
  • 算法奇妙屋(六)-哈希表
  • Java基础加强14-File、字符的编码与解码、IO流、IO框架
  • [算法练习]Day 8: 变长滑动窗口
  • 做网站联系wordpress怎么做背景图片
  • 道路建设网站专题上海网站seo设计
  • asp.net做网站系统wordpress 首页不显示
  • GESP2025年9月认证C++四级( 第三部分编程题（1）排兵布阵）
  • 论文解读 -- A FOUNDATION MODEL FOR MUSIC INFORMATICS
  • Redis-管道和发布订阅