设为首页 加入收藏

TOP

Docker下dubbo开发三部曲之三:java开发(一)
2019-09-18 11:10:56 】 浏览:49
Tags:Docker dubbo 开发 三部曲之三 java

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

源码下载

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

  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

首页 上一页 1 2 下一页 尾页 1/2/2
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇Docker下kafka学习三部曲之二:本.. 下一篇百度地图WEB端判断用户是否在网格..

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目