官方网站建设账务处理,建设管理网站首页,天城建设网站,优化推广服务商1. JAVA NIO基本介绍 Java NIO 全称 java non-blocking IO#xff0c;是指 JDK 提供的新API。从 JDK1.4 开始#xff0c;Java 提供了一系列改进的输入/输出的新特性#xff0c;被统称为 NIO(即 New IO)#xff0c;是同步非阻塞的 NIO 相关类都被放在 java.nio 包及子包下是指 JDK 提供的新API。从 JDK1.4 开始Java 提供了一系列改进的输入/输出的新特性被统称为 NIO(即 New IO)是同步非阻塞的 NIO 相关类都被放在 java.nio 包及子包下并且对原java.io 包中的很多类进行改写。 NIO 有三大核心部分Channel(通道)Buffer(缓冲区), Selector(选择器) NIO是 面向缓冲区 或者面向块编程的。数据读取到一个它稍后处理的缓冲区需要时可在缓冲区中前后移动这就增加了处理过程中的灵活性使用它可以提供非阻塞式的高伸缩性网络 Java NIO的非阻塞模式使一个线程从某通道发送请求或者读取数据但是它仅能得到目前可用的数据如果目前没有数据可用时就什么都不会获取而不是保持线程阻塞所以直至数据变的可以读取之前该线程可以继续做其他的事情。非阻塞写也是如此一个线程请求写入一些数据到某通道但不需要等待它完全写入这个线程同时可以去做别的事情。 通俗理解NIO是可以做到用一个线程来处理多个操作的。假设有10000个请求过来,根据实际情况可以分配50或者100个线程来处理。不像之前的阻塞IO那样非得分配10000个。 HTTP2.0使用了多路复用的技术做到同一个连接并发处理多个请求而且并发请求的数量比HTTP1.1大了好几个数量级。
2. NIO 和 BIO 的比较
BIO 以流的方式处理数据,而 NIO 以块的方式处理数据,块I/O 的效率比流I/O高很多BIO 是阻塞的NIO 则是非阻塞的BIO基于字节流和字符流进行操作而 NIO 基于Channel(通道)和Buffer(缓冲区)进行操作数据总是从通道读取到缓冲区中或者从缓冲区写入到通道中。Selector(选择器)用于监听多个通道的事件比如连接请求数据到达等因此使用单个线程就可以监听多个客户端通道
3. NIO 三大核心原理示意图 一张图描述NIO 的 Selector 、 Channel 和 Buffer 的关系((简单版) 关系图说明: 每个channel 都会对应一个BufferSelector 对应一个线程 一个线程对应多个channel(连接)该图反应了有三个channel 注册到 该selector //程序程序切换到哪个channel 是有事件决定的, Event 就是一个重要的概念Selector 会根据不同的事件在各个通道上切换Buffer 就是一个内存块 底层是有一个数组数据的读取写入是通过Buffer, 这个和BIO , BIO 中要么是输入流或者是输出流, 不能双向但是NIO的Buffer 是可以读也可以写, 需要 flip 方法切换channel 是双向的, 可以返回底层操作系统的情况, 比如Linux 底层的操作系统通道就是双向的. 3.1 缓冲区Buffer 缓冲区Buffer缓冲区本质上是一个可以读写数据的内存块可以理解成是一个容器对象(含数组)该对象提供了一组方法可以更轻松地使用内存块缓冲区对象内置了一些机制能够跟踪和记录缓冲区的状态变化情况。Channel 提供从文件、网络读取数据的渠道但是读取或写入的数据都必须经由Buffer
3.1.1 Buffer 类及其子类
3.1.1.1 Buffer继承关系 在 NIO 中Buffer 是一个顶层父类它是一个抽象类, 类的层级关系图: 记忆方法:java8大基本类型除了bool类型其他都有buffer对应的子类 ByteBuffer存储字节数据到缓冲区ShortBuffer存储字符串数据到缓冲区CharBuffer存储字符数据到缓冲区IntBuffer存储整数数据到缓冲区LongBuffer存储长整型数据到缓冲区DoubleBuffer存储小数到缓冲区FloatBuffer存储小数到缓冲区 3.1.1.2 Buffer的四个核心属性 Buffer类定义了所有的缓冲区都具有的四个属性来提供关于其所包含的数据元素的信息: Capacity:容量即可以容纳的最大数据量在缓冲区创建时被设定并且不能改变Limit:表示缓冲区的当前终点不能对缓冲区超过极限的位置进行读写操作。且极限是可以修改的Position: 位置下一个要被读或写的元素的索引每次读写缓冲区数据时都会改变改值为下次读写作准备Mark: 标记 3.1.1.3 Buffer类相关方法 public abstract class Buffer {//JDK1.4时引入的apipublic final int capacity( )//返回此缓冲区的容量public final int position( )//返回此缓冲区的位置public final Buffer position (int newPositio)//设置此缓冲区的位置public final int limit( )//返回此缓冲区的限制public final Buffer limit (int newLimit)//设置此缓冲区的限制public final Buffer mark( )//在此缓冲区的位置设置标记public final Buffer reset( )//将此缓冲区的位置重置为以前标记的位置public final Buffer clear( )//清除此缓冲区, 即将各个标记恢复到初始状态但是数据并不会真正擦除public final Buffer flip( )//反转此缓冲区 public final Buffer rewind( )//重绕此缓冲区public final int remaining( )//返回当前位置与限制之间的元素数public final boolean hasRemaining( )//告知在当前位置和限制之间是否有元素public abstract boolean isReadOnly( );//告知此缓冲区是否为只读缓冲区 //JDK1.6时引入的apipublic abstract boolean hasArray();//告知此缓冲区是否具有可访问的底层实现数组public abstract Object array();//返回此缓冲区的底层实现数组public abstract int arrayOffset();//返回此缓冲区的底层实现数组中第一个缓冲区元素的偏移量public abstract boolean isDirect();//告知此缓冲区是否为直接缓冲区
}3.1.1.4 ByteBuffer(其他子类类似只不过类型不同)
从前面可以看出对于 Java 中的基本数据类型(boolean除外)都有一个Buffer 类型与之相对应最常用的自然是ByteBuffer 类二进制数据该类的主要方法如下 public abstract class ByteBuffer {//缓冲区创建相关apipublic static ByteBuffer allocateDirect(int capacity)//创建直接缓冲区public static ByteBuffer allocate(int capacity)//设置缓冲区的初始容量public static ByteBuffer wrap(byte[] array)//把一个数组放到缓冲区中使用//构造初始化位置offset和上界length的缓冲区public static ByteBuffer wrap(byte[] array,int offset, int length) //缓存区存取相关API public abstract byte get( );//从当前位置position上getget之后position会自动1public abstract byte get (int index);//从绝对位置getpublic abstract ByteBuffer put (byte b);//从当前位置上添加put之后position会自动1public abstract ByteBuffer put (int index, byte b);//从绝对位置上put
}3.2 通道(Channel)
3.2.1 基本介绍 NIO的通道类似于流但有些区别如下 通道可以同时进行读写而流只能读或者只能写 通道可以实现异步读写数据 通道可以从缓冲读数据也可以写数据到缓冲 BIO 中的 stream 是单向的例如 FileInputStream 对象只能进行读取数据的操作而 NIO 中的通道 (Channel)是双向的可以读操作也可以写操作。 Channel在NIO中是一个接口 public interface Channel extends Closeable{}常用的 Channel 类有FileChannel、 DatagramChannel、ServerSocketChannel 和 SocketChannel。【ServerSocketChanne 类似 ServerSocket , SocketChannel 类似 Socket】 FileChannel 用于文件的数据读写DatagramChannel 用于 UDP 的数据读写ServerSocketChannel 和 SocketChannel 用于 TCP 的数据读写。
3.2.2 FileChannel 类
FileChannel主要用来对本地文件进行 IO 操作常见的方法有
public int read(ByteBuffer dst) 从通道读取数据并放到缓冲区中public int write(ByteBuffer src) 把缓冲区的数据写到通道中public long transferFrom(ReadableByteChannel src, long position, long count)从目标通道中复制数据到当前通道public long transferTo(long position, long count, WritableByteChannel target)把数据从当前通道复制给目标通道
3.2.3 应用实例1-本地文件写数据 实例要求: 使用前面学习后的ByteBuffer(缓冲) 和 FileChannel(通道)将hello,尚硅谷写入到file01.txt 中文件不存在就创建 package site.zhourui.nioAndNetty.nio;import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;public class NIOFileChannel01 {public static void main(String[] args) throws Exception{String str hello,尚硅谷;//创建一个输出流-channelFileOutputStream fileOutputStream new FileOutputStream(d://FileChannel01.txt);//通过 fileOutputStream 获取 对应的 FileChannel//这个 fileChannel 真实 类型是 FileChannelImplFileChannel fileChannel fileOutputStream.getChannel();//创建一个缓冲区 ByteBufferByteBuffer byteBuffer ByteBuffer.allocate(1024);//将 str 放入 byteBufferbyteBuffer.put(str.getBytes());//对byteBuffer 进行flipbyteBuffer.flip();//将byteBuffer 数据写入到 fileChannelfileChannel.write(byteBuffer);fileOutputStream.close();}
}执行结果: 3.2.4 应用实例2-本地文件读数据 实例要求: 使用前面学习后的ByteBuffer(缓冲) 和 FileChannel(通道)将file01.txt 中的数据读入到程序并显示在控制台屏幕假定文件已经存在 package site.zhourui.nioAndNetty.nio;import java.io.File;
import java.io.FileInputStream;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;public class NIOFileChannel02 {public static void main(String[] args) throws Exception {//创建文件的输入流File file new File(d://FileChannel01.txt);FileInputStream fileInputStream new FileInputStream(file);//通过fileInputStream 获取对应的FileChannel - 实际类型 FileChannelImplFileChannel fileChannel fileInputStream.getChannel();//创建缓冲区ByteBuffer byteBuffer ByteBuffer.allocate((int) file.length());//将 通道的数据读入到BufferfileChannel.read(byteBuffer);//将byteBuffer 的 字节数据 转成StringSystem.out.println(new String(byteBuffer.array()));fileInputStream.close();}
}执行结果: 3.2.5 应用实例3-使用一个Buffer完成文件读取 实例要求: 使用 FileChannel(通道) 和 方法 read , write完成文件的拷贝拷贝一个文本文件 1.txt , 放在项目下即可 package site.zhourui.nioAndNetty.nio;import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;public class NIOFileChannel03 {public static void main(String[] args) throws Exception{File file new File(d://FileChannel01.txt);FileInputStream fileInputStream new FileInputStream(file);FileChannel fileChannel fileInputStream.getChannel();FileOutputStream fileOutputStream new FileOutputStream(new File(d://copy.txt));FileChannel channel fileOutputStream.getChannel();ByteBuffer byteBuffer ByteBuffer.allocate(5);while (true){ //循环读取//这里有一个重要的操作一定不要忘了/*public final Buffer clear() {position 0;limit capacity;mark -1;return this;}*/byteBuffer.clear(); //清空bufferint read fileChannel.read(byteBuffer);if (read-1){//表示读完break;}//将buffer 中的数据写入到 -- copy.txtbyteBuffer.flip();channel.write(byteBuffer);}//关闭相关的流fileInputStream.close();fileOutputStream.close();}
}
执行结果: 注意事项: 在每次循环读取数据到byteBuffer之前一定要清空buffer,即byteBuffer.clear(); //clear方法
public final Buffer clear() {position 0;limit capacity;mark -1;return this;
} 如果不进行清空buffer,那么5和limit就会一直相等导致read变量后续一直为0,不能跳出循环 3.2.6 应用实例4-拷贝文件transferFrom 方法 实例要求: 使用 FileChannel(通道) 和 方法 transferFrom 完成文件的拷贝拷贝一张图片 package site.zhourui.nioAndNetty.nio;import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.channels.FileChannel;public class NIOFileChannel04 {public static void main(String[] args) throws IOException {//创建相关流FileInputStream fileInputStream new FileInputStream(D:\\1.jpeg);FileOutputStream fileOutputStream new FileOutputStream(D:\\2.jpeg);//获取各个流对应的filechannelFileChannel sourceCh fileInputStream.getChannel();FileChannel destCh fileOutputStream.getChannel();//使用transferForm完成拷贝
// destCh.transferFrom(sourceCh,0,sourceCh.size());sourceCh.transferTo(0,sourceCh.size(),destCh);//关闭相关通道和流sourceCh.close();destCh.close();fileInputStream.close();fileOutputStream.close();}
} 也可以使用transferTo sourceCh.transferTo(0,sourceCh.size(),destCh);3.3 关于Buffer 和 Channel的注意事项和细节
3.3.1 ByteBuffer 支持类型化的put 和 get ByteBuffer 支持类型化的put 和 get, put 放入的是什么数据类型get就应该使用相应的数据类型来取出否则可能有 BufferUnderflowException异常。 3.3.2 只读Buffer-asReadOnlyBuffer 可以将一个普通Buffer 转成只读BufferasReadOnlyBuffer() 3.3.3 映射Buffer-MappedByteBuffer NIO 还提供了 MappedByteBuffer 可以让文件直接在内存堆外的内存中进行修改 而如何同步到文件由NIO 来完成. MappedByteBuffer 可让文件直接在内存(堆外内存)修改, 操作系统不需要拷贝一次 文件之前内容: package site.zhourui.nioAndNetty.nio;import java.io.IOException;
import java.io.RandomAccessFile;
import java.nio.MappedByteBuffer;
import java.nio.channels.FileChannel;/*
说明
1. MappedByteBuffer 可让文件直接在内存(堆外内存)修改, 操作系统不需要拷贝一次*/
public class MappedByteBufferTest {public static void main(String[] args) throws IOException {// 创建一个随机访问文件流以从具有指定名称的文件中读取并可选择写入。RandomAccessFile randomAccessFile new RandomAccessFile(D:\\1.txt, rw);//获取对应的通道FileChannel channel randomAccessFile.getChannel();/*** 参数1: FileChannel.MapMode.READ_WRITE 使用的读写模式* 参数2 0 可以直接修改的起始位置* 参数3: 5: 是映射到内存的大小(不是索引位置) ,即将 1.txt 的多少个字节映射到内存* 可以直接修改的范围就是 0-5* 实际类型 DirectByteBuffer*/MappedByteBuffer mappedByteBuffer channel.map(FileChannel.MapMode.READ_WRITE, 0, 5);mappedByteBuffer.put(0, (byte) H);mappedByteBuffer.put(3, (byte) 9);mappedByteBuffer.put(4, (byte) Y);randomAccessFile.close();System.out.println(修改成功~~);}
}执行结果: 注意: 当channel.map第三个参数为5时mappedByteBuffer.put(5, (byte) ‘Y’);会爆IndexOutOfBoundsException 即 5: 是映射到内存的大小(不是索引位置) 3.3.4 Buffer的分散Scattering和聚集Gathering 前面我们讲的读写操作都是通过一个Buffer 完成的NIO还支持通过多个Buffer (即 Buffer 数组) 完成读写操作即 Scattering和Gathering package site.zhourui.nioAndNetty.nio;import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Arrays;/*** Scattering将数据写入到buffer时可以采用buffer数组依次写入 [分散]* Gathering: 从buffer读取数据时可以采用buffer数组依次读*/
public class ScatteringAndGatheringTest {public static void main(String[] args) throws Exception {//使用 ServerSocketChannel 和 SocketChannel 网络ServerSocketChannel serverSocketChannel ServerSocketChannel.open();InetSocketAddress inetSocketAddress new InetSocketAddress(7000);//绑定端口到socket 并启动serverSocketChannel.socket().bind(inetSocketAddress);//创建buffer数组ByteBuffer[] byteBuffers new ByteBuffer[2];byteBuffers[0] ByteBuffer.allocate(5);byteBuffers[1] ByteBuffer.allocate(3);//等客户端连接(telnet)SocketChannel socketChannel serverSocketChannel.accept();int messageLength 8; //假定从客户端接收8个字节//循环的读取while (true) {int byteRead 0;while (byteRead messageLength ) {long l socketChannel.read(byteBuffers);byteRead l; //累计读取的字节数System.out.println(byteRead byteRead);//使用流打印, 看看当前的这个buffer的position 和 limitArrays.asList(byteBuffers).stream().map(buffer - postion buffer.position() , limit buffer.limit()).forEach(System.out::println);}//将所有的buffer进行flipArrays.asList(byteBuffers).forEach(buffer - buffer.flip());//将数据读出显示到客户端long byteWirte 0;while (byteWirte messageLength) {long l socketChannel.write(byteBuffers); //byteWirte l;}//将所有的buffer 进行clearArrays.asList(byteBuffers).forEach(buffer- {buffer.clear();});System.out.println(byteRead: byteRead byteWrite byteWirte , messagelength messageLength);}}
}3.3.4.1 使用telnet测试
#连接服务端
telnet 127.0.0.1 7000
#发送4字节数据
send hellp执行结果: Scattering将数据写入到buffer时可以采用buffer数组依次写入 [分散]Gathering: 从buffer读取数据时可以采用buffer数组依次读 3.4 Selector(选择器)
3.4.1 基本介绍
Java 的 NIO用非阻塞的 IO 方式。可以用一个线程处理多个的客户端连接就会使用到Selector(选择器)Selector 能够检测多个注册的通道上是否有事件发生(注意:多个Channel以事件的方式可以注册到同一个Selector)如果有事件发生便获取事件然后针对每个事件进行相应的处理。这样就可以只用一个单线程去管理多个通道也就是管理多个连接和请求。只有在 连接/通道 真正有读写事件发生时才会进行读写就大大地减少了系统开销并且不必为每个连接都创建一个线程不用去维护多个线程避免了多线程之间的上下文切换导致的开销
3.4.2 Selector示意图和特点说明 Netty 的 IO 线程NioEventLoop 聚合了Selector(选择器也叫多路复用器)可以同时并发处理成百上千个客户端连接。当线程从某客户端Socket 通道进行读写数据时若没有数据可用时该线程可以进行其他任务。线程通常将非阻塞IO 的空闲时间用于在其他通道上执行 IO 操作所以单独的线程可以管理多个输入和输出通道。由于读写操作都是非阻塞的这就可以充分提升IO线程的运行效率避免由于频繁I/O阻塞导致的线程挂起。一个 I/O 线程可以并发处理N个客户端连接和读写操作这从根本上解决了传统同步阻塞I/O一连接一线程模型架构的性能、弹性伸缩能力和可靠性都得到了极大的提升。
3.4.3 Selector类相关方法 Selector 类是一个抽象类:
public abstract class Selector implements Closeable 常用方法和说明如下:
public static Selector open();//得到一个选择器对象public int select(long timeout);//监控所有注册的通道当其中有 IO 操作可以进行时将 对应的 SelectionKey 加入到内部集合中并返回参数timeout用来设置超时时间public Set selectedKeys();//从内部集合中得到所有的 SelectionKey 注意事项 ) NIO中的 ServerSocketChannel功能类似ServerSocketSocketChannel功能类似Socketselector 相关方法说明 selector.select()//阻塞selector.select(1000);//阻塞1000毫秒在1000毫秒后返回selector.wakeup();//唤醒selector 将阻塞select中的selector唤醒 selector.selectNow();//不阻塞立马返还 3.4.4 NIO 非阻塞 网络编程原理分析图 NIO 非阻塞 网络编程相关的(Selector、SelectionKey、ServerScoketChannel和SocketChannel) 关系梳理图 当客户端连接时会通过ServerSocketChannel 得到SocketChannelSelector 进行监听select方法,返回有事件发生的通道的个数.将socketChannel注册到Selector上,register(Selector sel, int ops),一个selector上可以注册多个SocketChannel注册后返回一个SelectionKey,会和该Selector 关联(集合)进一步得到各个SelectionKey(有事件发生)在通过SelectionKey反向获取SocketChannel , 方法channel()可以通过得到的channel , 完成业务处理
3.4.4.1 应用实例5-实现服务器端和客户端之间的数据简单通讯非阻塞 案例要求: 编写一个 NIO 入门案例实现服务器端和客户端之间的数据简单通讯非阻塞目的理解NIO非阻塞网络编程机制 3.4.4.1.1 NIOServer 服务端注意事项: serverSocketChannel拿到后一定要设置为非阻塞configureBlocking(false) 客户端连接服务器时创建socketChannel之后一定要设置为非阻塞 否则会爆如下异常IllegalBlockingModeException: register第三个参数可以关联buffer 我们可以通过key.channel()拿到对应的channel 我们可以通过key.attachment()拿到对应的buffer SelectionKey事件 OP_READ–读事件OP_WRITE–写事件OP_CONNECT–客户端连接事件OP_ACCEPT–数据接收事件 处理过对应事件的key一定要从selectedKeys中移除,防止重复操作 keyIterator.remove();accept方法是阻塞的,为什么我们serverSocketChannel.accept()程序仍然是非阻塞的? 因为NIO服务端是isAcceptable为true才去accept的,肯定就可以accept成功而BIO则不知道数据什么时候到达accept就会一直阻塞 package site.zhourui.nioAndNetty.nio.nioPractise;import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.*;
import java.util.Iterator;
import java.util.Set;public class NIOServer {public static void main(String[] args) throws Exception{//创建ServerSocketChannel - ServerSocketServerSocketChannel serverSocketChannel ServerSocketChannel.open();//绑定一个端口6666, 在服务器端监听serverSocketChannel.socket().bind(new InetSocketAddress(8888));//设置为非阻塞serverSocketChannel.configureBlocking(false);//得到一个Selecor对象Selector selector Selector.open();//把 serverSocketChannel 注册到 selector 关心 事件为 OP_ACCEPTserverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);System.out.println(注册后的selectionkey 数量 selector.keys().size()); // 1//循环等待客户端连接while (true) {//这里我们等待1秒如果没有事件发生, 返回if (selector.select(1000)0){System.out.println(服务器等待了1秒无连接);continue;}//如果返回的0, 就获取到相关的 selectionKey集合//1.如果返回的0 表示已经获取到关注的事件//2. selector.selectedKeys() 返回关注事件的集合// 通过 selectionKeys 反向获取通道SetSelectionKey selectionKeys selector.selectedKeys();System.out.println(selectionKeys 数量 selectionKeys.size());//遍历 SetSelectionKey, 使用迭代器遍历IteratorSelectionKey keyIterator selectionKeys.iterator();//监听事件while (keyIterator.hasNext()){//获取到SelectionKeySelectionKey key keyIterator.next();//根据key 对应的通道发生的事件做相应处理if(key.isAcceptable()){//如果是 OP_ACCEPT, 有新的客户端连接//该该客户端生成一个 SocketChannelSocketChannel socketChannel serverSocketChannel.accept();System.out.println(客户端连接成功 生成了一个 socketChannel socketChannel.hashCode());//将 SocketChannel 设置为非阻塞socketChannel.configureBlocking(false);//将socketChannel 注册到selector, 关注事件为 OP_READ 同时给socketChannel//关联一个BuffersocketChannel.register(selector,SelectionKey.OP_READ, ByteBuffer.allocate(1024));System.out.println(客户端连接后 注册的selectionkey 数量 selector.keys().size()); //2,3,4..}if (key.isReadable()){//发生 OP_READ//通过key 反向获取到对应channelSocketChannel channel (SocketChannel) key.channel();//获取到该channel关联的bufferByteBuffer buffer (ByteBuffer) key.attachment();channel.read(buffer);System.out.println(form 客户端 new String(buffer.array()));}//手动从集合中移动当前的selectionKey, 防止重复操作keyIterator.remove();}}}
}3.4.4.1.2 NIOClient 客户端的socketChannel也一定要设置为非阻塞ByteBuffer.wrap(byte[] array)方法将字节数组包裹到缓冲区中。可以获取一个刚好array大小的buffer package site.zhourui.nioAndNetty.nio.nioPractise;import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;public class NIOClient {public static void main(String[] args) throws Exception{//得到一个网络通道SocketChannel socketChannel SocketChannel.open();//提供服务器端的ip 和 端口InetSocketAddress inetSocketAddress new InetSocketAddress(127.0.0.1, 8888);//设置非阻塞socketChannel.configureBlocking(false);//连接服务器if (!socketChannel.connect(inetSocketAddress)){while (!socketChannel.finishConnect()){System.out.println(因为连接需要时间客户端不会阻塞可以做其它工作..);}}//...如果连接成功就发送数据String str hello~;//Wraps a byte array into a buffer//将字节数组包装到缓冲区中。ByteBuffer buffer ByteBuffer.wrap(str.getBytes());//发送数据将 buffer 数据写入 channelsocketChannel.write(buffer);System.in.read();}
}3.4.4.1.3 开启服务端连接一个客户端 3.4.4.1.4 开启服务端连接两个客户端
