并行的RPC框架(Concurrent RPC Framework) Yar Java Client

wh469012917 發(fā)布于2019-08-14 15:08 / 2116人閱讀

摘要：客戶端并行調(diào)用這兩個(gè)服務(wù)這里的方法的命令皆以原版為準(zhǔn)則。回調(diào)函數(shù)需要繼承實(shí)現(xiàn)里面定義了兩個(gè)方法是針對(duì)并行調(diào)用發(fā)出之后立即執(zhí)行的任務(wù)，而則是每個(gè)請(qǐng)求之后返回的結(jié)果。

簡(jiǎn)介

Yar 是一個(gè)輕量級(jí), 高效的 RPC 框架, 它提供了一種簡(jiǎn)單方法來讓 PHP 項(xiàng)目之間可以互相遠(yuǎn)程調(diào)用對(duì)方的本地方法. 并且 Yar 也提供了并行調(diào)用的能力. 可以支持同時(shí)調(diào)用多個(gè)遠(yuǎn)程服務(wù)的方法.
Yar 鳥哥博客介紹 http://www.laruence.com/2012/09/15/2779.html
Yar 鳥哥原始項(xiàng)目 https://github.com/laruence/yar
Yar Java Client 則實(shí)現(xiàn)了跨語言的遠(yuǎn)程調(diào)用。使得 Java 客戶端能夠調(diào)用 Yar PHP 服務(wù)器端本地的方法。

github: https://github.com/zhoumengkang/yar-java-client 
您的 star 就是對(duì)我們小菜的最大的鼓勵(lì)，O(∩_∩)O~~

特性

執(zhí)行速度快，依舊保持鳥哥初衷，框架輕，使用簡(jiǎn)單

支持并行的 RPC 調(diào)用

方法的使用和參數(shù)的和 PHP 版本保持一致

范例 PHP服務(wù)器端提供了服務(wù)

兩個(gè) rpc api ，模擬的業(yè)務(wù)場(chǎng)景是點(diǎn)贊贈(zèng)送金幣和發(fā)布帖子贈(zèng)送金幣。

handle();

Java客戶端同步調(diào)用這兩個(gè)服務(wù)

public class YarClientTest extends TestCase {
    /**
     * 定義 rpc 接口
     */
    public interface RewardScoreService{
        String support(int uid,int fid);
        String post(int uid,int fid);
    }

    /**
     * rpc api 地址
     */
    static String uri = "http://mengkang.net/demo/yar-server/RewardScoreService.php";

    public void testUserService(){
        // 第一種調(diào)用方式
        YarClient yarClient  = new YarClient(uri);
        RewardScoreService rewardScoreService = (RewardScoreService) yarClient.useService(RewardScoreService.class);
        for (int i = 0; i < 10; i++) {
            System.out.println(rewardScoreService.support(1, 2));
        }
        // 第二種調(diào)用方式
        YarClientOptions yarClientOptions = new YarClientOptions();
        yarClientOptions.setConnect_timeout(2000);
        YarClient yarClient2  = new YarClient(uri,yarClientOptions);
        RewardScoreService rewardScoreService2 = (RewardScoreService) yarClient2.useService(RewardScoreService.class);
        for (int i = 0; i < 10; i++) {
            System.out.println(rewardScoreService2.post(1, 20));
        }
    }

}

考慮到 Java 和 PHP 的數(shù)據(jù)類型的不同，這里做了一個(gè)折中的處理，返回?cái)?shù)據(jù)類型客戶端框架統(tǒng)一以O(shè)bject類型接受，然后使用時(shí)再根據(jù)接口定義的數(shù)據(jù)類型進(jìn)行轉(zhuǎn)換。

Java客戶端并行調(diào)用這兩個(gè)服務(wù)

這里的方法的命令皆以 Yar 原版為準(zhǔn)則。
YarConcurrentClient.call方法注冊(cè)，
YarConcurrentClient.loop并行調(diào)用，
YarConcurrentClient.reset清空任務(wù)。
回調(diào)函數(shù)需要繼承實(shí)現(xiàn)YarConcurrentCallback里面定義了兩個(gè)方法：async是針對(duì)并行調(diào)用發(fā)出之后立即執(zhí)行的任務(wù)，而success則是每個(gè)請(qǐng)求之后返回的結(jié)果。

public class YarConcurrentClientTest extends TestCase {

    /**
     * rpc api 地址
     */
    static String uri = "http://mengkang.net/demo/yar-server/RewardScoreService.php";

    public class callback extends YarConcurrentCallback {

        public void async() {
            System.out.println("現(xiàn)在, 所有的請(qǐng)求都發(fā)出去了, 還沒有任何請(qǐng)求返回");
        }

        public Object success() {
            return retValue;
        }

    }

    public class errorCallback extends YarConcurrentErrorCallback {
        @Override
        void error() {
            System.out.println("出錯(cuò)了");
        }
    }

    public void testLoop() throws Exception {

        String packagerName = YarConfig.getString("yar.packager");
        YarClientOptions yarClientOptions = new YarClientOptions();
        yarClientOptions.setConnect_timeout(2000);

        for (int i = 0; i < 10; i++) {
            // 第一種調(diào)用方式
            YarConcurrentClient.call(new YarConcurrentTask(uri, "support", new Object[]{1, 2}, packagerName, new callback()));
            // 第二種調(diào)用方式 增加一些額外配置選項(xiàng)
            YarConcurrentClient.call(new YarConcurrentTask(uri, "support", new Object[]{1, 2}, packagerName, new callback(),yarClientOptions));
        }

        for (int i = 0; i < 10; i++) {
            // 第三種調(diào)用方式 有正確的回調(diào)和錯(cuò)誤的回調(diào)
            YarConcurrentClient.call(new YarConcurrentTask(uri,"post",new Object[]{1,2},packagerName,new callback(),new errorCallback()));
            // 第四種調(diào)用方式 在第三種的基礎(chǔ)上增加額外的配置選項(xiàng)
            YarConcurrentClient.call(new YarConcurrentTask(uri,"post",new Object[]{1,2},packagerName,new callback(),new errorCallback(),yarClientOptions));
        }

        YarConcurrentClient.loop(new callback());
        YarConcurrentClient.reset();
    }
}

github: https://github.com/zhoumengkang/yar-java-client 
您的 star 就是對(duì)我們小菜的最大的鼓勵(lì)，O(∩_∩)O~~

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

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

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

wh469012917

男|高級(jí)講師

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

TA的文章

tensorflow

閱讀 3142·2023-04-26 00:32
css清除浮動(dòng)clearfix：after

閱讀 592·2019-08-30 15:52
頁面設(shè)計(jì)筆記

閱讀 2189·2019-08-30 15:52
小程序輸入框文字上移問題文字彈出輸入框

閱讀 3491·2019-08-30 15:44
使用GitHub（一）：添加SSHkey

閱讀 3363·2019-08-30 14:09
Fixed with absolute

閱讀 1497·2019-08-29 15:15
## CSS 的黑科技

閱讀 3477·2019-08-28 18:12
原生js實(shí)現(xiàn)each方法

閱讀 1180·2019-08-26 13:55

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

資訊專欄INFORMATION COLUMN

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

并行的RPC框架(Concurrent RPC Framework) Yar Java Client

相關(guān)文章

**phpcms 里面 Yar 的使用**

SOA面向服務(wù)基礎(chǔ)

服務(wù)治理深入淺出（2）- 遠(yuǎn)程方法調(diào)用的實(shí)現(xiàn)

記JVM堆外內(nèi)存泄漏Bug查找

**基于Yar的WordPress微博墻插件**

發(fā)表評(píng)論

0條評(píng)論

wh469012917

男|高級(jí)講師

TA的文章

tensorflow

css清除浮動(dòng)clearfix：after

頁面設(shè)計(jì)筆記

小程序輸入框文字上移問題文字彈出輸入框

使用GitHub（一）：添加SSHkey

Fixed with absolute

## CSS 的黑科技

原生js實(shí)現(xiàn)each方法

最新活動(dòng)

資訊專欄INFORMATION COLUMN

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

并行的RPC框架(Concurrent RPC Framework) Yar Java Client

相關(guān)文章

發(fā)表評(píng)論

0條評(píng)論

男|高級(jí)講師

TA的文章

最新活動(dòng)

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