dubbo接口demo開發

Dubbo是一款高性能、輕量級的開源Java RPC框架。

很多朋友想學習測試dubbo接口，但是苦於沒有可練習的dubbo接口而放棄，下面我就帶大家開發一個簡單的dubbo接口。

接口需求

客戶端輸入uncleyong（當然，也可以輸入其它字符串），服務端返回hello uncleyong

開發環境

jdk + idea + maven + zookeeper

jdk安裝：https://www.cnblogs.com/uncleyong/p/10732951.html

idea安裝：https://www.cnblogs.com/uncleyong/p/10971923.html

maven安裝：https://www.cnblogs.com/uncleyong/p/10743181.html

zookeeper安裝：https://www.cnblogs.com/uncleyong/p/10737119.html

common開發

idea中創建模塊dubbo-common

存放公共的實體類、接口

package com.uncleyong.dubbotest.service;


public interface SayHelloToClient {
    public String sayHello(String name);
}

然后mvn install打包，供provider及consumer在pom文件中引包　

provider開發

idea中創建模塊dubbo_provider

創建實現類

package com.uncleyong.dubbotest.service.impl;

import com.uncleyong.dubbotest.service.SayHelloToClient;


public class SayHelloToClientImpl implements SayHelloToClient {

    public String sayHello(String name){
        System.out.println("from client ：" + name);
        return "hello, " + name;
    }
}

配置文件，provider.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <dubbo:application name="dubbo-provider"/>

    <!-- 使用zookeeper廣播注冊中心暴露服務地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>

    <!-- 用dubbo協議在20880端口暴露服務 -->
    <dubbo:protocol name="dubbo" port="20888"/>

    <!-- 聲明需要暴露的服務接口 -->
    <dubbo:service interface="com.uncleyong.dubbotest.service.SayHelloToClient" ref="sayhellotoclient"/>


    <!-- 和本地bean一樣實現服務 -->
    <bean id="sayhellotoclient" class="com.uncleyong.dubbotest.service.impl.SayHelloToClientImpl"/>

</beans>

創建主運行文件，ProviderMain

package com.uncleyong.dubbotest.main;

import org.springframework.context.support.ClassPathXmlApplicationContext;


public class ProviderMain {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
                new String[] {"provider.xml"});
        context.start();
        System.out.println("注冊成功，如想退出，按任意鍵退出");
        System.in.read(); // 按任意鍵退出
    }
}

consumer開發

idea中創建模塊dubbo_consumer

主運行文件

package com.uncleyong.dubbotest.main;

import com.uncleyong.dubbotest.service.SayHelloToClient;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.util.Scanner;


public class ConsumerMain {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
                new String[] {"consumer.xml"});
        context.start();
        // 獲取遠程服務代理
        SayHelloToClient say = (SayHelloToClient) context.getBean("sayhellotoclient");
        // 執行遠程方法
        String res = say.sayHello("UncleYong");
        // 顯示調用結果
        System.out.println(res);
        new Scanner(System.in).next();
    }
}

配置文件，consumer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">


    <dubbo:application name="dubbo-consumer"/>

    <!-- 使用zookeeper廣播注冊中心暴露發現服務地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>

    <!-- 生成遠程服務代理，可以和本地bean一樣使用demoService -->
    <dubbo:reference id="sayhellotoclient" interface="com.uncleyong.dubbotest.service.SayHelloToClient"/>

</beans>

運行結果

先啟動zookeeper，進入zookeeper的bin目錄，點擊【zkServer.cmd】

啟動provider

服務注冊成功

啟動consumer，可以看到輸出了結果

在provider端，也可以看到客戶端發過來的消息

 

至此，開發完成。