1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package io.netty.example.udt.echo.bytes;
17
18 import io.netty.bootstrap.ServerBootstrap;
19 import io.netty.channel.ChannelFuture;
20 import io.netty.channel.ChannelInitializer;
21 import io.netty.channel.ChannelOption;
22 import io.netty.channel.nio.NioEventLoopGroup;
23 import io.netty.channel.udt.UdtChannel;
24 import io.netty.channel.udt.nio.NioUdtProvider;
25 import io.netty.handler.logging.LogLevel;
26 import io.netty.handler.logging.LoggingHandler;
27 import io.netty.util.concurrent.DefaultThreadFactory;
28
29 import java.util.concurrent.ThreadFactory;
30
31
32
33
34
35
36 public final class ByteEchoServer {
37
38 static final int PORT = Integer.parseInt(System.getProperty("port", "8007"));
39
40 public static void main(String[] args) throws Exception {
41 final ThreadFactory factory = new DefaultThreadFactory("udt");
42 final NioEventLoopGroup group = new NioEventLoopGroup(1, factory, NioUdtProvider.BYTE_PROVIDER);
43
44 try {
45 final ServerBootstrap boot = new ServerBootstrap();
46 boot.group(group)
47 .channelFactory(NioUdtProvider.BYTE_ACCEPTOR)
48 .option(ChannelOption.SO_BACKLOG, 10)
49 .handler(new LoggingHandler(LogLevel.INFO))
50 .childHandler(new ChannelInitializer<UdtChannel>() {
51 @Override
52 public void initChannel(final UdtChannel ch)
53 throws Exception {
54 ch.pipeline().addLast(
55 new LoggingHandler(LogLevel.INFO),
56 new ByteEchoServerHandler());
57 }
58 });
59
60 final ChannelFuture future = boot.bind(PORT).sync();
61
62 future.channel().closeFuture().sync();
63 } finally {
64
65 group.shutdownGracefully();
66 }
67 }
68 }