Dubbo入门 Demo:Spring + Zookeeper + Dubbo

举报
SHQ5785 发表于 2024/05/27 09:36:27 2024/05/27
【摘要】 了解Dubbo以后,自然要搭建一个简单的Demo实现。本文采用Dubbo与Zookeeper、Spring框架的整合。主要是以下几个步骤:安装Zookeeper,启动;创建MAVEN项目,构建Dubbo+Zookeeper+Spring实现的简单Demo;安装Dubbo-admin,实现Dubbo服务治理。 Zookeeper介绍与安装Demo中的Dubbo注册中心采用的是Zookeeper...

了解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注册中心的功能。

2. 创建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模块:
    运行提供者
    消费者成功调用提供者所提供的远程服务
    当然,这只是一个模拟的项目,实际中有多提供者多消费者情况,比这要复杂的多,当然只有这样才能体现dubbo的特性。

Dubbo管理控制台介绍

  • 管理控制台功能
  • 路由规则,动态配置,服务降级
  • 访问控制,权重调整
  • 负载均衡

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

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

查看服务消费者:

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

Zookeeper 下载地址: 点我下载

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

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

【版权声明】本文为华为云社区用户原创内容,未经允许不得转载,如需转载请自行联系原作者进行授权。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。