微博RPC框架Motan

原文来自：http://blog.csdn.net/autfish/article/details/51374798

从14年开始就陆续看到新浪微博RPC框架Motan的介绍，时隔两年后，微博团队终于宣布开源轻量级RPC框架Motan，项目地址：

https://github.com/weibocom/motan/

项目文档介绍比较详细，搭建开发环境非常简单，如果只是使用而不需要源码的话，只配置maven依赖项目即可，按照示例几分钟就可以搭建起一个Hello world。当然这也是官方介绍中的优点之一。

我们来扩展一下官方的示例，并测试一下集群式部署。首先创建一个maven项目

1 公共部分

pom.xml

[java] view plain copy print ?

<dependencies>
<dependency>
<groupId>com.weibo</groupId>
<artifactId>motan-core</artifactId>
<version>0.0.1</version>
</dependency>
<dependency>
<groupId>com.weibo</groupId>
<artifactId>motan-transport-netty</artifactId>
<version>0.0.1</version>
</dependency>
<dependency>
<groupId>com.weibo</groupId>
<artifactId>motan-springsupport</artifactId>
<version>0.0.1</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>4.2.4.RELEASE</version>
</dependency>
<dependency>
<groupId>com.weibo</groupId>
<artifactId>motan-registry-zookeeper</artifactId>
<version>0.0.1</version>
</dependency>
</dependencies>

项目结构如图

User类，注意必须实现Serializable

[java] view plain copy print ?

public class User implements Serializable {
private static final long serialVersionUID = 2925168737226033271L;
public User(int id, String name) {
this.id = id;
this.name = name;
}
private int id;
private String name;
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String toString() {
return String.format("{id=%d,name=%s}", this.id, this.name);
}
}

UserService

[java] view plain copy print ?

public interface UserService {
public User find(int id);
}

2 服务器部分

UserServiceImpl

[java] view plain copy print ?

public class UserServiceImpl implements UserService {
public User find(int id) {
System.out.println(id + " invoked rpc service");
return new User(id, "name" + id);
}
}

motan_server.xml

[java] view plain copy print ?

<?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:protocol name="motan" loadbalance="roundrobin" maxWorkerThread="500" minWorkerThread="20" />
<bean id="serviceImpl" class="quickstart.UserServiceImpl" />
<motan:registry regProtocol="zookeeper" name="my_zookeeper" address="127.0.0.1:2181"/>
<motan:service interface="quickstart.UserService" ref="serviceImpl" registry="my_zookeeper" export="8002" />
</beans>

Server.java

[java] view plain copy print ?

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

集群部署需要使用Zookeeper做注册中心

3 部署Zookeeper

以windows环境为例

下载地址 http://zookeeper.apache.org/

下载后得到gz包如zookeeper-3.4.8.tar.gz，解压到任意目录如d:\zookeeper-3.4.8

在zookeeper-3.4.8目录下建立data文件夹

进入zookeeper-3.4.8/conf目录，把zoo_sample.cfg重命名为zoo.cfg，并修改dataDir选项

dataDir=d:\\zookeeper-3.4.8\\data

进入zookeeper-3.4.8/bin目录，执行zkServer.cmd

运行Server.java测试，启动成功

4 部署多服务器实例

下面把服务器端部署两个实例，修改pom.xml，添加

[java] view plain copy print ?

<build>
<finalName>motan-examples</finalName>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-jar-plugin</artifactId>
<version>2.4</version>
<configuration>
<archive>
<manifest>
<addClasspath>true</addClasspath>
<classpathPrefix>.</classpathPrefix>
<mainClass>quickstart.Server</mainClass>
</manifest>
</archive>
</configuration>
</plugin>
</plugins>
</build>

注意正确配置mainClass的类全路径

进入项目目录执行

mvn dependency:copy-dependencies

mvn clean package

把生成的可执行jar和依赖jar包复制到一起，并执行

java -jar motan-examples.jar

修改motan_server.xml中的export端口为8003，重复上面步骤再启动一个在8003端口上的实例

5 客户端部分

motan_client.xml

[java] view plain copy print ?

<?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:protocol name="motan" haStrategy="failover" />
<motan:registry regProtocol="zookeeper" name="my_zookeeper" address="127.0.0.1:2181"/>
<motan:referer id="remoteService" interface="quickstart.UserService" registry="my_zookeeper"/>
</beans>