Docker下dubbo开发,三部曲之三:java开发

在前两章《Docker下dubbo开发,三部曲之一:极速体验》《Docker下dubbo开发,三部曲之二:本地环境搭建》中,我们体验了dubbo环境搭建以及服务的发布和消费,对dubbo有了初步认识,本章我们来实战dubbo服务的发布和消费代码的编写,实战后的我们能将自己的服务发布到dubbo环境供别人调用,也能让自己的工程去调用dubbo环境中的已有服务;

源码下载

本次实战一共有两个工程,分别是服务的提供者和消费者,都是web工程,代码在github上,地址是git@github.com:zq2599/blog_demos.git,这里面有多个工程,本章所需的代码如下: 1. 服务提供者的代码在目录dubbo_service_provider下,如下图红框所示:

  1. 服务消费者的代码在目录dubbo_service_consumer下,如下图红框所示:

接下来我们逐个分析,实战开发;

服务提供者开发

首先是pom中的依赖关系,除了常用的spring相关的,我们还要加入dubbo和zookeeper的依赖,如下所示:

<!-- dubbo -->
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.5.3</version>
      <exclusions>
        <exclusion>
          <artifactId>spring</artifactId>
          <groupId>org.springframework</groupId>
        </exclusion>
      </exclusions>
    </dependency>
    <!-- zkclient  -->
    <dependency>
      <groupId>com.github.sgroschupf</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.1</version>
    </dependency>
    <!--  zookeeper -->
    <dependency>
      <groupId>org.apache.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>3.3.6</version>
    </dependency>

接下来看代码,本次实战提供了两个服务,分别实现了一下两个接口: 1. CalculateService定义add方法,执行最基础的int型加法服务,实现如下:

public class CalculateServiceImpl implements CalculateService{

    @Override
    public int add(int a, int b) {
        return a + b;
    }
}
  1. PlatformService定义getRpcFrom方法,返回当前环境系统中的换变量TOMCAT_SERVER_ID的值,这个值是docker容器启动的时候从docker-compose.yml中传入的;
public class PlatformServiceImpl implements PlatformService {

    @Override
    public String getRpcFrom() {
        return System.getenv().get("TOMCAT_SERVER_ID");
    }
}

以上是两个演示用的服务实现,逻辑很简单,现在看如何将服务发布到dubbo环境:

spring-extends.xml是我们自定义的spring配置文件,想发布到dubbo环境的服务都在这里声明:

<dubbo:application name="dubbo_service_provider" />
    <!-- 本机 伪集群 测试 -->
    <!--
    <dubbo:registry  protocol="zookeeper"  address="192.9.145.19:2181,192.9.145.19:2182,192.9.145.19:2183"  />
    -->
    <dubbo:registry address="zookeeper://zkhost:2181" />
    <dubbo:protocol name="dubbo" port="20880" />
    <dubbo:service interface="com.bolingcavalry.service.CalculateService"
                   ref="calculateService" />
    <dubbo:service interface="com.bolingcavalry.service.PlatformService"
                   ref="platformService" />
    <!-- 和本地bean一样实现服务 -->
    <bean id="calculateService" class="com.bolingcavalry.service.impl.CalculateServiceImpl" />
    <bean id="platformService" class="com.bolingcavalry.service.impl.PlatformServiceImpl" />

dubbo:application定义了服务归属的应用为dubbo_service_provider; dubbo:registry定义了注册中心地址,本次实战的zookeeper配置为单机,所以只填写了一个地址”zookeeper://zkhost:2181”,其中zkhost是docker容器的link属性的别名(连接到zookeeper容器),在dubbo:registry配置的上面有一个被注释掉的dubbo:registry配置,里面是zookeeper集群时候的连接方式; dubbo:protocol定义采用dubbo协议,使用20880端口; dubbo:service配置了要发布的服务,指定服务接口以及对应的bean;

使用以上配置,在spring环境启动后注册中心就会感知到,在pom.xml文件所在目录下执行mvn clean package -Dmaven.test.skip=true 即可编译打包,在docker容器发布运行方式请参照《Docker下dubbo开发,三部曲之二:本地环境搭建》;

服务消费者开发

服务消费者工程是dubbo_service_consumer,pom中的依赖关系和服务提供者的一样的,由于要调用dubbo_service_provider提供的服务,所以要把CalculateService和PlatformService这两个接口引入到工程中,一般是通过jar包方式引入,这里图个方便,直接将两个接口的源码复制到工程中,如下图:

再来看看调用服务的代码,如下图所示,通过普通的Autowired就能直接使用了,就像普通的spring环境中使用服务一样简单:

从dubbo环境获取远程服务的能力,是通过以下spring配置来实现的:

<!-- 消费方应用名,用于计算依赖关系,不是匹配条件,不要与提供方一样 -->
    <dubbo:application name="dubbo_service_consumer" />
    <!-- 使用multicast广播注册中心暴露发现服务地址 -->
    <!--
    <dubbo:registry  protocol="zookeeper"  address="192.9.145.19:2181,192.9.145.19:2182,192.9.145.19:2183" />
    -->
    <dubbo:registry address="zookeeper://172.28.0.3:2181" />
    <!-- 生成远程服务代理,可以和本地bean一样使用demoService -->
    <dubbo:reference id="calculateService" interface="com.bolingcavalry.service.CalculateService" />
    <dubbo:reference id="platformService" interface="com.bolingcavalry.service.PlatformService" />

dubbo:application和dubbo:registry的作用和前面分析的服务提供者的一样,dubbo:reference是指从dubbo环境获得远程的服务,interface指定了服务类型,应用启动后,用到服务端的时候就会根据注册中心的信息,远程调用服务提供者的服务;

以上就是dubbo的服务提供者和消费者的实战源码,实际的生产环境中,还会涉及到更详细更复杂的配置和使用,请读者们关注dubbo官网的开发手册。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏我的博客

Memcached介绍和配置

1、memcached介绍 Memcache是一个高性能的分布式的内存对象缓存系统,通过在内存里维护一个统一的巨大的hash表,它能够用来存 储各种格式的数...

3114
来自专栏L宝宝聊IT

Nagios监控系统

1403
来自专栏云计算教程系列

如何在CentOS 7上安装和配置Zabbix以安全地监视远程服务器

Zabbix是用于网络和应用程序的开源监控软件。它提供对从服务器,虚拟机和任何其他类型的网络设备收集的数千个指标的实时监控。这些指标可帮助您确定IT基础架构当前...

250
来自专栏信安之路

手把手教你制作漏洞复现环境

在学习的过程中, 是否看到别人搭建的 Exploit 练习平台心痒痒呢? 通过本篇教程的学习, 将手把手教你搭建属于自己的漏洞测试利用环境, 不管是自己学习还有...

1040
来自专栏安富莱嵌入式技术分享

【RL-TCPnet网络教程】第35章 FTP文件传输协议基础知识

本章节为大家讲解FTP(File Transfer Protocol,文件传输协议)的基础知识,方便后面章节的实战操作。

501
来自专栏分布式系统和大数据处理

Kafka分布式消息系统(搭建Zookeeper集群) - Part.2

kafka使用zookeeper来管理Brokers(kafka服务进程)、执行partition(分区)的leader选举、当出现变更时向kafka发送通知(...

872
来自专栏python学习指南

python爬虫(二)_HTTP的请求和响应

HTTP和HTTPS HTTP(HyperText Transfer Protocol,超文本传输协议):是一种发布和接收HTML页面的方法 HTTPS(Hyp...

30510
来自专栏性能与架构

linux 查看I/O状态的常用命令

介绍下linux的3个常用I/O相关命令,解决I/O压力过大问题时很有用 iostat 查看磁盘的I/O状态 iotop 查看I/O进程排名 lsof 查...

3549
来自专栏CaiRui

cookie和session

cookie: 1. `cookie`出现的原因:在网站中,http请求是无状态的。也就是说即使第一次和服务器连接后并且登录成功后,第二次请求服务器依然不能知道...

1805
来自专栏云计算教程系列

如何在Ubuntu 16.04上安装和配置Zabbix以安全地监视远程服务器

Zabbix是用于web和应用程序的开源监控软件。它提供对从服务器,虚拟机和任何其他类型的网络设备收集的数千个指标的实时监控。这些指标可帮助确定IT基础架构的当...

1073

扫码关注云+社区