netty³õ̽

netty API

//Æô¶¯Àà

 ServerBootstrap bootstrap = new
  ServerBootstrap( NioServerSocketChannelFactory(new
 Executors.newCachedThreadPool()),Executors.newCachedThreadPool());

//¹Ø¼üµÄ²¿·Ö,Set up the event pipeline factory.

bootstrap.setPipelineFactory(new
 WebSocketServerPipelineFactory());

// Bind and start to accept incoming connections.

 bootstrap.bind(new
 InetSocketAddress(8080));

WebSocketServerPipelineFactory²¿·Ö£º

public
 class WebSocketServerpipelineFactory implements
 ChannelPipelineFactory{

 public
 ChannelPipeline getPipeline(){
                  //´´½¨Ò»¸öĬÈϵÄpipeline implemenation.

                  ChannelPipeline pipeline = pipeline();
                  pipeline.addLast("decoder"
,new
 HttpRequestDecoder());
                  pipeline.addLast("aggregator"
,new
 HttpChunkAggregator(65536));
    pipeline.addLast("encoder"
,new
 HttpResponseEncoder());
                  pipeline.addLast("handler"
,new
 WebSocketServerhandler());

       }
}

WebSocketServerhandler²¿·Ö£º

public
 class WebSocketServerHandler extends
 SimpleChannelUpstreamHandler {
 
  private
 static
 final
 String
 WEBSOCKET_PATH = "/websocket"
;

 public
 void messageReceived(ChannelHandlerContext ctx, MessageEvent evt) {  
    Object
 message = evt.getMessage();  
    // Do something with the received message.  

    ...  
    // And forward the event to the next handler.  

    ctx.sendUpstream(evt);  
 }
}

netty Îĵµ

http://www.jboss.org/netty/documentation.html
http://jef.javaeye.com/blog/544206