新浪開源輕量級(jí)分布式RPC框架motan簡(jiǎn)單示例解析
前言
好消息，支撐微博千億調(diào)用的輕量級(jí) RPC 框架 Motan 在2016年5月份正式開源了，業(yè)界現(xiàn)在除了Dubbo 和 DubboX典型的分布式RPC服務(wù)治理型框架外，又多了一個(gè)優(yōu)秀的分布式RPC了。心動(dòng)了嗎？使用過dubbo的話，so easy的上手，官方實(shí)例如下，動(dòng)起來吧
我的demo地址，參考官方實(shí)例的簡(jiǎn)單demo，包含zookeeper注冊(cè)中心，以及服務(wù)監(jiān)控平臺(tái)：https://coding.net/u/kailingchen/p/motan_Test/git
概述
Motan是一套高性能、易于使用的分布式遠(yuǎn)程服務(wù)調(diào)用(RPC)框架。
github項(xiàng)目地址：https://github.com/weibocom/motan
功能
- 支持通過spring配置方式集成，無需額外編寫代碼即可為服務(wù)提供分布式調(diào)用能力。
- 支持集成consul、zookeeper等配置服務(wù)組件，提供集群環(huán)境的服務(wù)發(fā)現(xiàn)及治理能力。
- 支持動(dòng)態(tài)自定義負(fù)載均衡、跨機(jī)房流量調(diào)整等高級(jí)服務(wù)調(diào)度能力。
- 基于高并發(fā)、高負(fù)載場(chǎng)景進(jìn)行優(yōu)化，保障生產(chǎn)環(huán)境下RPC服務(wù)高可用。
簡(jiǎn)單調(diào)用示例
在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>為調(diào)用方和服務(wù)方創(chuàng)建公共接口
src/main/java/quickstart/FooService.java
package quickstart; public interface FooService { public String hello(String name);
}編寫業(yè)務(wù)接口邏輯、創(chuàng)建并啟動(dòng)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...");
}
}執(zhí)行Server類中的main函數(shù)將會(huì)啟動(dòng)Motan服務(wù)，并監(jiān)聽8002端口.
創(chuàng)建并執(zhí)行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"));
}
}執(zhí)行Client類中的main函數(shù)將執(zhí)行一次遠(yuǎn)程調(diào)用，并輸出結(jié)果。
集群調(diào)用示例
在集群環(huán)境下使用Motan需要依賴外部服務(wù)發(fā)現(xiàn)組件，目前支持consul或zookeeper。
使用CONSUL作為注冊(cè)中心
Consul安裝與啟動(dòng)
安裝（官方文檔）
# 這里以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
啟動(dòng)（官方文檔）
測(cè)試環(huán)境啟動(dòng)： consul agent -dev
ui后臺(tái) 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服務(wù)發(fā)現(xiàn)。
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程序啟動(dòng)后，需要顯式調(diào)用心跳開關(guān)，注冊(cè)到consul。
MotanSwitcherUtil.setSwitcherValue(MotanConstants.REGISTRY_HEARTBEAT_SWITCHER, true)
進(jìn)入ui后臺(tái)查看服務(wù)是否正常提供調(diào)用
啟動(dòng)client，調(diào)用服務(wù)
使用ZOOKEEPER作為注冊(cè)中心
ZooKeeper安裝與啟動(dòng)
單機(jī)版安裝與啟動(dòng)
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為單節(jié)點(diǎn)
<motan:registry regProtocol="zookeeper" name="my_zookeeper" address="127.0.0.1:2181"/>
zookeeper多節(jié)點(diǎn)集群
<motan:registry regProtocol="zookeeper" name="my_zookeeper" address="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183"/>
在Motan client及server配置改為通過registry服務(wù)發(fā)現(xiàn)。
client
<motan:referer id="remoteService" interface="quickstart.FooService" registry="my_zookeeper"/>
server
<motan:service interface="quickstart.FooService" ref="serviceImpl" registry="my_zookeeper" export="8002" />
server程序啟動(dòng)后，需要顯式調(diào)用心跳開關(guān)，注冊(cè)到zookeeper。
MotanSwitcherUtil.setSwitcherValue(MotanConstants.REGISTRY_HEARTBEAT_SWITCHER, true)
啟動(dòng)client，調(diào)用服務(wù)
以上就是新浪開源輕量級(jí)分布式RPC框架motan簡(jiǎn)單示例解析的詳細(xì)內(nèi)容，更多關(guān)于新浪開源輕量級(jí)分布式RPC框架motan的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
這篇文章主要介紹了Java枚舉類用法,實(shí)例分析了java中枚舉類的實(shí)現(xiàn)與使用技巧,需要的朋友可以參考下2015-05-05
簡(jiǎn)單了解redis常見客戶端及Sharding機(jī)制原理
這篇文章主要介紹了簡(jiǎn)單了解redis常見客戶端及Sharding機(jī)制原理,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-09-09
這篇文章主要介紹了SpringMVC中的HandlerAdapter解析,HandlerAdapter是一個(gè)關(guān)鍵的組件,用于將請(qǐng)求與處理程序方法進(jìn)行適配和調(diào)度,它充當(dāng)了控制器和處理程序之間的橋梁,負(fù)責(zé)將請(qǐng)求的參數(shù)和處理程序方法進(jìn)行匹配,并將結(jié)果返回給前端,需要的朋友可以參考下2023-10-10
java實(shí)現(xiàn)單機(jī)版五子棋小游戲
這篇文章主要為大家詳細(xì)介紹了java實(shí)現(xiàn)單機(jī)版五子棋小游戲，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2020-12-12
用3個(gè)實(shí)例從原理到實(shí)戰(zhàn)講清楚Log4j史詩級(jí)漏洞
最近應(yīng)該很多人都在關(guān)注著一個(gè)漏洞Apache Log4j 2遠(yuǎn)程代碼執(zhí)行,該漏洞一旦被攻擊者利用會(huì)造成嚴(yán)重危害,這篇文章主要給大家介紹了關(guān)于如何用3個(gè)實(shí)例從原理到實(shí)戰(zhàn)講清楚Log4j史詩級(jí)漏洞的相關(guān)資料,需要的朋友可以參考下2021-12-12
從Myeclipse 導(dǎo)入到eclipse中無法識(shí)別為 web項(xiàng)目 問題的解決步驟
這篇文章主要介紹了從Myeclipse 導(dǎo)入到eclipse中無法識(shí)別為 web項(xiàng)目 問題的解決步驟,需要的朋友可以參考下2018-05-05
Java實(shí)現(xiàn)選擇排序算法的實(shí)例教程
這篇文章主要介紹了Java實(shí)現(xiàn)選擇排序算法的實(shí)例教程,選擇排序的時(shí)間復(fù)雜度為О(n²),需要的朋友可以參考下2016-05-05
mybatis TypeHandler注入spring的依賴方式
這篇文章主要介紹了mybatis TypeHandler注入spring的依賴方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-01-01
很多同學(xué)會(huì)重載和重寫分不清楚，這篇文章主要介紹了詳解java重載與覆寫的區(qū)別，有需要的朋友可以了解一下。2016-11-11
Spring MVC獲取參數(shù)和自定義參數(shù)類型轉(zhuǎn)換器及編碼過濾器
這篇文章主要為大家詳細(xì)介紹了Spring MVC獲取參數(shù)和自定義參數(shù)類型轉(zhuǎn)換器及編碼過濾器，文中通過代碼示例介紹的非常詳細(xì)，具有一定的參考價(jià)值,需要的朋友可以參考下2023-06-06