新浪开源轻量级分布式RPC框架motan简单示例解析

新浪开源轻量级分布式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 { ApSfXrNplicationContext 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.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依赖

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.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依赖

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的资料请关注我们其它相关文章！

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。