项目网站建设业务分析,wordpress主题 google,自己做电商网站吗,免费静态网页1.阻塞模式
一个线程来处理多个连接显得力不从心
accept等待连接 是一个阻塞方法
read读取SocketChannel中的数据 是一个阻塞方法 /*** 服务端* param args* throws IOException*/public static void main(String[] args) throws IOException {//建立一个缓冲区ByteBuffer b…1.阻塞模式
一个线程来处理多个连接显得力不从心
accept等待连接 是一个阻塞方法
read读取SocketChannel中的数据 是一个阻塞方法 /*** 服务端* param args* throws IOException*/public static void main(String[] args) throws IOException {//建立一个缓冲区ByteBuffer byteBuffer ByteBuffer.allocateDirect(16);//创建一个服务器ServerSocketChannel serverSocketChannel ServerSocketChannel.open();//给服务器绑定一个端口8000让客户端来连接serverSocketChannel.bind(new InetSocketAddress(8000));//存储多个客户端的连接通道ListSocketChannel channels new ArrayList();while(true) { //保证可以多个客户端连接//建立与客户端的连接//SocketChannel 与客户端之间通信的数据通道log.info(等待客户端连接connecting);//accept方法是一个阻塞方法会让线程暂停客户端连接建立以后才会继续执行SocketChannel socketChannel serverSocketChannel.accept();log.info(已连接connected...{}, socketChannel);channels.add(socketChannel);for (SocketChannel sc: channels ) {//接受客户端发送的数据log.info(等待客户端向SocketChannel中传输数据...{}, sc);//read方法是一个阻塞方法会让线程暂停sc.read(byteBuffer);byteBuffer.flip();//读模式String byteBufferContent StandardCharsets.UTF_8.decode(byteBuffer).toString();log.info(byteBufferContent{}, byteBufferContent);byteBuffer.clear();//写模式从0开始log.info(读完毕..{}, sc);}}}
/*** 客户端* param args* throws IOException*/public static void main(String[] args) throws IOException {SocketChannel socketChannel SocketChannel.open();//连接服务端地址localhost:8000socketChannel.connect(new InetSocketAddress(localhost, 8000));//将hello字符串-byte[]-ByteBuffer-socketChannelsocketChannel.write(StandardCharsets.UTF_8.encode(hello));System.out.println(waiting...);}
2.非阻塞模式
/*** 服务端* param args* throws IOException*/public static void main(String[] args) throws IOException {//建立一个缓冲区ByteBuffer byteBuffer ByteBuffer.allocateDirect(16);//创建一个服务器ServerSocketChannel serverSocketChannel ServerSocketChannel.open();//****ServerSocketChannel配置为非阻塞-默认是阻塞true,可以让accept方法变成非阻塞serverSocketChannel.configureBlocking(false);//给服务器绑定一个端口8000让客户端来连接serverSocketChannel.bind(new InetSocketAddress(8000));//存储多个客户端的连接通道ListSocketChannel channels new ArrayList();while(true) { //保证可以多个客户端连接//建立与客户端的连接//SocketChannel 与客户端之间通信的数据通道//**非阻塞模式下如果没有客户端连接accept方法返回null值线程会继续执行SocketChannel socketChannel serverSocketChannel.accept();if(null ! socketChannel) {log.info(已连接connected...{}, socketChannel);channels.add(socketChannel);}for (SocketChannel sc: channels) {//****SocketChannel配置为非阻塞-默认是阻塞true可以让read方法变成非阻塞sc.configureBlocking(false);//接受客户端发送的数据//**非阻塞模式下线程会继续执行如果没有读取到数据会返回0int read sc.read(byteBuffer);if(read 0) {byteBuffer.flip();//读模式String byteBufferContent StandardCharsets.UTF_8.decode(byteBuffer).toString();log.info(byteBufferContent{}, byteBufferContent);byteBuffer.clear();//写模式从0开始log.info(读完毕..{}, sc);}}}} 问题非阻塞模式会让线程一直在跑太忙了不能这么用。参考后续的Selector用法。
