netty java 调用

之前使用过MINA框架，感觉效率非常好，使用长连接可以支持10万次以上的并发。
今天尝试使用了Netty框架，感觉使用上也非常方便，具体效率问题，在接下来的博客会详细解读：

NioServerSocketChannelFactory创建服务端的ServerSocketChannel，采用多线程执行非阻塞IO，和Mina的设计

模式一样，都采用了Reactor模式。其中bossExecutor、workerExecutor是两个线程池，bossExecutor用来接收客户端连接，workerExecutor用来执行非阻塞的IO操作，主要是read，write。

Java代码  

1. package netty;
2. import org.jboss.netty.bootstrap.ServerBootstrap;
3. import org.jboss.netty.channel.ChannelFactory;
4. import org.jboss.netty.channel.ChannelPipeline;
5. import org.jboss.netty.channel.ChannelPipelineFactory;
6. import org.jboss.netty.channel.Channels;
7. import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
8. import org.jboss.netty.handler.codec.string.StringDecoder;
9. import org.jboss.netty.handler.codec.string.StringEncoder;
10. import java.net.InetSocketAddress;
11. import java.util.concurrent.Executors;
12. /**
13. * Created by IntelliJ IDEA.
14. * User: flychao88
15. * Date: 12-6-6
16. * Time: 上午10:14
17. * To change this template use File | Settings | File Templates.
18. */
19. public class DiscardServer {
20. public static void main(String[] args) throws Exception {
21. ChannelFactory factory = new NioServerSocketChannelFactory(
22. Executors.newCachedThreadPool(),
23. Executors.newCachedThreadPool());
24. ServerBootstrap bootstrap = new ServerBootstrap (factory);
25. bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
26. public ChannelPipeline getPipeline() {
27. ChannelPipeline pipeline = Channels.pipeline();
28. pipeline.addLast("encode",new StringEncoder());
29. pipeline.addLast("decode",new StringDecoder());
30. pipeline.addLast("handler",new DiscardServerHandler());
31. return pipeline;
32. }
33. });
34. bootstrap.setOption("child.tcpNoDelay", true);
35. bootstrap.setOption("child.keepAlive", true);
36. bootstrap.bind(new InetSocketAddress(8080));
37. }
38. }

Java代码  

1. package netty;
2. import org.jboss.netty.buffer.ChannelBuffer;
3. import org.jboss.netty.buffer.ChannelBuffers;
4. import org.jboss.netty.channel.*;
5. /**
6. * Created by IntelliJ IDEA.
7. * User: flychao88
8. * Date: 12-6-6
9. * Time: 上午10:10
10. * To change this template use File | Settings | File Templates.
11. */
12. public class DiscardServerHandler extends SimpleChannelUpstreamHandler  {
13. @Override
14. public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {
15. System.out.println("服务器接收1："+e.getMessage());
16. }
17. @Override
18. public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) {
19. e.getCause().printStackTrace();
20. Channel ch = e.getChannel();
21. ch.close();
22. }
23. }

Java代码  

1. package netty;
2. import org.jboss.netty.bootstrap.ClientBootstrap;
3. import org.jboss.netty.channel.ChannelFactory;
4. import org.jboss.netty.channel.ChannelPipeline;
5. import org.jboss.netty.channel.ChannelPipelineFactory;
6. import org.jboss.netty.channel.Channels;
7. import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory;
8. import org.jboss.netty.handler.codec.string.StringDecoder;
9. import org.jboss.netty.handler.codec.string.StringEncoder;
10. import java.net.InetSocketAddress;
11. import java.util.concurrent.Executors;
12. /**
13. * Created by IntelliJ IDEA.
14. * User: flychao88
15. * Date: 12-6-6
16. * Time: 上午10:21
17. * To change this template use File | Settings | File Templates.
18. */
19. public class TimeClient {
20. public static void main(String[] args) throws Exception {
21. ChannelFactory factory = new NioClientSocketChannelFactory(
22. Executors.newCachedThreadPool(),
23. Executors.newCachedThreadPool());
24. ClientBootstrap bootstrap = new ClientBootstrap(factory);
25. bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
26. public ChannelPipeline getPipeline() {
27. ChannelPipeline pipeline = Channels.pipeline();
28. pipeline.addLast("encode",new StringEncoder());
29. pipeline.addLast("decode",new StringDecoder());
30. pipeline.addLast("handler",new TimeClientHandler());
31. return pipeline;
32. }
33. });
34. bootstrap.setOption("tcpNoDelay" , true);
35. bootstrap.setOption("keepAlive", true);
36. bootstrap.connect (new InetSocketAddress("127.0.0.1", 8080));
37. }
38. }

Java代码  

1. package netty;
2. /**
3. * Created by IntelliJ IDEA.
4. * User: flychao88
5. * Date: 12-6-6
6. * Time: 上午10:22
7. * To change this template use File | Settings | File Templates.
8. */
9. import org.jboss.netty.buffer.ChannelBuffer;
10. import org.jboss.netty.buffer.ChannelBuffers;
11. import org.jboss.netty.channel.*;
12. import java.util.Date;
13. public class TimeClientHandler extends SimpleChannelUpstreamHandler  {
14. @Override
15. public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) {
16. e.getChannel().write("abcd");
17. }
18. @Override
19. public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {
20. e.getChannel().close();
21. }
22. @Override
23. public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) {
24. e.getCause().printStackTrace();
25. e.getChannel().close();
26. }