Netty
2021-02-06 06:17
标签：异步 编写 void 机制 io操作 关闭 color bytes 技术 先了解四个概念： 同步 ： 自己亲自出马持银行卡到银行取钱（使用同步IO时，Java自己处理IO读写）。 异步 ： 委托一小弟拿银行卡到银行取钱，然后给你（使用异步IO时，Java将IO读写委托给OS处理， 需要将数据缓冲区地址和大小传给OS(银行卡和密码)，OS需要支持异步IO操作API）。 阻塞 ： ATM排队取款，你只能等待（使用阻塞IO时，Java调用会一直阻塞到读写完成才返回）。 非阻塞 ： 柜台取款，取个号，然后坐在椅子上做其它事，等号广播会通知你办理，没到号你就不能去， 你可以不断问大堂经理排到了没有，大堂经理如果说还没到你就不能去（使用非阻塞IO时，如果不能读写Java调用会马上返回， 当IO事件分发器会通知可读写时再继续进行读写，不断循环直到读写完成）。 区分NIO BIO AIO Java对BIO、NIO、AIO的支持： Java BIO ： 同步并阻塞，服务器实现模式为一个连接一个线程，即客户端有连接请求时服务器端就需要启动一个线程进行处理， 如果这个连接不做任何事情会造成不必要的线程开销，当然可以通过线程池机制改善。（同步的，阻塞的） 再看一个BIO的案例 然后运用telnet 127.0.0.1 6666 按住ctrl+] =============================== Java NIO ： 同步非阻塞，服务器实现模式为一个请求一个线程，即客户端发送的连接请求都会注册到多路复用器上，多路复用器轮询到连接有I/O请求时才启动一个线程进行处理。 学习Netty的，Netty是一个NIO框架，因此在学习netty之前，还是先梳理一下NIO的知识。 Buffer是NIO用于存放特定基元类型数据的容器。缓冲区是特定基元类型的元素的线性有限序列。通过容量(capacity)、限制(limit)和位置(position)三个属性控制数据的写入大小和可读大小。 Netty 标签：异步 编写 void 机制 io操作 关闭 color bytes 技术 原文地址：https://www.cnblogs.com/yangj-Blog/p/13121316.html
package com.yang;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class BIO {
public static void main(String[] args) throws Exception{
//创建线程池
ExecutorService newCachedThreadPool = Executors.newCachedThreadPool();
//创建ServerSocket
ServerSocket serverSocket = new ServerSocket(6666);
System.out.println("服务器启动了");
while (true)
{
//监听，等待客户端连接
final Socket socket = serverSocket.accept();
System.out.println("连接到一个客户端");
//就创建一个线程，与之通信
newCachedThreadPool.execute(new Runnable() {
public void run() { //重写线程
//和客户端通讯
handler(socket);
}
});
}
}
//编写一个Hander方法和客户端通信
public static void handler(Socket socket){
//通过socket获得输入流
try {
System.out.println("连接线程id="+Thread.currentThread().getId()+"名字是"+Thread.currentThread().getName());
byte[] bytes = new byte[1024];
InputStream inputStream= socket.getInputStream();
while (true)
{
//执行handler先执行这里
System.out.println("通信线程id="+Thread.currentThread().getId()+"名字是"+Thread.currentThread().getName());
int read = inputStream.read(bytes);
//表示数据没有读取完毕
if(read!=-1)
{
//输出客户端发送的数据
System.out.println(new String(bytes,0,read));
}
//表示数据读取完毕
else {
break;
}
}
} catch (IOException e) {
e.printStackTrace();
}
finally {
System.out.println("连接关闭");
try {
socket.close();
}
catch (Exception e)
{
e.printStackTrace();
}
}
}
}
什么是Buffer
上一篇：JSP_登陆，查看新闻列表