博客

【Dubbo】Dubbo整合Zookeeper

  • Post author:
  • Post category:其他



目录


一、什么是分布式


二、软件架构演进过程


1.1 单体架构


1.2 垂直架构


1.3 SOA架构


1.4 微服务架构


三、什么是RPC


四、Dubbo


4.1 基本概念


4.2 Dubbo环境搭建


4.2.1 Zookeeper


4.2.2 在windows环境中安装zookeeper


4.2.3 windows下面安装dubbo-admin


4.2.4 编写服务方和消费方


4.2.5 接口工程

一、什么是分布式

分布式系统是由一组通过网络进行通信、为了完成共同的任务而协调工作的计算机节点组成的系统。其目的是

利用更多的机器，处理更多的数据

。是建立在网络之上的系统

二、软件架构演进过程

1.1 单体架构


架构说明：

全部功能集中在一个项目内（All in one）。


架构优点：

架构简单，前期开发成本低、开发周期短，适合小型项目。


架构缺点：

全部功能集成在一个工程中，对于大型项目不易开发、扩展和维护。

技术栈受限，只能使用一种语言开发。

系统性能扩展只能通过扩展集群节点，成本高。

1.2 垂直架构


架构说明：

按照业务进行切割，形成小的单体项目。


架构优点：

技术栈可扩展（不同的系统可以用不同的编程语言编写）。


架构缺点：

功能集中在一个项目中，不利于开发、扩展、维护。

系统扩张只能通过集群的方式。

项目之间功能冗余、数据冗余、耦合性强。各项目之间可能产生相同的功能

1.3 SOA架构

SOA全称为Service-Oriented Architecture，即面向服务的架构。它可以根据需求通过网络对松散耦合的粗粒度应用组件(服务)进行分布式部署、组合和使用。一个服务通常以独立的形式存在于操作系统进程中。

站在功能的角度，把业务逻辑抽象成可复用的服务，通过服务的编排实现业务的快速再生

目的：把原先固有的业务功能转变为通用的业务服务，实现业务逻辑的快速复用。


架构说明：

将重复功能或模块抽取成组件的形式，对外提供服务，在项目与服务之间使用ESB（企业服务总线）的形式作为通信的桥梁。

这里的ESB理解为注册中心


架构优点：

重复功能或模块抽取为服务，提高开发效率。

可重用性高。

可维护性高。


架构缺点：

各系统之间业务不同，很难确认功能或模块是重复的。

抽取服务的粒度大。

系统和服务之间耦合度高。

1.4 微服务架构


架构说明：

将系统服务层完全独立出来，抽取为一个一个的微服务。

抽取的粒度更细，遵循单一原则。

采用轻量级框架协议传输。


架构优点：

服务拆分粒度更细，有利于提高开发效率。

可以针对不同服务制定对应的优化方案。

适用于互联网时代，产品迭代周期更短。


架构缺点：

粒度太细导致服务太多，维护成本高。

分布式系统开发的技术成本高，对团队的挑战大。

三、什么是RPC


什么是RPC？

RPC全称为remote procedure call，即

远程过程调用，

是一种进程间通信方式。比如两台服务器A和B，A服务器上部署一个应用，B服务器上部署一个应用，A服务器上的应用想调用B服务器上的应用提供的方法，由于两个应用不在一个内存空间，不能直接调用，所以需要通过网络来表达调用的语义和传达调用的数据。

需要注意的是RPC并不是一个具体的技术，而是指整个网络远程调用过程，是一种思想。

RPC是一个泛化的概念，严格来说一切远程过程调用手段都属于RPC范畴。各种开发语言都有自己的RPC框架。Java中的RPC框架比较多，广泛使用的有RMI、Hessian、Dubbo等。

四、Dubbo

4.1 基本概念

一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。

节点 角色名称
Provider 暴露服务的服务提供方，在服务中心进行注册
Consumer 调用远程服务的服务消费方，订阅服务注册中心的服务
Registry 服务注册与发现的注册中心
Monitor 统计服务的调用次数和调用时间的监控中心
Container 服务运行容器

4.2 Dubbo环境搭建

4.2.1 Zookeeper

Zookeeper 是 Apache Hadoop 的子项目，是一个树型的目录服务，支持变更推送，适合作为 Dubbo 服务的注册中心

zookeeper的目录结构：

流程说明：

  • 服务提供者(Provider)启动时: 向

    /dubbo/com.foo.BarService/providers

    目录下写入自己的 URL 地址

  • 服务消费者(Consumer)启动时: 订阅

    /dubbo/com.foo.BarService/providers

    目录下的提供者 URL 地址。并向

    /dubbo/com.foo.BarService/consumers

    目录下写入自己的 URL 地址

  • 监控中心(Monitor)启动时: 订阅

    /dubbo/com.foo.BarService

    目录下的所有提供者和消费者 URL 地址

4.2.2 在windows环境中安装zookeeper

1. 下载地址：

Index of /dist/zookeeper

2.  将conf文件夹下面的zoo_sample.cfg复制一份改名为zoo.cfg。

3. 在zookeeper目录下创建：

修改zoo.fcg文件 

dataDir=../data
dataLogDir=../log

clientPort=2181   zookeeper的端口号

4.启动bin目录下：zkServer.cmd ， zkClient

启动成功后，Client窗口会显示：

可能遇到问题：闪退

解决方案：编辑zkServer.cmd文件末尾添加pause 。这样运行出错就不会退出，会提示错误信息，方便找到原因。

4.2.3 windows下面安装






dubbo-admin






dubbo本身并不是一个服务软件。它其实就是一个jar包，能够帮你的java程序连接到zookeeper，并利用zookeeper消费、提供服务。

开发时，需要

监视

Zookeeper注册中心都注册了哪些服务，有哪些消费者来消费这些服务。我们可以通过部署一个管理中心来实现，

官方提供了一个可视化的监控程序dubbo-admin

。其实管理中心就是一个web应用，部署到tomcat即可。


详细安装可以看这个连接：


新版本 Dubbo-admin 安装_Future_LL的博客-CSDN博客_dubboadmin安装

(1) 将dubbo-admin-2.6.0.war文件复制到tomcat的webapps目录下

（2）启动tomcat，此war文件会自动解压

（3）修改WEB-INF下的dubbo.properties文件，注意dubbo.registry.address对应的值需要对应当前使用的

Zookeeper的ip地址和端口号

dubbo.registry.address=zookeeper://127.0.0.1:2181 dubbo.admin.root.password=root dubbo.admin.guest.password=guest

（4）重启tomcat

(5) 访问

http://localhost:8080/dubbo-admin-2.6.0/

，输入用户名(root)和密码(root)

4.2.4 编写服务方和消费方

1. 服务提供者

导入依赖： 

<dependencies>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-webmvc</artifactId>
      <version>${spring.version}</version>
    </dependency>

    <!-- dubbo相关 -->
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.6.0</version>
    </dependency>
    <dependency>
      <groupId>org.apache.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>3.4.7</version>
    </dependency>
    <dependency>
      <groupId>com.github.sgroschupf</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.1</version>
    </dependency>
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>fastjson</artifactId>
      <version>1.2.47</version>
    </dependency>
  </dependencies>
  <build>
    <plugins>
      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-compiler-plugin</artifactId>
        <version>2.3.2</version>
        <configuration>
          <source>1.8</source>
          <target>1.8</target>
        </configuration>
      </plugin>
      <plugin>
        <groupId>org.apache.tomcat.maven</groupId>
        <artifactId>tomcat7-maven-plugin</artifactId>
        <configuration>
          <!-- 指定端口 -->
          <port>8082</port>
          <!-- 请求路径 -->
          <path>/</path>
        </configuration>
      </plugin>
    </plugins>
  </build>

插件部分使用了内置的tomcat， 可以忽略，自己配置

service接口： 

public interface HelloService {
    String sayHello(String name);
}

service实现类： 

import com.alibaba.dubbo.config.annotation.Service;
import com.righteye.service.HelloService;

@Service
public class HelloServiceImpl implements HelloService {
    public String sayHello(String name) {
        return "hello " + name;
    }
}

这里的@Service是dubbo提供的，添加这个注解表示这个服务被暴露出去

web.xml配置 

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"
         version="4.0">
    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>classpath:applicationContext*.xml</param-value>
    </context-param>
    <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>
</web-app>

applicationContext_provider.xml (dubbo配置文件) 

<!-- 当前应用名称，用于注册中心计算应用间依赖关系，注意：消费者和提供者应用名不要一样 -->
    <dubbo:application name="dubbodemo_provider" />
    <!-- 连接服务注册中心zookeeper ip为zookeeper所在服务器的ip地址-->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    <!-- 注册  协议和port   端口默认是20880 -->
    <dubbo:protocol name="dubbo" port="20880"></dubbo:protocol>
    <!-- 扫描指定包，加入@Service注解的类会被发布为服务  -->
    <dubbo:annotation package="com.righteye.service.impl" />

启动内置tomcat, tomacat run

观察dubbo-admin:



这里一定要启动zookeeper的服务端，以及dubbo-admin ！！！！


, 昨天试了一晚上，zookeeper的服务端我没启动，查看不到服务，然后provider也不知道为啥访问不了，想砸电脑的心都有，反正就特sb, 低谷了 （QAQ）

如果各位大大有其他这个问题真正错误的原因，希望多多指正，孩子真的快哭了

2.服务消费者

导入依赖和提供者相同，如果使用内置tomcat，改下端口号

由于没有使用接口工程，所以在消费者中也创建了和提供者目录结构相同的service接口

controller层： 

package com.righteye.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.righteye.service.HelloService;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@Controller
public class UserController {
    @Reference
    private HelloService helloServiceImpl;

    @RequestMapping("/test")
    @ResponseBody
    public String getName(String name){
        System.out.println(name);
        //远程调用
        String result = helloServiceImpl.sayHello(name);
        System.out.println(result);
        return result;
    }
}

@Reference 是dubbo中的注解，注入的功能

web.xml配置 

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"
         version="4.0">
    <servlet>
        <servlet-name>springmvc</servlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
        <!-- 指定加载的配置文件 ，通过参数contextConfigLocation加载 -->
        <init-param>
            <param-name>contextConfigLocation</param-name>
            <param-value>classpath:applicationContext-web.xml</param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
    </servlet>
    <servlet-mapping>
        <servlet-name>springmvc</servlet-name>
        <url-pattern>/</url-pattern>
    </servlet-mapping>
</web-app>

applicationContext-web.xml（dubbo配置文件） 

<!-- 当前应用名称，用于注册中心计算应用间依赖关系，注意：消费者和提供者应用名不要一样 -->
    <dubbo:application name="dubbo_consumer" />
    <!-- 连接服务注册中心zookeeper ip为zookeeper所在服务器的ip地址-->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    <!-- 扫描的方式暴露接口  -->
    <dubbo:annotation package="com.righteye.controller" />

这里的dubbo:annotation加入后似乎自动就扫描了@Controller, 不需要加入组件扫描器；之前报错以为是Controller没有容器管理，目前删了也可以正常访问

启动消费者的tomcat


不争气的眼泪似乎要流落下来。。。。因为没启动弄了好长时间


4.2.5 接口工程



上面的消费者中引入了service，但是这只为了不让程序报错；当服务增多的时候，service接口在消费者和提供者中就很冗余；所以可以使用接口工程，将service接口单独抽离出来

将接口工程打包，在消费者和提供者中导入依赖： 

 <!--接口工程-->
    <dependency>
      <groupId>com.righteye</groupId>
      <artifactId>ch04_zk_interface</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>


版权声明：本文为qq_45888932原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。