Netty权威指南之文件传输

本章相关知识点：

文件是最常见的数据源之一，在程序经常需要将数据存储到文件中，比如：图片文件、声音文件等数据文件。在实际使用中，文件都包含一个特定的格式，这个格式需要程序员根据需求进行设计。读取已有文件是需要熟悉对应文件格式，才能把数据从文件中正确的读取出来。

在NIO类库提供之前，Java所以的文件操作分为两大类：

1、基于字节流的InputStream和OutputStram;

2、基于字符流的Reader和Writer；

通过NIO新提供的FileChannel类库可以方便地以“管道”方式对文件进行各种I/O操作，相比于传统以流方式进行的I/O操作有了很大的变化和改进。

本章主要学习目标

1、文件的基础知识

2、Netty文件传输开发

3、运行Netty 文件传输项目；

第一节：文件的基础知识

可以参考下面这边文章：

第二节：Netty文件传输开发

服务端源代码：

FileServer.java

package com.nio.file;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.LineBasedFrameDecoder;
import io.netty.handler.codec.string.StringDecoder;
import io.netty.handler.codec.string.StringEncoder;
import io.netty.util.CharsetUtil;
/**
* Created by vixuan-008 on 2015/6/25.
*/
public class FileServer {
public void run(int port) throws Exception {
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.option(ChannelOption.SO_BACKLOG, 100)
.childHandler(new ChannelInitializer<SocketChannel>() {
/*
* (non-Javadoc)
*
* @see
* io.netty.channel.ChannelInitializer#initChannel(io
* .netty.channel.Channel)
*/
public void initChannel(SocketChannel ch)
throws Exception {
ch.pipeline().addLast(
new StringEncoder(CharsetUtil.UTF_8),
new LineBasedFrameDecoder(1024),
new StringDecoder(CharsetUtil.UTF_8),
new FileServerHandler());
}
});
ChannelFuture f = b.bind(port).sync();
System.out.println("Start file server at port : " + port);
f.channel().closeFuture().sync();
} finally {
// 优雅停机
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
public static void main(String[] args) throws Exception {
int port = 17887;
new FileServer().run(port);
}
}

package com.nio.file;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.DefaultFileRegion;
import io.netty.channel.FileRegion;
import io.netty.channel.SimpleChannelInboundHandler;
import java.io.File;
import java.io.RandomAccessFile;
/**
* Created by vixuan-008 on 2015/6/25.
*/
public class FileServerHandler extends SimpleChannelInboundHandler<String> {
private static final String CR = System.getProperty("line.separator");
/*
* (non-Javadoc)
*
* @see
* io.netty.channel.SimpleChannelInboundHandler#messageReceived(io.netty
* .channel.ChannelHandlerContext, java.lang.Object)
*/
public void messageReceived(ChannelHandlerContext ctx, String msg)
throws Exception {
File file = new File(msg);
if (file.exists()) {
if (!file.isFile()) {
ctx.writeAndFlush("Not a file : " + file + CR);
return;
}
ctx.write(file + " " + file.length() + CR);
RandomAccessFile randomAccessFile = new RandomAccessFile(msg, "r");
FileRegion region = new DefaultFileRegion(
randomAccessFile.getChannel(), 0, randomAccessFile.length());
ctx.write(region);
ctx.writeAndFlush(CR);
randomAccessFile.close();
} else {
ctx.writeAndFlush("File not found: " + file + CR);
}
}
/*
* (non-Javadoc)
*
* @see
* io.netty.channel.ChannelHandlerAdapter#exceptionCaught(io.netty.channel
* .ChannelHandlerContext, java.lang.Throwable)
*/
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
throws Exception {
ctx.close();
}
}

启动文件服务器，打开CMD控制台，通过telnet命令连接到主机，如图所示：

连接成功后，输入需要传输的文件路径：D:network.xml，然后输入回车键，显示结果如图所示：

最后

以上就是深情板凳为你收集整理的Netty权威指南之文件传输的全部内容，希望文章能够帮你解决Netty权威指南之文件传输所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。