第4 章 hadoop-RPC

分享未结  0  763

李延 LV6 2022-03-06

悬赏：20积分

# 1 背景

在hadoop中存在各自网络交互，而这些网络交互都被封装为一个个的RPC接口。

本次主要说明的是hadoop-common下的ipc.RPC类

# 2 测试用例

本章主要通过RPC类实现一个远程调用的过程

## 2.1 业务接口与实现

接口

```java
public interface RPCProtocolTest {

long versionID = 6000;
     int work(String name,int id);
}
```

在接口中我们看到定义了versionID这个字段，这个是必须的，用于区分具体是哪个RPC服务
实现

```java
public class RPCProtocolTestImpl implements RPCProtocolTest {
    @Override
    public int work(String name, int id) {
        System.out.println("调用服务:" + name + ",id:" + id);
        return id;
    }
}

```

##  2.2 服务端主函数

```java
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;

import java.io.IOException;

public class RPCServiceTest {

public static void main(String[] args) throws IOException {

final RPC.Server localhost = new RPC.Builder(new Configuration())
                .setBindAddress("localhost")
                .setPort(8080)
                .setProtocol(RPCProtocolTest.class)
                .setInstance(new RPCProtocolTestImpl())
                .build();

localhost.start();
    }
}

```

## 2.3 客户端调用

```java

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;

import java.io.IOException;
import java.net.InetSocketAddress;

public class RPCClientTest {

public static void main(String[] args) throws IOException {

final RPCProtocolTest localhost = RPC.getProxy(RPCProtocolTest.class, RPCProtocolTest.versionID, new InetSocketAddress("localhost", 8080), new Configuration());

final int liyan = localhost.work("liyan", 123);

System.out.println(liyan);

}
}

```

这样我们接可以通过8080端口直接调用到RPCProtocolTestImpl类了。

回帖

消灭零回复