Grizzly開發Echo服務器實戰

作者：chszs，轉載需注明。博客主頁：http://blog.csdn.net/chszs

用Java編寫可伸縮的服務器應用是有難度的，用Java NIO開發、線程管理、為成千上萬的用戶做服務器擴展，這些都是難點。Grizzly NIO框架的設計目標就是幫助開發者很好地利用Java NIO API，編寫出高可擴展性的、功能強大的服務器，并提高了擴展的框架組件：Web Framework（HTTP/S）、WebSocket、Comet等。

Grizzly 2.3開發Echo服務器/客戶端的例子

1、下載grizzly-framework.jar庫

Maven依賴

<dependency><groupId>org.glassfish.grizzly</groupId><artifactId>grizzly-framework</artifactId><version>2.3.16</version> </dependency>
或下載地址： http://central.maven.org/maven2/org/glassfish/grizzly/grizzly-framework/2.3.16/grizzly-framework-2.3.16.jar
2014.10.23日剛發布了2.3.17版，地址見：?
https://maven.java.net/content/repositories/releases/org/glassfish/grizzly/grizzly-framework/2.3.17/grizzly-framework-2.3.17.jar
也可以用這個版本。

服務器端：

1）創建Echo過濾器
Echo過濾器負責把接收到的消息（不管其類型）原樣返回給Grizzly連接。
import java.io.IOException;import org.glassfish.grizzly.filterchain.BaseFilter; import org.glassfish.grizzly.filterchain.FilterChainContext; import org.glassfish.grizzly.filterchain.NextAction;public class EchoFilter extends BaseFilter{/*** 僅處理讀操作，當消息到來時進行處理* @param ctx 處理的上下文* @return 下一個動作*/@Overridepublic NextAction handleRead(FilterChainContext ctx) throws IOException{// Peer address用于無連接的UDP連接final Object peerAddress = ctx.getAddress();final Object message = ctx.getMessage();System.out.println("Server received: " + message);ctx.write(peerAddress, message, null);return ctx.getStopAction();} }
2）服務器初始化代碼
所有的服務器過濾器鏈都準備好，開始初始化并啟動服務器。
import java.io.IOException; import java.nio.charset.Charset; import java.util.logging.Logger;import org.glassfish.grizzly.filterchain.FilterChainBuilder; import org.glassfish.grizzly.filterchain.TransportFilter; import org.glassfish.grizzly.nio.transport.TCPNIOTransport; import org.glassfish.grizzly.nio.transport.TCPNIOTransportBuilder; import org.glassfish.grizzly.utils.StringFilter;public class EchoServer {private static final Logger logger = Logger.getLogger(EchoServer.class.getName());public static final String HOST = "localhost";public static final int PORT = 7777;public static void main(String[] args) throws IOException{// 用FilterChainBuilder創建過濾器鏈FilterChainBuilder filterChainBuilder = FilterChainBuilder.stateless();// 添加TransportFilter，它負責從連接中讀數據，并寫數據到連接filterChainBuilder.add(new TransportFilter());// 字符串過濾器StringFilter負責緩沖和字符串之間的轉換filterChainBuilder.add(new StringFilter(Charset.forName("UTF-8")));// 過濾器EchoFilter負責把接收到的消息原樣返回給連接filterChainBuilder.add(new EchoFilter());// 創建TCP傳輸final TCPNIOTransport transport = TCPNIOTransportBuilder.newInstance().build();transport.setProcessor(filterChainBuilder.build());try{// 綁定傳輸，開始對主機+端口進行監聽transport.bind(HOST, PORT);// 開始傳輸transport.start();logger.info("Press any key to stop the Echo server...");System.in.read();} finally{logger.info("Stopping transport...");// 停止傳輸服務器transport.shutdown();logger.info("Stopped transport...");}} }
運行Echo服務器：
java -classpath grizzly-framework.jar EchoServer
客戶端：

1）創建客戶端過濾器
客戶端過濾器負責重定向服務器的響應到標準輸出。要注意，客戶端過濾器需要FilterChainContext消息
import java.io.IOException;import org.glassfish.grizzly.filterchain.BaseFilter; import org.glassfish.grizzly.filterchain.FilterChainContext; import org.glassfish.grizzly.filterchain.NextAction;public class ClientFilter extends BaseFilter{/*** 僅處理讀操作，當消息到來時進行處理* @param ctx 處理的上下文* @return 下一個動作*/@Overridepublic NextAction handleRead(final FilterChainContext ctx) throws IOException{// 從上下文得到字符串消息，過濾器鏈只使用了字符串過濾器StringFilterfinal String serverResponse = ctx.getMessage();System.out.println("Server echo: " + serverResponse);return ctx.getStopAction();} }
2）客戶端代碼
簡單的客戶端，向Echo服務器發送消息并等待響應。
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.nio.charset.Charset; import java.util.concurrent.ExecutionException; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import java.util.logging.Logger;import org.glassfish.grizzly.Connection; import org.glassfish.grizzly.Grizzly; import org.glassfish.grizzly.filterchain.FilterChainBuilder; import org.glassfish.grizzly.filterchain.TransportFilter; import org.glassfish.grizzly.nio.transport.TCPNIOTransport; import org.glassfish.grizzly.nio.transport.TCPNIOTransportBuilder; import org.glassfish.grizzly.utils.StringFilter;import ch.echo.server.EchoServer;public class EchoClient {private static final Logger logger = Grizzly.logger(EchoClient.class);public static void main(String[] args) throws IOException,ExecutionException, InterruptedException, TimeoutException{Connection connection = null;// 用FilterChainBuilder類創建過濾器鏈FilterChainBuilder filterChainBuilder = FilterChainBuilder.stateless();// 添加傳輸過濾器，它負責從連接讀數據并向連接寫數據filterChainBuilder.add(new TransportFilter());// 添加字符串過濾器，它負責緩沖和字符串之間的轉換filterChainBuilder.add(new StringFilter(Charset.forName("UTF-8")));// 添加客戶端過濾器，他負責把服務器響應重定向到標準輸出filterChainBuilder.add(new ClientFilter());// 創建TCP傳輸final TCPNIOTransport transport = TCPNIOTransportBuilder.newInstance().build();transport.setProcessor(filterChainBuilder.build());try{// 啟動傳輸transport.start();// 異步執行，連接到服務器Future<Connection> future = transport.connect(EchoServer.HOST, EchoServer.PORT);// 等待連接操作的完成connection = future.get(10, TimeUnit.SECONDS);assert connection!=null;System.out.println("Ready...(\"q\" to exit");final BufferedReader inReader = new BufferedReader(new InputStreamReader(System.in));do{final String userInput = inReader.readLine();if(userInput==null || "q".equals(userInput))break;connection.write(userInput);} while(true);} finally{// 關閉客戶端連接if(connection!=null)connection.close();// 停止傳輸transport.shutdownNow();}} }
運行Echo客戶端：
java -classpath grizzly-framework.jar EchoClient
已經通過測試，程序運行的非常完美。

總結

以上是生活随笔為你收集整理的Grizzly开发Echo服务器实战的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。