17_网络编程

文章目录

  • 网络数据传输的基本原理
  • UDP
    • 发送端步骤
    • 接收端步骤
    • DatagramSocket
    • DatagramPacket
    • 举例
      • 版本1：发送端发送消息,接收端接收并打印
      • 版本2：创建一个NetworkUtils工具类优化版本1
      • 版本3：发送端接收端相互发送
      • 版本4：使用多线程
  • TCP
    • 客户端步骤
    • 服务端步骤
    • Socket
    • ServerSocket
    • 举例
      • 版本1：客户端发送消息，服务端接收并打印
      • 版本2：多个客户端发送,服务端接收(多线程处理)
      • 版本3：客户端发送对象(序列化),服务端接收
      • 版本4：客户端上传文件到服务端

网络数据传输的基本原理

在这里插入图片描述

  • ip地址
    • 唯一确定目的主机
  • port 端口号
    • 唯一确定进程
  • 协议
    • UDP协议：无连接的不可靠的协议
    • TCP协议：面向连接的可靠的协议

UDP

在这里插入图片描述

发送端步骤

  1. 创建发送端的socket对象
  2. 把要发送的数据封装成数据报包
  3. send方法发送数据报包
  4. 释放资源close

接收端步骤

  1. 创建接收端的socket对象
  2. 创建用于接收的数据报包
  3. receive方法接收数据
  4. 解析数据报包
  5. 释放资源close

DatagramSocket

此类表示用来发送和接收数据报包的套接字。

构造方法：


DatagramSocket(int port)     //  创建数据报套接字并将其绑定到本地主机上的指定端口。

成员方法：
在这里插入图片描述

DatagramPacket

此类表示数据报包。

构造方法


1. 用于发送的
DatagramPacket(byte[] buf,  int offset, int length, InetAddress address, int port)      
// 构造数据报包，用来将长度为 length 偏移量为 offset  的包发送到指定主机上的指定端口号
// InetAddress address ---> ip值2. 用于接受的
DatagramPacket(byte[] buf,  int offset, int length)      
// 构造DatagramPacket，用来接收长度为 length 的包，在缓冲区中指定了偏移量。

成员方法：

在这里插入图片描述

举例

版本1：发送端发送消息,接收端接收并打印


// 发送端sender
public class Sender {public static void main(String[] args) throws IOException {//   1. 创建发送端的socket对象DatagramSocket datagramSocket = new DatagramSocket(8888);//   2. 把要发送的数据封装成数据报包String s = "hello";// DatagramPacket(byte[] buf, int offset, int length, InetAddress address, int port)// 构造数据报包，用来将长度为 length 偏移量为 offset  的包发送到指定主机上的指定端口号byte[] bytes = s.getBytes();InetAddress targetIP = InetAddress.getByName("127.0.0.1");int port = 9999;DatagramPacket sendPacket =new DatagramPacket(bytes, 0, bytes.length, targetIP, port);//   3. send方法发送数据报包datagramSocket.send(sendPacket);//   4. 释放资源closedatagramSocket.close();}
}———————————————————————————————————————————————————————————————————————————————————————————// 接收端receiver
public class Receiver {public static void main(String[] args) throws IOException {// 1. 创建接收端的socket对象DatagramSocket datagramSocket = new DatagramSocket(9999);// 2. 创建用于接收的数据报包// DatagramPacket(byte[] buf,  int offset, int length)// 构造DatagramPacket，用来接收长度为 length 的包，在缓冲区中指定了偏移量。byte[] bytes = new byte[1024];DatagramPacket receivePacket = new DatagramPacket(bytes, 0, bytes.length);// 3. receive方法接收数据System.out.println("receiver before");datagramSocket.receive(receivePacket);System.out.println("receiver after");// 4. 解析数据报包byte[] data = receivePacket.getData();int length = receivePacket.getLength();int offset = receivePacket.getOffset();System.out.println(new String(data, offset, length));// 5. 释放资源closedatagramSocket.close();}
}

版本2：创建一个NetworkUtils工具类优化版本1


NetworkUtil.javapublic class NetworkUtils {// 提供一个获取发送数据报包的方法public static DatagramPacket getSendPacket(String msg, String ip, int port) throws UnknownHostException {// 把数据封装到包里byte[] bytes = msg.getBytes();InetAddress targetIP = InetAddress.getByName(ip);DatagramPacket sendPacket = new DatagramPacket(bytes, 0, bytes.length, targetIP, port);return sendPacket;}// 提供一个获取接受数据报包的方法public static DatagramPacket getReceivePacket() {// 创建接收数据报的包byte[] bytes = new byte[1024];DatagramPacket receivePacket = new DatagramPacket(bytes, 0, bytes.length);return receivePacket;}// 提供一个解析数据报包的方法public static String parseMsg(DatagramPacket receivePacket) {byte[] bytes = receivePacket.getData();int length = receivePacket.getLength();int offset = receivePacket.getOffset();return new String(bytes,offset,length);}
}————————————————————————————————————————————————————————————————————————————————————————————// sender 发送端
public class Sender {public static void main(String[] args) throws IOException {DatagramSocket datagramSocket = new DatagramSocket(8888);String s = "hello hi";DatagramPacket sendPacket = NetworkUtils.getSendPacket(s, "127.0.0.1", 9999);datagramSocket.send(sendPacket);datagramSocket.close();}
}————————————————————————————————————————————————————————————————————————————————————————————// 接收端receiverpublic class Receiver {public static void main(String[] args) throws IOException {DatagramSocket datagramSocket = new DatagramSocket(9999);DatagramPacket receivePacket = NetworkUtils.getReceivePacket();datagramSocket.receive(receivePacket);String s = NetworkUtils.parseMsg(receivePacket);System.out.println(s);datagramSocket.close();}
}

版本3：发送端接收端相互发送


// 发送端sender
public class Sender {public static void main(String[] args) throws IOException {// 1. 创建发送端的socket对象DatagramSocket datagramSocket = new DatagramSocket(8888);// 2. 创建Scannner对象Scanner scanner = new Scanner(System.in);// while循环while (true) {// 3. 发送逻辑// 键盘接收数据String s = scanner.nextLine();// 把数据封装成数据包DatagramPacket sendPacket = NetworkUtils.getSendPacket(s, "127.0.0.1", 9999);// senddatagramSocket.send(sendPacket);// 4. 接受逻辑// 创建用于接受的数据报包DatagramPacket receivePacket = NetworkUtils.getReceivePacket();// receive方法接收datagramSocket.receive(receivePacket);// 解析String s1 = NetworkUtils.parseMsg(receivePacket);System.out.println("接收到了" + receivePacket.getSocketAddress() + "的消息" + s1);}}
}// 接收端 receiver
public class Receiver {public static void main(String[] args) throws IOException {// 创建接收端的Socket对象DatagramSocket datagramSocket = new DatagramSocket(9999);// 创建Scanner对象Scanner scanner = new Scanner(System.in);// while循环while (true) {// 接受逻辑// 创建用于接受的数据报包DatagramPacket receivePacket = NetworkUtils.getReceivePacket();// receive接受datagramSocket.receive(receivePacket);// parse解析String msg = NetworkUtils.parseMsg(receivePacket);System.out.println("接收到了" + receivePacket.getSocketAddress() + "的消息" + msg);// 发送逻辑// 键盘接收数据String s = scanner.nextLine();// 把数据封装成包DatagramPacket sendPacket = NetworkUtils.getSendPacket(s, "127.0.0.1", 8888);// senddatagramSocket.send(sendPacket);}}
}

版本4：使用多线程

在这里插入图片描述

  • 定义发送任务 SendTask 专门用来发送消息
  • 定义接收任务 receiveTask 专门用来接收消息

eg：


SendTask:
public class SenderTask implements Runnable {// DatagramSocket datagramSocketDatagramSocket datagramSocket;// String ipString ip;// int portint port;public SenderTask(DatagramSocket datagramSocket, String ip, int port) {this.datagramSocket = datagramSocket;this.ip = ip;this.port = port;}@Overridepublic void run() {// 创建Scanner对象Scanner scanner = new Scanner(System.in);// whilewhile(true){// 键盘输入消息String s = scanner.nextLine();// 把消息封装成数据报包try {DatagramPacket sendPacket = NetworkUtils.getSendPacket(s, ip, port);// senddatagramSocket.send(sendPacket);} catch (UnknownHostException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}}
}ReceiveTask:
public class ReceiveTask implements Runnable{// 成员变量DatagramSocket datagramSocket;public ReceiveTask(DatagramSocket datagramSocket) {this.datagramSocket = datagramSocket;}@Overridepublic void run() {// 只是接收数据while(true){// 创建用于接收的数据报包DatagramPacket receivePacket = NetworkUtils.getReceivePacket();// receive接收try {datagramSocket.receive(receivePacket);// 解析String s = NetworkUtils.parseMsg(receivePacket);// 打印System.out.println("s = " + s);} catch (IOException e) {e.printStackTrace();}}}
}OnePerson:
public class OnePerson {public static void main(String[] args) throws IOException {// 创建DatagramSocket对象DatagramSocket datagramSocket = new DatagramSocket(8888);// 创建发送线程 接收线程并启动new Thread(new SenderTask(datagramSocket,"127.0.0.1",9999)).start();// 创建接收线程new Thread(new ReceiveTask(datagramSocket)).start();}
}AnotherPerson：
public class AnotherPerson {public static void main(String[] args) throws IOException {// 创建DatagramSocket对象DatagramSocket datagramSocket = new DatagramSocket(9999);// 创建发送线程 接收线程并启动new Thread(new SenderTask(datagramSocket, "127.0.0.1", 8888)).start();// 创建接收线程new Thread(new ReceiveTask(datagramSocket)).start();}
}

TCP

在这里插入图片描述

客户端步骤

  1. 创建客户端Socket对象(Socket)

  2. 从socket中获取输入输出流

  3. 利用输出输出流进行读写操作

  4. 释放资源close

服务端步骤

  1. 创建服务端的socket对象(ServerSocket)

  2. 通过accept建立连接, 得到socket对象

  3. 从socket中得到输入输出流

  4. 利用输入输出流进行读写操作

  5. 释放资源

Socket

此类实现客户端套接字

构造方法：


Socket(String host,  int port)       
// 创建一个流套接字并将其连接到指定主机上的指定端口号。

注：这里的host指的是目的主机的指定端口

成员方法：

  • 在这里插入图片描述
  • 在这里插入图片描述

ServerSocket

此类实现服务器套接字

构造方法：


ServerSocket(int port)        
// 创建绑定到特定端口的服务器套接字。

成员方法：

  • 在这里插入图片描述

举例

版本1：客户端发送消息，服务端接收并打印

注意事项：

  • 先启动服务端，后启动客户端
  • 端口号不能重复，如果重复占用的话，换一个端口号

eg：


客户端Client：
public class Client {public static void main(String[] args) throws IOException {// 1. 创建客户端Socket对象// Socket(String host,  int port)Socket socket = new Socket("127.0.0.1", 9999);// 2. 从socket中获取输入输出流OutputStream out = socket.getOutputStream();// 3. 利用输出输出流进行读写操作out.write("hello".getBytes());// 4. 释放资源closesocket.close();}
}服务端Server：
public class Server {public static void main(String[] args) throws IOException {// 1. 创建服务端的socket对象(ServerSocket)// ServerSocket(int port)ServerSocket serverSocket = new ServerSocket(9999);// 2. 通过accept建立连接, 得到socket对象Socket socket = serverSocket.accept();// 3. 从socket中得到输入输出流InputStream inputStream = socket.getInputStream();// 4. 利用输入输出流进行读写操作byte[] bytes = new byte[1024];int readCount = inputStream.read(bytes);System.out.println(new String(bytes, 0, readCount));// 5. 释放资源serverSocket.close();socket.close();}
}

版本2：多个客户端发送,服务端接收(多线程处理)

eg：


客户端Client：
public class Client {public static void main(String[] args) throws IOException {// 创建客户端的socket对象Socket socket = new Socket("127.0.0.1",9999);// 创建scanner对象Scanner scanner = new Scanner(System.in);// while循环while(true){String s = scanner.nextLine();// 从socket对象中获取输入输出流// 字节流OutputStream out = socket.getOutputStream();// 转换成字符流OutputStreamWriter outputStreamWriter = new OutputStreamWriter(out);// write
//            out.write(s.getBytes());outputStreamWriter.write(s);// flushoutputStreamWriter.flush();}}
}服务端Server：
public class Server {public static void main(String[] args) throws IOException {// 创建服务端的socket对象ServerSocket serverSocket = new ServerSocket(9999);// 创建线程池ExecutorService pool = Executors.newFixedThreadPool(2);// while循环while (true){// 通过accept方法建立连接Socket socket = serverSocket.accept();// 向线程池中提交任务pool.submit(new ConnectTask(socket));// 使用多线程// new Thread(new ConnectTask(socket)).start();}}
}// 多线程改进
class ConnectTask implements Runnable{// 定义成员变量Socket socket;public ConnectTask(Socket socket) {this.socket = socket;}@Overridepublic void run() {// 读取数据while (true){try {InputStream in = socket.getInputStream();byte[] bytes = new byte[1024];int readCount = in.read(bytes);String s = new String(bytes, 0, readCount);System.out.println("接收到了来自" + socket.getLocalAddress()+ "端口号是：" + socket.getPort()+ "线程名是：" + Thread.currentThread().getName()+ "，内容是：" + s);} catch (IOException e) {e.printStackTrace();}}}
}

版本3：客户端发送对象(序列化),服务端接收

ObjectOutputStream 将 Java 对象的基本数据类型和图形写入 OutputStream。
可以使用 ObjectInputStream 读取（重构）对象。通过在流中使用文件可以实现对象的持久存储。如果流是网络套接字流，则可以在另一台主机上或另一个进程中重构对象。

eg：


客户端Client：
public class Client {public static void main(String[] args) throws IOException {// 创建客户端socket对象Socket socket = new Socket("127.0.0.1", 12300);// 从socket中获取输出流OutputStream out = socket.getOutputStream();// 把输出流进行包装，包装成序列化流ObjectOutputStream objectOutputStream = new ObjectOutputStream(out);// 创建学生对象Student student = new Student("zs", 20);// writeObjectobjectOutputStream.writeObject(student);// closeobjectOutputStream.close();socket.close();}
}服务端Server：
public class Server {public static void main(String[] args) throws IOException, ClassNotFoundException {// 创建客户端的socket对象ServerSocket serverSocket = new ServerSocket(12300);// accept方法建立连接，得到socket对象Socket socket = serverSocket.accept();// 得到输入流InputStream in = socket.getInputStream();// 把输入流进行包装 ObjectInputStreamObjectInputStream objectInputStream = new ObjectInputStream(in);// readObjectObject o = objectInputStream.readObject();// 打印System.out.println(o);// closeobjectInputStream.close();socket.close();serverSocket.close();}
}

版本4：客户端上传文件到服务端

在这里插入图片描述

eg：


客户端Client：
// 客户端上传文件到服务端
public class Client {public static void main(String[] args) throws IOException {// 创建客户端的socket对象Socket socket = new Socket("127.0.0.1", 12345);// 创建自己的输入流对象FileInputStream fileInputStream = new FileInputStream("D:\\Java_test\\testPhoto.jpg");// 通过自己的输入流读取文件信息OutputStream outputStream = socket.getOutputStream();// 通过socket获取输出流对象int readCount;byte[] bytes = new byte[1024];while ((readCount = fileInputStream.read(bytes)) != -1) {// 边读边写outputStream.write(bytes, 0, readCount);}// 释放资源fileInputStream.close();outputStream.close();socket.close();}
}服务端Server：
public class Server {public static void main(String[] args) throws IOException {// 创建服务端的socket对象ServerSocket serverSocket = new ServerSocket(12345);// 创建自己的输出流对象FileOutputStream fileOutputStream = new FileOutputStream("D:\\darkNight.jpg");// accept方法建立连接 得到socket对象Socket socket = serverSocket.accept();// 从socket中获取输入流InputStream in = socket.getInputStream();// 边读边写int readCount;byte[] bytes = new byte[1024];while ((readCount = in.read(bytes)) != -1) {fileOutputStream.write(bytes, 0, readCount);}// 释放serverSocket.close();socket.close();fileOutputStream.close();in.close();}
}
  • 在这里插入图片描述
    Socket的半关闭

版本4plus：

eg：


客户端Client：
public class Server {public static void main(String[] args) throws IOException {// 创建服务端的socket对象ServerSocket serverSocket = new ServerSocket(12345);// 创建自己的输出流对象FileOutputStream fileOutputStream =new FileOutputStream("D:\\darkNight.jpg");// accept方法建立连接 得到socket对象Socket socket = serverSocket.accept();// 从socket中获取输入流InputStream in = socket.getInputStream();// 边读边写int readCount;byte[] bytes = new byte[1024];while ((readCount = in.read(bytes)) != -1) {fileOutputStream.write(bytes, 0, readCount);}OutputStream outputStream = socket.getOutputStream();outputStream.write("文件上传成功".getBytes());// 释放serverSocket.close();socket.close();fileOutputStream.close();in.close();}
}服务端Server：
public class Server {public static void main(String[] args) throws IOException {// 创建服务端的socket对象ServerSocket serverSocket = new ServerSocket(12345);// 创建自己的输出流对象FileOutputStream fileOutputStream =new FileOutputStream("D:\\darkNight.jpg");// accept方法建立连接 得到socket对象Socket socket = serverSocket.accept();// 从socket中获取输入流InputStream in = socket.getInputStream();// 边读边写int readCount;byte[] bytes = new byte[1024];while ((readCount = in.read(bytes)) != -1) {fileOutputStream.write(bytes, 0, readCount);}OutputStream outputStream = socket.getOutputStream();outputStream.write("文件上传成功".getBytes());// 释放serverSocket.close();socket.close();fileOutputStream.close();in.close();}
}

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

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

相关文章

湘鄂赣三省职称互认，这个消息是真的吗？

湘鄂赣三省职称互认，这个消息是真的吗？

甘建二今天明确告诉大家，是真的，这个是属实的，就是说湖南、湖北、江西三地职称是互认的。 2022年就有文件出来了，说的就是三省职称互认，具体看文件： 职称原则都是互相认可，通用的，所…
阅读更多...
Alphafold2蛋白质结构预测AI工作站配置推荐

Alphafold2蛋白质结构预测AI工作站配置推荐

AlphaFold2计算特点 蛋白质三维结构预测是一项计算量非常巨大的任务，科学家多年的探索研究，形成了X射线晶体学法、核磁共振法、冷冻电镜等。 2021年底，谷歌的DeepMind团队的采用人工智能方法的AlphaFold2算法在生物界引起了极大的轰动…
阅读更多...
18-链表-移除链表元素

18-链表-移除链表元素

这是链表的第18题，力扣链接。 给你一个链表的头节点 head 和一个整数 val ，请你删除链表中所有满足 Node.val val 的节点，并返回 新的头节点 。 示例 1： 输入：head [1,2,6,3,4,5,6], val 6 输出：[1,2,3,…
阅读更多...
PHP短链接url还原成长链接

PHP短链接url还原成长链接

在开发过程中，碰到了需要校验用户回填的短链接是不是系统所需要的，于是就需要还原找出短链接所对应的长链接。 长链接转短链接 在百度上搜索程序员，跳转页面后的url就是一个长链接。当然你可以从任何地方复制一个长链接过来。 长链接 http…
阅读更多...
17- Echarts 配置系列之：单轴 singleAxis

17- Echarts 配置系列之：单轴 singleAxis

singleAxis： 用于展示只有一个数据维度的数据。它通常用于展示时间序列数据或者数值序列数据。 对于单轴的应用和绘制，其实就相当于我们平时的直角坐标系少一个 X 或者 Y ，然后进行图形绘制。 注意： 1.在使用单轴时&#xff0…
阅读更多...
Android Firebase （FCM）推送接入

Android Firebase （FCM）推送接入

官方文档： 向后台应用发送测试消息 | Firebase Cloud Messaging 1、根级（项目级）Gradlegradle的dependencies中添加： dependencies {...// Add the dependency for the Google services Gradle pluginclasspath com.google.gm…
阅读更多...
使用组合框QComboBox模拟购物车

使用组合框QComboBox模拟购物车

1.组合框: QComboBox 组合框：QComboBox 用于存放一些列表项 实例化 //实例化QComboBox* comboBox new QComboBox(this);1.1 代码实现 1.1.1 组合框的基本函数 QComboBox dialog.cpp #include "dialog.h" #include "ui_dialog.h"Dialog::Dialog…
阅读更多...
UM2004 一款低功耗、高性能、即插即用型 OOK 射频接收器芯片

UM2004 一款低功耗、高性能、即插即用型 OOK 射频接收器芯片

UM2004 是一款低功耗、高性能、即插即用型 OOK 射频接收器，该芯片具有 2.5V ~ 5.5V 较宽的输入电压范围，灵敏度高达到-109dBm，工作频段为 300MHz ~ 480MHz，支持 1Kbps~ 5Kbps 的数据率传输。采用 SOP8 封装类型，应用时…
阅读更多...
如何将MIUI系统转换为AOSP Material You系统？

如何将MIUI系统转换为AOSP Material You系统？

如何将MIUI系统转换为AOSP Material You系统？ 许多安卓用户都喜欢使用原始设备制造商（OEM）ROM，也有一部分用户喜欢更接近原版安卓系统（AOSP）的体验。然而，MIUI系统往往难以达到用户希望的AOSP外…
阅读更多...
4《数据结构》

4《数据结构》

文章目录 绪论逻辑结构存储结构【物理结构】顺序和链式存储区别顺序表和数组区别数组和链表的区别链表结点概念链表为空条件链表文章http://t.csdnimg.cn/dssVK二叉树B树B树【MYSQL索引默认数据结构】B树和B树区别冒泡排序插排选排快排 绪论 数据结构：研究非数值计…
阅读更多...
对外贸易数据平台解析_外贸三大支撑力_箱讯科技

对外贸易数据平台解析_外贸三大支撑力_箱讯科技

添加图片注释，不超过 140 字（可选） 三大支撑力支撑我国外贸持续回暖 海关总署近日发布数据显示，今年前11个月，我国进出口总值37.96万亿元，与去年同期持平。进入四季度，我国外贸发展的积极因素…
阅读更多...
100个GEO基因表达芯片或转录组数据处理之GSE159676（002）

100个GEO基因表达芯片或转录组数据处理之GSE159676（002）

写在前边 虽然现在是高通量测序的时代，但是GEO、ArrayExpress等数据库储存并公开大量的基因表达芯片数据，还是会有大量的需求去处理芯片数据，并且建模或验证自己所研究基因的表达情况，芯片数据的处理也可能是大部分刚学生信的道友…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023