新浪开源轻量级分布式RPC框架motan简单示例解析
目录
- 前言
- 概述
- 功能
- 简单调用示例
- 在pom中添加依赖
- 为调用方和服务方创建公共接口
- 编写业务接口逻辑、创建并启动RPCServer
- 创建并执行RPCClient
- 集群调用示例
- 使用CONSUL作为注册中心
- Motan-Consul配置
- 使用ZOOKEEPER作为注册中心
- Motan-ZooKeeper配置
前言 好消息,支撑微博千亿调用的轻量级 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中添加依赖
com.weibogroupId>motan-coreartifactId> 0.1.1version>dependency> com.weibogroupId>motan-transport-nettyartifactId> 0.1.1version>dependency> com.weibogroupId>motan-springsupportartifactId> 0.1.1version>dependency> org.springframeworkgroupId>spring-contextartifactId> 4.2.4.RELEASEversion>
为调用方和服务方创建公共接口
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
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
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.zipunzip consul_0.6.4_linux_amd64.zipsudo mv consul /bin
启动(官方文档)
测试环境启动:consul agent -dev
ui后台 http://localhost:8500/ui
Motan-Consul配置 在server和client中添加motan-registry-consul依赖
com.weibogroupId>motan-registry-consulartifactId> 0.1.1version>
在server和client的配置文件中分别增加consul registry定义。
在Motan client及server配置改为通过registry服务发现。
client
server
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.gztar zxvf zookeeper-3.4.8.tar.gzcd zookeeper-3.4.8/conf/cp zoo_sample.cfg zoo.cfgcd ../sh bin/zkServer.sh start
Motan-ZooKeeper配置 在server和client中添加motan-registry-zookeeper依赖
com.weibogroupId>motan-registry-zookeeperartifactId> 0.1.1version>
在server和client的配置文件中分别增加zookeeper registry定义。
zookeeper为单节点
zookeeper多节点集群
在Motan client及server配置改为通过registry服务发现。
client
server
server程序启动后,需要显式调用心跳开关,注册到zookeeper。
MotanSwitcherUtil.setSwitcherValue(MotanConstants.REGISTRY_HEARTBEAT_SWITCHER, true)
启动client,调用服务
【新浪开源轻量级分布式RPC框架motan简单示例解析】以上就是新浪开源轻量级分布式RPC框架motan简单示例解析的详细内容,更多关于新浪开源轻量级分布式RPC框架motan的资料请关注脚本之家其它相关文章!
推荐阅读
- 轻量级ORM框架Dapper应用之实现CURD操作
- 自动驾驶|2021年电赛F题智能送药小车(国二)开源分享
- 不眠者科技团队|(不眠者①队)国电-F题(智能送药小车,广东赛区一等奖,推国赛,开源(代码+设计方案))
- 昇思MindSpore再突破(蛋白质结构预测训练推理全流程开源,助力生物医药发展)
- Pico.css|Pico.css - 简单优雅的纯 CSS 开源 UI 框架,用原始的 HTML 元素标签来做界面
- 开源项目因支持乌克兰遭issue刷屏,网友(别用Nginx,别用元素周期表)
- 开源绘画应用|开源绘画应用 Pinta 已移植到GTK 3和.NET 6
- ant|炽热开源心,漫漫开源路,8月16日 ALC Beijing邀你共品开源路书!
- 大话开源|ALC北京发起人 姜宁(通过开放与协作,我们可以实现一个人想都不敢想的事情 I OpenTEKr 大话开源 Vol.6)
- 区块链|活动回顾丨ALC Beijing 首场 Meetup(《开源到底有多难(》))