170328、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接口类

1
2
3
4
5
6
7
8
9
10
11
12
<code class="hljs java">package com.dubbo.service;
 
public interface TestService {
 
    /**
     * 测试发消息
     * @param name
     * @return
     */
    public String sayHello(String name);
 
}</code>

pom.xml配置

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
  <modelversion>4.0.0</modelversion>
 
  <groupid>com.dubbo</groupid>
  <artifactid>dubbo-api</artifactid>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>jar</packaging>
 
  <name>dubbo-api</name>
  <url>http://maven.apache.org</url>
 
  <properties>
    <project.build.sourceencoding>UTF-8</project.build.sourceencoding>
  </properties>
 
  <dependencies>
    <dependency>
      <groupid>junit</groupid>
      <artifactid>junit</artifactid>
      <version>3.8.1</version>
      <scope>test</scope>
    </dependency>
  </dependencies>
</project></code>

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

2、dubbo-controller
新建MyController类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
<code class="hljs avrasm">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();
    }
 
}</code>

新建dubbo-config.xml

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
       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="test_consumer">
 
 
    <dubbo:registry address="zookeeper://192.168.2.193:2181">
 
 
    <dubbo:reference interface="com.dubbo.service.TestService" id="testService" check="false">
 
</dubbo:reference></dubbo:registry></dubbo:application></beans></code>

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

pom.xml配置

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
  <modelversion>4.0.0</modelversion>
 
  <groupid>com.dubbo</groupid>
  <artifactid>dubbo-controller</artifactid>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>war</packaging>
 
  <name>dubbo-contoller</name>
  <url>http://maven.apache.org</url>
 
  <properties>
    <project.build.sourceencoding>UTF-8</project.build.sourceencoding>
 <org.springframework.version>3.1.4.RELEASE</org.springframework.version>
  </properties>
 
  <dependencies>
    <dependency>
        <groupid>junit</groupid>
        <artifactid>junit</artifactid>
        <version>3.8.1</version>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupid>javax.servlet</groupid>
            <artifactid>javax.servlet-api</artifactid>
            <version>3.1.0</version>
        </dependency>
 
        <dependency>
            <groupid>org.springframework</groupid>
            <artifactid>spring-context</artifactid>
            <version>${org.springframework.version}</version>
        </dependency>
        <dependency>
            <groupid>org.springframework</groupid>
            <artifactid>spring-context-support</artifactid>
            <version>${org.springframework.version}</version>
        </dependency>
        <dependency>
            <groupid>org.springframework</groupid>
            <artifactid>spring-web</artifactid>
            <version>${org.springframework.version}</version>
        </dependency>
        <dependency>
            <groupid>org.springframework</groupid>
            <artifactid>spring-webmvc</artifactid>
            <version>${org.springframework.version}</version>
        </dependency>
 
        <dependency>
            <groupid>org.codehaus.jackson</groupid>
            <artifactid>jackson-core-asl</artifactid>
            <version>1.9.12</version>
        </dependency>
        <dependency>
            <groupid>org.codehaus.jackson</groupid>
            <artifactid>jackson-mapper-asl</artifactid>
            <version>1.9.12</version>
        </dependency>
        <dependency>
            <groupid>net.sf.json-lib</groupid>
            <artifactid>json-lib</artifactid>
            <version>2.4</version>
            <classifier>jdk15</classifier>
        </dependency>
 
        <dependency>
            <groupid>com.alibaba</groupid>
            <artifactid>dubbo</artifactid>
            <version>2.5.3</version>
            <exclusions>
                <exclusion>
                    <artifactid>spring</artifactid>
                    <groupid>org.springframework</groupid>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupid>org.apache.zookeeper</groupid>
            <artifactid>zookeeper</artifactid>
            <version>3.3.6</version>
            <exclusions>
                <exclusion>
                    <groupid>log4j</groupid>
                    <artifactid>log4j</artifactid>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupid>log4j</groupid>
            <artifactid>log4j</artifactid>
            <version>1.2.16</version>
        </dependency>
        <dependency>
          <groupid>com.github.sgroschupf</groupid>
          <artifactid>zkclient</artifactid>
          <version>0.1</version>
        </dependency>
 
        <dependency>
            <groupid>com.dubbo</groupid>
            <artifactid>dubbo-api</artifactid>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
    </dependencies>
    <build>
        <finalname>dubbo-controller</finalname>
    </build>
</project></code>

3、dubbo-service
新建TestServiceImpl类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
<code class="hljs java">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!";
    }
 
}</code>

新建applicationContext.xml

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
    http://code.alibabatech.com/schema/dubbo
    http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 
 
    <dubbo:application name="test_provider">
 
 
    <dubbo:registry address="zookeeper://192.168.2.193:2181">
 
 
    <dubbo:protocol name="dubbo" port="20880">
 
 
    <dubbo:service interface="com.dubbo.service.TestService" ref="testService">
 
 
    <bean id="testService" class="com.dubbo.service.impl.TestServiceImpl">
</bean></dubbo:service></dubbo:protocol></dubbo:registry></dubbo:application></beans></code>

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

pom.xml配置

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
  <modelversion>4.0.0</modelversion>
  <groupid>com.dubbo</groupid>
  <artifactid>dubbo-service</artifactid>
  <packaging>war</packaging>
  <version>0.0.1-SNAPSHOT</version>
  <name>dubbo-service Maven Webapp</name>
  <url>http://maven.apache.org</url>
 
  <properties>
        <project.build.sourceencoding>UTF-8</project.build.sourceencoding>
         <spring.vesion>3.1.4.RELEASE</spring.vesion>
  </properties>
 
  <dependencies>
    <dependency>
      <groupid>com.alibaba</groupid>
      <artifactid>dubbo</artifactid>
      <version>2.5.3</version>
      <exclusions>
        <exclusion>
            <artifactid>spring</artifactid>
            <groupid>org.springframework</groupid>
        </exclusion>
      </exclusions>
    </dependency>
    <dependency>
      <groupid>org.apache.zookeeper</groupid>
      <artifactid>zookeeper</artifactid>
      <version>3.4.6</version>
      <exclusions>
        <exclusion>
          <artifactid>log4j</artifactid>
          <groupid>log4j</groupid>
        </exclusion>
      </exclusions>
    </dependency>
    <dependency>
      <groupid>log4j</groupid>
      <artifactid>log4j</artifactid>
      <version>1.2.17</version>
    </dependency>
    <dependency>
      <groupid>com.github.sgroschupf</groupid>
      <artifactid>zkclient</artifactid>
      <version>0.1</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-aop</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-asm</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-aspects</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-beans</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-context</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-context-support</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-core</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-expression</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-instrument</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-instrument-tomcat</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.aspectj</groupid>
      <artifactid>aspectjweaver</artifactid>
      <version>1.6.9</version>
    </dependency>
    <dependency>
      <groupid>commons-pool</groupid>
      <artifactid>commons-pool</artifactid>
      <version>1.5.3</version>
    </dependency>
    <dependency>
      <groupid>commons-collections</groupid>
      <artifactid>commons-collections</artifactid>
      <version>3.2</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-jms</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-oxm</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-web</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-webmvc</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-webmvc-portlet</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>org.springframework</groupid>
      <artifactid>spring-struts</artifactid>
      <version>${spring.vesion}</version>
    </dependency>
    <dependency>
      <groupid>commons-httpclient</groupid>
      <artifactid>commons-httpclient</artifactid>
      <version>3.1</version>
    </dependency>
 
    <dependency>
        <groupid>com.dubbo</groupid>
        <artifactid>dubbo-api</artifactid>
        <version>0.0.1-SNAPSHOT</version>
    </dependency>
  </dependencies>
  <build>
    <finalname>dubbo-service</finalname>
  </build>
</project>
</code>

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

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配置文件的位置,我们这里在指定一下数据目录以及数据日志目录

1
2
<code class="hljs tex">dataDir=D:\hwy\www\zookeeper\data
dataLogDir=D:\hwy\www\zookeeper\log</code>

启动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暴露端口号,通过输出不同信息,判断消费者调用哪个服务提供者提供的服务。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
<code class="hljs java">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!";
    }
 
}</code>

接着,我们在修改下dubbo的暴漏端口号,修改applicationContext.xml里面的

1
<code class="hljs xml"><dubbo:protocol name="dubbo" port="20881"></dubbo:protocol></code>

好了,我们在重新启动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服务治理方案,我用到的只是冰山一角,他的更多功能,大家一起研究下吧!

原文地址:https://www.cnblogs.com/zrbfree/p/6709027.html