Hadoop HDFS编程 API入门系列之RPC版本2

Posted 2020-08-23 大数据和人工智能躺过的坑

 

　　不多说，直接上代码。

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

代码

 1 package zhouls.bigdata.myWholeHadoop.RPC.rpc2;
 2 
 3 public class LoginServiceImpl implements LoginServiceInterface {
 4 
 5     @Override
 6     public String login(String username, String password) {
 7         
 8         return username + " logged in successfully!";
 9     }
10 
11 }

 

 

 

 

 

 

 

 1 package zhouls.bigdata.myWholeHadoop.RPC.rpc2;
 2 
 3 public class LoginServiceImpl implements LoginServiceInterface {
 4 
 5     @Override
 6     public String login(String username, String password) {
 7         
 8         return username + " logged in successfully!";
 9     }
10 
11 }

 

 

 

 

 

 

 1 package zhouls.bigdata.myWholeHadoop.RPC.rpc2;
 2 
 3 import java.io.IOException;
 4 
 5 import org.apache.hadoop.HadoopIllegalArgumentException;
 6 import org.apache.hadoop.conf.Configuration;
 7 import org.apache.hadoop.ipc.RPC;
 8 import org.apache.hadoop.ipc.RPC.Builder;
 9 import org.apache.hadoop.ipc.RPC.Server;
10 
11 public class Starter {
12 
13     public static void main(String[] args) throws HadoopIllegalArgumentException, IOException {
14         
15         
16         Builder builder = new RPC.Builder(new Configuration());
17         
18         builder.setBindAddress("HadoopMaster").setPort(10000).setProtocol(LoginServiceInterface.class).setInstance(new LoginServiceImpl());
19         
20         Server server = builder.build();
21         
22         server.start();
23         
24         
25         
26     }
27     
28     
29 }