最近听闻公司的项目打算进行重构，大佬们商量准备使用近年大火的SpringCloud，所以在开始学习Springcloud前，先来复习下之前项目中使用到的Dubbo+Zookeeper。之前的项目很老使用的Spring+Struct2搭建的，使用Dubbo2.5.3都是基于xml配置的，就想尝试最新的springboot+dubbo+yml配置来搭建，并想看下老版本提供服务，在新的消费者是否能获取成功消费。
Dubbo官方也在3年之后的17年连发了5个版本，在dubbo2.5.7之前也早已支持通过注解@Server暴露服务和@Reference消费服务（但是我们老项目并没有使用 = =），在2.5.7中Dubbo团队通过增加了一个@DubboComponentScan修复了一些通过注解暴露消费服务产生的Issues,具体产考：Dubbo 注解驱动（Annotation-Driven） ，有兴趣的同学可以看下，这篇文章主要是使用Dubbo2.5.8中提供的spring-boot-starter-dubbo来搭建Dubbo。这里服务注册中心使用Zookeeper，Zookeeper的相关问题不清楚的同学可以自行百度，有很多资料。
需要新建两个maven的SpringBoot项目，通过SpringBoot官方提供的快速搭建项目的网站：SPRING INITIALIZR ，很容易的搭建出一个基本的SpringBoot项目,为了方便我们后面通过页面测试，项目中添加上web依赖,如下图：
快速搭建SpringBoot
- 项目依赖（除了基本的SpringBoot依赖，服务提供者和消费者的依赖都是一样）
<!--dubbo-springBoot依赖-->
<dependency>
<groupId>io.dubbo.springboot</groupId>
<artifactId>spring-boot-starter-dubbo</artifactId>
<version>1.0.0</version>
</dependency>
<!--zookeeper依赖-->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.8</version>
</dependency>
<!--服务接口Jar-->
<dependency>
<groupId>com.aspire.aplus</groupId>
<artifactId>sim</artifactId>
<version>1.3.3</version>
</dependency>
这里说明下，最后一个依赖服务接口jar是服务接口暴露的，是自己搭建的一个项目打成jar放到自己镜像库，里面主要是一些服务的interface接口。没有自己Maven镜像库的同学，可以把这个项目打成jar手动导入到项目依赖中。（所以不止俩个项目，还需要一个服务接口项目。）
-
服务接口项目及DemoService接口code
需暴露服务的interface接口code
1.服务提供者dubboProvide：
- 服务提供者yml配置文件
server:
port: 8086
spring:
dubbo:
application: #应用配置，用于配置当前应用信息，不管该应用是提供者还是消费者。
name: Provide
registry: #注册中心配置，用于配置连接注册中心相关信息。
address: zookeeper://127.0.0.1:2181
protocol: #协议配置，用于配置提供服务的协议信息，协议由提供方指定，消费方被动接受。
name: dubbo
port: 20880
scan: com.dubboProvide.dubboProvide.service #服务暴露与发现消费所在的package
-
服务提供者项目结构
dubboProvide项目结构
- 服务接口实现
编写Dubbo服务，只需要添加要发布的服务实现上添加@Service，如下：
package com.dubboProvide.dubboProvide.service.imp;
import com.alibaba.dubbo.config.annotation.Service;
import com.aspire.aplus.service.DemoService;
@Service(version = "1.0.0")
public class DemoServerImp implements DemoService {
@Override
public String sayHello(String s) {
return "你好，"+s+"!";
}
}
2 服务消费者dubboConsumer：
- 服务提供者yml配置文件
server:
port: 8085
spring:
dubbo:
application: #应用配置，用于配置当前应用信息，不管该应用是提供者还是消费者。
name: Consumer
registry: #注册中心配置，用于配置连接注册中心相关信息。
address: zookeeper://127.0.0.1:2181
protocol: #协议配置，用于配置提供服务的协议信息，协议由提供方指定，消费方被动接受。
name: dubbo
port: 20880
scan: com.dubboconsumer.dubboConsumer.service #服务暴露与发现消费所在的package
-
服务消费者项目结构
dubboConsumer项目结构
- 服务消费者
引用Dubbo服务，只需要添加要发布的服务实现上添加@Reference，如下：
package com.dubboconsumer.dubboConsumer.service.imp;
import com.alibaba.dubbo.config.annotation.Reference;
import com.aspire.aplus.service.DemoService;
import org.springframework.stereotype.Component;
@Component
public class DubboTestService {
@Reference(version = "1.0.0")
public DemoService demoService;
public String Echo(String s){
String ret_msg;
try {
ret_msg = demoService.sayHello(s);
}catch (Exception e){
e.printStackTrace();
ret_msg = "出错啦！";
}
return ret_msg;
}
}
- 页面接口
接口去调用获取了dubbo服务的DubboTestService，在DubboTestService 再调用远程dubbo服务demoService的sayHello()方法
package com.dubboconsumer.dubboConsumer.controller;
import com.dubboconsumer.dubboConsumer.service.imp.DubboTestService;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
@RestController
public class DubboTestController {
@Resource
private DubboTestService dubboTestService;
@RequestMapping(value = "hello/{name}",method = RequestMethod.GET)
public String Hello(@PathVariable String name){
return dubboTestService.Echo(name);
}
}
3 验证
将两个项目逐一启动（先启动服务提供者dubboProvide后启动服务消费者dubboConsumer），打开浏览器，输入消费者提供的接口：localhost:8085/hello/小咩,结果如下：
emmm...到这里说明最基本的dubbo项目搭建成功啦。成功的在dubboConsumer项目中调用了在dubboProvide提供的业务代码。
上面说的老版本dubbo提供的服务是否能在新版本中使用，经过尝试，答案是肯定，过程踩了个坑，其中最主要的还是配置文件问题，yml文件写的不符合规范导致，可以看下我另一篇文章写到的：yml配置文件读取出错 Exception in thread "main" while scanning for the next token found character '\t(TAB)' 。
文章到此就结束了，写下这篇文章主要是当做一个笔记，同时也希望能帮助到一些刚接触dubbo的同学。有什么错误还希望各位能够帮我指出，大家共同进步。^ ^
网友评论