1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package io.netty.example.mqtt.heartBeat;
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.EventLoopGroup;
23 import io.netty.channel.MultiThreadIoEventLoopGroup;
24 import io.netty.channel.nio.NioIoHandler;
25 import io.netty.channel.socket.SocketChannel;
26 import io.netty.channel.socket.nio.NioServerSocketChannel;
27 import io.netty.handler.codec.mqtt.MqttDecoder;
28 import io.netty.handler.codec.mqtt.MqttEncoder;
29 import io.netty.handler.timeout.IdleStateHandler;
30
31 import java.util.concurrent.TimeUnit;
32
33 public final class MqttHeartBeatBroker {
34
35 private MqttHeartBeatBroker() {
36 }
37
38 public static void main(String[] args) throws Exception {
39 EventLoopGroup bossGroup = new MultiThreadIoEventLoopGroup(1, NioIoHandler.newFactory());
40 EventLoopGroup workerGroup = new MultiThreadIoEventLoopGroup(NioIoHandler.newFactory());
41
42 try {
43 ServerBootstrap b = new ServerBootstrap();
44 b.group(bossGroup, workerGroup);
45 b.option(ChannelOption.SO_BACKLOG, 1024);
46 b.channel(NioServerSocketChannel.class);
47 b.childHandler(new ChannelInitializer<SocketChannel>() {
48 @Override
49 protected void initChannel(SocketChannel ch) throws Exception {
50 ch.pipeline().addLast("encoder", MqttEncoder.INSTANCE);
51 ch.pipeline().addLast("decoder", new MqttDecoder());
52 ch.pipeline().addLast("heartBeatHandler", new IdleStateHandler(45, 0, 0, TimeUnit.SECONDS));
53 ch.pipeline().addLast("handler", MqttHeartBeatBrokerHandler.INSTANCE);
54 }
55 });
56
57 ChannelFuture f = b.bind(1883).sync();
58 System.out.println("Broker initiated...");
59
60 f.channel().closeFuture().sync();
61 } finally {
62 workerGroup.shutdownGracefully();
63 bossGroup.shutdownGracefully();
64 }
65 }
66 }