一.服务器端程序:
package rpc;
public interface LoginService {
public static final long versionID= 1L;
public String login(String username,String password);
}
确定业务接口
package rpc;
public class LoginServiceImpl implements LoginService {
@Override
public String login(String username, String password) {
return username+" successful login";
}
}
确定业务实现
package 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.RPC.Server;
public class ServiceStrart {
public static void main(String[] args) throws HadoopIllegalArgumentException, IOException {
Builder builder = new RPC.Builder(new Configuration());
builder.setBindAddress("192.168.245.129").setPort(10000).setProtocol(LoginService.class).setInstance(new LoginServiceImpl());
Server server = builder.build();
server.start();
}
}
服务器端开始运行程序
二.客户端程序
package rpc;
public interface LoginService {
public static final long versionID= 1L;
public String login(String username,String password);
}
业务接口类需要和服务器端一致
package 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 {
LoginService proxy = RPC.getProxy(LoginService.class, 1L, new InetSocketAddress("192.168.245.129",10000), new Configuration());
String result = proxy.login("bluefat", "123");
System.out.println(result);
}
}
客户端发起请求