dubbo的简单实现-白红宇

dubbo的简单实现

阅读量：5119 次

发布时间：2019-06-13

本文共 4040 字，大约阅读时间需要 13 分钟。

一是什么

一般网站架构随着业务的发展，逻辑越来越复杂，数据量越来越大，交互越来越多,dubbo使前后端分离，完成负载均衡。

dubbo架构图

节点角色说明：

Provider: 暴露服务的服务提供方。

Consumer: 调用远程服务的服务消费方。

Registry: 服务注册与发现的注册中心。

Monitor: 统计服务的调用次调和调用时间的监控中心。

Container: 服务运行容器。

调用关系说明：

0. 服务容器负责启动，加载，运行服务提供者。

1. 服务提供者在启动时，向注册中心注册自己提供的服务。

2. 服务消费者在启动时，向注册中心订阅自己所需的服务。

3. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。

4. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

5. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

二怎么做

本案例共有三个工程和一个zookeeper 服务器工程将接口注册在zookeeper中提供服务客户端工程消费zookeeper中注册的接口服务

1、下载安装zookeeper

　　在安装目录下的bin中启动 zkServer

　　在zookkeeper中的conf/zoo.cfg中可以看到端口号和一些基本配置

2、接口工程

public interface IUserInfo {    String queryUserInfo();}

在这里我使用maven管理项目打包到本地

3、服务端工程

这里我建的是普通java工程主要是dao层和service层

　 (1)下载相关jar包

使用maven pom文件为


             
                  
       
        cn.com.study-dubbo-api
                   
       
        dubbo-api
                   
       
        1.0-SNAPSHOT
               
              
                  
       
        org.springframework
                   
       
        spring-context
                   
       
        4.2.4.RELEASE
               
              
                  
       
        com.alibaba
                   
       
        dubbo
                   
       
        2.5.3
               
              
                  
       
        com.101tec
                   
       
        zkclient
                   
       
        0.7

　　第一段dependency是我打包到本地的api工程的坐标

　　但是这个pom有问题之后会描述到

　　（2）需要提供的服务

@Service("iUserInfo")public class IUserInfoImpl implements IUserInfo {    @Override    public String queryUserInfo() {        return "aaa";    }}

　　(3)配置文件（我是把dubbo配置在spring配置文件中的）

　　（4）启动服务器工程，通过读取配置文件,并通过CountDownLatch使程序阻塞

public class Test {    public static void main(String[] args) throws InterruptedException {        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring-config.xml");        new CountDownLatch(1).await();    }}

　　至此服务端结束，并且在zookeeper中可以看到相关信息

4客户端工程

　　这里我建的是web工程，controller层和显示界面

　　（1）pom.xml

之前提到上面那个pom文件有点问题，主要是用maven下载dubbo包的时候会把加进来导致和自己下载的spring包冲突报异常java.lang.NoSuchMethodError: org.springframework.util.ClassUtils.getMethod。所以要在pom中dubbo包下排除这个包


             
                  
       
        cn.com.study-dubbo-api
                   
       
        dubbo-api
                   
       
        1.0-SNAPSHOT
               
              
                  
       
        org.springframework
                   
       
        spring-context
                   
       
        4.2.4.RELEASE
               
              
                  
       
        org.springframework
                   
       
        spring-webmvc
                   
       
        4.2.4.RELEASE
               
              
                  
       
        com.alibaba
                   
       
        dubbo
                   
       
        2.5.3
                   
                       
                            
         
          org.springframework
                             
         
          spring
                         
                    
               
              
                  
       
        com.101tec
                   
       
        zkclient
                   
       
        0.7

　　（2）dubbo消费的配置文件（配置在sping的配置文件中，记得在web.xml中读取这个配置文件和spring mvc的配置文件）

　　（3）我是通过spring mvc页面请求测试的，所以同时配置spring mvc配置文件

　　（4）写请求拦截的controller

@Controllerpublic class TestController {    @Autowired    IUserInfo iUserInfo;    @RequestMapping("/test")    @ResponseBody    public void show(){        System.out.println(iUserInfo.queryUserInfo());    }}

启动tomcat，这个时候可能会提示端口被占用，百度上说是zookeeper启动会占用8080端口，把tomcat启动端口改了，然后启动。

至此dubbo简单案例已经搭建完成。

测试一下，输入请求url