最近听闻公司的项目打算进行重构,大佬们商量准备使用近年大火的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依赖,服务提供者和消费者的依赖都是一样)
<!--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
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
-
服务提供者项目结构
- 服务接口实现
编写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
-
服务消费者项目结构
- 服务消费者
引用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的同学。有什么错误还希望各位能够帮我指出,大家共同进步。^ ^