Solon rpc 之 SocketD 協議 - RPC鑑權模式
阿新 • • 發佈:2021-01-12
Solon rpc 之 SocketD 協議系列
Solon rpc 之 SocketD 協議 - 概述
Solon rpc 之 SocketD 協議 - 訊息上報模式
Solon rpc 之 SocketD 協議 - 訊息應答模式
Solon rpc 之 SocketD 協議 - 訊息訂閱模式
Solon rpc 之 SocketD 協議 - RPC呼叫模式
Solon rpc 之 SocketD 協議 - 單鏈接雙向RPC模式
Solon rpc 之 SocketD 協議 - 訊息加密模式
Solon rpc 之 SocketD 協議 - 訊息鑑權模式
Solon rpc 之 SocketD 協議 - RPC鑑權模式
SocketD 是一種二進位制的點對點通訊協議,是一種新的網路通訊第七層協議。旨在用於分散式應用程式中。從這個意義上講,SocketD可以是RSocket等其他類似協議的替代方案。它的訊息協議規範具有非同步,背壓的雙向,多路複用,斷線重連,基於訊息等特性。暫時只提供Java實現,目前做為Solon rpc的sockte通道協議。
本案在RPC呼叫模式的基礎上增加簽權為例演示:
介面定義
Rpc 模式借用了 Nami 做客戶端定義(Nami 是 Solon 伴生框架,定位為 Rpc 通用客戶端)
@NamiClient("demo:/demoe/rpc") public interface HelloService { @Handshake boolean auth(String sn, String token); String hello(String name); }
服務端
//啟動服務端 public class ServerApp { public static void main(String[] args) { //啟動Solon容器(SocketD bean&plugin 由solon容器管理) Solon.start(ServerApp.class, args, app -> app.enableSocketD(true)) .socket("**", (session, message) -> { if (message.flag() != MessageFlag.handshake) { if (session.getHandshaked() == false) { System.out.println("這個客戶端很壞,沒簽權就想發包:("); session.close(); } } }); //.socket(..) 可替代 @ServerEndpoint 使用 } } //定義遠端服務元件 @Mapping(value = "/demoe/rpc", method = MethodType.SOCKET) @Component(remoting = true) public class HelloServiceImpl implements HelloService { @Override public boolean auth(String sn, String token) { Session session = (Session) Context.current().request(); if ("1".equals(token)) { session.setHandshaked(true); System.out.println("籤權成功!"); return true; }else{ session.setHandshaked(false); return false; } } public String hello(String name) { return "name=" + name; } }
客戶端
//啟動客戶端
public class ClientApp {
public static void main(String[] args) throws Throwable {
//啟動Solon容器(SocketD bean&plugin 由solon容器管理)
Solon.start(ClientApp.class, args);
//[客戶端] 呼叫 [服務端] 的 rpc
//
HelloService rpc = SocketD.create("tcp://localhost:28080", HelloService.class);
if (rpc.auth("1", "1")) {
System.out.println("RPC result: " + rpc.hello("noear"));
}
}
}