基于Netty實現的輕量級分布式服務框架

Dogee 發布于2019-08-14 18:00 / 3281人閱讀

摘要：對分布式技術比較感興趣，于是在閑暇時間寫了一個簡單的框架娛樂一下，項目持續更新中項目地址如果感覺對你有幫助可以順手點個哦哈哈直接看一下示例代碼吧第一步啟動注冊中心創建服務注冊中心啟動注冊中心第二步啟動服務提供者創建服務提供者和服務包裝器連接

對分布式技術比較感興趣，于是在閑暇時間寫了一個簡單的RPC框架娛樂一下，項目持續更新中...... GitHub項目地址: Pudding

如果感覺Pudding對你有幫助可以順手點個Star哦......哈哈

直接看一下示例代碼吧 第一步: 啟動注冊中心

public class RegistryTest {
    public static void main(String[] args) {
        // 創建服務注冊中心
        ServiceRegistry registry = new DefaultServiceRegistry();
        // 啟動注冊中心
        registry.startRegistry(20000);
    }
}

第二步: 啟動服務提供者

public class ProviderTest {
    public static void main(String[] args) {
        // 創建服務提供者和服務包裝器
        ServiceProvider provider = new DefaultServiceProvider();
        ServiceWrapper serviceWrapper = new DefaultServiceWrapper();
        // 連接注冊中心
        provider.connectRegistry("127.0.0.1:20000");
        // 創建服務
        MyService myService = new MyServiceImpl();
        // 包裝服務為ServiceMeta
        Service service = serviceWrapper.build(myService, "127.0.0.1:30001");
        // 啟用服務
        provider.startService(service);
        // 發布所有已啟用的服務
        provider.publishAllService();
    }
}

第三步: 啟動服務消費者 同步調用

public class SyncConsumerTest {
    public static void main(String[] args) {
        // 創建服務消費者
        ServiceConsumer serviceConsumer = new DefaultServiceConsumer();
        // 連接注冊中心
        serviceConsumer.connectRegistry("127.0.0.1:20000");
        // 訂閱服務
        serviceConsumer.subscribeService(MyService.class);
        // 創建同步服務代理
        MyService myService = ProxyFactory.createSyncProxy(MyService.class);
        try {
            // 發起調用
            int result = myService.add(100, 200);
            System.out.println("調用結果: " + result);
        } catch (InvokeTimeoutException e) {
            System.out.println("遠程調用超時");
        } catch (InvokeFailedException e) {
            System.out.println("遠程調用失敗");
        }
    }
}

異步調用

public class AsyncConsumerTest {
    public static void main(String[] args) {
        // 創建服務消費者
        ServiceConsumer serviceConsumer = new DefaultServiceConsumer();
        // 連接注冊中心
        serviceConsumer.connectRegistry("127.0.0.1:20000");
        // 訂閱服務
        serviceConsumer.subscribeService(MyService.class);
        // 創建同步服務代理
        MyService myService = ProxyFactory.createAsyncProxy(MyService.class);
        // 發起調用
        myService.add(100, 200);
        // 監聽調用結果
        InvokeFuture.addInvokeFutureListener(new InvokeFutureListener() {
            @Override
            public void success(Integer result) {
                System.out.println("調用結果: " + result);
            }

            @Override
            public void failure(Exception e) {
                e.printStackTrace();
            }
        });
    }
}

云服務器 GPU云服務器 netty框架 java的輕量級框架基于webrtc的框架有哪些 php的重量級框架

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/66932.html

Java 程序員必備的 15 個框架，前 3 個地位無可動搖！

摘要：官網源碼推薦從開始手寫一個框架更多請在技術棧微信公眾號后臺回復關鍵字。是一個開放源代碼的對象關系映射框架，它對進行了非常輕量級的對象封裝，它將與數據庫表建立映射關系，是一個全自動的框架。 Java 程序員方向太多，且不說移動開發、大數據、區塊鏈、人工智能這些，大部分 Java 程序員都是 Java Web/后端開發。那作為一名 Java Web 開發程序員必須需要熟悉哪些框架呢？今天...

galaxy_robot 2019-08-16 13:37 評論0 收藏0
后端好書閱讀與推薦（續三）

摘要：后端好書閱讀與推薦系列文章后端好書閱讀與推薦后端好書閱讀與推薦續后端好書閱讀與推薦續二后端好書閱讀與推薦續三這里依然記錄一下每本書的亮點與自己讀書心得和體會，分享并求拍磚。然后又請求封鎖，當釋放了上的封鎖之后，系統又批準了的請求一直等待。后端好書閱讀與推薦系列文章：后端好書閱讀與推薦后端好書閱讀與推薦（續）后端好書閱讀與推薦（續二）后端好書閱讀與推薦（續三）這里依然記錄一下每本書的...

lauren_liuling 2019-08-16 11:00 評論0 收藏0
后端好書閱讀與推薦（續三）

摘要：后端好書閱讀與推薦系列文章后端好書閱讀與推薦后端好書閱讀與推薦續后端好書閱讀與推薦續二后端好書閱讀與推薦續三這里依然記錄一下每本書的亮點與自己讀書心得和體會，分享并求拍磚。然后又請求封鎖，當釋放了上的封鎖之后，系統又批準了的請求一直等待。后端好書閱讀與推薦系列文章：后端好書閱讀與推薦后端好書閱讀與推薦（續）后端好書閱讀與推薦（續二）后端好書閱讀與推薦（續三）這里依然記錄一下每本書的...

ckllj 2019-06-28 16:11 評論0 收藏0
后端好書閱讀與推薦（續三）

摘要：后端好書閱讀與推薦系列文章后端好書閱讀與推薦后端好書閱讀與推薦續后端好書閱讀與推薦續二后端好書閱讀與推薦續三這里依然記錄一下每本書的亮點與自己讀書心得和體會，分享并求拍磚。然后又請求封鎖，當釋放了上的封鎖之后，系統又批準了的請求一直等待。后端好書閱讀與推薦系列文章：后端好書閱讀與推薦后端好書閱讀與推薦（續）后端好書閱讀與推薦（續二）后端好書閱讀與推薦（續三）這里依然記錄一下每本書的...

jcc 2019-06-24 17:55 評論0 收藏0
dubbo源碼解析（一）Hello,Dubbo

摘要：英文全名為，也叫遠程過程調用，其實就是一個計算機通信協議，它是一種通過網絡從遠程計算機程序上請求服務而不需要了解底層網絡技術的協議。 Hello,Dubbo 你好，dubbo，初次見面，我想和你交個朋友。 Dubbo你到底是什么？先給出一套官方的說法：Apache Dubbo是一款高性能、輕量級基于Java的RPC開源框架。那么什么是RPC？文檔地址：http://dubbo.a...

evin2016 2019-08-16 13:27 評論0 收藏0