SocketChannel上的ByteBuffer - 腾讯云开发者社区 - 腾讯云

开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

ByteBuffer的用法

ByteBuffer是NIO里用得最多的Buffer。 ByteBuffer最核心的方法是put(byte)和get()。分别是往ByteBuffer里写一个字节，和读一个字节。...值得注意的是，ByteBuffer的读写模式是分开的，正常的应用场景是：往ByteBuffer里写一些数据，然后flip()，然后再读出来。我们先来看看ByteBuffer的几个主要的方法。...可以通过，ByteBuffer buffer=ByteBuffer.allocate(256);创建或者 ByteBuffer buffer=ByteBuffer.wrap(byteArray);这里的...buffer.clear(); 这个方法实际上也不会改变缓冲区的数据,而只是简单的重置了缓冲区的主要索引值，不必为了每次读写都创建新的缓冲区，那样做会降低性能。...给大家两个例子：这个代码是针对有数据的ByteBuffer，我们读取出来数据，写成文件的操作。之前用来做H264写文件用到的。仅供参考。

1.8K1 0

012. NIO 非阻塞网络编程

介绍缓冲区本质上是一个可以写入数据的内存块(类似数组)，然后可以再次读取。此内存块包含在 NIO Buffer 对象中，该对象提供了一组方法，可以更轻松地使用内存块。...读取模式时代表读取数据的位置。 limit 限制：写入模式，限制等于 buffer 的容量。读取模式下，limit 等于写入的数据量。 ? 3. ByteBuffer 内存类型 4....socketChannel = (SocketChannel) key.attachment(); ByteBuffer requestBuffer = ByteBuffer.allocate...1、创建main和sub两组线程 nioServer.initAndRegister(); // 2、创建serverSocketChannel，注册到mainReactor线程上的...selector上 nioServer.bind(); // 3、为serverSocketChannel绑定端口 } } 6.

4002 0

您找到你想要的搜索结果了吗？

是的

没有找到

Java使用NIO实现Socket通信

注册到selector上，事件为OP_ACCEPT，接收事件 serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT)...// 此方法虽然是阻塞的，但由于上面基于事件的判断，到这一步时，连接就已经产生了，所以不会阻塞 SocketChannel socketChannel = serverSocketChannel.accept...); // 将上面的socketChannel注册到selector选择器上，事件注册为OP_READ，读取事件 socketChannel.register...// 获取到该socketChannel关联的缓冲 ByteBuffer byteBuffer = (ByteBuffer) selectionKey.attachment...(); // 读取通道中的数据 socketChannel.read(byteBuffer);

7742 0

NIO之Channel通道（二）-SelectableChannel、SocketChannel、ServerSocketChannel

可选通道的使用大致过程如下： 1.新建通道。 2.将通道的事件注册到选择器Selector上。 3.通过SelectKey获得需要处理的通道，然后对通道进行处理。...在ServerSocketChannle和SocketChannel上提供了register方法来实现注册，通过SelectionKey来实现选择。...write(ByteBuffer) write(ByteBuffer[], int, int) write(ByteBuffer[]) 2.1.15getLocalAddress() 获取此通道的套接字绑定的地址...并设置选择器的时间是OP_ACCET // 一个通道可以注册到多个选择器上，但是一个通道在一个选择器上只能注册一次。...channel = server.accept(); // 将建立的链接设置为准备读，并注册到选择器上。

5872 0

【NIO】NIO版本鸿儒聊天室

ByteBuffer NIO中使用的读写缓冲区 Selector 多路复用器将channel注册在多路复用器上，并监听相应的事件多线程线程池 # 代码温馨提示：注意看代码注释哟~ 跟上节奏，很简单...SocketChannel接入事件 try { // ServerSocketChannel上触发的客户端SocketChannel接入...try { // 读取通道上的数据写入缓冲区(返回0或者-1说明读到了末尾) while (socketChannel.read(byteBuffer...(); // 在首尾进行标记，因为需要给每个客户端发送同样的数据，需要重复读取 byteBuffer.mark(); // 当前注册在多路复用器上的SelectionKey...try { // 将通道上的数据写入缓冲区(返回0或者-1说明读到了末尾) while (socketChannel.read(byteBuffer

5741 0

NIO之SocketChannel,SocketChannel ,DatagramChannel解读

基本概述（1）SocketChannel 就是 NIO 对于非阻塞 socket 操作的支持的组件，其在 socket 上封装了一层，主要是支持了非阻塞的读写。...如果 SocketChannel 在一个线程上 read 阻塞，另一个线程对该 SocketChannel 调用 shutdownInput，则读阻塞的线程将返回-1 表示没有读取任何数据；如果 SocketChannel...在一个线程上 write 阻塞，另一个线程对该 SocketChannel 调用 shutdownWrite，则写阻塞的线程将抛出AsynchronousCloseException SocketChannel...", 80)); ByteBuffer byteBuffer = ByteBuffer.allocate(16); socketChannel.read(byteBuffer); socketChannel.close...(false); ByteBuffer byteBuffer = ByteBuffer.allocate(16); socketChannel.read(byteBuffer); socketChannel.close

4253 0

Java网络编程--NIO非阻塞网络编程

Buffer（缓冲区）缓冲区本质上是一个可以写入数据的内存块（类似数组），然后可以再次读取。此内存块包含在NIO Buffer对象中，该对象提供了一组方法，可以更轻松的使用内存块。...有两种创建SocketChannel的形式，一个是客户端主动发起和服务器的连接，还有一个就是服务端获取的新连接。...socketChannel = (SocketChannel) key.attachment(); try { ByteBuffer byteBuffer...= ByteBuffer.allocate(1024); while (socketChannel.isOpen() && socketChannel.read(byteBuffer...byteBuffer = ByteBuffer.wrap(msg.getBytes()); while (byteBuffer.hasRemaining()) { socketChannel.write

9032 0

NIO从入门到踹门

2.1.2 常用的类型ByteBuffer 一般我们常用的类型是ByteBuffer，把数据转成字节进行处理。实质上是一个byte[]数组。...HeapByteBuffer的使用场景：除了以上的场景外，其他情况还是建议使用HeapByteBuffer，没有达到一定的量级，实际上使用DirectByteBuffer是体现不出优势的。...所以可以看出实质上capacity容量大小是不变的，实际上是通过控制position和limit的值来控制读写的数据。 2.2 管道(Channel) 首先我们看一下Channel有哪些子类： ?...这就是一个简单的例子，实际上上面的例子是阻塞式的。要做到非阻塞还需要使用选择器Selector。...2.3 选择器(Selector) Selector翻译成选择器，有些人也会翻译成多路复用器，实际上指的是同一样东西。只有网络IO才会使用选择器，文件IO是不需要使用的。

9562 0

【Netty】NIO 网络编程聊天室案例

处理客户端消息转发事件 : ① 读取客户端上传的数据 : 通过 SelectionKey 获取通道和缓冲区 , 使用套接字通道 ( SocketChannel ) 读取缓冲区 ( ByteBuffer...message)); } catch (IOException e) { //e.printStackTrace(); // 如果此处出现异常, 说明该客户端离线了, 服务器提示, 取消选择器上的注册信息...IOException e) { //e.printStackTrace(); // 如果此处出现异常, 说明该客户端离线了, 服务器提示, 取消选择器上的注册信息...//e.printStackTrace(); // 如果此处出现异常, 说明该客户端离线了, 服务器提示, 取消选择器上的注册信息...//e.printStackTrace(); // 如果此处出现异常, 说明该客户端离线了, 服务器提示, 取消选择器上的注册信息

1.4K1 0

NIO - 多人聊天室Demo代码

socketChannel.configureBlocking(false); // 将channel注册到selector上，监听可读事件 socketChannel.register...(); // 读取buffer中的内容 request += Charset.forName("UTF-8").decode(byteBuffer);...} // 将channel再次注册到selector上，监听其他的可读事件 socketChannel.register(selector, SelectionKey.OP_READ...socketChannel = (SocketChannel) selectionKey.channel(); ByteBuffer byteBuffer = ByteBuffer.allocate...("UTF-8").decode(byteBuffer); } // 将channel再次注册到selector上，监听他的可读事件 socketChannel.register

1.5K3 0

21天学习挑战赛之Java网络编程（二）

} //给客户端的回写数据 socketChannel.write(ByteBuffer.wrap("哎哟喂好疼啊...JavaWeb在进行学习)，是建立在TCP/IP协议基础上,是网络应用层的协议。...socketChannel.configureBlocking(false); //把socketChannel注册到选择器上...socketChannel = (SocketChannel) selectionKey.channel(); ByteBuffer byteBuffer1 = ByteBuffer.wrap...//把socketChannel注册到选择器上 socketChannel.register(selectionKey.selector(), SelectionKey.OP_READ

2783 0

JAVA NIO Socket通道

DatagramChannel和SocketChannel都实现定义读写功能，ServerSocketChannel不实现，只负责监听传入的连接，并建立新的SocketChannel，本身不传输数据。...一个通道可以被注册到多个选择器上，但在每个选择器上，只能注册一次。...选择器： Selector上的已注册键集合中，会存在失效键、null，keys()返回，不可修改。已选择键集合，selectedKeys()返回，已经准备好的键集合，可能为空。...调用 Selector 对象的 wakeup( )方法将使得选择器上的第一个还没有返回的选择操作立即回。如果当前没有在进行中的选择，那么下一次对 select( )方法的一种形式的调用将立即返回。...socketChannel = (SocketChannel) selectionKey.channel(); ByteBuffer byteBuffer

9942 0

阻塞式网络通信和非阻塞式网络通信区别

); // 绑定链接 serverSocketChannel.bind(new InetSocketAddress(2022)); // 获取客户端的通道...byteBuffer = ByteBuffer.allocate(1024); while (socketChannel.read(byteBuffer) !...socketChannel.configureBlocking(false); ByteBuffer byteBuffer = ByteBuffer.allocate(1024);...Iterator iterator = selector.selectedKeys().iterator(); // 获得事件的key...= (SocketChannel) key.channel(); ByteBuffer byteBuffer = ByteBuffer.allocate(10

5571 0

NIO之完成网络通信

} // 显示的告诉服务器数据写完了 socketChannel.shutdownOutput(); int num = 0 ; byteBuffer.clear(); while...((num = socketChannel.read(byteBuffer)) !...(阻塞的) SocketChannel client = server.accept(); // 5.声明Buffer存储图片 ByteBuffer byteBuffer = ByteBuffer.allocate...轮训地获取选择器上已“就绪”的事件--->只要select()>0，说明已就绪 while (selector.select() > 0) { // 6....(false); // 8.2 注册到选择器上-->拿到客户端的连接为了读取通道的数据(监听读就绪事件) client.register(selector, SelectionKey.OP_READ

5510 0

搞清IO的四种模式

中写入数据时，这是在客户端线程中进行的，而SocketChannel.write()方法可能由于网络原因导致一定的阻塞，从而导致线程池线程长时间耗费在等待上，导致服务器响应降低。...NIO本质上采用的是IO多路复用模式，实际上就是一个事件驱动模型，简单的理解为一个服务器在绑定某个端口之后，其可以在一个线程了同时监听多个客户端连接，而且服务器可以对每个客户端分别设置对其哪些事件感兴趣...这里的Selector就可以理解为一个多路复用器，每个客户端连接就是一个SocketChannel，这些SocketChannel会在Selector上注册，并且设置对各个Channel感兴趣的事件。...上， // 同时监听服务端和客户端的事件； // 2....AIO本质上还是使用的NIO的多路复用来实现的，只不过在模型上其使用的是一种事件回调的方式处理各个事件，这种方式更加符合NIO异步模型的概念，并且在编码难易程度上比NIO要小很多。

7082 0

ReactorProactor

继上一篇的 IO 多路复用之后，我们已经从操作系统的层面上，解决了 IO 不必要等待的问题不用再写类似的代码了： while (true) { if (socket.isReadable)...(byteBuffer); // 必须使用 interestOps 改变在 select 上注册的监听事件 key.interestOps...），flip 做的就是这件事 byteBuffer.flip(); socketChannel.write...(byteBuffer); // 必须使用 interestOps 改变在 select 上注册的监听事件...并且将两个 select 放在不同线程上跑，当有客户连接到来，监听客户连接的 select 将生成的 socketChannel 注册到监听客户连接上读写请求的 select 如果还不够，还可以使用多个

3322 0

Netty: NIO Selector选择器（CS demo详细注释与源码）

Netty 基础 java NIO Selector 三个元素： Selector选择器、SelectableChannel可选择的通道、SelectionKey选择键本质上，Selector是监听器...FileChannel就不是可选择的，Socket相关的通道都是可选择的一个通道可以被注册到多个选择器上吗？...可以的多个通道可以注册到一个选择器上，但一个通道只能在一个选择器中注册一次 SelectionKey，封装了要监听的事件，连接、接收、读、写。...(writebuffer); // 读取客户端的数据 ByteBuffer readbuffer = ByteBuffer.allocate(128);...); // 读取客户端的数据 ByteBuffer readbuffer = ByteBuffer.allocate(128); StringBuffer

2683 0

Java 17 - NIO

NIO 概念我们传统上处理socket IO时, 需要给每一个连接创建一个线程, 当并发的连接数量非常大的时候, 线程所占用的栈内存和CPU线程切换的开销将非常大....NIO实现了IO多路复用中的Reactor模型, 一个线程使用Selector通过轮询的方式去监听多个Channel上的时间, 从而使一个线程可以处理多个事件....注册Channel 当我们将Channel注册到Selector上时, 要指定注册的具体事件, 事件的定义如下: public static final int OP_READ = 1 << 0; public...socketChannel) throws IOException { ByteBuffer byteBuffer = ByteBuffer.allocate(1024);...int n = socketChannel.read(byteBuffer); if(n == -1) { break;

4002 0

Java网络编程——NIO处理写事件(SelectionKey.OP_WRITE)

网上有一些例子都是在服务端读完数据后直接给客户端SocketChannel对应的SelectionKey注册上写事件（SelectionKey.OP_WRITE），写完数据后也不注销写事件： @Slf4j...socketChannel = (SocketChannel) selectionKey.channel(); ByteBuffer readBuffer = ByteBuffer.allocate...socketChannel = (SocketChannel) selectionKey.channel(); ByteBuffer writeBuffer = (ByteBuffer...，向服务端发送100MB的数据，在ByteBuffer readBuffer = ByteBuffer.allocate(MESSAGE_LENGTH);打上断点，运行到断点时，当服务端调用了socketChannel.write...这里的客户端是以阻塞模式运行的，即使把客户端的SocketChannel设置为非阻塞模式，也是无法及时收到服务端返回的数据的。

9151 0

Netty - IO模型之NIO

---- Non Blocking I/O 同步非阻塞模型同步非阻塞一个线程可以处理多个请求(连接)，客户端发送的连接请求都会注册到多路复用器selector上，多路复用器轮询到连接有IO请求就进行处理...，底层调用了linux内核的accept函数 SocketChannel socketChannel = serverSocket.accept(); if...Channel，即创建epoll Selector selector = Selector.open(); // 把ServerSocketChannel注册到selector上，...socketChannel = (SocketChannel) key.channel(); ByteBuffer byteBuffer = ByteBuffer.allocate...(128); int len = socketChannel.read(byteBuffer); // 如果有数据，把数据打印出来

3052 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

运营活动

活动名称

广告关闭