写点什么

InfoQ 极客传媒 15 周年庆征文|Dubbo 入门实战:Spring + Zookeeper + Dubbo

  • 2022 年 6 月 11 日
  • 本文字数:3053 字

    阅读完需:约 10 分钟

InfoQ 极客传媒 15 周年庆征文|Dubbo入门实战:Spring + Zookeeper + Dubbo

一、前言

了解Dubbo以后,自然要搭建一个简单的Demo实现。本文采用DubboZookeeperSpring框架的整合。


主要是以下几个步骤:


  1. 安装Zookeeper,启动;

  2. 创建MAVEN项目,构建Dubbo+Zookeeper+Spring实现的简单Demo

  3. 安装Dubbo-admin,实现 Dubbo 服务治理。

二、Zookeeper 介绍与安装

Demo中的Dubbo注册中心采用的是Zookeeper


为什么采用Zookeeper呢?


Zookeeper是一个分布式的服务框架,是树型目录服务的数据存储,能做到集群管理数据,这里能很好的作为Dubbo服务的注册中心。


Dubbo能与Zookeeper配合做到集群部署,当提供者出现断电等异常停机时,Zookeeper注册中心能自动删除提供者信息,当提供者重启时,能自动恢复注册数据,以及订阅请求


具体的安装方法在此不一一叙述,可参考博文: 《ZooKeeper进阶(一):Zookeeper简介》、《ZooKeeper进阶(二):ZooKeeper的运行》。


安装完成后,进入到bin目录,并且启动zkServer.cmd,脚本中会启动一个java进程。


注:需要先启动zookeeper后,后续dubbo demo代码运行才能使用zookeeper注册中心的功能。


三、创建 MAVEN 项目

项目结构:主要分三大模块:


  • dubbo-api : 存放公共接口;

  • dubbo-consumer : 调用远程服务;

  • dubbo-provider : 提供远程服务。


下面将详细叙述代码构建过程。


  1. 首先构建MAVEN项目,导入所需要的jar包依赖。 需要导入的有spring, dubbo, zookeeperjar包。

  2. 创建dubbo-apiMAVEN项目(有独立的pom.xml,用来打包供提供者、消费者使用)。在项目中定义服务接口:该接口需单独打包,在服务提供方和消费方共享。


package com.alibaba.dubbo.demo;import java.util.List;public interface DemoService {    List<String> getPermissions(Long id);}
复制代码


  1. 创建dubbo-providerMAVEN项目(有独立的pom.xml,用来打包供消费者使用)。实现公共接口,此实现对消费者隐藏:


package com.alibaba.dubbo.demo.impl;import com.alibaba.dubbo.demo.DemoService;import java.util.ArrayList;import java.util.List;public class DemoServiceImpl implements DemoService {    public List<String> getPermissions(Long id) {        List<String> demo = new ArrayList<String>();        demo.add(String.format("Permission_%d", id - 1));        demo.add(String.format("Permission_%d", id));        demo.add(String.format("Permission_%d", id + 1));        return demo;    }}
复制代码


需加入公共接口所在的依赖



Spring配置声明暴露服务:


<?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-admin或dubbo-monitor会显示这个名字,方便辨识-->    <dubbo:application name="demotest-provider" owner="programmer" organization="dubbox"/>    <!--使用 zookeeper 注册中心暴露服务,注意要先开启 zookeeper-->    <dubbo:registry address="zookeeper://localhost:2181"/>    <!-- 用dubbo协议在20880端口暴露服务 -->    <dubbo:protocol name="dubbo" port="20880" />    <!--使用 dubbo 协议实现定义好的 api.PermissionService 接口-->    <dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService" protocol="dubbo" />    <!--具体实现该接口的 bean-->    <bean id="demoService" class="com.alibaba.dubbo.demo.impl.DemoServiceImpl"/></beans>
复制代码


启动远程服务:


package com.alibaba.dubbo.demo.impl;import org.springframework.context.support.ClassPathXmlApplicationContext;import java.io.IOException;public class Provider {  public static void main(String[] args) throws IOException {     ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("provider.xml");     System.out.println(context.getDisplayName() + ": here");     context.start();     System.out.println("服务已经启动...");     System.in.read();  }}
复制代码


  1. 创建dubbo-consumerMAVEN项目(可以有多个consumer,但是需要配置好),调用所需要的远程服务:


通过Spring配置引用远程服务:


<?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="demotest-consumer" owner="programmer" organization="dubbox"/>    <!--向 zookeeper 订阅 provider 的地址,由 zookeeper 定时推送-->    <dubbo:registry address="zookeeper://localhost:2181"/>    <!--使用 dubbo 协议调用定义好的 api.PermissionService 接口-->    <dubbo:reference id="permissionService" interface="com.alibaba.dubbo.demo.DemoService"/></beans>
复制代码


启动Consumer,调用远程服务:


package com.alibaba.dubbo.consumer;import com.alibaba.dubbo.demo.DemoService;import org.springframework.context.support.ClassPathXmlApplicationContext;public class Consumer {    public static void main(String[] args) {        //测试常规服务        ClassPathXmlApplicationContext context =new ClassPathXmlApplicationContext("consumer.xml");        context.start();        System.out.println("consumer start");        DemoService demoService = context.getBean(DemoService.class);        System.out.println("consumer");        System.out.println(demoService.getPermissions(1L));    }}
复制代码


  1. 运行项目,先确保provider已被运行后再启动consumer模块:运行提供者:

  2. 消费者成功调用提供者所提供的远程服务:

  3. 当然,这只是一个模拟的项目,实际中有多提供者多消费者情况,比这要复杂的多,当然只有这样才能体现dubbo的特性。

四、Dubbo 管理控制台介绍

  • 管理控制台功能

  • 路由规则,动态配置,服务降级

  • 访问控制,权重调整

  • 负载均衡

  • 下载dubbo-admin,可自行根据网上介绍安装。大致做法就是将dubbo-admin中的某个文件夹内容替换到tomcatwebapps中,再运行tomcat即可。但我在实际操作中发现JDK8无法运行,后来找到一个JDK8可以实现的dubbo-admin版本,下载地址:点我下载


成功开启输入用户名、密码root后,即可进入控制台首页查看消费者提供者情况:查看服务提供者:



查看服务消费者:



很遗憾,官方Dubbo网址早已不维护了,也出现了很多更新的Dubbo,比如当当网的Dubbox,可以自行了解。

五、拓展阅读

Zookeeper 下载地址: 点我下载


Dubbo-admin 下载地址: 点我下载


Dubbo-monitor 下载地址: 点我下载

发布于: 刚刚阅读数: 5
用户头像

No Silver Bullet 2021.07.09 加入

岂曰无衣 与子同袍

评论

发布
暂无评论
InfoQ 极客传媒 15 周年庆征文|Dubbo入门实战:Spring + Zookeeper + Dubbo_zookeeper_No Silver Bullet_InfoQ写作社区