使用yml配置SpringBoot整合Dubbo

2018-01-09 本文已影响1561人 Ranger23

最近听闻公司的项目打算进行重构，大佬们商量准备使用近年大火的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的同学。有什么错误还希望各位能够帮我指出，大家共同进步。^ ^

使用yml配置SpringBoot整合Dubbo

猜你喜欢

热点阅读