RPC框架是啥之Java自帶RPC實(shí)現(xiàn)，RMI框架入門

ZHAO_ 發(fā)布于2019-08-16 16:51 / 2038人閱讀

摘要：讓我們優(yōu)先來實(shí)現(xiàn)一個(gè)的案例吧。為了防止被防火墻攔截，需要強(qiáng)制制定的通信端口，一般通過自定義一個(gè)類來實(shí)現(xiàn)。完美支持語言所獨(dú)有的特性，不支持其他語言。使用了原生序列化，所有序列化對象必須實(shí)現(xiàn)接口。

本博客 貓叔的博客，轉(zhuǎn)載請申明出處

學(xué)習(xí)系列

RPC框架是啥？

Java自帶RPC實(shí)現(xiàn)，RMI框架入門

首先RMI（Remote Method Invocation）是Java特有的一種RPC實(shí)現(xiàn)，它能夠使部署在不同主機(jī)上的Java對象進(jìn)行通信與方法調(diào)用，它是一種基于Java的遠(yuǎn)程方法調(diào)用技術(shù)。

讓我們優(yōu)先來實(shí)現(xiàn)一個(gè)RMI的RPC案例吧。

項(xiàng)目源碼地址：RPC_Demo，記得是項(xiàng)目里面的comgithubrmi

1、首先我們需要為服務(wù)端創(chuàng)建一個(gè)接口方法，而且這個(gè)接口最好繼承Remote

package com.github.rmi.server;

import java.rmi.Remote;
import java.rmi.RemoteException;

/**
 * Create by UncleCatMySelf in 21:03 2019420 0020
 */
public interface MyService extends Remote {

    String say(String someOne)throws RemoteException;

}

2、對于接口實(shí)現(xiàn)類，RMI接口方法定義必須顯式聲明拋出RemoteException異常，服務(wù)端方法實(shí)現(xiàn)必須繼承UnicastRemoteObject類，該類定義了服務(wù)調(diào)用與服務(wù)提供方對象實(shí)現(xiàn)，并建立一對一的連接。

package com.github.rmi.server;

import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;

/**
 * Create by UncleCatMySelf in 21:05 2019420 0020
 */
public class MyServiceImpl extends UnicastRemoteObject implements MyService {

    protected MyServiceImpl() throws RemoteException {
    }

    public String say(String someOne) throws RemoteException {
        return someOne + ",Welcome to Study!";
    }
}

3、這里我們還需要一個(gè)針對服務(wù)端的配置類，因?yàn)镽MI的通信端口是隨機(jī)產(chǎn)生的，因此有可能會(huì)被防火墻攔截。為了防止被防火墻攔截，需要強(qiáng)制制定RMI的通信端口，一般通過自定義一個(gè)RMISocketFactory類來實(shí)現(xiàn)。

package com.github.rmi.config;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.rmi.server.RMISocketFactory;

/**
 * Create by UncleCatMySelf in 21:15 2019420 0020
 */
public class CustomerSocketFactory extends RMISocketFactory {

    public Socket createSocket(String host, int port) throws IOException {
        return new Socket(host, port);
    }

    public ServerSocket createServerSocket(int port) throws IOException {
        if (port == 0){
            port = 8855;
        }
        System.out.println("RMI 通信端口 : " + port);
        return new ServerSocket(port);
    }
}

4、好了，這時(shí)你可以寫出服務(wù)端的啟動(dòng)代碼了。

package com.github.rmi.server;

import com.github.rmi.config.CustomerSocketFactory;

import java.rmi.Naming;
import java.rmi.registry.LocateRegistry;
import java.rmi.server.RMISocketFactory;

/**
 * Create by UncleCatMySelf in 21:07 2019420 0020
 */
public class ServerMain {

    public static void main(String[] args) throws Exception {
        //注冊服務(wù)
        LocateRegistry.createRegistry(8866);
        //指定通信端口，防止被防火墻攔截
        RMISocketFactory.setSocketFactory(new CustomerSocketFactory());
        //創(chuàng)建服務(wù)
        MyService myService = new MyServiceImpl();
        Naming.bind("rmi://localhost:8866/myService",myService);
        System.out.println("RMI 服務(wù)端啟動(dòng)正常");
    }

}

5、客戶端的啟動(dòng)就相對比較簡單，我們僅需要進(jìn)入服務(wù)，并調(diào)用對應(yīng)的遠(yuǎn)程方法即可。

package com.github.rmi.client;

import com.github.rmi.server.MyService;

import java.rmi.Naming;

/**
 * Create by UncleCatMySelf in 21:10 2019420 0020
 */
public class ClientMain {

    public static void main(String[] args) throws Exception {
        //服務(wù)引入
        MyService myService = (MyService) Naming.lookup("rmi://localhost:8866/myService");
        //調(diào)用遠(yuǎn)程方法
        System.out.println("RMI 服務(wù)端調(diào)用返回：" + myService.say("MySelf"));
    }

}

最后可以看看效果。

關(guān)于RMI的一些關(guān)鍵點(diǎn)

支持真正的面向?qū)ο蟮亩鄳B(tài)性，這是RMI的優(yōu)勢。

完美支持Java語言所獨(dú)有的特性，不支持其他語言。

使用了Java原生序列化，所有序列化對象必須實(shí)現(xiàn)java.io.Serializablie接口。

底層通信是BIO（同步阻塞I/O）實(shí)現(xiàn)的Socket

由于BIO與原生序列化存在的性能問題，導(dǎo)致RMI的性能較差，如果你的項(xiàng)目性能要求較高，可能并不合適哦！

公眾號(hào)：Java貓說

學(xué)習(xí)交流群：728698035

現(xiàn)架構(gòu)設(shè)計(jì)（碼農(nóng)）兼創(chuàng)業(yè)技術(shù)顧問，不羈平庸，熱愛開源，雜談程序人生與不定期干貨。

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://www.ezyhdfw.cn/yun/74225.html

發(fā)表評論

登陸后可評論

0條評論

ZHAO_

男|高級講師

我要關(guān)注我要私信

TA的文章

??【C++教程第二篇】：兩千字入門必備基礎(chǔ)，建議收藏??

閱讀 1498·2021-09-03 10:29
【基礎(chǔ)】固定列寬的表格及示例演示

閱讀 3522·2019-08-29 16:24
如何優(yōu)雅的選擇字體(font-family)

閱讀 2190·2019-08-29 11:03
手把手教你用typescript擼一個(gè)npm包

閱讀 1496·2019-08-26 13:52
canvas繪制視頻封面

閱讀 3006·2019-08-26 11:36
javascript中的依賴注入【轉(zhuǎn)】

閱讀 2860·2019-08-23 17:19
正則表達(dá)式- [...]

閱讀 614·2019-08-23 17:14
Proxy介紹

閱讀 867·2019-08-23 13:59

亚洲中字慕日产2020,大陆极品少妇内射AAAAAA,无码av大香线蕉伊人久久,久久精品国产亚洲av麻豆网站

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長期優(yōu)惠，快來選購！

RPC框架是啥之Java自帶RPC實(shí)現(xiàn)，RMI框架入門

相關(guān)文章

RPC框架是啥之Apache CXF一款WebService RPC框架入門教程

**后端必備——數(shù)據(jù)通信知識(shí)(RPC、消息隊(duì)列)一站式總結(jié)**

Java 遠(yuǎn)程通訊技術(shù)及原理分析

分布式服務(wù)框架之遠(yuǎn)程通訊技術(shù)及原理分析

分布式服務(wù)框架之遠(yuǎn)程通訊技術(shù)及原理分析

發(fā)表評論

0條評論

ZHAO_

男|高級講師

TA的文章

??【C++教程第二篇】：兩千字入門必備基礎(chǔ)，建議收藏??

【基礎(chǔ)】固定列寬的表格及示例演示

如何優(yōu)雅的選擇字體(font-family)

手把手教你用typescript擼一個(gè)npm包

canvas繪制視頻封面

javascript中的依賴注入【轉(zhuǎn)】

正則表達(dá)式- [...]

Proxy介紹

最新活動(dòng)

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長期優(yōu)惠，快來選購！

RPC框架是啥之Java自帶RPC實(shí)現(xiàn)，RMI框架入門

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動(dòng)

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長期優(yōu)惠，快來選購！

RPC框架是啥之Java自帶RPC實(shí)現(xiàn)，RMI框架入門