文件服务器
实现一个可以展示指定用户输入的文件路径，返回对应文件内容的服务器。
实例代码
服务端
[java]
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35public class FileServer {
public static void main(String[] args) {
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap serverBootstrap = new ServerBootstrap();
ChannelFuture channelFuture = serverBootstrap.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new ChannelInitializer<SocketChannel>() {
@Override
protected void initChannel(SocketChannel ch) throws Exception {
// 编码 String
ch.pipeline().addLast(new StringEncoder(CharsetUtil.UTF_8))
// 按照行进行解码
.addLast(new LineBasedFrameDecoder(1024))
// String 解码
.addLast(new StringDecoder(CharsetUtil.UTF_8))
// 大数据流的处理
.addLast(new ChunkedWriteHandler())
.addLast(new FileServerHandler());
}
})
.bind(8889)
.syncUninterruptibly();
channelFuture.channel().closeFuture().syncUninterruptibly();
} finally {
workerGroup.shutdownGracefully();
bossGroup.shutdownGracefully();
}
}
}
FileServerHandler.java
针对文件服务器的处理，实现如下：
[java]
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32import java.io.RandomAccessFile;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.stream.ChunkedFile;
public class FileServerHandler extends SimpleChannelInboundHandler<String> {
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
// 提醒客户端输入文件路径
ctx.writeAndFlush("HELLO: Type the path of the file to retrieve.\n");
}
@Override
protected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception {
// 只读方式打开文件
try(RandomAccessFile file = new RandomAccessFile(msg, "r")) {
long length = file.length();
ctx.write("OK: " + length + '\n');
ctx.write(new ChunkedFile(file));
ctx.writeAndFlush("\n");
}
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
cause.printStackTrace();
ctx.close();
}
}
整体比较简单，exceptionCaught 为异常时的处理。
channelActive() 为客户端连接时，服务端返回客户端的提示。
channelRead0() 为服务端对于客户端的反馈，就是通过客户端输入的文件路劲，返回文件内容。
测试验证
我们直接使用本地的 telnet
- 打开命令行
输入 telnet localhost 8889
[plaintext]
1
2
3
4
5192:~ houbinbin$ telnet localhost 8889
Trying ::1...
Connected to localhost.
Escape character is '^]'.
HELLO: Type the path of the file to retrieve.
- 输入文件路径
[java]
1/Users/houbinbin/code/_github/netty-learn/netty-learn-four/src/main/java/com/github/houbb/netty/learn/four/file/FileServer.java
反馈如下：
就是把 FileServer.java 这个文件内容全部返回回来了。
[plaintext]
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30OK: 2387
/*
* Copyright (c) 2019. houbinbin Inc.
* netty-learn All rights reserved.
*/
package com.github.houbb.netty.learn.four.file;
....... 内容省略
/**
* <p> </p>
*
* <pre> Created: 2019/9/21 11:49 PM </pre>
* <pre> Project: netty-learn </pre>
*
* @author houbinbin
*/
public class FileServer {
public static void main(String[] args) {
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
.... 内容省略
}
}
Connection closed by foreign host.
拓展阅读
小结
可以发现基于 netty 实现一个文件的读写工具其实并不难。
我当时的第一个感觉是可以实现一个日志实时刷新的界面，感兴趣的小伙伴也可以自己实现以下。
希望本文对你有所帮助，如果喜欢，欢迎点赞收藏转发一波。
我是老马，期待与你的下次相遇。
源码阅读
我们使用的 handler
[java]
1
2
3
4
5
6
7
8
9
10
11
12
13
14.childHandler(new ChannelInitializer<SocketChannel>() {
@Override
protected void initChannel(SocketChannel ch) throws Exception {
// 编码 String
ch.pipeline().addLast(new StringEncoder(CharsetUtil.UTF_8))
// 按照行进行解码
.addLast(new LineBasedFrameDecoder(1024))
// String 解码
.addLast(new StringDecoder(CharsetUtil.UTF_8))
// 大数据流的处理
.addLast(new ChunkedWriteHandler())
.addLast(new FileServerHandler());
}
})
这里我们使用了多个 netty 内置的 handler。
下面来简单学习一下。
ps: 此处跳过 String 的编码器和解码器。
拓展阅读
LineBasedFrameDecoder
TODO…
