Java NIO系列教程(四) Scatter/Gather

转载自   Java NIO系列教程(四) Scatter/Gather

译文地址  作者:Jakob Jenkov   译者:郭蕾   

Java NIO开始支持scatter/gather,scatter/gather用于描述从Channel(译者注:Channel在中文经常翻译为通道)中读取或者写入到Channel的操作。
分散(scatter)从Channel中读取是指在读操作时将读取的数据写入多个buffer中。因此,Channel将从Channel中读取的数据“分散(scatter)”到多个Buffer中。
聚集(gather)写入Channel是指在写操作时将多个buffer的数据写入同一个Channel,因此,Channel 将多个Buffer中的数据“聚集(gather)”后发送到Channel。

scatter / gather经常用于需要将传输的数据分开处理的场合,例如传输一个由消息头和消息体组成的消息,你可能会将消息体和消息头分散到不同的buffer中,这样你可以方便的处理消息头和消息体。

Scattering Reads
Scattering Reads是指数据从一个channel读取到多个buffer中。如下图描述:

Java NIO: Scattering Read

代码示例如下:

1ByteBuffer header = ByteBuffer.allocate(128);
2ByteBuffer body   = ByteBuffer.allocate(1024);
3 
4ByteBuffer[] bufferArray = { header, body };
5 
6channel.read(bufferArray);

注意buffer首先被插入到数组,然后再将数组作为channel.read() 的输入参数。read()方法按照buffer在数组中的顺序将从channel中读取的数据写入到buffer,当一个buffer被写满后,channel紧接着向另一个buffer中写。

Scattering Reads在移动下一个buffer前,必须填满当前的buffer,这也意味着它不适用于动态消息(译者注:消息大小不固定)。换句话说,如果存在消息头和消息体,消息头必须完成填充(例如 128byte),Scattering Reads才能正常工作。

Gathering Writes

Gathering Writes是指数据从多个buffer写入到同一个channel。如下图描述:

Java NIO: Gathering Write

代码示例如下:

1ByteBuffer header = ByteBuffer.allocate(128);
2ByteBuffer body   = ByteBuffer.allocate(1024);
3 
4//write data into buffers
5 
6ByteBuffer[] bufferArray = { header, body };
7 
8channel.write(bufferArray);

buffers数组是write()方法的入参,write()方法会按照buffer在数组中的顺序,将数据写入到channel,注意只有position和limit之间的数据才会被写入。因此,如果一个buffer的容量为128byte,但是仅仅包含58byte的数据,那么这58byte的数据将被写入到channel中。因此与Scattering Reads相反,Gathering Writes能较好的处理动态消息。


本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/329018.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Linux获取本机hostname函数,Linux下获得主机与域名-gethostbyname和gethostbyaddr

1.数据结构hostent和servent:struct hostent{char *h_name;/* official domain name of host */char **h_aliases;/* null-terminated array of domain names */int h_addrtype;/* host address type (AF_INET) */int h_length;/* length of an address, in bytes */char **h_a…

ASP.NET Core Docker部署

前言 在前面文章中,介绍了 ASP.NET Core在 macOS,Linux 上基于Nginx和Jexus的发布和部署,本篇文章主要是如何在Docker容器中运行ASP.NET Core应用程序。 Asp.Net Core 发布和部署( MacOS Linux Nginx ) Asp.Net Core…

Java NIO系列教程(五) 通道之间的数据传输

转载自 Java NIO系列教程(五) 通道之间的数据传输译文地址 作者:Jakob Jenkov 译者:郭蕾 校对:周泰 在Java NIO中,如果两个通道中有一个是FileChannel,那你可以直接将数据从一个chan…

linux下单点故障的软件,KeepAlived防止单点故障

负载均衡器里面,HAProxy比较出名了,但是如果只用一台HAProxy,则会出现单点故障。这个时候,该KeepAlived出马了。环境介绍OS: Ubuntu 12.04虚拟IP: 192.168.56.2KeepAlived HaProxy : 192.168.56.101 (master)KeepAlived HaProxy : 192.168.…

当当网上书店购物车——JS源码

$(function($){//根据您挑选的商品,当当为您推荐部分的显示和隐藏$("#shopping_commend_arrow").click(function(){if($("#shopping_commend_sort").css("display")"none"){$(this).attr("src","images/sho…

开放重定向(Open Redirection)

简介 那些通过请求(如查询字符串和表单数据)指定重定向URL的Web程序可能会被篡改,而把用户重定向到外部的恶意URL。这种篡改就被称为开发重定向攻击。 场景分析 假设有一个正规网站http://nerddinner.com/,还有一个恶意网站或钓鱼…

linux ssh密钥对,Mac使用ssh密钥登录Linux

ssh登录Linux通常有两种方法:用户名密码登录、用户名密钥登录;使用用户名密码登录每次都要输入密码,相当麻烦,而使用用户名密钥登录则可以避免这个问题。创建密钥对文件打开本地终端,执行 ssh-keygen 命令创建密钥对&a…

ASP.NET Core quot;完整发布,自带运行时quot; 到jexus

一、阅读前须知 1.使用 jexus整合asp.net core的优点: 1)支持多站点,同一端口可以同时支持任何多的asp.net core应用程序; 2)应用程序启动、停止、重启与站点的启动、停止、重启等操作一致,无需手工管理asp.net core应用程序…

当当网头部和尾部——源码

头部&#xff1a; <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"> <html xmlns"http://www.w3.org/1999/xhtml"> <head><meta http-equiv&…

linux 文档操作,Linux学习之文档操作

8种机械键盘轴体对比本人程序员&#xff0c;要买一个写代码的键盘&#xff0c;请问红轴和茶轴怎么选&#xff1f;The Linux Command Line 学习翻译mkdirThe mkdir command is used to create directories.It works like this:mkdir命令是用来创建目录的&#xff0c;这样使用&am…

过多提交(Over Posting)

简介 过多提交的内容相对比较简单&#xff0c;因此&#xff0c;我只打算把原文中的一些关键信息翻译一下。原文链接如下&#xff1a; http://www.asp.net/mvc/overview/getting-started/getting-started-with-ef-using-mvc/implementing-basic-crud-functionality-with-the-ent…

关于ByteBuffer使用解释

转载自 关于ByteBuffer使用解释之前看过相关的ByteBuffer的使用&#xff0c;但是问题是那时还年轻&#xff0c;所以现在有点老了&#xff0c;因此&#xff0c;忘记了&#xff0c;所以决心看源代码了解一番----故作此篇文章。查看ByteBuffer的API&#xff0c;看的我是一头雾水&…

linux 命令 抛后台,在后台运行Linux命令的方法

通常情况下&#xff0c;当你在终端运行一个命令&#xff0c;在你开始输入另外一个命令之前&#xff0c;你必须等待当前命令运行结束。这被称为在前台运行命令&#xff0c;或者前台进程。当一个进程在前台运行时&#xff0c;它占用了你的 shell&#xff0c;并且你可以通过输入设…

.Net 分布式云平台基础服务建设说明概要

1&#xff09; 背景 建设云平台的基础框架&#xff0c;用于支持各类云服务的业务的构建及发展。 2&#xff09; 基础服务 根据目前对业务的理解和发展方向&#xff0c;总结抽象出以下几个基础服务&#xff0c;如图所示 3&#xff09; 概要说明 基础服务的发展会根据业务的发…

当当网头部和尾部——CSS源码

头部 charset "utf-8"; /* CSS Document *//*网页头部导航样式开始*/ .header_top,.header_middle,.header_search{margin-left:auto;margin-right:auto;width:955px;clear:both; } .header_top{border:solid 1px #999;background-image:url(../images/dd_header_bg.…

全球首发免费的MySql for Entity Framework Core

Background 一时兴起&#xff0c;想实现.NET Core下的MySQL ADO层和与Entity Framework Core对接&#xff0c;同时也是非常鄙视某厂商借着目前Oracle官方没有对.NET Core进行支持的时机捞金&#xff0c;然后也是为了学习一下Microsoft的Entity Framework原理&#xff0c;于是这…

麒麟linux百度云,百度网盘 Linux 版发布,搭配优麒麟运行更完美!

百度网盘 Linux 版发布&#xff0c;搭配优麒麟运行更完美!Linuxer 2019年6月21日 暂无评论 阅读 3,363 次近日&#xff0c;百度官宣推出了百度网盘 Linux 版(在此之前已发布 Windows、Android、iPhone、iPad、Windows Phone、Mac 等多个平台的版本)&#xff0c;版本号为 Linux …

学习笔记之ByteBuffer使用和实现以及文件内存映射

转载自 学习笔记之ByteBuffer使用和实现以及文件内存映射ByteBuffer和CharBuffer等其它Buffer的直接子类一样&#xff0c;顾名思义&#xff0c;就是存取字节的Buffer。很多数据最终在和底层交互上都是使用了字节&#xff0c;而更大的数据是由字节组合而成。谈到字节的组合&…

当当网上书店头部和尾部——JS源码

头部 $(function($){ // οnmοuseοver"myddang_show(dd_menu_top_down)" οnmοuseοut"myddang_hidden(dd_menu_top_down)"//下拉菜单$("#menu").mouseenter(function(){$("#dd_menu_top_down").slideDown(1000);}).mouseleave(…

SQL注入(SQL Injection)

简介 SQL注入攻击指的是通过构建特殊的输入作为参数传入Web应用程序&#xff0c;而这些输入大都是SQL语法里的一些组合&#xff0c;通过执行SQL语句进而执行攻击者所要的操作&#xff0c;其主要原因是程序没有细致地过滤用户输入的数据&#xff0c;致使非法数据侵入系统。 根据…