Hadoop中的RPC應用實例

1、環境準備：

CentOS 6.9 32位
Linux和Windows版的Eclipse 32位
Hadoop 2.4.1版本
JDK 7+

---

2、Linux和Windows中的都須要引入Hadoop的Jar包：建立一個 User Libraries，引入

---

3、Linux中Eclipse做爲服務端

• 一、建立一個接口LoginServiceInterface.java

package cn.joker.hadoop.rpc;

public interface LoginServiceInterface {

	public static final long versionID=1L;
	
	public String login(String username,String password);
	
}

• 二、建立一個接口實現類LoginServiceImpl.java

package cn.joker.hadoop.rpc;

public class LoginServiceImpl implements LoginServiceInterface {

	@Override
	public String login(String username, String password) {
		// TODO Auto-generated method stub
		return username + " logged in successfully!";
	}

}

• 三、建立一個啓動類Starter.java

package cn.joker.hadoop.rpc;

import java.io.IOException;

import org.apache.hadoop.HadoopIllegalArgumentException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
import org.apache.hadoop.ipc.RPC.Builder;
import org.apache.hadoop.ipc.Server;

public class Starter {

	public static void main(String[] args) throws HadoopIllegalArgumentException, IOException {
		
	Builder builder = new RPC.Builder(new Configuration());

	builder.setBindAddress("weekend110").setPort(10000).setProtocol(LoginServiceInterface.class).setInstance(new LoginServiceImpl());
	
	Server server = builder.build();
	
	server.start();
	
	}

}

---

4、Windows中的Eclipse做爲客戶端：

• 一、建立一個接口LoginServiceInterface.java

package cn.joker.hadoop.rpc;

public interface LoginServiceInterface {
	
	public static final long versionID=1L;
	
	public String login(String username,String password);

}

• 二、建立一個控制類LoginController.java

package cn.joker.hadoop.rpc;

import java.net.InetSocketAddress;

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

public class LoginController {

	public static void main(String[] args) throws Exception {
		LoginServiceInterface proxy = RPC.getProxy(LoginServiceInterface.class, 1L, new InetSocketAddress("weekend110", 10000), new Configuration());
		
		String result = proxy.login("kevintan", "abc1234");
		
		System.out.println(result);
	}
	
	
}

---

5、運行Linux端的服務，再運行Windows端的請求，便可完成一個簡單的RPC應用。