- 浏览: 1383335 次
- 性别:
- 来自: 北京
文章分类
- 全部博客 (346)
- linux (10)
- hbase (50)
- hadoop (23)
- java (52)
- java multi-thread (13)
- Oracle小记 (41)
- 机器学习 (12)
- 数据结构 (10)
- hadoop hive (16)
- java io (4)
- jms (1)
- web css (1)
- kafka (19)
- xml (2)
- j2ee (1)
- spring (6)
- ibatis (2)
- mysql (3)
- ext (3)
- lucene (3)
- hadoop pig (3)
- java nio (3)
- twemproxy (1)
- antlr (2)
- maven (6)
- mina (1)
- 列数据库 (1)
- oozie (2)
- mongodb (0)
- 报错 (0)
- jetty (1)
- neo4j (1)
- zookeeper (2)
- 数据挖掘 (3)
- jvm (1)
- 数据仓库 (4)
- shell (3)
- mahout (1)
- python (9)
- yarn (3)
- storm (6)
- scala (2)
- spark (5)
- tachyon (1)
最新评论
-
guokaiwhu:
赞啊!今晚遇到相同的问题,正追根溯源,就找到了博主!
hbase 报错gc wal.FSHLog: Error while AsyncSyncer sync, request close of hlog YouAr -
喁喁不止:
很清楚,有帮助。
hive常用函数 -
dsxwjhf:
Good job !!
kafka获得最新partition offset -
Locker.Xai:
参考了
freemaker教程 -
maoweiwer:
为啥EPHEMERAL_SEQUENTIAL类型的节点并没有自 ...
zookeeper 入门讲解实例 转
java nio的实例
public class NewIOChannel { private String file = ""; private String file2 = ""; @Before public void init(){ file = NewIOChannel.class.getResource("").getPath()+"\\myfile.txt"; file2 = NewIOChannel.class.getResource("").getPath()+"\\myfile2.txt"; System.out.println(file); } /** * outputStream channel写文件 * @throws IOException */ @Test public void FileTest() throws IOException{ String info[] = {"wang","fwefwe","北京"}; File file = new File(this.file); FileOutputStream output = null; output = new FileOutputStream(file); FileChannel fout = null; fout = output.getChannel(); ByteBuffer buf = ByteBuffer.allocate(1024); for (int i = 0; i < info.length; i++) { buf.put(info[i].getBytes("UTF-8")); } buf.flip(); fout.write(buf); fout.close(); output.close(); } @Test public void writeFile()throws IOException{ File file = new File(this.file); FileInputStream input = new FileInputStream(file); FileChannel fileChannel = input.getChannel(); byte data[] = new byte[(int)file.length()]; // MappedByteBuffer mbb = fileChannel.map(FileChannel.MapMode.READ_ONLY, 0, file.length()); // int foot = 0; // while(mbb.hasRemaining()) // data[foot++] = mbb.get(); ByteBuffer bufs = ByteBuffer.wrap(data); fileChannel.read(bufs); System.out.println(new String(data)); fileChannel.close(); } @Test public void writereadFile() throws IOException{ File file = new File(this.file); File file2 = new File(this.file2); FileInputStream input = new FileInputStream(file); FileOutputStream output = new FileOutputStream(file2); FileChannel fout = output.getChannel(); FileChannel fin = input.getChannel(); ByteBuffer buf = ByteBuffer.allocate(1024); int temp =0; while ((temp = fin.read(buf)) != -1) { buf.flip(); fout.write(buf); buf.clear(); } fin.close(); fout.close(); } @Test public void FileLockDemo() throws IOException, InterruptedException{ File file = new File(this.file); FileOutputStream output = new FileOutputStream(file,true); FileChannel fout = output.getChannel(); FileLock lock = fout.tryLock(); if(lock != null){ System.out.println(file.getName()+"文件被锁定5秒"); Thread.sleep(5000); lock.release(); System.out.println(file.getName()+"文件被解锁"); } fout.close(); output.close(); } }
发表评论
-
java内存使用查看 转
2015-10-29 14:51 832转:http://mxsfengg.iteye.com ... -
Java线上应用故障排查之二:高内存占用
2015-08-17 16:28 0搞Java开发的,经常会碰到下面两种异常: 1、java. ... -
java filechannel
2015-08-14 15:42 1012Java NIO中的FileChannel是一个连接到文件 ... -
Java线上应用故障排查之一:高CPU占用
2015-08-06 13:58 6126转http://blog.csdn.net/blade20 ... -
java注释
2015-04-10 15:49 0Java注解是附加在代码中的一些元信息,用于一些工具在编译、 ... -
转jvm
2015-03-24 14:13 1640一、回顾JVM内存分配 ... -
java 域名转换
2014-12-22 11:05 737import java.net.InetAddres ... -
freemaker教程
2014-10-13 11:56 1920新换了工作,与想象差距也太大了 最近沦落到做报表了,我就 ... -
protocal buffers入门实例
2014-09-22 21:08 1606hadoop yarn中新的系列化protocol buf ... -
正则小计
2014-09-18 20:47 0&site=(.*?)&可以匹配site的值 ... -
在HBase中应用MemStore-Local Allocation Buffers解决Full GC问题
2014-06-13 23:05 1550译者注:上个月 ... -
java ipc 实例
2014-05-21 22:59 4837java ipc实例,仿照hadoop ipc写的实例 1 ... -
java worker thread模式
2014-03-25 22:46 1940转两个帖子 一个java wo ... -
bloom filter
2014-03-09 19:41 1930看到hadoop join和hbase都有bloo ... -
java reference
2014-03-09 17:49 692转 http://www.iteye.com/to ... -
annotation实例
2014-02-11 22:04 1104加载指定目录的所有class,通过注释区分实体类 p ... -
java获取子类 转
2014-02-11 16:58 3090获取子类 package com.tools; ... -
动态代理
2013-08-14 20:38 1045动态代理,转:http://langyu.iteye. ... -
java byte inputstream and outputstream
2013-02-18 11:47 0转http://blog.csdn.net/rcoder ... -
JVM同步浅析
2013-01-11 11:38 1612堆 (所有类的实例或 ...
相关推荐
该资源包含了一个用javaNIO实现的读写文件以及复制文件的简单的demo,程序注释清晰,简单易懂,喜欢的下载!!!
实例介绍了一个简单的nio实例,适合刚接触nio的童鞋们....
nio代码实例,Java NIO 系列教程,买不了吃亏,买不了上当
java NIO 消息推送实例代码,解压Tmp.zip Desk为桌面程序,DeskAppServer为服务端程序,江巅
Java NIO 深入探讨了 1.4 版的 I/O 新特性,并告诉您如何使用这些特性来极大地提升您所写的 Java 代码的执行效率。这本小册子就程序员所面临的有代表性的 I/O 问题作了详尽阐述,并讲解了 如何才能充分利用新的 I/O ...
JavaNIO服务器实例Java开发Java经验技巧共6页.pdf.zip
java nio 编程一个实例子.服务端程序
java基于nio的通信实例,带UML结构图及server、client源码。
NULL 博文链接:https://dengqsintyt.iteye.com/blog/2083316
实例化HashMap类型的一个对象用来存放每一个客户对应的套接字和通道,实例化线程通道选择器等,当由用户请求时,接受,加入选择项,注册感兴趣事件,另一线程处理输入流,在前面加echo:,发给客户端。
NULL 博文链接:https://shift-alt-ctrl.iteye.com/blog/1840554
Java高并发编程代码(Netty NIO 实例)
主要介绍了Java NIO实例UDP发送接收数据代码分享,分享了客户端和服务端完整代码,小编觉得还是挺不错的,共需要的朋友参考。
基于Java NIO的网络服务器Netty生产实例
Java NIO深入探讨了1.4版的I/O新特性,并告诉您如何使用这些特性来极大地提升您所写的Java代码的执行效率。这本小册子就程序员所面临的有代表性的I/O问题作了详尽阐述,并讲解了如何才能充分利用新的I/O特性所提供的...
[第4节] JavaNIO流-通道1.flv [第5节] Java NIO流-通道2.flv [第6节] Java NIO流-socket通道操作.flv [第7节] Java NIO流-文件通道操作.flv [第8节] Java NIO流-选择器 .flv [第9节] Java NIO流-选择器操作.flv...
NIO编程实现实例,
Java NIO 深入探讨了 1.4 版的 I/O 新特性,并告诉您如何使用这些特性来极大地提升您所写的Java 代码的执行效率。这本小册子就程序员所面临的有代表性的 I/O 问题作了详尽阐述,并讲解了如何才能充分利用新的 I/O ...
基于Java的实例源码-NIO网络框架 xSocket.zip
一个NIO服务端,客户端的例子