怎么用 Netty 實現簡單的 RPC

本篇內容主要講解“怎么用 Netty 實現簡單的 RPC”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“怎么用 Netty 實現簡單的 RPC”吧!

1、需求

模仿 dubbo，消費者和提供者約定接口和協議，消費者遠程調用提供者，提供者返回一個字符串，消費者打印提供者返回的數據。底層網絡通信使用 Netty 4.1.16。

2、設計

1. 創建一個接口，定義抽象方法。用于消費者和提供者之間的約定。

2. 創建一個提供者，該類需要監聽消費者的請求，并按照約定返回數據。

3. 創建一個消費者，該類需要透明的調用自己不存在的方法，內部需要使用 Netty 請求提供者返回數據。

3、 實現

1. 創建 maven 項目，導入 Netty 4.1.16。

<groupId>cn.thinkinjava</groupId><artifactId>rpc-demo</artifactId><version>1.0-SNAPSHOT</version><dependencies>   <dependency>     <groupId>io.netty</groupId>     <artifactId>netty-all</artifactId>     <version>4.1.16.Final</version>   </dependency></dependencies>

2. 項目目錄結構如下：

3. 設計接口

===============

一個簡單的 hello world：

public interface HelloService {	String hello(String msg);}

4. 提供者相關實現

==================

4.1. 首先實現約定接口，用于返回客戶端數據：

/** * 實現類 */public class HelloServiceImpl implements HelloService { public String hello(String msg) { return msg != null ? msg + " -----> I am fine." : "I am fine."; }}

4.2. 實現 Netty 服務端和自定義 handler

啟動 Netty Server 代碼：

private static void startServer0(String hostName, int port) {    try {     ServerBootstrap bootstrap = new ServerBootstrap();     NioEventLoopGroup eventLoopGroup = new NioEventLoopGroup();     bootstrap.group(eventLoopGroup)         .channel(NioServerSocketChannel.class)         .childHandler(new ChannelInitializer<SocketChannel>() {            @Override           protected void initChannel(SocketChannel ch) throws Exception {             ChannelPipeline p = ch.pipeline();             p.addLast(new StringDecoder());             p.addLast(new StringEncoder());             p.addLast(new HelloServerHandler());           }         });     bootstrap.bind(hostName, port).sync();   } catch (InterruptedException e) {     e.printStackTrace();   } }

上面的代碼中添加了 String類型的編解碼 handler，添加了一個自定義 handler。

自定義 handler 邏輯如下：

/*** 用于處理請求數據*/public class HelloServerHandler extends ChannelInboundHandlerAdapter {  @Override public void channelRead(ChannelHandlerContext ctx, Object msg) {    // 如何符合約定，則調用本地方法，返回數據   if (msg.toString().startsWith(ClientBootstrap.providerName)) {     String result = new HelloServiceImpl()         .hello(msg.toString().substring(msg.toString().lastIndexOf("#") + 1));     ctx.writeAndFlush(result);   } }}

這里顯示判斷了是否符合約定（并沒有使用復雜的協議，只是一個字符串判斷），然后創建一個具體實現類，并調用方法寫回客戶端。為什么Netty這么火？為什么？

還需要一個啟動類：

public class ServerBootstrap {  public static void main(String[] args) {   NettyServer.startServer("localhost", 8088); }}

好，關于提供者的代碼就寫完了，主要就是創建一個 netty 服務端，實現一個自定義的 handler，自定義 handler 判斷是否符合之間的約定（算是協議吧），如果符合，就創建一個接口的實現類，并調用他的方法返回字符串。

5. 消費者相關實現

消費者有一個需要注意的地方，就是調用需要透明，也就是說，框架使用者不用關心底層的網絡實現。這里我們可以使用 JDK 的動態代理來實現這個目的。

思路：客戶端調用代理方法，返回一個實現了 HelloService 接口的代理對象，調用代理對象的方法，返回結果。

我們需要在代理中做手腳，當調用代理方法的時候，我們需要初始化 Netty 客戶端，還需要向服務端請求數據，并返回數據。

5.1. 首先創建代理相關的類

public class RpcConsumer {  private static ExecutorService executor = Executors     .newFixedThreadPool(Runtime.getRuntime().availableProcessors());  private static HelloClientHandler client;  /**  * 創建一個代理對象  */ public .........

到此，相信大家對“怎么用 Netty 實現簡單的 RPC”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！