Grizzly学习笔记(一)

Grizzly是基于JAVA NIO的网络通信框架，网上一些网友的测试来看,grizzly的性能比较好。

1. package org.guojje.grizzly;  
2.  
3. import java.io.IOException;  
4.  
5. import com.sun.grizzly.Controller;  
6. import com.sun.grizzly.DefaultProtocolChain;  
7. import com.sun.grizzly.ProtocolFilter;  
8. import com.sun.grizzly.TCPSelectorHandler;  
9. import com.sun.grizzly.DefaultProtocolChain.EventHandler;  
10. import com.sun.grizzly.DefaultProtocolChain.Phase;  
11. import com.sun.grizzly.filter.EchoFilter;  
12. import com.sun.grizzly.filter.LogFilter;  
13. import com.sun.grizzly.filter.ReadFilter;  
14. import com.sun.grizzly.util.WorkerThreadImpl;  
15.  
16. public class Server {  
17.    public static void main(String args[]) throws IOException{  
18.      //控制中心,  
19.      Controller controller = new Controller();  
20.      //添加SelectorHandler,如果不添加，在Controller.start  
21.      //的时候，会默认添加TCPSelectorHandler  
22.        
23.      TCPSelectorHandler tcpHandler = new TCPSelectorHandler();  
24.      tcpHandler.setPort(1900);  
25.      controller.setSelectorHandler(tcpHandler);  
26.        
27.      //创建一个协议Chain,  
28.      DefaultProtocolChain protocolChain = new DefaultProtocolChain();  
29.  
30.     //必须添加ReadFilter,不然无法读数据  
31.      protocolChain.addFilter(new ReadFilter());  
32.      protocolChain.addFilter(new LogFilter());  
33.      //添加回显功能  
34.      protocolChain.addFilter(new EchoFilter());  
35.      //这里需要注意，ReadFilter，EchoFilter顺序不能倒，先读了数据才能回显。  
36.      //filter的执行按队列顺序执行。再比如LogFilter,需要放在EchoFilter前面，  
37.      //不然Buffer里没有数据，LogFilter就没什么数据可LOG了。  
38.      //这不知道是不是设计的问题。  
39.  
40.        
41.     //添加协议Chain  
42.     controller.getProtocolChainInstanceHandler().offer(protocolChain);  
43.     //启动Controller  
44.     controller.start();  
45.    }  
46. } 

启动Server,再启动client,查看console输出，可看到通信成功。

1. package org.guojje.grizzly;  
2.  
3. import java.io.IOException;  
4. import java.net.InetAddress;  
5. import java.net.InetSocketAddress;  
6. import java.net.UnknownHostException;  
7. import java.nio.ByteBuffer;  
8.  
9. import com.sun.grizzly.TCPConnectorHandler;  
10. import com.sun.grizzly.util.OutputWriter;  
11.  
12. public class Client {  
13.     
14.     public static void main(String[] args) throws UnknownHostException, IOException {  
15.           
16.         TCPConnectorHandler tch = new TCPConnectorHandler();  
17.         tch.connect(new InetSocketAddress(InetAddress.getLocalHost(), 1900));  
18.         OutputWriter.flushChannel(tch.getUnderlyingChannel(), ByteBuffer.wrap("Hello".getBytes()));  
19.         ByteBuffer bb = ByteBuffer.allocate(100);  
20.         tch.read(bb, true);  
21.         System.out.println(new String(bb.array(),0,bb.remaining()));  
22.     }  
23. }  

 本文转自 anranran 51CTO博客，原文链接:http://blog.51cto.com/guojuanjun/651608