1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package io.netty.testsuite.autobahn;
17
18 import io.netty.bootstrap.ServerBootstrap;
19 import io.netty.buffer.PooledByteBufAllocator;
20 import io.netty.channel.ChannelFuture;
21 import io.netty.channel.ChannelOption;
22 import io.netty.channel.EventLoopGroup;
23 import io.netty.channel.MultiThreadIoEventLoopGroup;
24 import io.netty.channel.nio.NioIoHandler;
25 import io.netty.channel.socket.nio.NioServerSocketChannel;
26
27
28
29
30
31 public class AutobahnServer {
32
33 private final int port;
34
35 public AutobahnServer(int port) {
36 this.port = port;
37 }
38
39 public void run() throws Exception {
40 EventLoopGroup group = new MultiThreadIoEventLoopGroup(NioIoHandler.newFactory());
41 try {
42 ServerBootstrap b = new ServerBootstrap();
43 b.group(group)
44 .channel(NioServerSocketChannel.class)
45 .childOption(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT)
46 .childHandler(new AutobahnServerInitializer());
47
48 ChannelFuture f = b.bind(port).sync();
49 System.out.println("Web Socket Server started at port " + port);
50 f.channel().closeFuture().sync();
51 } finally {
52 group.shutdownGracefully();
53 }
54 }
55
56 public static void main(String[] args) throws Exception {
57 int port;
58 if (args.length > 0) {
59 port = Integer.parseInt(args[0]);
60 } else {
61 port = 9000;
62 }
63 new AutobahnServer(port).run();
64 }
65 }