package com.vyloy.server;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.Channels;
import java.nio.channels.ReadableByteChannel;
import java.nio.charset.Charset;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.vyloy.server.db.File;
import com.vyloy.server.db.service.FileService;
import com.vyloy.server.fileupload.FileUpload;
/**
* Servlet implementation class UploadServlet
*/
public class UploadServlet extends HttpServlet {
private static final long serialVersionUID = 1L;
/**
* @see HttpServlet#HttpServlet()
*/
public UploadServlet() {
super();
}
/**
* @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
*/
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
ByteBuffer result = ByteBuffer.allocate(3*1024*1024);
try {
ReadableByteChannel in = Channels.newChannel(request
.getInputStream());
ByteBuffer tempbytes = ByteBuffer.allocate(1024*1024);
while ((in.read(tempbytes)) != -1) {
tempbytes.flip();
//重点--比较临时字节数是否比输出字节缓存剩余容量大
if(result.remaining()<tempbytes.limit()){
ByteBuffer _result=ByteBuffer.allocate(result.capacity()*2);
result.flip();
_result.put(result);
result=_result;
}
result.put(tempbytes);
tempbytes.clear();
}
result.flip();
} catch (IOException e) {
e.printStackTrace();
response.getWriter().write("0");
return;
}
try{
//重点--result.array()会返回底层数组,如果有效数据少于容量,
//则数据中会包含很多没用的值为0的字节
//所以这里创建一个新的数组再把有效数据存入
byte[] bytes=new byte[result.limit()];
result.get(bytes);
result.clear();
FileUpload fileUpload = new FileUpload(bytes);
String fileName=new String(fileUpload.get("Filename"),Charset.forName("utf-8"));
byte[] data=fileUpload.get("Filedata");
File file = new File(fileName);
FileService.getInstance().save(file, data);
response.getWriter().write("1");
}catch(Exception e){
e.printStackTrace();
response.getWriter().write("0");
}
}
}
不变式
标记、位置、限制和容量值遵守以下不变式:
0 <= 标记 <= 位置 <= 限制 <= 容量
新创建的缓冲区总有一个 0 位置和一个未定义的标记。初始限制可以为 0,也可以为其他值,这取决于缓冲区类型及其构建方式。一般情况下,缓冲区的初始内容是未定义的。
清除、反转和重绕
除了访问位置、限制、容量值的方法以及做标记和重置的方法外,此类还定义了以下可对缓冲区进行的操作:
clear() 使缓冲区为一系列新的通道读取或相对放置 操作做好准备:它将限制设置为容量大小,将位置设置为 0。
flip() 使缓冲区为一系列新的通道写入或相对获取 操作做好准备:它将限制设置为当前位置,然后将位置设置为 0。
rewind() 使缓冲区为重新读取已包含的数据做好准备:它使限制保持不变,将位置设置为 0。
作者:翁志艺
分享到:
相关推荐
本文实例讲述了Android在JNI中使用ByteBuffer的方法。分享给大家供大家参考。具体如下: 一、ByteBuffer 定义 在NIO中,数据的读写操作始终是与缓冲区相关联的(读取时信道(SocketChannel)将数据读入缓冲区,写入时...
java api之ByteBuffer基础、应用场景、实战讲解 文档中有丰富的例子代码实现
Android GLSurfaceView 例子,演示了自定义GLSurfaceView、自定义渲染器的实现,创建一个3D透视模型的例子,里面涉及到触控笔、坐标、数据缓冲、模式矩阵、绘制图形、透视投影矩阵等相关技巧例子,写有几个自定义...
pvDataNativeJava 该项目使用 POJO 实现 pvData 序列化,而不是 pvData PV 容器类。 pvData 自省接口类和机制,其中使用 Java 反射 API 替换。... 序列化到缓冲区ByteBuffer buffer = ByteBuffer .
Android USB转串口通信开发实例详解 好久没有写文章了,年前公司新开了一个项目,是和usb转串口通信相关的,需求是用安卓平板通过usb转接后与好几个外设进行通信,一直忙到最近,才慢慢闲下来,趁着这个周末不忙,...
用java.nio.ByteBuffer类实现音频的反向播放,这个可以让你感觉时光倒流时我们能听到的声音。 举个例子:假如你说了句话“我爱你!”,时光倒回的话就是“!你爱我”,很有意思哦 体验下吧! 你会发现那些明星那么...
例子 public class StringData : ISerializable { public string Text { get ; set ; } public StringData ( string text ) { Text = text ; } public void Serialize ( ByteWriter writer ) { writer . ...
本文实例讲述了Android编程实现TCP客户端的方法。分享给大家供大家参考,具体如下: 因为项目上需要实现一个TCP Client 端;在网上找好多例子基本上都是阻塞方式完成; 我的实现例子:由Activity 及sever 来实现,在...
本文将通过一些实例来简介NIO库提供的一些新特性:非堵塞I/O,字符转换,缓冲以及通道。 一. 介绍NIO NIO包(java.nio.*)引入了四个关键的抽象数据类型,它们共同解决传统的I/O类中的一些问题。 1. ...
本文实例讲述了C#读取中文文件出现乱码的解决方法。分享给大家供大家参考。具体分析如下: 先来看这段代码: FileStream aFile = new FileStream(SingleFile,FileMode.Open); StreamReader sr = new StreamReader(a...