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

简介

Motan是新浪微博公司开发的一个轻量级分布式RPC框架，主要用于各种服务之间的调用。其定位是一个高性能、易扩展、易用的分布式RPC框架。

安装配置

1. 下载motan

在项目的GitHub页面中，找到 Download 按钮，下载最新版的 motan-x.x.x-release.zip。

2. 解压

将下载好的 motan-x.x.x-release.zip 解压到项目中。

例如，解压到项目的 lib 文件夹下。

3. 依赖

在项目的 pom.xml 文件中加入以下依赖：

<dependency>
    <groupId>com.weibo</groupId>
    <artifactId>motan-core</artifactId>
    <version>${motan.version}</version>
</dependency>

4. 配置文件

在项目的 resources 目录下创建 motan_server.xml 和 motan_client.xml 两个配置文件，并进行相关配置。

以 motan_server.xml 为例：

<motan:server port="8002" maxContentLength="1048576">
    <motan:services>
        <motan:service interface="com.xxx.demo.api.DemoService"
                       ref="demoServiceImpl"/>
    </motan:services>
    <motan:registry address="N/A"/>
</motan:server>

其中，port 表示Motan服务端启动的端口，interface 表示暴露的API接口，ref 表示实现该接口的服务。

5. 注册中心

Motan使用Zookeeper作为注册中心，因此需要在本地安装Zookeeper。

Zookeeper的安装方法可以参考官方文档：https://zookeeper.apache.org/doc/r3.1.2/zookeeperStarted.html

示例

1. 服务端

1.1 创建接口

在项目的 src/main/java 目录下创建接口 com.xxx.demo.api.DemoService，并定义相关方法：

public interface DemoService {
    String hello(String name);
}

1.2 实现接口

在项目的 src/main/java 目录下创建服务实现类 com.xxx.demo.service.impl.DemoServiceImpl，并实现接口方法：

public class DemoServiceImpl implements DemoService {
    @Override
    public String hello(String name) {
        return "hello, " + name;
    }
}

1.3 启动服务

在项目中创建一个 Server 类，用于启动Motan服务：

public class Server {
    public static void main(String[] args) {
        ConfigurableApplicationContext context = new 
            ClassPathXmlApplicationContext("classpath:motan_server.xml");
        context.start();
    }
}

在 main 方法中启动 context 上下文，就可以启动Motan服务了。

2. 客户端

2.1 创建客户端

在项目中创建一个 Client 类，用于调用Motan服务：

public class Client {
    public static void main(String[] args) {
        // 1. 注册Motan框架
        ExtensionLoader extensionLoader = ExtensionLoaderFactory.getExtensionLoader(
                RegistryFactory.class);
        RegistryFactory registryFactory = (RegistryFactory) extensionLoader
                .getExtension(RegistryFactory.class);

        // 2. 获取注册中心
        RegistryConfig registryConfig = new RegistryConfig();
        registryConfig.setRegProtocol("zookeeper");
        registryConfig.setAddress("127.0.0.1:2181");

        Registry registry = registryFactory.getRegistry(registryConfig);

        // 3. 创建Motan Referer
        ProtocolConfig protocolConfig = new ProtocolConfig();
        protocolConfig.setName("motan");

        SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
        factory.setConnectTimeout(3000);
        factory.setReadTimeout(3000);

        HttpClient httpClient = new HttpClient(factory);

        RefererConfig<DemoService> refererConfig = new RefererConfig<DemoService>();
        refererConfig.setInterface(DemoService.class);
        refererConfig.setUrl(protocolConfig + "://127.0.0.1:8002/" + DemoService.class.getName());
        refererConfig.setSerialization("hessian2");
        refererConfig.setHttpClient(httpClient);

        DemoService demoService = refererConfig.getRef();

        // 4. 调用服务
        String result = demoService.hello("world!");

        System.out.println(result);
    }
}

在 main 方法中依次完成以下步骤：

1. 注册Motan框架

2. 获取注册中心

3. 创建Motan Referer，设置服务接口、URL、序列化方式等参数

4. 调用服务，输出结果

2.2 运行客户端

运行 Client 类，输出结果为：

hello, world!

总结

以上是一个简单的Motan示例，通过该示例我们可以了解到如何搭建Motan服务端和客户端，在使用Motan进行服务调用时，需要修改相应的XML文件和注册中心参数，适配自己的业务方案。