import static io.netty.handler.codec.http.HttpHeaders.Names.CONNECTION;

import static io.netty.handler.codec.http.HttpHeaders.Names.CONTENT_LENGTH;

import static io.netty.handler.codec.http.HttpHeaders.Names.CONTENT_TYPE;

import static io.netty.handler.codec.http.HttpResponseStatus.CONTINUE;

import static io.netty.handler.codec.http.HttpResponseStatus.OK;

import static io.netty.handler.codec.http.HttpVersion.HTTP_1_1;

import java.io.UnsupportedEncodingException;

import java.util.ArrayList;

import java.util.List;

import java.util.Random;

import org.json.simple.JSONObject;

import io.netty.bootstrap.ServerBootstrap;

import io.netty.buffer.Unpooled;

import io.netty.channel.Channel;

import io.netty.channel.ChannelFutureListener;

import io.netty.channel.ChannelHandlerContext;

import io.netty.channel.ChannelInboundHandlerAdapter;

import io.netty.channel.ChannelInitializer;

import io.netty.channel.ChannelOption;

import io.netty.channel.ChannelPipeline;

import io.netty.channel.EventLoopGroup;

import io.netty.channel.nio.NioEventLoopGroup;

import io.netty.channel.socket.SocketChannel;

import io.netty.channel.socket.nio.NioServerSocketChannel;

import io.netty.handler.codec.http.DefaultFullHttpResponse;

import io.netty.handler.codec.http.FullHttpResponse;

import io.netty.handler.codec.http.HttpHeaders;

import io.netty.handler.codec.http.HttpRequest;

import io.netty.handler.codec.http.HttpServerCodec;

import io.netty.handler.codec.http.HttpHeaders.Values;

import io.netty.handler.logging.LogLevel;

import io.netty.handler.logging.LoggingHandler;

/**

* An HTTP server that sends back the content of the received HTTP request

* in a pretty plaintext form.

*/

public final class ToyJavaApp {

public static void main(String[] args) throws Exception {

// Configure the server.

/*EventLoopGroup bossGroup = new NioEventLoopGroup(1);

EventLoopGroup workerGroup = new NioEventLoopGroup();

try {

ServerBootstrap b = new ServerBootstrap();

b.option(ChannelOption.SO_BACKLOG, 1024);

b.group(bossGroup, workerGroup)

.channel(NioServerSocketChannel.class)

.handler(new LoggingHandler(LogLevel.INFO))

.childHandler(new HttpHelloWorldServerInitializer());

Channel ch = b.bind(8080).sync().channel();

ch.closeFuture().sync();

} finally {

bossGroup.shutdownGracefully();

workerGroup.shutdownGracefully();

}

*/

while(true)

{

System.out.println("Hello World");

try

{

Thread.sleep(2000);

}

catch(Exception e)

{

// Ignore

}

}

}

}

class HttpHelloWorldServerInitializer extends ChannelInitializer<SocketChannel> {

public HttpHelloWorldServerInitializer() {

}

@Override

public void initChannel(SocketChannel ch) {

ChannelPipeline p = ch.pipeline();

p.addLast(new HttpServerCodec());

p.addLast(new HttpHelloWorldServerHandler());

}

}

class HttpHelloWorldServerHandler extends ChannelInboundHandlerAdapter {

@Override

public void channelReadComplete(ChannelHandlerContext ctx) {

ctx.flush();

}

/**

* Runs the server.

*/

static Random random = new Random();

public static JSONObject createJsonResponse() {

JSONObject jsonObject = new JSONObject();

List<JSONObject> stockQuotes = new ArrayList<JSONObject>();

JSONObject googleQuote = new JSONObject();

googleQuote.put("name", "inlet-temperature");

googleQuote.put("value", random.nextInt(30));

googleQuote.put("unit", "celsius");

stockQuotes.add(googleQuote);

JSONObject ciscoQuote = new JSONObject();

ciscoQuote.put("name", "outdoor-ambience");

ciscoQuote.put("value", random.nextInt(50));

ciscoQuote.put("unit", "lux");

stockQuotes.add(ciscoQuote);

jsonObject.put("sensors", stockQuotes);

return jsonObject;

}

@Override

public void channelRead(ChannelHandlerContext ctx, Object msg) {

if (msg instanceof HttpRequest) {

HttpRequest req = (HttpRequest) msg;

if (HttpHeaders.is100ContinueExpected(req)) {

ctx.write(new DefaultFullHttpResponse(HTTP_1_1, CONTINUE));

}

boolean keepAlive = HttpHeaders.isKeepAlive(req);

FullHttpResponse response;

try {

response = new DefaultFullHttpResponse(HTTP_1_1, OK, Unpooled.wrappedBuffer(createJsonResponse().toJSONString().getBytes("UTF-8")));

response.headers().set(CONTENT_TYPE, "application/json");

response.headers().set(CONTENT_LENGTH, response.content().readableBytes());

if (!keepAlive) {

ctx.write(response).addListener(ChannelFutureListener.CLOSE);

} else {

response.headers().set(CONNECTION, Values.KEEP_ALIVE);

ctx.write(response);

}

} catch (UnsupportedEncodingException e) {

e.printStackTrace();

}

}

}

@Override

public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {

cause.printStackTrace();

ctx.close();

}

}