第二十一章网络通信总结博客

网络程序设计基础

局域网与互联网

为了实现两台计算机的通信，必须用一个网络线路连接两台计算机。如下图所示

网络协议

1.IP协议

IP是Internet Protocol的简称，是一种网络协议。Internet 网络采用的协议是TCP/IP协议，其全称是Transmission Control Protocol/Internet Protocol。Internet 依靠TCP/IP协议，在全球范围内实现了不同硬件结构、不同操作系统、不同网络系统间的互联。在Internet 网络上存在着数以亿计的主机，每台主机都用网络为其分配的 Internet 地址代表自己，这个地址就是I地址。到目前为止，I地址用4个字节，也就是32位的二进制数来表示，称为IPv4。为了便于使用，通常取用每个字节的十进制数，并且每个字节之间用圆点隔开来表示I地址，如192.168.1.1。现在人们正在试验使用16个字节来表示I地址，这就是IPv6，但IPv6还没有投入使用。

TCP/IP 模式是一种层次结构，共分为4层，分别为应用层、传输层、互联网层和网络层。各层实现特定的功能，提供特定的服务和访问接口，并具有相对的独立性，如图所示。

2. TCP与UDP协议

在TCPAIP 协议栈中，有两个高级协议是网络应用程序编写者应该了解的，即传输控制协议(Transmission Control Protocol，TCP)与用户数据报协议（User Datagram Protocol， UDP）。

TCP 协议是一种以固接连线为基础的协议，它提供两台计算机间可靠的数据传送。TCP可以保证数据从一端送至连接的另一端时，能够确实送达，而且抵达的数据的排列顺序和送出时的顺序相同。因此，TCP协议适合可靠性要求比较高的场合。就像拨打电话，必须先拨号给对方，等两端确定连接后，相互才能听到对方说话，也知道对方回应的是什么。

HTTP、FTP 和Telnet 等都需要使用可靠的通信频道。例如，HTTP从某个URL读取数据时，如果收到的数据顺序与发送时不相同，可能就会出现一个混乱的HTML文件或是一些无效的信息。

UDP是无连接通信协议，不保证数据的可靠传输，但能够向若干个目标发送数据，或接收来自若干个源的数据。UDP以独立发送数据包的方式进行。这种方式就像邮递员送信给收信人，可以寄出很多信给同一个人，且每一封信都是相对独立的，各封信送达的顺序并不重要，收信人接收信件的顺序也不能保证与寄出信件的顺序相同。

UDP 协议适合于一些对数据准确性要求不高，但对传输速度和时效性要求非常高的网站，如网络聊天室、在线影片等。这是由于TCP协议在认证上存在额外耗费，可能使传输速度减慢，而UDP协议即使有一小部分数据包遗失或传送顺序有所不同，也不会严重危害该项通信。

端口与套接字

一般而言，一台计算机只有单一的连到网络的物理连接（Physical Connection），所有的数据都通过此连接对内、对外送达特定的计算机，这就是端口。网络程序设计中的端口（port）并非真实的物理存在，而是一个假想的连接装置。端口被规定为一个在0~65535的整数。HTTP服务一般使用80端口,FTP 服务使用21端口。假如一台计算机提供了HTTP、FTP等多种服务，那么客户机会通过不同的端口来确定连接到服务器的哪项服务上，如图所示。

通常，0~1023的端口数用于一些知名的网络服务和应用，用户的普通网络应用程序应该使用1024以上的端口数，以避免端口号与另一个应用或系统服务所用端口冲突。

网络程序中的套接字（Socket）用于将应用程序与端口连接起来。套接字是一个假想的连接装置，就像插座一样可连接电器与电线，如图所示。

Java 将套接字抽象化为类，程序设计者只需创建Socket类对象，即可使用套接字。

TCP程序

TCP网络程序设计是指利用Socket 类编写通信程序。利用TCP协议进行通信的两个应用程序是有主次之分的，一个称为服务器程序，另一个称为客户机程序，两者的功能和编写方法大不一样。服务器端与客户端的交互过程如图所示。

  1. 服务器程序创建一个 ServerSocket（服务器端套接字）对象，调用accept0方法等待客户机来连接
  2. 客户端程序创建一个Socket对象，请求与服务器建立连接
  3. 服务器接收客户机的连接请求，同时创建一个新的Socket 对象与客户建立连接。随后服务器继续等待新的请求

InetAddress 类

java.net包中的InetAddress类是与IP地址相关的类，利用该类可以获取IP地址、主机地址等信息。

例题21.1

import java.net.*;										//导出Java.net包public class Address {									//创建类public static void main(String[] args) {InetAddress ip;									//创建InetAddress对象try {											//捕捉可能出现的异常ip = InetAddress.getLocalHost();			//实例化对象String locaIname = ip.getHostName();		//获取本机名String localip = ip.getHostAddress();		//获取本机IP地址System.out.println("本机名："+locaIname);		//将本机名输出System.out.println("本机名IP地址："+localip);	//将本机IP地址输出}catch(UnknownHostException e){e.printStackTrace();						//输出异常信息}}}//例题21.1

运行结果如下：

ServerSocket 类

  • ServerSocker 类的构造方法通常会抛出1OException异常，具体有以下几种形式：
  • ServerSocket()：创建非绑定服务器套接字。
  • ServerSocket(int port)：创建绑定到特定端口的服务器套接字。
  • ServerSocket(int port, int backlog）：利用指定的backlog创建服务器套接字，并将其绑定到指定的本地端口号上。
  • ServerSocket(int port, int backlog, InetAddress bindAddress)：使用指定的端口、侦听backlog和要绑定到的本地IP地址创建服务器。这种情况适用于计算机上有多块网卡和多个I地址的情况，用户可以明确规定ServerSocket在哪块网卡或哪个IP地址上等待客户的连接请求。

ServerSocket 类的常用方法如表21.2所示。

TCP网络程序设计

例题21.2

import java.io.*;
import java.net.*;public class MyServer {private ServerSocket server; // 服务器套接字private Socket socket; // 客户端套接字void start() {// 启动服务器try {server = new ServerSocket(8998); // 服务器启用8998端口System.out.println("服务器套接字已经创建成功");while (true) {System.out.println("等待客户端的连接");socket = server.accept(); // 服务器监听客户端连接// 根据套接字字节流创建字符输入流BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));while (true) {// 循环接受信息String message = reader.readLine();// 读取一行文本if ("exit".equals(message)) {// 如果客户端发来的内容为“exit”System.out.println("客户端退出");break;// 停止接受信息}System.out.println("客户端:" + message);}reader.close(); // 关闭流socket.close(); // 关闭套接字}} catch (IOException e) {e.printStackTrace();}}public static void main(String[] args) {MyServer tcp = new MyServer();tcp.start(); // 启动服务器}
}
//21.2

运行结果如下：

 

编写客户端程序，将用户在文本框中输入的信息发送至服务端，并将文本框中输入的信息显示再客户端的文本域中。

import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.Socket;
import javax.swing.*;public class MyClient extends JFrame {private PrintWriter writer;// 根据套接字字节流创建的字符输出流Socket socket; // 客户端套接字private JTextArea area = new JTextArea();// 展示信息的文本域private JTextField text = new JTextField(); // 发送信息的文本框public MyClient() {setTitle("向服务器送数据");setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);Container c = getContentPane(); // 主容器JScrollPane scrollPane = new JScrollPane(area);// 滚动面板getContentPane().add(scrollPane, BorderLayout.CENTER);c.add(text, "South"); // 将文本框放在窗体的下部text.addActionListener(new ActionListener() {// 文本框触发回车事件public void actionPerformed(ActionEvent e) {writer.println(text.getText().trim()); // 将文本框中的信息写入流area.append(text.getText() + '\n'); // 将文本框中的信息显示在文本域中text.setText(""); // 将文本框清空}});}private void connect() { // 连接服务器方法area.append("尝试连接\n"); // 文本域中提示信息try {socket = new Socket("127.0.0.1", 8998); // 连接本地计算机的8998端口writer = new PrintWriter(socket.getOutputStream(), true);area.append("完成连接\n");} catch (IOException e) {e.printStackTrace();}}public static void main(String[] args) {MyClient clien = new MyClient();clien.setSize(200, 200); // 窗体大小clien.setVisible(true); // 显示窗体clien.connect(); // 连接服务器}
}
//21.2

运行结果如下：

 

UDP程序

基于 UDP通信的基本模式如下：

  • 将数据打包（称为数据包），然后将数据包发往目的地。
  • 接收别人发来的数据包，然后查看数据包。

发送数据包的步骤如下：

（1）使用DatagramSocketO创建一个数据包套接字。

（2)使用DatagramPacket(byte[] buf,int offset, int length,InetAddress address,int port)创建要发送的数据包。

（3)使用DatagramSocket 类的sendO方法发送数据包。

接收数据包的步骤如下：

（1）使用DatagramSocket(int port)创建数据包套接字，绑定到指定的端口。

  (2）使用 DatagramPacket(byte buf, int length)创建字节数组来接收数据包。

（3）使用DatagramPacket 类的receive0方法接收UDP包。

DatagramPacket类

java.net 包的DatagramPacket 类用来表示数据包。DatagramPacket 类的构造方法如下:

  • DatagramPacket(byte[] buf, int length)
  • DatagramPacket(bytel] buf, int length, InetAddress address, int port)

第一种构造方法在创建DatagramPacket 对象时，指定了数据包的内存空间和大小。

第二种构造方法不仅指定了数据包的内存空间和大小，还指定了数据包的目标地址和端口。

DatagramSocker 类

  • java.net 包中的()
  • DatagramSocket(int port)
  • DatagramSocket(int port, InetAddress addr)

第一种构造方法创建DatagramSocket对象，构造数据报套接字，并将其绑定到本地主机任何可用的端口上。

第二种构造方法创建DatagramSocket对象，创建数据报套接字，并将其绑定到本地主机的指定端口上。

第三种构造方法创建DatagramSocket对象，创建数据报套接字，并将其绑定到指定的端口和指定的本地地址上。第三种构造函数适用于有多块网卡和多个I地址的情况。

UDP网络程序设计

例题21.3

（1）广播主机程序不断地向外播放信息，代码如下：


import java.io.IOException;
import java.net.*;public class Notification extends Thread {String weather = "节目预报：八点有大型晚会，请收听";// 发送的消息int port = 9898; // 端口InetAddress iaddress = null;MulticastSocket socket = null; // 多点广播套接字Notification() {try {iaddress = InetAddress.getByName("224.255.10.0"); // 实例化InetAddress，指定地址socket = new MulticastSocket(port); // 实例化多点广播套接字socket.setTimeToLive(1); // 指定发送范围是本地网络socket.joinGroup(iaddress); // 加入广播组} catch (IOException e) {e.printStackTrace(); // 输出异常信息}}public void run() {while (true) {DatagramPacket packet = null; // 数据包byte data[] = weather.getBytes(); // 字符串消息的字节数组packet = new DatagramPacket(data, data.length, iaddress, port); // 将数据打包System.out.println(weather); // 控制台打印消息try {socket.send(packet); // 发送数据sleep(3000); // 线程休眠} catch (IOException e) {e.printStackTrace(); } catch (InterruptedException e) {e.printStackTrace();}}}public static void main(String[] args) { Notification w = new Notification();w.start(); // 启动线程}
}
//21.3

运行结果如下：

（2）接收广播程序。单机“开始接收”按钮，系统开始接收主机播出的信息；单机“停止接收”按钮，系统停止接收广播主机播出的信息。代码如下：


import java.awt.*;
import java.awt.event.*;
import java.io.IOException;
import java.net.*;
import javax.swing.*;public class Receive extends JFrame implements Runnable, ActionListener {int port; // 端口InetAddress group = null; // 广播组地址MulticastSocket socket = null; // 多点广播套接字对象JButton inceBtn = new JButton("开始接收");JButton stopBtn = new JButton("停止接收");JTextArea inceAr = new JTextArea(10, 10); // 显示接收广播的文本域JTextArea inced = new JTextArea(10, 10);Thread thread;boolean stop = false; // 停止接受信息状态public Receive() {setTitle("广播数据报");setDefaultCloseOperation(WindowConstants.EXIT_ON_CLOSE);thread = new Thread(this);inceBtn.addActionListener(this); // 绑定按钮ince的单击事件stopBtn.addActionListener(this); // 绑定按钮stop的单击事件inceAr.setForeground(Color.blue); // 指定文本域中文字的颜色JPanel north = new JPanel(); // 创建Jpanel对象north.add(inceBtn); // 将按钮添加到面板north上north.add(stopBtn);add(north, BorderLayout.NORTH); // 将north放置在窗体的上部JPanel center = new JPanel(); // 创建面板对象centercenter.setLayout(new GridLayout(1, 2)); // 设置面板布局center.add(inceAr); // 将文本域添加到面板上center.add(inced);add(center, BorderLayout.CENTER); // 设置面板布局validate(); // 刷新port = 9898; // 设置端口号try {group = InetAddress.getByName("224.255.10.0"); // 指定接收地址socket = new MulticastSocket(port); // 绑定多点广播套接字socket.joinGroup(group); // 加入广播组} catch (IOException e) {e.printStackTrace(); // 输出异常信息}setBounds(100, 50, 360, 380); // 设置布局setVisible(true); // 将窗体设置为显示状态}public void run() { // run()方法while (!stop) {byte data[] = new byte[1024]; // 创建缓存字节数组DatagramPacket packet = null;packet = new DatagramPacket(data, data.length, group, port); // 待接收的数据包try {socket.receive(packet); // 接收数据包String message = new String(packet.getData(), 0, packet.getLength()); // 获取数据包中的内容inceAr.setText("正在接收的内容：\n" + message); // 将接收内容显示在文本域中inced.append(message + "\n"); // 每条信息为一行} catch (IOException e) {e.printStackTrace(); // 输出异常信息}}}public void actionPerformed(ActionEvent e) { // 单击事件if (e.getSource() == inceBtn) { // 单击按钮ince触发的事件inceBtn.setBackground(Color.red); // 设置按钮颜色stopBtn.setBackground(Color.yellow);if (!(thread.isAlive())) { // 如线程不处于“新建状态”thread = new Thread(this); // 实例化Thread对象}thread.start(); // 启动线程stop = false; // 开始接受信息}if (e.getSource() == stopBtn) { // 单击按钮stop触发的事件inceBtn.setBackground(Color.yellow); // 设置按钮颜色stopBtn.setBackground(Color.red);stop = true; // 停止接受信息}}public static void main(String[] args) {Receive rec = new Receive();rec.setSize(460, 200);}
}

运行结果如下：

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

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

相关文章

Linux 环境变量 与 命令行参数

Linux 环境变量 与 命令行参数

什么是环境变量 从结构上来看，环境变量就是操作系统维护的一组：key-value 的键值对。 不知道你是否有一个疑问：为什么我们写代码编译链接 形成的可执行程序要运行起来需要带路径呢？Linux 内置的命令也是可执行程序，为…
阅读更多...
Builder设计模式

Builder设计模式

我们往往不想一下子从构造方法里面把参数传递过去，而是一个个参数构造。此时就用到Builder设计模式。 比如：属性计算中，我们构造各个方法。
阅读更多...
11.AUTOSAR 诊断栈分析(四)--FIM和DCM

11.AUTOSAR 诊断栈分析(四)--FIM和DCM

目录 1.Event Debounce策略 2.Function Inhibition Manager 3.DCM 4.小结 前面我们用了大概三篇的篇幅描述了诊断栈的基本概念，分别如下： 8.AUTOSAR 诊断栈分析(一)-CSDN博客 9.AUTOSAR 诊断栈分析(二)-CSDN博客
阅读更多...
html刷题笔记

html刷题笔记

1 em 12 pt 16 px 100% source元素为audio、video、picture元素指定多个媒体文件 margin是用来隔开元素与元素的间距；padding是用来隔开元素与内容的间隔。 margin用于布局分开元素使元素与元素互不相干；padding用于元素与内容之间的间隔，…
阅读更多...
华清作业day41

华清作业day41

阅读更多...
【前端架构】清洁前端架构

【前端架构】清洁前端架构

探索前端架构：概述与干净的前端架构相关的一些原则（SOLID、KISS、DRY、DDD等）。 在我之前的一篇帖子中，我谈到了Signals和仍然缺少的内容[1]。现在，我想谈谈一个更通用的主题，即Clean Frontend Architectu…
阅读更多...
Mysql综合案例练习＜1＞

Mysql综合案例练习＜1＞

MySql综合案例练习<1> 题目一题目二题目三题目四题目五题目六题目七题目八题目九题目十题目十一题目十二题目十三题目十四题目十五题目十六题目十七题目十八题目十九 题目一 创建数据库test01_library 创建表 books&#xff0c;表结构如下&#xff1a; CREATE DATABASE …
阅读更多...
【js】连续相同请求时，如何中断还未返回的请求

【js】连续相同请求时，如何中断还未返回的请求

需求 前端页面&#xff0c;用户连续翻页&#xff0c;或是连续筛选这样的连续请求&#xff0c;如果保证发起一次请求时&#xff0c;去中断掉上一次还未返回的请求&#xff1f; 代码 使用axios实现 import axios from axios; import requistDuplicateBlacklist from ./requis…
阅读更多...
量子纠缠通讯：未来通讯技术的革命性突破

量子纠缠通讯：未来通讯技术的革命性突破

量子纠缠通讯：未来通讯技术的革命性突破 引言 随着科学技术的不断发展，量子纠缠通讯已成为当今最热门的研究领域之一。作为一种革新性的通讯技术，量子纠缠通讯有望为我们的信息安全和传输速度带来前所未有的提升。那么，究竟什么是量子纠缠通讯，它的原理又是如何的呢？本…
阅读更多...
【Hadoop-Distcp】通过Distcp的方式进行两个HDFS集群间的数据迁移

【Hadoop-Distcp】通过Distcp的方式进行两个HDFS集群间的数据迁移

【Hadoop-Distcp】通过Distcp的方式进行两个HDFS集群间的数据迁移 1&#xff09;Distcp 工具简介及参数说明2&#xff09;Shell 脚本 1&#xff09;Distcp 工具简介及参数说明 【Hadoop-Distcp】工具简介及参数说明 2&#xff09;Shell 脚本 应用场景&#xff1a; 两个实时集…
阅读更多...
HWL-2511-SS 路由器命令执行漏洞复现 [附POC]

HWL-2511-SS 路由器命令执行漏洞复现 [附POC]

文章目录 HWL-2511-SS 路由器命令执行漏洞复现 [附POC]0x01 前言0x02 漏洞描述0x03 影响版本0x04 漏洞环境0x05 漏洞复现1.访问漏洞环境2.构造POC3.复现0x06 修复建议HWL-2511-SS 路由器命令执行漏洞复现 [附POC] 0x01 前言 免责声明：请勿利用文章内的相关技术从事非法测试，…
阅读更多...
股市复苏中的明懿金汇：抓住新机遇

股市复苏中的明懿金汇：抓住新机遇

2023年对于明懿金汇来说是充满挑战与机遇的一年。面对复杂多变的市场环境&#xff0c;明懿金汇展现了其对市场趋势的敏锐洞察和卓越的策略适应能力。以下是该公司在2023年的主要投资策略和市场适应方式的详细分析。 随着2023年中国股市迎来反弹&#xff0c;明懿金汇迅速调整了…
阅读更多...
Linux Docker 安装Nginx

Linux Docker 安装Nginx

1.21、查看可用的Nginx版本 访问Nginx镜像库地址&#xff1a;https://hub.docker.com/_/nginx 2、拉取指定版本的Nginx镜像 docker pull nginx:latest #安装最新版 docker pull nginx:1.25.3 #安装指定版本的Nginx 3、查看本地镜像 docker images 4、根据镜像创建并运行…
阅读更多...
Shopify 开源 WebAssembly 工具链 Ruvy

Shopify 开源 WebAssembly 工具链 Ruvy

最近，Spotify 开源了Ruvy，一个 WebAssembly 工具链，能够将 Ruby 代码转换为 Wasm 模块。Ruvy 基于ruby.wasm， 用 Rust 实现，提升了性能并简化了 Wasm 模块的执行。 Ruvy 利用了ruby.wasm提供的 Ruby 解释器模块，并使用wasi-vfs (WASI 虚拟文件系统)将其与所有指定的 Rub…
阅读更多...
汽水瓶

汽水瓶

某商店规定&#xff1a;三个空汽水瓶可以换一瓶汽水&#xff0c;允许向老板借空汽水瓶&#xff08;但是必须要归还&#xff09;。小张手上有n个空汽水瓶&#xff0c;她想知道自己最多可以喝到多少瓶汽水。 数据范围&#xff1a;输入的正整数满足 1≤n≤100 注意&#xff1a;本…
阅读更多...
java.lang.UnsupportedOperationException解决方法

java.lang.UnsupportedOperationException解决方法

问题描述 在实际开发中经常会有类似的这种代码&#xff0c;想要按类的某一个属性对列表中的元素分组。 例如&#xff1a; 有一些学生&#xff0c;然后根绝他们的年龄对他们进行分组。可以写出如下代码。 public class UnsupportedOperationExceptionDemo {DataNoArgsConstru…
阅读更多...
ARM Cortex-M安全之MPU介绍

ARM Cortex-M安全之MPU介绍

ARM Cortex-M处理器系列中的存储保护单元&#xff08;Memory Protection Unit&#xff0c;简称MPU&#xff09;是一种硬件机制&#xff0c;可用于在嵌入式系统中实现存储保护和访问权限控制。MPU允许开发人员对不同的内存区域分配不同的权限&#xff0c;从而提供对系统代码和数…
阅读更多...
关键字volatile作用和用法

关键字volatile作用和用法

目录 一、多线程编程中的volatile关键字 二、嵌入式编程中的volatile关键字 三、 优化编译器优化 四、 指针类型转换 一个定义为volatile的变量是说这变量可能会被意想不到地改变&#xff0c;这样&#xff0c;编译器就不会去假设这个变量的值了。 精确地说就是&#xff0c;…
阅读更多...
动态规划求解完全背包问题(c++实现)

动态规划求解完全背包问题(c++实现)

首先是朴素版代码&#xff0c;三层for循环第一层是第几个物品&#xff0c;第二层是体积&#xff0c;第三层是第几个物品的个数&#xff1b;朴素版代码时间复杂度较高&#xff0c;效率低&#xff0c;容易超时。 #include<iostream> using namespace std; const int N1010…
阅读更多...
【Docker】Swarm的ingress网络

【Docker】Swarm的ingress网络

Docker Swarm Ingress网络是Docker集群中的一种网络模式&#xff0c;它允许在Swarm集群中运行的服务通过一个公共的入口点进行访问。Ingress网络将外部流量路由到Swarm集群中的适当服务&#xff0c;并提供负载均衡和服务发现功能。 在Docker Swarm中&#xff0c;Ingress网络使…
阅读更多...
最新文章

Copyright @ 2022~2023