Java网络编程
计算机网络就是通过传输介质、通信设施和网络协议,把分散在不同地点的计算设备互连起来,实现资 源共享和数据传输的系统。
TCP/IP协议簇
TCP/IP协议栈是一系列网络协议的总和,是构成网络通信的核心骨架。
分层模型
TCP/IP协议栈的分层模型常见的有2个,分别是TCP/IP参考模型和ISO组织提出的OSI参考模型。在 TCP/IP参考模型中将网络分为网络访问层【数据链路层】、互联网层【网络层】、传输层、应用层共4 层,OSI参考模型分为物理层、数据链路层、网络层、传输层、会话层、表示层、应用层共7个层。 OSI参考模型是一个开放的通信系统互联参考模型
TCP/IP参考模型
TCP/IP协议采用4层架构,从上向下分为应用层、传输层、网络层和链路层,每一层都可以使用其下一层 的协议完成自己的需求,不允许下层访问上层 当通过http协议发起一个请求时,从上往下依次通过应用层、传输层、网络层和链路层,每一层相关协 议都依次对数据包进行处理,并携带响应的首部,最终在链路层生成以太网数据包,通过物理介质进行 传输,传送到对方主机后,对方主机再依次从下向上使用响应协议进行拆包,最终经应用层数据交给应 用程序进行处理 配送车就是物理介质、配送站就是网关、快递员就是路由器、收货地址就是IP地址、联系电话就是 MAC地址
三次握手
TCP是面向连接的协议,连接连接需要有3个阶段:连接建立、数据传送和连接释放。其中连接建立需要 经历3个步骤,通常称为三次握手 1、第一次握手,客户端发起请求 2、第二次握手,服务器端回传确认 3、第三次握手,客户端回传确认
四次挥手
由于TCP连接是双工的,所以每个方向都必须单独进行关闭 为什么连接的时候是3次握手,而断开连接时是4次挥手?
粘包
多个数据包存储在缓存中,对数据包的处理由于无法确认边界,所以经常采用估测值大小进行数据的读 写,如果发送和接收数据的双方size不一致时,会使用发送方发送的若干个包数据到接受方接收时粘成 一个包 原因 既可以是发送方造成的,也可能是接收方造成。粘包并不是TCP协议造成的,出现是因为应用层设计的 缺陷 Nagle算法通过减少数据包数量的方式提供TCP传输性能 解决方案 应用层协议自己划分消息边界,常见的方案有基于长度或者基于终结符号
拥塞控制拥塞控制
防止过多的数据注入网络,以避免使网络中的路由器或者链路过载 拥塞控制前提是网络能够承受现有的网络负荷 不同于流量控制,流量控制就是拟制发送方发送数据的速率,以便使接收方能够来得及接收数据 拥塞控制的机制 慢开始、拥塞避免、快重传和快恢复 慢开始就是当主机发送数据时,先进行探测,可以由小到大逐渐增加发送窗口 拥塞避免是让拥塞窗口缓慢增大,不是加倍,而是加1 不使用快重传就是当发送方并没有在规定的时间内收到确认,则拥塞窗口减少到1,并执行慢开始 算法;快重传要求结束方每收到一个乱序的报文后立即确认 和快重传机制一起使用的是快恢复,将拥塞窗口的大小设置为慢开始的上限值的一半
IP地址
在网络中定位一个机器需要通过IP地址,IP协议可以分为IPv4和IPv6两种,IPv4采用的是点分十进制的 计法,例如192.168.1.8 Java中提供了一个InetAddress实现对IP地址的封装,子类Inet4Address和Inet6Address,这个类一般 会和Socket一起使用 InetAddress没有公共的构造方法,必须通过使用静态方法获取对应的实例 ping www.baidu.com 特殊方法isReachable用于测试是否可以到达指定的地址,防火墙或者服务器配置可能会阻塞请求,使得 访问指定地址时处于不用达状态
URL编程
java.net.URL对象用于代表一个网络环境的资源,资源可以是简单的文件或者目录,也可以是复杂对象 的引用,例如数据库或者搜索引擎的查询。URL使用协议名、主机名、端口号和资源组成,基本格式为 protocol://host:port/resource,例如http://www.yan.com:80/index.php,由于不同的协议有对应的标 准端口号,如果使用标准端口,这个端口号可以省略,http协议的标准端口号为80 URL统一资源定位器,实际上就是一个资源的指针 URI统一资源标识符,实际上就是一个URL的名称 目前考虑到http协议缺少安全机制,很容易被监听;所以引入https协议。https=http+SSL安全套 接层,可以实现传输数据的加密,默认端口号443
InetAddress ia=InetAddress.getByName("www.baidu.com");
System.out.println(ia);
System.out.println(ia.getHostName());
System.out.println(ia.getHostAddress());
InetAddress ia2=InetAddress.getLocalHost();
InetAddress ia = InetAddress.getByName("14.215.177.254");
也可以是IP地址
boolean bb=ia.isReachable(2000);
System.out.println(bb);
try {
URL url = new URL("http://campus.51job.com/ssjkq/images/banner.jpg");
InputStream is = url.openStream();
OutputStream os=new FileOutputStream("d:/banner.jpg");
byte[] buffer=new byte[8192];
int len=0;
while((len=is.read(buffer))>0){
os.write(buffer,0,len);
}
is.close();
可以通过URL对象获取访问相关的属性
String getFile()获取资源名
String getHost()获取主机名
String getPath()获取路径部分的名称
int getPort()获取端口号,如果不能获取则返回-1
可以使用字符串解析获取相应部分的内容
重要方法
openConnection():URLConnection可以获取输入、输出流
http协议依靠的是全双工的TCP协议
openStream():InputStream直接获取服务器的响应输出流
os.close();
} catch (IOException e) {
e.printStackTrace();
}
URL url = new URL("http://campus.51job.com:80/ssjkq/images/banner.jpg");
System.out.println(url.getFile());
System.out.println(url.getHost());
System.out.println(url.getPath());
System.out.println(url.getPort());
String ss = "http://campus.51job.com:80/ssjkq/images/banner.jpg";
String fileName = ss.substring(ss.lastIndexOf("/") + 1);
System.out.println(fileName);
int pos1 = ss.indexOf("http://") + "http://".length();
int pos2 = ss.indexOf("/", pos1);
String hostName = ss.substring(pos1, pos2);
System.out.println(hostName);
String pathName = ss.substring(pos2);
System.out.println(pathName);
int pos3 = ss.lastIndexOf(":");
if (pos3 != -1) {
int pos4=ss.indexOf("/",pos3);
String port=ss.substring(pos3+1,pos4);
System.out.println(port);
}
URL vs URLConnection
从语义的角度上来说:URL代表一个资源的位置,URLConnection代表的是连接 Java中提供了两种读取数据的方法:1、通过URL对象直接获取相关的网络信息。2、先获取一个 URLConnection实例,然后再得到响应的InputSteam和OutputStream,实现数据的读写 URL是一种简单直接的方法,但是缺乏灵活性,并且只能读取只读性质的信息;URLConnection提供了 非常灵活有效的方法来读取网络资源
**URL url = new
URL("https://news.cctv.com/2022/04/10/ARTIWLj3f0W2lIKwP8lp7HTb220410.shtml")
;
URLConnection connection = url.openConnection();
InputStream is = connection.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
PrintWriter pw = new PrintWriter(new BufferedWriter(new
FileWriter("d:/bb.html")));
String tmp = "";
while ((tmp = br.readLine()) != null) {
System.out.println(tmp);
pw.println(tmp);
}
br.close();
pw.close();
**
TCP编程
TCP是一种面向虚电路连接的端对端的保证可靠传输的协议,使用TCP协议可以得到一个顺序的无差错的 数据流 UDP是一种不保证数据的可靠性,但是协议简单、传输速度块。一般用于视频或者音频的传输,不需要 很高的可靠性,可以容忍偶尔的丢帧 在具体编程中发送方和接收方必须成对的使用socket建立连接,在tcp协议的基础上进行通信 TCP是一种面向虚电路连接的端对端的保证可靠传输的协议,使用TCP协议可以得到一个顺序的无差错的 数据流 UDP是一种不保证数据的可靠性,但是协议简单、传输速度块。一般用于视频或者音频的传输,不需要 很高的可靠性,可以容忍偶尔的丢帧 在具体编程中发送方和接收方必须成对的使用socket建立连接,在tcp协议的基础上进行通信
Socket
socket套接字就是两个进行通信的主机之间逻辑连接的端点。socket编程实现主要涉及到客户端和服务 器端两方面。首先在服务器端创建一个服务器套接字ServerSocket,并将其附加到一个端口上,服务器 可以通过这个端口监听客户端的连接请求。端口号是int类型,取值范围为0到65535,但是一般0到1024 属于特殊保留的端口。 服务器和客户端建立连接时,需要服务器的域名或者IP地址,加上端口号,可以打开一个套接字。当服 务器接收到客户端的连接请求后,服务器和客户端之间的通信实际上就是一种输出输入流的操作 典型的网络编程模型 ServerSocket类 java.net.ServerSocket用于表示一个服务器端套接字,主要功能就是监听客户端的连接请求,并将照客 户端的连接请求存入到请求队列中,默认请求队列大小为50 ServerSocket()创建非绑定服务器指定端口的套接字 ServerSocket(int)创建绑定到服务器指定算口的套接字,其中的int类型参数就是对应的监听端口 号,取值范围为0-65535,一般不建议使用1024以下的端口号。其中0表示使用任意的没有被占用 的端口。如果当前指定端口已经被占用,则出异常
for(int i=0; i<=65535;i++){
ServerSocket ss=null;
try{
ss=new ServerSocket(i);
行,如果报错则表示该端口已经占用
} catch(Exception e){
System.out.println(i+"端口已经被占用")
} finally{
if(ss!=null)
ss.close();
}
}
package intnet;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class Server {
public static void main(String[] args) throws Exception {
ServerSocket ss = new ServerSocket(9000);
Socket socket = ss.accept();
Scanner sc = new Scanner(System.in);
InputStream is = socket.getInputStream();
OutputStream os = socket.getOutputStream();
for (int i = 0; i < 3; i++) {
BufferedReader br = new BufferedReader(new InputStreamReader(is));
String str = br.readLine();
System.out.println("服务器接收到客户端的数据:" + str);
PrintStream ps = new PrintStream(os);
System.out.println("服务器请说话");
String ss1 = sc.nextLine();
ps.println(ss1 + i);
}
is.close();
os.close();
sc.close();
socket.close();
}
}
package intnet;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
import java.util.Scanner;
public class Client {
public static void main(String[] args) throws Exception {
Socket socket = new Socket("localhost", 9000);
Scanner sc = new Scanner(System.in);
InputStream is = socket.getInputStream();
OutputStream os = socket.getOutputStream();
for (int i = 0; i < 3; i++) {
PrintStream ps = new PrintStream(os);
System.out.println("客户端请说话");
String ss = sc.nextLine();
ps.println(ss + i);
BufferedReader br = new BufferedReader(new InputStreamReader(is));
String str = br.readLine();
System.out.println("客户端收到服务器接的数据:" + str);
}
is.close();
os.close();
sc.close();
socket.close();
}
}
UDP编程
UDP是用户数据报协议的简称,是一种无连接的协议,每个数据报都是一个独立信息,包括完成的源地 址和目标地址,它能够在网络上以任何可能的路径传送到目的地,因此是否能够到达目的地、到达目的 地的时间以及内容的正确性都是不能保证的 UDP vs TCP UDP 每个数据报中都由完整的地址信息,因此无需在发送方和接收方之间建立连接 UDP传输数据时是有大小限制的,每个传输的数据报应该在64KB之内 UDP是一个不可靠的协议,所以发送方发送的数据报并不一定以相同的顺序到达接收方 UDP操作简单,一般只需要少量的监控,常用于局域网高可靠的分散系统的网络环境中,例如视频 会议 TCP 面向虚电路连接的协议,在socket之间进行数据传输之前必须协商建立连接,所以在TCP中需要有 连接时间 理论上来说TCP传送数据大小没有限制 TCP是一个可靠的协议,能够保证正确的传送和接收 TCP为了保证数据的可靠传送是需要付出代价的,对数据内容的校验必然占据计算机的处理时间和 网络带宽,所以TCP的传送效率不如UDP UDP通信过程 发送数据报过程: 1、使用DatagramSocket创建一个数据报套接字 2、使用DatagramPacket(byte[] data数据,int offset偏移量指定下标,int length长度,InetAddress接收方 地址,port接收方端口号) 创建一个要发送的数据报 3、使用DatagramSocket的send方法就可以发送数据报
package intnet;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class UDPclient {
public static void main(String[] args) throws Exception {
DatagramSocket socket = new DatagramSocket();
String str = "小胖回家吃饭!";
byte[] data = str.getBytes();
DatagramPacket dp = new DatagramPacket(data, data.length, InetAddress.getLocalHost(), 9999);
socket.send(dp);
socket.close();
}
package intnet;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class UDPservice {
public static void main(String[] args) throws Exception {
DatagramSocket socket = new DatagramSocket(9999);
byte[] buffer = new byte[30];
DatagramPacket dp = new DatagramPacket(buffer, buffer.length);
socket.receive(dp);
String res = new String(dp.getData(), 0, dp.getLength());
socket.close();
System.out.println("接收到的数据:" + res);
}
}
|