等经验分享

Linkis-RPC的设计目标是提供一种灵活、可扩展的微服务间通信机制支持以下功能

异步请求与响应支持请求方发送异步请求接收方处理完后再响应给请求方。

广播请求支持将请求广播给所有目标服务实例。

自定义拦截器允许用户定义拦截器来实现特定功能如缓存、重试等。

服务选择基于Eureka实现的服务发现支持通过服务名和实例信息选择特定服务实例。

解耦通信机制请求方和接收方的代码实现解耦便于独立开发和维护。

Sender请求发送器用于发送请求到目标服务。

Receiver请求接收器负责接收和处理请求。

Interceptor拦截器链用于在请求发送前进行处理如广播、重试、缓存等。

Decoder/Encoder用于请求和响应的序列化和反序列化。

Eureka服务注册与发现中心。

Sender接口和实现负责发送请求并处理响应。

Receiver接口和实现负责接收请求并执行业务逻辑。

Interceptor接口和实现拦截器实现类用于增强请求功能。

RPCReceiveRestful内嵌的HTTP服务用于接收和解码请求。

请求和响应编码器/解码器实现请求和响应的序列化和反序列化。

Sender接口

Sender的实现类主要负责构建请求并通过Feign客户端发送请求。

public

feignClient.post(message);}Overridepublic

Object

feignClient.postWithTimeout(message,

void

{feignClient.send(message);}Overridepublic

void

异步发送逻辑CompletableFuture.runAsync(()

Receiver接口

异步处理逻辑System.out.println(Received

async

根据业务需求决定是否需要响应发送方}Overridepublic

Object

处理请求并返回响应System.out.println(Received

sync

processRequest(message);}Overridepublic

Object

处理请求并返回响应考虑超时System.out.println(Received

sync

processRequestWithTimeout(message,

duration);}private

processRequestWithTimeout(Object

message,

{Thread.sleep(duration.toMillis());}

catch

{Thread.currentThread().interrupt();return

Processing

广播逻辑System.out.println(Broadcasting

message:

ConcurrentHashMap();Overridepublic

void

ObjectMapper().writeValueAsString(message);}

}请求解码器

RPCReceiveRestful是一个内嵌的HTTP服务用于接收请求并调用解码器进行解码。

RestControllerRequestMapping(/rpc)

public

receiverManager;}PostMapping(/receive)public

ResponseEntityObject

receiverManager.getReceiver(request.getServiceName());//

调用Receiver处理请求Object

receiver.receiveAndReply(request.getMessage(),

catch

ResponseEntity.status(HttpStatus.BAD_REQUEST).body(Request

processing

异步发送消息sender.deliver(message);}public

Object

处理异步请求System.out.println(Server

received

处理同步请求并返回响应System.out.println(Server

received

处理带超时的同步请求并返回响应System.out.println(Server

received

Linkis-RPC提供了一种灵活且强大的微服务间通信机制解决了传统RPC框架在复杂场景中的不足。

通过自定义拦截器、异步请求处理和广播机制Linkis-RPC能够满足现代微服务架构的通信需求。

本文详细分析了Linkis-RPC的设计思想、代码结构并提供了完整的代码示例希望能为开发者提供有价值的参考。

如需进一步的讨论和问题解答欢迎留言共同探讨Linkis-RPC的更多应用场景和实现细节。

参考链接公共模块