使用Netty实现远程方法调用(RPC)

[原创] 使用Netty实现远程方法调用(RPC)

仧尐 2018/06/28 58 Netty/ RPC

# 使用Netty实现远程方法调用(RPC)

很多情况下，我们可能需要用到调用远程方法的时候。比如，我们有统一的布隆过滤器，其它服务需要调用布隆过滤器进行判重；比如，我们需要调用统一的缓存数据；比如我们需要跨机器调用一些服务方法等等。这些时候都可以使用远程方法调用。

接下来，开始讲解使用Netty实现远程方法调用的步骤。

代码目录结构为：

```java
netty
netty/client
//RPC消息回调类
netty/client/MessageCallBack.java
//Rpc客户端管道初始化
netty/client/MessageSendChannelInitializer.java
//RPC客户端消息发送执行（动态代理）类
netty/client/MessageSendExecutor.java
//RPC客户端消息发送处理类
netty/client/MessageSendHandler.java
//Rpc客户端线程任务处理
netty/client/MessageSendInitializeTask.java
//Rpc客户端代理
netty/client/MessageSendProxy.java
//RPC客户端消息序列化协议框架
netty/client/RpcSendSerializeFrame.java
//rpc客户端服务器配置加载
netty/client/RpcServerLoader.java
netty/interf
netty/interf.impl
//接口实现类
netty/interf/impl/CalculateImpl.java
//接口
netty/interf/Calculate.java
netty/serialize
netty/serialize.kryo
//Kryo RPC消息进行编码、解码类
netty/serialize/kryo/KryoCodecUtil.java
//Kryo 解码器
netty/serialize/kryo/KryoDecoder.java
//Kryo 编码器
netty/serialize/kryo/KryoEncoder.java
//Kryo 工厂类
netty/serialize/kryo/KryoPoolFactory.java
//Kryo RPC序列化类
netty/serialize/kryo/KryoSerialize.java
//RPC消息进行编码、解码接口
netty/serialize/MessageCodecUtil.java
//消息解码器
netty/serialize/MessageDecoder.java
//消息编码器
netty/serialize/MessageEncoder.java
//RPC消息序列化/反序列化接口定义
netty/serialize/RpcSerialize.java
//RPC消息序序列化协议选择器接口
netty/serialize/RpcSerializeFrame.java
//RPC消息序序列化协议类型
netty/serialize/RpcSerializeProtocol.java
netty/server
//服务端: 线程池异常策略
netty/server/AbortPolicyWithReport.java
//Rpc服务器执行模块
netty/server/MessageRecvChannelInitializer.java
//服务器执行模块
netty/server/MessageRecvExecutor.java
//Rpc服务器消息处理
netty/server/MessageRecvHandler.java
//Rpc服务器消息线程任务处理
netty/server/MessageRecvInitializeTask.java
//线程工厂:实际上就是对Runable进行一个包装,对线程设置一些信息和监控信息
netty/server/NamedThreadFactory.java
//RPC服务端消息序列化协议框架
netty/server/RpcRecvSerializeFrame.java
//自定义的线程池
netty/server/RpcThreadPool.java
//消息的请求体
netty/MessageRequest.java
//响应的请求体
netty/MessageResponse.java
//客户端
netty/NettyClient.java
//服务端
netty/NettyServer.java
```

启动NettyServer服务端：

```java
	public static void main(String[] args) {
		MessageRecvExecutor executor = new MessageRecvExecutor("127.0.0.1:8686", RpcSerializeProtocol.KRYOSERIALIZE.name());
		try {
			executor.startServer();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
```

控制台打印：

```java
RPC Server start success!
ip:127.0.0.1
port:8686
protocol:RpcSerializeProtocol[serializeProtocol=kryo,name=KRYOSERIALIZE,ordinal=1]
```

启动NettyClient客户端，并远程调用Calculate接口中的add方法：

```java
	final static MessageSendExecutor executor = new MessageSendExecutor("127.0.0.1:8686",RpcSerializeProtocol.KRYOSERIALIZE.name());
	final static Calculate cal = executor.execute(Calculate.class);
	
	public static void main(String[] args) throws Exception {
		
		for(int i = 1;i< 100000;i++)
		ThreadExecuteUtil.submitTaskBlock(ThreadExecuteUtil.CLIENT, new Runnable() {
			
			@Override
			public void run() {
				long start = System.currentTimeMillis();
				int result = cal.add(10, 20);
				System.out.println("result:"+result);
				long end = System.currentTimeMillis();
				System.out.println(end-start);
			}
		}, 1000);
				
	}
```

源码待开源。。。。

智能推荐

注意！

本站用户原创文章，版权为本站用户，转摘请注明本文地址：http://www.silva-art.net/blog/2018/06/28/3a4327ecb5774afb12be338b404a0b71.html。

猜您在找

使用Python的multiprocessing.connections实现远程方法调用（RPC） XML-RPC远程方法调用关于远程方法调用（RMI）的实现 spring实现远程方法调用 [置顶] 根据RemObject的远程方法调用原理实现的简单远程方法调用

赞助商链接

[原创] 使用Netty实现远程方法调用(RPC)

注意！

赞助商广告