hadoop中rpc的示例分析

這篇文章主要介紹hadoop中rpc的示例分析，文中介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們一定要看完！

超過(guò)十余年行業(yè)經(jīng)驗(yàn)，技術(shù)領(lǐng)先，服務(wù)至上的經(jīng)營(yíng)模式，全靠網(wǎng)絡(luò)和口碑獲得客戶，為自己降低成本，也就是為客戶降低成本。到目前業(yè)務(wù)范圍包括了：成都網(wǎng)站設(shè)計(jì)、做網(wǎng)站，成都網(wǎng)站推廣，成都網(wǎng)站優(yōu)化，整體網(wǎng)絡(luò)托管，微信小程序，微信開(kāi)發(fā)，成都app軟件開(kāi)發(fā)公司，同時(shí)也可以讓客戶的網(wǎng)站和網(wǎng)絡(luò)營(yíng)銷和我們一樣獲得訂單和生意！

[root@localhost  hadoop-2.4.1]# service network restart啟動(dòng)網(wǎng)卡

windos 端的UserLoginController

package cn.itcast.bigdata.hadoop.rpc;

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

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

public class UserLoginController {

    
    
    public static void main(String[] args) throws Exception {//先啟動(dòng)服務(wù)器端
        
        Configuration conf = new Configuration();
        LoginServiceInterface loginServiceImpl = RPC.getProxy(LoginServiceInterface.class, 1L, new InetSocketAddress("192.168.88.155", 10000), conf);
        
        String res = loginServiceImpl.login("angelababy", "123");
        
        System.out.println(res);
        
    }
    
    
}

package cn.itcast.bigdata.hadoop.rpc;

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

}

linux端的

package cn.itcast.bigdata.hadoop.rpc;

public class LoginServiceImpl implements LoginServiceInterface{

    @Override
    public String login(String username, String password) {
        

        
        
        return username + "logged in successfully!";
    }

}

package cn.itcast.bigdata.hadoop.rpc;

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

}

package cn.itcast.bigdata.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.RPC.Server;

public class ServerStarter {

    
    public static void main(String[] args) throws HadoopIllegalArgumentException, IOException {//先啟動(dòng)服務(wù)器端的
        
        Configuration conf = new Configuration();
        Builder builder = new RPC.Builder(conf);
        builder.setInstance(new LoginServiceImpl()).setBindAddress("192.168.88.155").setPort(10000).setProtocol(LoginServiceInterface.class);
        Server server = builder.build();
        server.start();
        
        
    }
}

以上是“hadoop中rpc的示例分析”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對(duì)大家有幫助，更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

當(dāng)前名稱：hadoop中rpc的示例分析
分享路徑：http://muchs.cn/article12/iepigc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站策劃、App設(shè)計(jì)、網(wǎng)頁(yè)設(shè)計(jì)公司、面包屑導(dǎo)航、網(wǎng)站制作、商城網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)