netty(1)http编程入门小Demo(HelloWorld)

package com.netty.day01;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;

public class TestServer {

	public static void main(String[] args) throws Exception {
		//定义一个bossGroup用来接收
		EventLoopGroup bossGroup=new NioEventLoopGroup();
		//定义一个workerGroup用来处理
		EventLoopGroup workerGroup=new NioEventLoopGroup();
		ServerBootstrap serverBootstrap=new ServerBootstrap();
		serverBootstrap.group(bossGroup,workerGroup).channel(NioServerSocketChannel.class)
		.childHandler(new TestServerInitializer());
		try {
			ChannelFuture channelFuture=serverBootstrap.bind(8899).sync();
			channelFuture.channel().closeFuture().sync();
		}finally{
			bossGroup.shutdownGracefully();
			workerGroup.shutdownGracefully();
			
		}
		
	}

}

package com.netty.day01;

import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.socket.SocketChannel;
import io.netty.handler.codec.http.HttpServerCodec;

public class TestServerInitializer extends ChannelInitializer<SocketChannel> {


	@Override
	protected void initChannel(SocketChannel ch) throws Exception {
		ChannelPipeline pipline=ch.pipeline();
		pipline.addLast("HttpServerCodec",new HttpServerCodec());
		pipline.addLast("testHttpServerHandler",new TestHttpServerHandler());
		
	}

}

package com.netty.day01;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.DefaultFullHttpResponse;
import io.netty.handler.codec.http.FullHttpResponse;
import io.netty.handler.codec.http.HttpHeaderNames;
import io.netty.handler.codec.http.HttpObject;
import io.netty.handler.codec.http.HttpRequest;
import io.netty.handler.codec.http.HttpResponseStatus;
import io.netty.handler.codec.http.HttpVersion;
import io.netty.util.CharsetUtil;

/**
 * 自定义处理器
 * @author Administrator
 *
 */
public class TestHttpServerHandler extends SimpleChannelInboundHandler<HttpObject> {

	@Override
	protected void channelRead0(ChannelHandlerContext ctx, HttpObject msg) throws Exception {
		if(msg instanceof HttpRequest){
			System.out.println("执行了channelRead0");
			ByteBuf content=Unpooled.copiedBuffer("Hello World",CharsetUtil.UTF_8);
			//响应
			FullHttpResponse response=new DefaultFullHttpResponse(HttpVersion.HTTP_1_1,
			HttpResponseStatus.OK,content);
			response.headers().set(HttpHeaderNames.CONTENT_TYPE,"text/plain");
			response.headers().set(HttpHeaderNames.CONTENT_LENGTH,content.readableBytes());
			ctx.writeAndFlush(response);
		}
	}

}