网络模型图
UDP协议
通过UDP协议实现课程案例，客户端与服务器端进行传输
class UdpServer{
public static void main(String[] args) throws IOException {
//1.ip地址+端口号
System.out.println("udp服务器已经启动... 8080");
//创建服务器端端口号 默认使用本机Ip地址
DatagramSocket ds = new DatagramSocket(8080);
//服务器接受客户端1024个字节
byte[] bytes= new byte[1024];
//定义数据包
DatagramPacket dp = new DatagramPacket(bytes, bytes.length);
//接受客户端请求，将数据封装给数据包 如果客户端不往服务器端发送请求，就一直阻塞。
ds.receive(dp);
System.out.println("来源IP地址:"+dp.getAddress()+",端口号"+dp.getPort());
String result= new String(dp.getData(),0,dp.getLength());
System.out.println("服务器端接受客户端内容:"+result);
ds.close();
}
}
//先写服务器端 在写客户端
public class UdpClinet {
public static void main(String[] args) throws IOException {
System.out.println("udp客户端启动连接...");
//不传入端口号 作用客户端 创建一个socket客户端
DatagramSocket ds = new DatagramSocket();
String str="蚂蚁课堂";
byte[] strBytes= str.getBytes();
DatagramPacket dp = new DatagramPacket(strBytes, strBytes.length,InetAddress.getByName("127.0.0.1"),8080);
ds.send(dp);
ds.close();
}
}
TCP握手协议
在TCP/IP协议中，TCP协议采用三次握手建立一个连接。
第一次握手:建立连接时，客户端发送SYN包(SYN=J)到服务器，并进入SYN_SEND状态，等待服务器确认；
第二次握手:服务器收到SYN包，必须确认客户的SYN（ACK=J+1），同时自己也发送一个SYN包（SYN=K），即SYN+ACK包，此时服务器V状态；
第三次握手:客户端收到服务器的SYN＋ACK包，向服务器发送确认包ACK(ACK=K+1)，此包发送完毕，客户端和服务器进入ESTABLISHED状态，完成三次握手。
完成三次握手，客户端与服务器开始传送数据
四次分手：
由于TCP连接是全双工的，因此每个方向都必须单独进行关闭。这个原则是当一方完成它的数据发送任务后就能发送一个FIN来终止这个方向的连接。收到一个 FIN只意味着这一方向上没有数据流动，一个TCP连接在收到一个FIN后仍能发送数据。首先进行关闭的一方将执行主动关闭，而另一方执行被动关闭。
（1）客户端A发送一个FIN，用来关闭客户A到服务器B的数据传送。
（2）服务器B收到这个FIN，它发回一个ACK，确认序号为收到的序号加1。和SYN一样，一个FIN将占用一个序号。
（3）服务器B关闭与客户端A的连接，发送一个FIN给客户端A。
（4）客户端A发回ACK报文确认，并将确认序号设置为收到序号加1。
class TcpServer {
public static void main(String[] args) throws IOException {
System.out.println("tcp协议服务器端启动..");
ExecutorService newCachedThreadPool = Executors.newCachedThreadPool();
// 创建服务器端连接
ServerSocket serverSocket = new ServerSocket(8080);
try {
// while (true) {
// 接受客户端请求 阻塞功能
Socket accept = serverSocket.accept();
newCachedThreadPool.execute(new Runnable(){
@Override
public void run() {
try {
InputStream inputStream = accept.getInputStream();
// 将字节流转换成String类型
byte[] bytes = new byte[1024];
int len = inputStream.read(bytes);
String result=new String(bytes,0,len);
System.out.println("服务器端接受客户端内容:"+result);
OutputStream outputStream = accept.getOutputStream();
outputStream.write("this is yes itmayiedu.com".getBytes());
} catch (Exception e) {
// TODO: handle exception
}
}
});
// }
} catch (Exception e) {
// TODO: handle exception
}finally {
serverSocket.close();
}
}
}
public class TcpClinet {
public static void main(String[] args) throws IOException {
System.out.println("socket tcp客户端启动....");
//创建socket客户端
Socket socket=new Socket("127.0.0.1",8080);
OutputStream outputStream = socket.getOutputStream();
outputStream.write("我是蚂蚁课堂忠实粉丝....".getBytes());
socket.close();
}
}
BIO与NIO
IO(BIO)和NIO区别:其本质就是阻塞和非阻塞的区别
阻塞概念:应用程序在获取网络数据的时候,如果网络传输数据很慢，就会一直等待,直到传输完毕为止。
非阻塞概念:应用程序直接可以获取已经准备就绪好的数据,无需等待。
IO为同步阻塞形式,NIO为同步非阻塞形式,NIO并没有实现异步,在JDK1.7后升级NIO库包，支持异步非阻塞
同学模型NIO2.0(AIO)
BIO：同步阻塞式IO，服务器实现模式为一个连接一个线程，即客户端有连接请求时服务器端就需要启动一个线程进行处理，如果这个连接不做任何事情会造成不必要的线程开销，当然可以通过线程池机制改善。
NIO：同步非阻塞式IO，服务器实现模式为一个请求一个线程，即客户端发送的连接请求都会注册到多路复用器上，多路复用器轮询到连接有I/O请求时才启动一个线程进行处理。
AIO(NIO.2)：异步非阻塞式IO，服务器实现模式为一个有效请求一个线程，客户端的I/O请求都是由OS先完成了再通知服务器应用去启动线程进行处理。
同步时，应用程序会直接参与IO读写操作,并且我们的应用程序会直接阻塞到某一个方法上,直到数据准备就绪:
或者采用轮训的策略实时检查数据的就绪状态,如果就绪则获取数据.
异步时,则所有的IO读写操作交给操作系统,与我们的应用程序没有直接关系，我们程序不需要关系IO读写，当操作
系统完成了IO读写操作时,会给我们应用程序发送通知,我们的应用程序直接拿走数据极即可。