SpringCloud Nacos 整合Dubbo

SpringCloud Nacos 整合Dubbo

文章目录

• 1.新建PayService模块
• 2.定义接口模块
• 3.服务提供者
• 4.服务消费者：
• 5.启动生产者
• 6.启动消费者

1.新建PayService模块

这是我父工程的部分定义：

    org.springframework.boot
    spring-boot-starter-parent
    2.1.6.RELEASE
     
  

  cn.redocloud
  crazy
  1.0

  crazy Maven Webapp
  
  http://www.example.com

  
    UTF-8
    1.8
    1.8
    UTF-8
    UTF-8
    
    2.1.5
    Greenwich.SR2
    0.9.0.RELEASE
    2.7.1
  

  
    
    
      org.projectlombok
      lombok
      true
    
  

  
    
      
      
        org.springframework.cloud
        spring-cloud-dependencies
        ${spring-cloud.version}
        pom
        import
      

      
      
        org.springframework.cloud
        spring-cloud-alibaba-dependencies
        ${spring-cloud-alibaba.version}
        pom
        import
      


      
      
        com.alibaba.cloud
        spring-cloud-alibaba-dependencies
        2.1.0.RELEASE
        pom
        import
      
    
  

选中工程文件，如我这里是crazy=>new Moudule=>填写模块信息=>Finish

2.定义接口模块

以下是common模块的部分内容：
因为我这里已经有了common模块，就将就用这个模块来定义dubbo服务的接口了

public interface PayService {
    void pay(Map map);
}

项目结构如下：

定义玩接口后，执行maven的package或者install命令：
可以在自己的本地maven仓库中看到，common-1.0.jar

3.服务提供者

以下是payservice服务的内容
依赖如下：

    
        crazy
        cn.redocloud
        1.0
    
    4.0.0

    payservice
    
        
        
            cn.redocloud
            common
            1.0
            compile
        

        
        
            org.apache.dubbo
            dubbo-spring-boot-starter
            ${dubbo.version}
        
        
            org.apache.dubbo
            dubbo
            ${dubbo.version}
        
        
            org.apache.dubbo
            dubbo-registry-nacos
            ${dubbo.version}
        
        
            org.springframework.cloud
            spring-cloud-starter-alibaba-nacos-config
        
        
            org.springframework.cloud
            spring-cloud-starter-alibaba-nacos-discovery
        
    

    
        8
        8
    

application.yml配置：

spring:
  profiles:
    active: dev
  application:
    name: payservice
dubbo:
  registry:
   address: nacos://127.0.0.1:8848
  ##dubbo nacos 命名空间 默认public
   parameters[namespace]: 9eeffe66-d561-4b00-a42c-38d13fd5cd09
  protocol:
    port: -1
    name: dubbo

bootstrap.yml配置

spring:
  cloud:
    nacos:
      config:
        namespace: 9eeffe66-d561-4b00-a42c-38d13fd5cd09
        group: dev
        server-addr: 127.0.0.1:8848
        file-extension: yaml
      discovery:
        namespace: 9eeffe66-d561-4b00-a42c-38d13fd5cd09
        server-addr: 127.0.0.1:8848

现在写一个服务类：
注意:此处的@Service为dubbo包下的注解而非Spring的注解

代码如下：

package cn.redocloud.service;

import cn.redocloud.api.PayService;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.config.annotation.Service;

import java.util.Map;


@Service
@Slf4j
public class PayServiceImpl implements PayService {
    @Override
    public void pay(Map map) {
        log.info("数据为{}",map);
    }
}

编写一个启动类

import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;


@SpringBootApplication
//scanbasePackages 这个就是业务类所在的包路径 启动dubbo
@EnableDubbo(scanbasePackages = "cn.redocloud.service")
public class PayApplication {
    public static void main(String[] args) {
        SpringApplication.run(PayApplication.class,args);
    }
}

4.服务消费者：

以下是uservice模块的内容：
依赖如下：

  
    crazy
    cn.redocloud
    1.0
  
  4.0.0

  cn.redocloud
  userservice
  1.0

  userservice Maven Webapp

  
    UTF-8
    1.8
    1.8
  

  
    
      org.springframework.cloud
      spring-cloud-starter-alibaba-nacos-config
    
    
      org.springframework.cloud
      spring-cloud-starter-alibaba-nacos-discovery
    
    
      org.springframework.boot
      spring-boot-starter-web
    

    
      cn.redocloud
      common
      1.0
      compile
    
    
      org.apache.dubbo
      dubbo-spring-boot-starter
      ${dubbo.version}
    
    
      org.apache.dubbo
      dubbo
      ${dubbo.version}
    
    
      org.apache.dubbo
      dubbo-registry-nacos
      ${dubbo.version}
    
  

application.yml如下

server:
  port: 9002
spring:
  profiles:
    active: dev
  application:
    name: userservice
dubbo:
  registry:
    address: nacos://127.0.0.1:8848
    ##dubbo nacos 命名空间 默认public
    parameters[namespace]: 9eeffe66-d561-4b00-a42c-38d13fd5cd09
  protocol:
    port: -1
    name: dubbo

bootstrap.yml如下

spring:
  cloud:
    nacos:
      config:
        namespace: 9eeffe66-d561-4b00-a42c-38d13fd5cd09
        group: dev
        server-addr: 127.0.0.1:8848
        file-extension: yaml
      discovery:
        namespace: 9eeffe66-d561-4b00-a42c-38d13fd5cd09
        server-addr: 127.0.0.1:8848

controller中写一个调用payservice的

@RestController
@RequestMapping("/user")
public class UserController {

    @Reference
    PayService payService;

    @RequestMapping("/pay")
    public String pay() {
        payService.pay(new HashMap());
        return "ok";
    }
}

编写启动类：

@SpringBootApplication
@EnableDubbo
public class UserServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(UserServiceApplication.class,args);
    }
}

5.启动生产者

启动payservice:

可以在nacos中看到已经多了一个provider，说明生产者注册成功了

6.启动消费者

消费者启动成功后，查看nacos

可以看到多了两个服务，一个是consumer
另外一个是userservice,笔者自己以前公司的项目是用的SpringCloud Alibaba的部分内容，网关使用gateway（继承了均衡负载）、配置中心注册中心使用的nacos、服务间调用用的openfeign（集成了熔断和均衡）、外部调用一般用的别人的官方jar或者是用resttemplate去做调用、reids缓存等等，笔者也在疑惑，如果把nacos-discovery的依赖删除了，是否能将dubbo服务注册上去：
注释discovery的依赖：

启动：

消费者服务正常启动：

此次nacos上只多了一个consumer服务
同理，注释掉生产者payservice的discovery配置：

发现服务正常注册：

说明其实对于dubbo+nacos来说，只需要如下依赖即可：也就是说上面的内容中可以注释掉discovery的内容（因为配置中心还是应该要的，所以这里就没有去掉nacos-config的依赖）

    org.apache.dubbo
    dubbo-spring-boot-starter
    ${dubbo.version}


    org.apache.dubbo
    dubbo
    ${dubbo.version}


    org.apache.dubbo
    dubbo-registry-nacos
    ${dubbo.version}

其他的就是你自己定义的接口和Spring等的一些包了

注意事项：
以上内容使用了nacos的配置中心，所以需要你在nacos中添加部分配置文件如我的：

其中data id的命名必须与你工程中的命名对应，如：
application.yml

spring:
  profiles:
    active: dev
  application:
    name: userservice

bootstrap.yml:

spring:
  cloud:
    nacos:
      config:
        namespace: 9eeffe66-d561-4b00-a42c-38d13fd5cd09
        group: dev
        server-addr: 127.0.0.1:8848
        file-extension: yaml

那么你的配置文件的名字应该为：
userservice-dev.yaml （也就是application.name+profiles+file-extension的内容）并且需要严格区分namespace 和 group，file-extension为文件后缀名。
其他服务的配置以此类推。

访问接口：

payservice打印内容（因为我没有传值所以打印的酒就是括号）

dubbo的熔断机制：
在调用者这里实现一个熔断类（和FeignClient差不多）

@Slf4j
public class PayServiceFallback implements PayService {
    @Override
    public void pay(Map map) {
        log.info("服务请求超时");
    }
}

在@Refrence注解中设置：

    @Reference(mock = "cn.redocloud.fallback;",cluster = "failfast")
    PayService payService;

关闭payservice服务后，再次访问接口：

可以看到在fallback类的 *** 作被执行了