[Dubbo]分布式服务治理技术 实践

一、在spring项目中如何使用dubbo远程调用接口

实现远程调用接口,那么至少需要一个客户端,一个服务端程序。
在这里,我分别利用IDEA 创建2个maven项目(maven-archetype-quickstart)。一个客户端:dubbo-client,一个服务端:dubbo-server。其中服务端dubbo-server中创建两个模块(maven-archetype-quickstart),一个是服务端接口:server-api,另一个是实现服务端接口的类:server-provider

图片
dubboClient-结构图.png
dubboserver-结构图.png

1、创建dubboserver项目

创建maven项目

图片
maven:maven-archetype-quickstart.png
dubbo-server.png

项目创建完成后,在dubboserver项目下接着创建两个maven模块:server-api,server-provider

图片
这里写图片描述

创建server-api

图片
Screenshot_5.png

|

同理,可创建server-provider模块。

2.创建dubboClient项目

步骤类同上面的创建dubboserver项目。


代码实践:dubbo-server

位置:dubbo-server-->server-api

创建抽象接口

清单1: 服务端 提供的api
package com.gupaoedu.dubbo;

/**
 * 服务端 提供的api  接口
 */
public interface IGpHello {
    String sayHello(String msg);
}


位置:dubbo-server-->server-provider

创建抽象接口(IGpHello)的实现类

清单2:服务端IGpHello的实现类GpHelloImpl
package com.gupaoedu.dubbo;

/**
 * Server-provider
 * 对服务端接口的实现
 */
public class GpHelloImpl implements  IGpHello{
    @Override
    public String sayHello(String msg) {
        return "Hello"+msg;
    }
}


位置:dubbo-server-->server-provider-->pom.xml

导入依赖

清单3、导入依赖
  <!--  TODO  方式一     -->
        <!--服务端  实现接口 API  start-->
         <!-- 客户端 依赖这个jar 包-->
        <dependency>
            <groupId>com.gupaoedu.dubbo</groupId>
            <artifactId>server-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.5.3</version>
        </dependency>

位置:dubbo-server-->server-provider-->dubbo-server.xml
需要将其中的jar安装 到本地仓库中去

图片
Screenshot_11.png


位置:dubbo-server-->server-provider-->dubbo-server.xml

创建dubbo-server.xml dubbo服务端配置文件

清单4、配置dubbo服务端配置文件
<?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://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
         http://www.springframework.org/schema/beans/spring-beans.xsd
           http://code.alibabatech.com/schema/dubbo
                http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <!--提供方信息-->
    <dubbo:application name="dubbo-server" owner="Cindy"/>
    <!--注册中心 不需要 N/A-->
    <dubbo:registry address="N/A"/>
    <!--配置协议-->
    <dubbo:protocol name="dubbo" port="20880"/>
    <dubbo:service interface="com.gupaoedu.dubbo.IGpHello" ref="gpHelloService"/>
    <bean id="gpHelloService" class="com.gupaoedu.dubbo.GpHelloImpl"/>
</beans>


位置:dubbo-server-->server-provider

创建启动类:Bootstrap

清单5、创建启动类:Bootstrap
package com.gupaoedu.dubbo;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.io.IOException;
public class Bootstrap {
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext context=
                new ClassPathXmlApplicationContext("/META-INF/spring/dubbo-server.xml");
        context.start();
        System.in.read();// 阻塞当前进程

    }
}

启动Bootstrap

图片
Screenshot_13.png

控制台输出的url便是接口的地址。

代码实践:dubbo-Client

位置:dubbo-cliient-->pom.xml

导入依赖

清单6:导入依赖
  <!--客户端  依赖 服务端实现接口中的jar 包-->
    <dependency>
      <groupId>com.gupaoedu.dubbo</groupId>
      <artifactId>server-api</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>

    <!--dubbo 依赖-->
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.5.3</version>
    </dependency>


位置:dubbo-cliient-->dubbo-client.xml

创建客户端配置文件:dubbo-client.xml

清单7:创建客户端配置文件:dubbo-client.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://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans    
        http://www.springframework.org/schema/beans/spring-beans.xsd 

        http://code.alibabatech.com/schema/dubbo    
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <!--提供方信息-->

    <dubbo:application name="dubbo-client" owner="Cindy"/>
    <!-- TODO N方式1   -->
    <!--注册中心 不需要 N/A-->
    <dubbo:registry address="N/A"/>

    <!--配置协议-->
    <dubbo:protocol name="dubbo" port="20880"/>

    <!-- TODO 方式一 远程调用接口地址   -->
   <dubbo:reference id="gpHelloService" interface="com.gupaoedu.dubbo.IGpHello"
    url="dubbo://192.168.0.116:20880/com.gupaoedu.dubbo.IGpHello"/>
</beans>



位置:dubbo-cliient

创建一个调用服务类:APP

清单8:客户端远程调用服务
package com.gupaoedu.dubbo;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class App
{
    public static void main( String[] args )
    {
        ClassPathXmlApplicationContext context=
                new ClassPathXmlApplicationContext("/META-INF/spring/dubbo-client.xml");
       // 得到IGhello远程访问对象
        IGpHello iGpHello=(IGpHello)context.getBean("gpHelloService");
        System.out.println(iGpHello.sayHello("Cindy") );
    }
}

现在我们启动这个APP类,能够在控制台看到输出:

HelloCindy。即说明调用成功。

二、dubbo 如何结合zookeeper 实现服务注册

上面的叙述只是调用一个接口,当调用的接口很多时,我们就得利用中间件来注册、获取服务接口信息。

代码实践:dubbo-server

位置:dubbo-server-->server-provider-->pom.xml

添加依赖:

清单9:zookeeper,zkCli
 <!--  TODO  方式二     -->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.10</version>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.10</version>
        </dependency>


位置:dubbo-server-->server-provider-->dubbo-server.xml

修改dubbo:registry

清单10:dubbo:registry 修改
 <!--注册中心: 利用zookeeper 将信息注册到zookeeper-->
    <dubbo:registry address="zookeeper://192.168.0.11:2181"/>

以上两步是关于服务端的修改,好,我们启动服务端的启动类:Bootstrap。

然后打开zookeeper的客户端查看

图片
Screenshot_14.png

能够看到 zookeeper为了存储信息 创建的节点。

代码实践:dubbo-client

位置:dubbo-client-->pom.xml

添加依赖:

清单11:添加依赖
    <!--  TODO 方式二 -->
    <!--使用zookeeper 获取注册信息-->
    <dependency>
      <groupId>org.apache.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>3.4.10</version>
    </dependency>
    <dependency>
      <groupId>com.101tec</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.10</version>
    </dependency>



位置:dubbo-client-->dubbo-client.xml

修改配置文件中的dubbo:registrydubbo:reference

清单12:修改配置文件
    <!-- TODO 方式2  -->
    <!--注册中心 -->
    <dubbo:registry address="zookeeper://192.168.0.11:2181"/>
  <!-- TODO 方式二 远程调用接口地址   -->
    <dubbo:reference id="gpHelloService" interface="com.gupaoedu.dubbo.IGpHello"/>

好了,这时候我们启动客户端APP类来远程调用接口。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 215,723评论 6 498
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,003评论 3 391
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 161,512评论 0 351
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,825评论 1 290
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,874评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,841评论 1 295
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,812评论 3 416
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,582评论 0 271
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,033评论 1 308
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,309评论 2 331
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,450评论 1 345
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,158评论 5 341
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,789评论 3 325
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,409评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,609评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,440评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,357评论 2 352

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,649评论 18 139
  • 0 准备 安装注册中心:Zookeeper、Dubbox自带的dubbo-registry-simple;安装Du...
    七寸知架构阅读 13,985评论 0 88
  • 今生新得 1.来自吴伯凡 不要让孩子输在起跑线的含义是给孩子有竞争力的无形资产:乐于帮助别人,给予,共情力。三点综...
    Pheeb阅读 274评论 1 1
  • 夜以静谧陪伴它柔软的寂寞 不能动摇的思想 是一种精彩绝伦的羽化 当黎明来临 忽有色彩旋飞,碾压过灰暗 反射斑斓的光...
    月亮河418阅读 327评论 6 3
  • 回村子里,建个房子,一起住吧 院子里有几棵树,猫咪走来走去,或窝在椅垫上晒太阳 木桌上,茶水清透,映着树叶盘旋落地...
    从良人阅读 251评论 0 1