Maven+SpringMVC+Dubbo 简单的入门demo配置

之前一直听说dubbo,是一个很厉害的分布式服务框架,而且巴巴将其开源,这对于咱们广大程序猿来说,真是一个好消息。最近有时间了,打算做一个demo把dubbo在本地跑起来先。

先copy一段dubbo的介绍哈!DUBBO是一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,是阿里巴巴SOA服务化治理方案的核心框架,每天为2,000+个服务提供3,000,000,000+次访问量支持,并被广泛应用于阿里巴巴集团的各成员站点(其他的详细介绍可以查看dubbo的官网地址dubbo,写的很详细哒!)。

该demo是基于maven搭建的,项目架构基于SpringMVC,这里忽略spring的基本配置,着重介绍下dubbo部分的配置,以及dubbo后台管理系统

一、软件环境
1、zookeeper
下载地址:https://zookeeper.apache.org/releases.html 下载最新版的zookeeper,我这里使用的版本是 zookeeper-3.4.8(当前最新版3.5.1)
2、springMVC (maven方式引入)
3、dubbo (maven方式引入)

二、项目搭建
这里我搭建了三个项目,分别为dubbo-api,dubbo-controller,dubbo-service
dubbo-api:主要是接口定义,供controller调用,以及service层去实现该接口,分离这一层的好处就是前段项目调用接口时候,直接调用dubbo-api的接口即可,不需要关注后端如何实现;而service层来具体实现该接口,进行业务逻辑处理,不需要关注 controller层如何调用。
dubbo-controller:主要controller层控制跳转等。
dubbo-service:主要是service实现,结合数据层实现后端业务逻辑处理。

项目搭建完成之后,的结构图如下:

三、项目配置
1、dubbo-api
新建TestService接口类

package com.dubbo.service;

public interface TestService {

    /**
     * 测试发消息
     * @param name
     * @return
     */
    public String sayHello(String name);

}

pom.xml配置

  4.0.0

  com.dubbo
  dubbo-api
  0.0.1-SNAPSHOT
  jar

  dubbo-api
  http://maven.apache.org

  
    UTF-8
  

  
    
      junit
      junit
      3.8.1
      test
    
  

注意: 这个项目最终打包成jar文件,直接maven引入到另外两个项目中

2、dubbo-controller
新建MyController类

package com.dubbo.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import com.dubbo.service.TestService;

/**
 * controller
 * @author hwy
 *
 */
@Controller
public class MyController {

    @Autowired
    private TestService testService;

    @RequestMapping(value = "/test")
    @ResponseBody
    public String testSay(@RequestParam(value = "name",defaultValue = "") String name){
        StringBuffer sb = new StringBuffer();
        sb.append("Dubbo: ").append(testService.sayHello(name));
        return sb.toString();
    }

}

新建dubbo-config.xml

    
    

    
    

    
    

注意:这里作为消费者名称为test_consumer,注释很详细,就不一一介绍了,这个项目最终打包成dubbo-service.war放在tomcat或其他容器中运行。

pom.xml配置

  4.0.0

  com.dubbo
  dubbo-controller
  0.0.1-SNAPSHOT
  war

  dubbo-contoller
  http://maven.apache.org

  
    UTF-8
 3.1.4.RELEASE
  

  
    
        junit
        junit
        3.8.1
        test
    
    
        javax.servlet
            javax.servlet-api
            3.1.0
        

        
            org.springframework
            spring-context
            ${org.springframework.version}
        
        
            org.springframework
            spring-context-support
            ${org.springframework.version}
        
        
            org.springframework
            spring-web
            ${org.springframework.version}
        
        
            org.springframework
            spring-webmvc
            ${org.springframework.version}
        

        
            org.codehaus.jackson
            jackson-core-asl
            1.9.12
        
        
            org.codehaus.jackson
            jackson-mapper-asl
            1.9.12
        
        
            net.sf.json-lib
            json-lib
            2.4
            jdk15
        

        
            com.alibaba
            dubbo
            2.5.3
            
                
                    spring
                    org.springframework
                
            
        
        
            org.apache.zookeeper
            zookeeper
            3.3.6
            
                
                    log4j
                    log4j
                
            
        
        
            log4j
            log4j
            1.2.16
        
        
          com.github.sgroschupf
          zkclient
          0.1
        

        
            com.dubbo
            dubbo-api
            0.0.1-SNAPSHOT
        
    
    
        dubbo-controller
    

3、dubbo-service
新建TestServiceImpl类

package com.dubbo.service.impl;

import com.dubbo.service.TestService;

/**
 * service impl
 * @author hwy
 *
 */
public class TestServiceImpl implements TestService{

    public String sayHello(String name) {
        return name + " service2 say hello word service2!";
    }

}

新建applicationContext.xml

    
    

    
    

    
    

    
    

    
    

注意:这里作为服务提供者名称为test_provider,注释很详细,就不一一介绍了,这个项目最终打包成dubbo-service.war放在tomcat或其他容器中运行,跟其他直接通过ClassPathXmlApplicationContext 启动方式稍微有点区别。

pom.xml配置

  4.0.0
  com.dubbo
  dubbo-service
  war
  0.0.1-SNAPSHOT
  dubbo-service Maven Webapp
  http://maven.apache.org

  
        UTF-8
         3.1.4.RELEASE
  

  
    
      com.alibaba
      dubbo
      2.5.3
      
        
            spring
            org.springframework
        
      
    
    
      org.apache.zookeeper
      zookeeper
      3.4.6
      
        
          log4j
          log4j
        
      
    
    
      log4j
      log4j
      1.2.17
    
    
      com.github.sgroschupf
      zkclient
      0.1
    
    
      org.springframework
      spring-aop
      ${spring.vesion}
    
    
      org.springframework
      spring-asm
      ${spring.vesion}
    
    
      org.springframework
      spring-aspects
      ${spring.vesion}
    
    
      org.springframework
      spring-beans
      ${spring.vesion}
    
    
      org.springframework
      spring-context
      ${spring.vesion}
    
    
      org.springframework
      spring-context-support
      ${spring.vesion}
    
    
      org.springframework
      spring-core
      ${spring.vesion}
    
    
      org.springframework
      spring-expression
      ${spring.vesion}
    
    
      org.springframework
      spring-instrument
      ${spring.vesion}
    
    
      org.springframework
      spring-instrument-tomcat
      ${spring.vesion}
    
    
      org.aspectj
      aspectjweaver
      1.6.9
    
    
      commons-pool
      commons-pool
      1.5.3
    
    
      commons-collections
      commons-collections
      3.2
    
    
      org.springframework
      spring-jms
      ${spring.vesion}
    
    
      org.springframework
      spring-oxm
      ${spring.vesion}
    
    
      org.springframework
      spring-web
      ${spring.vesion}
    
    
      org.springframework
      spring-webmvc
      ${spring.vesion}
    
    
      org.springframework
      spring-webmvc-portlet
      ${spring.vesion}
    
    
      org.springframework
      spring-struts
      ${spring.vesion}
    
    
      commons-httpclient
      commons-httpclient
      3.1
    

    
        com.dubbo
        dubbo-api
        0.0.1-SNAPSHOT
    
  
  
    dubbo-service
  

好了,经过这么配置之后,我们的项目编码配置部分就大功告成了!

maven编译下三个项目,将dubbo-controller和dubbo-service放到tomcat容器中,启动tomcat容器! 出错啦! 为啥容器不起来!那是因为我们还少了主要的一步,那就是配置启动zookeeper,不然dubbo去zookeeper注册中心暴露服务地址不成功啦!

四、配置启动zookeeper
将下载的zookeeper压缩包,解压到一个磁盘目录上去,这里我指定的位置:D:hwyzookeeper-3.4.8,我们可以通过启动D:hwyzookeeper-3.4.8inzkServer.cmd直接启动默认配置,默认端口为2181,当然我们也可以指定其他的配置,打开D:hwyzookeeper-3.4.8confzoo.cfg,这个是zookeeper配置文件的位置,我们这里在指定一下数据目录以及数据日志目录

dataDir=D:\hwy\www\zookeeper\data
dataLogDir=D:\hwy\www\zookeeper\log

启动zookeeper!

再次启动tomcat容器,是不是就成功啦!我们来访问下http://127.0.0.1:8090/dubbo-controller/test?name=hwy,看下返回结果是不是正确啦!

好啦!经过上边的一系列操作,一个Maven+SpringMVC+Dubbo 的demo就配置完成了,但是我们如果管理这些服务提供者以及消费者呢?当然,dubbo给我们提供了现成的后台管理网站,专门管理这些服务,应用,路由规则,动态配置,访问控制、权重控制、负载均衡等等,还可以查看系统日志,系统状态,系统环境等等,功能很是强大,通过这个后台,可以可视化控制你的服务和应用。

接下来我们来简单的看看后台系统,以及简单修改下权重控制啥的看看效果吧!我们将dubbo-admin-2.5.3.war包放到tomcat容器中,启动tomcat容器,访问http://127.0.0.1:8080/dubbo-admin-2.5.3

一、登录
这里写图片描述
注意:用户名和密码默认为root,当然为了安全起见,线上必须更改这个用户名和密码,

二、首页

注意:我们看到红色区域,里面显示 服务数:1 应用数:2 提供者数:1 消费者数:1 。
这就是刚刚我们启动的那个服务1(com.dubbo.service.TestService服务),应用2(test_consumer,test_provider),提供者1(192.168.2.193:20880) 消费者1(192.168.2.193),分别来张截图看看:
1、服务
服务
2、应用
应用
3、提供者
提供者
4、消费者
消费者

看看,是不是很直观的看到刚刚我们启动的服务,应用,提供者及消费者信息,这里,我们在演示下里面的功能之一权重调节功能,给不同的服务提供者分配不同的权限,看下消费者消费提供者的次数的变化。

为了达到演示效果,我将dubbo-service项目在复制一份放到tomcat里面去,并将TestServiceImpl类修改下sayHello()方法,并修改dubbo暴露端口号,通过输出不同信息,判断消费者调用哪个服务提供者提供的服务。

package com.dubbo.service.impl;

import com.dubbo.service.TestService;

/**
 * service impl
 * @author hwy
 *
 */
public class TestServiceImpl implements TestService{

    public String sayHello(String name) {
        return name + " say hello word!";
    }

}

接着,我们在修改下dubbo的暴漏端口号,修改applicationContext.xml里面的,好了,我们在重新启动tomcat,继续访问http://127.0.0.1:8080/dubbo-admin-2.5.3,我们能看到提供者里面,已经有我们刚新加的192.168.2.193:20881服务提供者啦!

这里写图片描述

这个时候我们在访问http://127.0.0.1:8090/dubbo-controller/test?name=hwy,当我们刷新时,返回的结果中除了上面截图返回的结果,也会返回刚新修改的返回结果,而且多刷新几次,两种结果出现的几率是一样哒!因为这里的提供者权重是一样的。

这里写图片描述

现在,我们修改这2个提供者的权重,我们让192.168.2.193:20881的权重降一半即50,另一个192.168.2.193:20880提高到200,我们在来刷新多次,看下返回的两种结果出现的几率是不是1:4。亲测,是哒!!!

这里写图片描述

好了,上边只是简单介绍了这个后台管理系统,里面还有很多很强大的功能,我也暂时还没完全玩转,大家一起尝试下,分享下吧!

dubbo是一个很强大的分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案,我用到的只是冰山一角,他的更多功能,大家一起研究下吧!这次分享就到这吧! 打字打的手疼啦!O(∩_∩)O哈哈~

原文地址:https://www.cnblogs.com/martin-roger/p/7218010.html