zoukankan      html  css  js  c++  java
  • Hadoop RPC简单实例

    1、导入Hadoop-Common-2.6.0.jar导入工程,里面的IPC实现RPC需要的文件。

    2、服务器端

     (1)服务接口
    package com.neu.rpc.server;
    
    /**
     * Created by apple on 16/6/26.
     */
    public interface LoginServiceInterface {
        public static final long versionID = 1L;
    
        public String login(String username, String password);
    }
    

    (2)服务实现

    package com.neu.rpc.server;
    
    
    /**
     * Created by apple on 16/6/26.
     */
    public class LoginServiceImpl implements LoginServiceInterface {
        @Override
        public String login(String username, String password) {
            return username + " login success";
        }
    }
    

    (3)RPC服务端,将上述服务进行发布,监控RPC客户端发来的请求

    package com.neu.rpc.server;
    
    import org.apache.hadoop.conf.Configuration;
    import org.apache.hadoop.ipc.RPC;
    
    import java.io.IOException;
    
    /**
     * Created by apple on 16/6/26.
     */
    public class Starter {
        public static void main(String[] args) throws IOException {
            RPC.Builder build = new RPC.Builder(new Configuration());
            build.setBindAddress("localhost").setPort(10000).setProtocol(LoginServiceInterface.class).setInstance(new LoginServiceImpl());
            RPC.Server server = build.build();
            server.start();
        }
    }

    3、客户端

     (1)RPC服务接口【问题:因为服务协议是包名加类名,因此客户端的服务接口的包名要与服务端接口的包名一致
    package com.neu.rpc.server;
    
    /**
     * Created by apple on 16/6/26.
     */
    public interface LoginServiceInterface {
        public static final long versionID = 1L;
    
        public String login(String username, String password);
    }
    

    (2)RPC客户端请求服务

    public class LoginController {
        public static void main(String[] args) throws IOException {
            LoginServiceInterface proxy= RPC.getProxy(LoginServiceInterface.class,1L,new InetSocketAddress("localhost",10000),new Configuration());
            String msg=proxy.login("xiaoming","123123");
            System.out.println(msg);
        }
    }

    4、实验结果

    com.intellij.rt.execution.application.AppMain com.neu.rpc.client.LoginController
    2016-06-28 00:23:36,542 WARN  [main] util.NativeCodeLoader (NativeCodeLoader.java:<clinit>(62)) - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
    xiaoming login success
    
    Process finished with exit code 0
    

      

  • 相关阅读:
    题目1007:奥运排序问题(自定义排序问题)
    题目1005:Graduate Admission(录取算法)
    九度OJ小结2
    题目1049:字符串去特定字符(简单字符判断)
    题目1111:单词替换(字符串查找)
    题目1168:字符串的查找删除(字符串操作)
    题目1455:珍惜现在,感恩生活(多重背包问题)
    题目1454:Piggy-Bank(完全背包问题)
    题目1453:Greedy Tino(dp题目)
    题目1452:搬寝室(dp题目)
  • 原文地址:https://www.cnblogs.com/arbitrary/p/5621987.html
Copyright © 2011-2022 走看看