Dubbo--学习demo

爱被打了一巴掌 2022-05-14 02:04 206阅读 0赞

## 题外话： ##

紧接着上篇博文[https://blog.csdn.net/qq\_33371766/article/details/82253987][https_blog.csdn.net_qq_33371766_article_details_82253987] 实现该demo。

保持zookeeper启动和Tomcat启动

![70][]

## 二.实现dubbo的demo ##

我这边是使用springboot创建的多模块项目。（多模块的实现跨越参考我的另外一篇博文：[https://blog.csdn.net/qq\_33371766/article/details/80716837][https_blog.csdn.net_qq_33371766_article_details_80716837]）

目录结构：

![70 1][]

项目中的application这个模块是springboot的启动类，这里的demo暂时用不到，可以忽略。

dubbo-consumer:调用远程服务.

dubbo-consumer2:也是调用远程服务.

dubbo-interface:存放公共接口.

dubbo-provider:提供远程服务.

我自己的理解是：

1.dubbo-interface编写接口类，提供需要实现的方法接口。

2.dubbo-provider现实上面的接口，编写具体的业务代码，并且将服务暴露出来（启动起来）。

3.dubbo-consumer直接使用上面的接口提供的方法，得到自己想要的最终结果。

4.dubbo-consumer2也是调用远程服务，同步骤3，只是为了体现多消费者调用接口。

代码的实现。

1.my-dubbo的pom文件：

<?xml version="1.0" encoding="UTF-8"?>
    <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.cxb</groupId>
       <artifactId>my-dubbo</artifactId>
       <version>0.0.1-SNAPSHOT</version>
       <modules>
          <module>dubbo-provider</module>
          <module>dubbo-consumer</module>
          <module>dubbo-consumer2</module>
          <module>application</module>
          <module>dubbo-interface</module>
       </modules>
       <packaging>pom</packaging>
    
       <name>my-dubbo</name>
       <description>Demo project for Spring Boot</description>
    
       <parent>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-parent</artifactId>
          <version>2.0.2.RELEASE</version>
          <relativePath/> 
       </parent>
    
       <properties>
          <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
          <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
          <java.version>1.8</java.version>
       </properties>
    
       <dependencies>
          <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-data-jpa</artifactId>
          </dependency>
          <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-jdbc</artifactId>
          </dependency>
          <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
          </dependency>
          <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter</artifactId>
          </dependency>
    
          <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
          </dependency>
          
          <dependency>
             <groupId>com.github.pagehelper</groupId>
             <artifactId>pagehelper-spring-boot-starter</artifactId>
             <version>1.2.3</version>
          </dependency>
          <dependency>
             <groupId>org.mybatis.spring.boot</groupId>
             <artifactId>mybatis-spring-boot-starter</artifactId>
             <version>1.3.2</version>
          </dependency>
          
          <dependency>
             <groupId>mysql</groupId>
             <artifactId>mysql-connector-java</artifactId>
          </dependency>
          
          <dependency>
             <groupId>com.alibaba</groupId>
             <artifactId>dubbo</artifactId>
             <version>2.5.6</version>
          </dependency>
          <dependency>
             <groupId>org.apache.zookeeper</groupId>
             <artifactId>zookeeper</artifactId>
             <version>3.4.12</version>
          </dependency>
          <dependency>
             <groupId>com.101tec</groupId>
             <artifactId>zkclient</artifactId>
             <version>0.10</version>
          </dependency>
       </dependencies>
    
    </project>

2.dubbo-interface的pom文件：

3.编写公共接口：

package com.cxb.mydubbo;
    
    import java.util.List;
    
    /**
     * Created by 81046 on 2018-08-31
     */
    public interface DubboService {
        List<String> getPermissions(Long id);
    }

4.dubbo-provider的pom文件：

5.接口的具体实现类DubboServiceImpl：

package com.cxb.mydubbo;
    
    import java.util.ArrayList;
    import java.util.List;
    
    /**
     * Created by 81046 on 2018-08-31
     */
    public class DubboServiceImpl  implements DubboService{
    
        //这里只是模拟数据，根据自己的实际业务编写
        @Override
        public List<String> getPermissions(Long id) {
            List<String> demo = new ArrayList<>();
            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;
        }
    }

6.1 提供服务Provider：

package com.cxb.mydubbo;
    
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import java.io.IOException;
    
    /**
     * Created by 81046 on 2018-08-31
     */
    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();
        }
    }

6.2 这里还需要provider.xml。在xml文件中指定zookeeper和接口信息。

<?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-provider" owner="programmer" organization="dubbox"/>
        
        <dubbo:registry address="zookeeper://localhost:2181"/>
        
        <dubbo:protocol name="dubbo" port="20880" />
        
        <dubbo:service interface="com.cxb.mydubbo.DubboService" ref="demoService" protocol="dubbo" />
        
        <bean id="demoService" class="com.cxb.mydubbo.DubboServiceImpl"/>
    </beans>

7.1 消费者Consumer去使用上面提供的服务Consumer：

package com.cxb.mydubbo;
    
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    /**
     * Created by 81046 on 2018-08-31
     */
    public class Consumer {
        public static void main(String[] args) {
            //测试常规服务
            ClassPathXmlApplicationContext context =
                    new ClassPathXmlApplicationContext("consumer.xml");
            context.start();
            System.out.println("consumer start");
            DubboService demoService = context.getBean(DubboService.class);
            System.out.println("consumer");
            System.out.println(demoService.getPermissions(1L));
        }
    }

7.2 这里也需要consumer.xml，这里是需要指定链接的zookeeper地址和服务地址

测试：1.先运行6.1的Provider的main方法，启动服务。

2.再运行7.1的main方法，消费者使用上面提供的服务。

### **Dubbo管理控制台介绍** ###

管理控制台功能:

> 路由规则，动态配置，服务降级   
>    访问控制，权重调整   
>    负载均衡

![format_png][]

![70 2][]

这里是Tomcat启动的页面，这里可以查看提供的公共的接口。

消费者调用的结果：

![70 3][]

自此一个简单的dubbo的demo就实现了。

[https_blog.csdn.net_qq_33371766_article_details_82253987]: https://blog.csdn.net/qq_33371766/article/details/82253987
[70]: /images/20220514/aadc001018794426b7260e899d2340d7.png
[https_blog.csdn.net_qq_33371766_article_details_80716837]: https://blog.csdn.net/qq_33371766/article/details/80716837
[70 1]: /images/20220514/1fcb0a5c6672443ea1374dfc60249c12.png
[format_png]: /images/20220514/a8b0b1dc4390435d9b81a92263a3cc92.png
[70 2]: /images/20220514/9b2c4beb5de942acb3104560ff67aa47.png
[70 3]: /images/20220514/c64d0145f35847759fd3859218f35a87.png