forked from PhantomBot/PhantomBot
-
-
Notifications
You must be signed in to change notification settings - Fork 0
/
HTTPWSServerInitializer.java
72 lines (65 loc) · 2.52 KB
/
HTTPWSServerInitializer.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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
/*
* Copyright (C) 2016-2019 phantombot.tv
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package com.gmt2001.httpwsserver;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.http.HttpObjectAggregator;
import io.netty.handler.codec.http.HttpServerCodec;
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;
import io.netty.handler.codec.http.websocketx.extensions.compression.WebSocketServerCompressionHandler;
import io.netty.handler.ssl.OptionalSslHandler;
import io.netty.handler.ssl.SslContext;
/**
* Initializes {@link SocketChannel} objects for a {@link HTTPWSServer}
*
* @author gmt2001
*/
class HTTPWSServerInitializer extends ChannelInitializer<SocketChannel> {
/**
* The SSL context to use
*/
private final SslContext sslCtx;
/**
* Constructor
*
* @param sslCtx Either {@code null} or a prepared {@link SslContext}
*/
public HTTPWSServerInitializer(SslContext sslCtx) {
super();
this.sslCtx = sslCtx;
}
/**
* Initializes the {@link SocketChannel}
*
* @param ch The {@link SocketChannel} to initialize
* @throws Exception Passes any thrown exceptions up the stack
*/
@Override
protected void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline pipeline = ch.pipeline();
if (sslCtx != null) {
pipeline.addLast(new HttpOptionalSslHandler(sslCtx));
}
pipeline.addLast(new HttpServerCodec());
pipeline.addLast(new HttpObjectAggregator(65536));
pipeline.addLast(new WebSocketServerCompressionHandler());
pipeline.addLast(new WebSocketServerProtocolHandler("/ws", null, true, 65536, false, true));
pipeline.addLast("pagehandler", new HttpServerPageHandler());
pipeline.addLast("wshandler", new WebSocketFrameHandler());
}
}