互联网级微服务架构神器Duubo

时间  2019-12-13
标签 互联网 微服 架构 神器 duubo 栏目 系统架构 繁體版
原文   原文链接

目录前端

互联网级微服务架构神器Duubo

Editor：SimpleWu

Dubbo是 阿里巴巴公司开源的一个高性能优秀的服务框架使得应用可经过高性能的 RPC 实现服务的输出和输入功能，能够和 Spring框架无缝集成。java

背景

随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已没法应对，分布式服务架构以及流动计算架构势在必行，亟需一个治理系统确保架构有条不紊的演进。git

单一应用架构

当网站流量很小时，只需一个应用，将全部功能都部署在一块儿，以减小部署节点和成本。此时，用于简化增删改查工做量的数据访问框架(ORM)是关键。github

垂直应用架构

当访问量逐渐增大，单一应用增长机器带来的加速度愈来愈小，将应用拆成互不相干的几个应用，以提高效率。此时，用于加速前端页面开发的Web框架(MVC)是关键。spring

分布式服务架构

当垂直应用愈来愈多，应用之间交互不可避免，将核心业务抽取出来，做为独立的服务，逐渐造成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。此时，用于提升业务复用及整合的分布式服务框架(RPC)是关键。apache

流动计算架构

当服务愈来愈多，容量的评估，小服务资源的浪费等问题逐渐显现，此时需增长一个调度中心基于访问压力实时管理集群容量，提升集群利用率。此时，用于提升机器利用率的资源调度和治理中心(SOA)是关键。json

zookeeper安装

官方网站api

http://zookeeper.apache.org/架构

下载地址app

http://mirrors.hust.edu.cn/apache/zookeeper/

下载好咱们解压出来直接启动bin目录下zkServer.bat是不行的，咱们暂时将zoo_sample.cfg改为zoo.cfg而后就能够正常启动了，启动后咱们能够看到默认的端口2181到时候咱们的Dubbo就调用这个端口

发布Dubbo服务

Dubbo下载地址

https://github.com/apache/incubator-dubbo

下载后咱们参照里面的Demo先来搞一个provider。（dubbo-provider）

1.打开eclipse新建一个maven工程（先配置个阿里云镜像，不然本地没有超级慢）
<!--  配置阿里云  -->
<mirror>
    <id>nexus-aliyun</id>
    <mirrorOf>*</mirrorOf>
    <name>Nexus aliyun</name>
    <url>http://maven.aliyun.com/nexus/content/groups/public</url>
 </mirror>
2.POM.XML中添加依赖
<dependencies>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>dubbo</artifactId>
        <version>2.6.0</version>
    </dependency>
    <dependency>
        <groupId>com.101tec</groupId>
        <artifactId>zkclient</artifactId>
        <version>0.10</version>
    </dependency>
    <dependency>
        <groupId>org.apache.curator</groupId>
        <artifactId>curator-framework</artifactId>
        <version>4.0.1</version>
    </dependency>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>fastjson</artifactId>
        <version>1.2.46</version>
    </dependency>
    <dependency>
        <groupId>log4j</groupId>
        <artifactId>log4j</artifactId>
        <version>1.2.17</version>
    </dependency>
    <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-api</artifactId>
        <version>1.7.25</version>
    </dependency>
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-lang3</artifactId>
        <version>3.4</version>
    </dependency>
    <dependency>
        <groupId>io.netty</groupId>
        <artifactId>netty-all</artifactId>
        <version>4.0.35.Final</version>
    </dependency>
</dependencies>

3.添加服务接口，实现服务

package com.miya.dubbo.service;
/**
 * 服务提供者接口
 * @author SimpleWu
 *
 */
public interface MyProviderService {
    public String sayHello(String name);
}

实现接口

package com.miya.dubbo.service.impl;
import com.miya.dubbo.service.MyProviderService;
/**
 * 服务提供者接口实现类
 * @author SimpleWu
 *
 */
public class MyProviderServiceImpl implements MyProviderService {

    @Override
    public String sayHello(String name) {
        return "服务1 ： MyProviderServiceImpl 。。 sayHello ";
    }
}

4.在resources资源文件夹中添加dubbo-provider.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
       http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <!-- 提供方应用名称，用于计算依赖关系 -->
    <dubbo:application name="demo-provider" />
    
    <!-- 使用zookeeper注册中心暴露服务地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    
    <!-- 使用dubbo协议，在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880"/>
    
    <!-- service实现类做为本地的一个bean -->
    <bean id="myProviderService" class="com.miya.dubbo.service.impl.MyProviderServiceImpl"/>
    
    <!-- 声明须要暴露的服务接口 -->
    <dubbo:service interface="com.miya.dubbo.service.MyProviderService" ref="myProviderService"/>
</beans>
5.建立测试类发布服务

发布服务以前须要先启动zookeeper，启动后图示：

建立测试类发布服务

public static void main(String[] args){
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
                new String[] { "dubbo-provider.xml" });
        context.start();
        System.out.println("服务提供者向zookeeper中心注册服务成功 暴露的端口为：20880");
        try {
            System.in.read();
        } catch (IOException e) {
            e.printStackTrace();
        }
}

发布后图示：

若是看到咱们的服务接口后就说明服务发布成功！

Dubbo Admin管理

1.首先在Dubbo目录里面找到dubbo-admin将他打成WAR包不能带项目路径

咱们须要将WAR包发布到Tomcat里面最好独立运行，咱们将Tomcat wepapps下的ROOT所有删掉将WAR包解压到里面，而后启动Tomcat（必须先开启咱们的zookeeper），咱们直接访问localhost:8080会弹出：

默认的帐号root密码root登录

咱们能够看到这个页面

咱们能够在这里管理咱们的服务

目前咱们点击服务是没有查询到服务的，咱们将咱们以前的那个服务运行发布上去能够看到

咱们能够点击服务名进去管理咱们的服务

在这里能够对应的去操做咱们的服务，注意咱们的服务就是在20880端口暴露的，这里咱们的服务也是20880说明咱们的服务成功发布。

消费Dubbo服务

建立一个maven项目(dubbo-consumer)开启消费者：

1.POM.XML导入依赖
<dependencies>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.6.0</version>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.10</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>4.0.1</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.46</version>
        </dependency>
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.17</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>1.7.25</version>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
            <version>3.4</version>
        </dependency>
        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-all</artifactId>
            <version>4.0.35.Final</version>
        </dependency>
</dependencies>
2.建立消费者接口
package com.miya.dubbo.service;
/**
 * 服务提供者接口
 * @author SimpleWu
 *
 */
public interface MyProviderService {
    public String sayHello(String name);
}
3.在resources下建立消费者配置文件(dubbo-consumer.xml)
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
       http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <!-- 消费方应用名称，用于计算依赖关系，不是匹配条件，不要与提供方名称同样  -->
    <dubbo:application name="demo-consumer"/>

    <!-- 使用zookeeper注册中心暴露服务地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>

    <!-- 生成远程服务代理，能够与本地bean同样使用  check属性，启动时候是否检查 通常设置成false 启动时候不检查 -->
    <dubbo:reference id="myProviderService" check="false" interface="com.miya.dubbo.service.MyProviderService"/>

</beans>
4.建立消费者测试类
package com.miya.dubbo.test;

import java.io.IOException;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.miya.dubbo.service.MyProviderService;

public class ConsumerTest {
    public static void main(String[] args) {
        //读取消费者配置文件
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"dubbo-consumer.xml"});
        context.start();
        //获取消费实例
        MyProviderService demoProviderService=(MyProviderService) context.getBean("myProviderService");
        String result=demoProviderService.sayHello("Miya");
        System.out.println("远程调用的结果："+result);
        try {
            System.in.read();
        } catch (IOException e) {
            e.printStackTrace();
        }
        context.close();
    }
}
5.开始消费

打开zookeeper-->Tomcat发布Dubbo Admin管理中心-->启动消费者测试程序

咱们能够看到消费者已经有了，图示：

抽取与依赖版本管理

抽取

在前面两个项目中咱们会发现两个项目中有两个相同的接口（MyProviderServiceImpl.java），这样是很差的，咱们如今参照官方demo来建立一个maven工程（dubbo-api）

咱们将接口咱们将这个接口放到api这个项目中去，而后将dubbo-consumer,dubbo-provider这两个工程中的接口删掉，这个时候咱们这两个项目会报错由于找不到这个接口，咱们能够将这两个项目添加依赖：

<dependency>
    <groupId>com.miya</groupId>
    <artifactId>dubbo-api</artifactId>
</dependency>

咱们只要依赖dubbo-api就能够获取到了吗？

依赖版本统一管理

咱们在dubbo-consumer,dubbo-provider这两个工程中会发现POM.xml中的版本号，若是咱们须要修改版本要一个一个去修改有两个工程不是要改两次？那夸张以点，一万不是得改半条命？

这个时候咱们仍是建立一个maven工程（dubbo-parent），这个工程Packaging咱们选择POM，这个项目负责版本统一。首先咱们抽取相同的依赖，而后给他们定义统一的版本管理方式。

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.miya</groupId>
    <artifactId>dubbo-parent</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>pom</packaging>
    <!-- 依赖版本管理 -->
    <properties>
        <dubbo-api.version>0.0.1-SNAPSHOT</dubbo-api.version>
        <dubbo.version>2.6.0</dubbo.version>
        <zkclient.version>0.10</zkclient.version>
        <curator-framework.version>4.0.1</curator-framework.version>
        <fastjson.version>1.2.46</fastjson.version>
        <log4j.version>1.2.17</log4j.version>
        <slf4j-api.version>1.7.25</slf4j-api.version>
        <commons-lang3.version>3.4</commons-lang3.version>
        <netty-all.version>4.0.35.Final</netty-all.version>
    </properties>

    <!--依赖管理 -->
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>com.miya</groupId>
                <artifactId>dubbo-api</artifactId>
                <version>${dubbo-api.version}</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>${dubbo.version}</version>
            </dependency>
            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>${zkclient.version}</version>
            </dependency>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>${curator-framework.version}</version>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>fastjson</artifactId>
                <version>${fastjson.version}</version>
            </dependency>
            <dependency>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
                <version>${log4j.version}</version>
            </dependency>
            <dependency>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-api</artifactId>
                <version>${slf4j-api.version}</version>
            </dependency>
            <dependency>
                <groupId>org.apache.commons</groupId>
                <artifactId>commons-lang3</artifactId>
                <version>${commons-lang3.version}</version>
            </dependency>
            <dependency>
                <groupId>io.netty</groupId>
                <artifactId>netty-all</artifactId>
                <version>${netty-all.version}</version>
            </dependency>
        </dependencies>
    </dependencyManagement>
</project>
相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程