新浪開源輕量級分散式RPC框架motan簡單範例解析

2022-03-05 19:00:29

前言

好訊息，支撐微博千億呼叫的輕量級 RPC 框架 Motan 在2016年5月份正式開源了，業界現在除了Dubbo 和 DubboX典型的分散式RPC服務治理型框架外，又多了一個優秀的分散式RPC了。心動了嗎？使用過dubbo的話，so easy的上手，官方範例如下，動起來吧

我的demo地址，參考官方範例的簡單demo，包含zookeeper註冊中心，以及服務監控平臺：https://coding.net/u/kailingchen/p/motan_Test/git

概述

Motan是一套高效能、易於使用的分散式遠端服務呼叫(RPC)框架。

github專案地址：https://github.com/weibocom/motan

功能

支援通過spring設定方式整合，無需額外編寫程式碼即可為服務提供分散式呼叫能力。
支援整合consul、zookeeper等設定服務元件，提供叢集環境的服務發現及治理能力。
支援動態自定義負載均衡、跨機房流量調整等高階服務排程能力。
基於高並行、高負載場景進行優化，保障生產環境下RPC服務高可用。

簡單呼叫範例

在pom中新增依賴

<dependency>
    <groupId>com.weibogroupId>
    <artifactId>motan-coreartifactId>
    <version>0.1.1version>
dependency>
<dependency>
    <groupId>com.weibogroupId>
    <artifactId>motan-transport-nettyartifactId>
    <version>0.1.1version>
dependency>  <dependency>
    <groupId>com.weibogroupId>
    <artifactId>motan-springsupportartifactId>
    <version>0.1.1version>
dependency>
<dependency>
    <groupId>org.springframeworkgroupId>
    <artifactId>spring-contextartifactId>
    <version>4.2.4.RELEASEversion>
<dependency>

為呼叫方和服務方建立公共介面

src/main/java/quickstart/FooService.java

package quickstart; public interface FooService { public String hello(String name);
}

編寫業務介面邏輯、建立並啟動RPC Server

src/main/java/quickstart/FooServiceImpl.java

package quickstart; public class FooServiceImpl implements FooService { public String hello(String name) { System.out.println(name + " invoked rpc service"); return "hello " + name;
    }
}

src/main/resources/motan_server.xml

<xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:motan="http://api.weibo.com/schema/motan" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd  http://api.weibo.com/schema/motan http://api.weibo.com/schema/motan.xsd">  <bean id="serviceImpl" class="quickstart.FooServiceImpl" />  <motan:service interface="quickstart.FooService" ref="serviceImpl" export="8002" />

src/main/java/quickstart/Server.java

package quickstart; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; public class Server { public static void main(String[] args) throws InterruptedException { ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:motan_server.xml"); System.out.println("server start...");
    }
}

執行Server類中的main函數將會啟動Motan服務，並監聽8002埠.

建立並執行RPC Client

src/main/resources/motan_client.xml

<xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:motan="http://api.weibo.com/schema/motan" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd  http://api.weibo.com/schema/motan http://api.weibo.com/schema/motan.xsd">  <motan:referer id="remoteService" interface="quickstart.FooService" directUrl="localhost:8002"/>

src/main/java/quickstart/Client.java

package quickstart; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; public class Client { public static void main(String[] args) throws InterruptedException { ApplicationContext ctx = new ClassPathXmlApplicationContext("classpath:motan_client.xml"); FooService service = (FooService) ctx.getBean("remoteService"); System.out.println(service.hello("motan"));
    }
}

執行Client類中的main函數將執行一次遠端呼叫，並輸出結果。

叢集呼叫範例

在叢集環境下使用Motan需要依賴外部服務發現元件，目前支援consul或zookeeper。

使用CONSUL作為註冊中心

Consul安裝與啟動

安裝（官方檔案）

# 這裡以linux為例
wget https://releases.hashicorp.com/consul/0.6.4/consul_0.6.4_linux_amd64.zip
unzip consul_0.6.4_linux_amd64.zip
sudo mv consul /bin

啟動（官方檔案）

測試環境啟動：
consul agent -dev

ui後臺 http://localhost:8500/ui

Motan-Consul設定

在server和client中新增motan-registry-consul依賴

<dependency>
    <groupId>com.weibogroupId>
    <artifactId>motan-registry-consulartifactId>
    <version>0.1.1version>
<dependency>

在server和client的組態檔中分別增加consul registry定義。

<motan:registry regProtocol="consul" name="my_consul" address="127.0.0.1:8500"/>

在Motan client及server設定改為通過registry服務發現。

client

<motan:referer id="remoteService" interface="quickstart.FooService" registry="my_consul"/>

server

<motan:service interface="quickstart.FooService" ref="serviceImpl" registry="my_consul" export="8002" />

server程式啟動後，需要顯式呼叫心跳開關，註冊到consul。

MotanSwitcherUtil.setSwitcherValue(MotanConstants.REGISTRY_HEARTBEAT_SWITCHER, true)

進入ui後臺檢視服務是否正常提供呼叫

啟動client，呼叫服務

使用ZOOKEEPER作為註冊中心

ZooKeeper安裝與啟動

單機版安裝與啟動

wget http://mirrors.cnnic.cn/apache/zookeeper/zookeeper-3.4.8/zookeeper-3.4.8.tar.gz
tar zxvf zookeeper-3.4.8.tar.gz

cd zookeeper-3.4.8/conf/
cp zoo_sample.cfg zoo.cfg

cd ../
sh bin/zkServer.sh start

Motan-ZooKeeper設定

在server和client中新增motan-registry-zookeeper依賴

<dependency>
    <groupId>com.weibogroupId>
    <artifactId>motan-registry-zookeeperartifactId>
    <version>0.1.1version>
<dependency>

在server和client的組態檔中分別增加zookeeper registry定義。

zookeeper為單節點

<motan:registry regProtocol="zookeeper" name="my_zookeeper" address="127.0.0.1:2181"/>

zookeeper多節點叢集

<motan:registry regProtocol="zookeeper" name="my_zookeeper" address="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183"/>