springboot2.4.5 springcloud alibaba dubbo nacos集成

末蓝、 2022-10-14 10:52 228阅读 0赞

遇到的坑

不支持jdk11,仅jdk8

注册中心配置

项目结构如下

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0ODc0Nzg0_size_16_color_FFFFFF_t_70][]

api代码

package com.example.demo.api;
    
    public interface HelloService {
        String sayHello(String name);
    }

plugins {
        id 'java'
    }
    
    repositories {
        //1.优先查找本地maven库，性能最好
        mavenLocal()
    
        //2.其次查找aliyun maven库
        maven {
            url 'https://maven.aliyun.com/repository/public/'
        }
        maven {
            url 'https://maven.aliyun.com/repository/spring/'
        }
        mavenLocal() //1.优先查找本地maven库，性能最好
        maven {//2.其次查找aliyun maven库
            url 'http://maven.aliyun.com/nexus/content/groups/public/'
        }
        mavenCentral()
        maven { url 'https://repo.spring.io/milestone' }
        maven { url 'https://repo.spring.io/snapshot' }
    }
    
    group = 'com.chenye'
    version = '1.0.0'
    //sourceCompatibility = '11'

/*
     * This file was generated by the Gradle 'init' task.
     */
    
    rootProject.name = 'api'

provider代码

plugins {
        id 'org.springframework.boot' version '2.4.5'
        id 'io.spring.dependency-management' version '1.0.11.RELEASE'
        id 'java'
    }
    
    group = 'com.example'
    version = '0.0.1-SNAPSHOT'
    //sourceCompatibility = '11'
    
    configurations {
        developmentOnly
        runtimeClasspath {
            extendsFrom developmentOnly
        }
        compileOnly {
            extendsFrom annotationProcessor
        }
    }
    
    repositories {
        //1.优先查找本地maven库，性能最好
        mavenLocal()
    
        //2.其次查找aliyun maven库
        maven {
            url 'https://maven.aliyun.com/repository/public/'
        }
        maven {
            url 'https://maven.aliyun.com/repository/spring/'
        }
        mavenLocal() //1.优先查找本地maven库，性能最好
        maven {//2.其次查找aliyun maven库
            url 'http://maven.aliyun.com/nexus/content/groups/public/'
        }
        mavenCentral()
        maven { url 'https://repo.spring.io/milestone' }
        maven { url 'https://repo.spring.io/snapshot' }
    }
    
    ext {
        set('springCloudAlibabaVersion', "2.2.1.RELEASE")
    }
    
    dependencies {
        implementation project(':api')
        implementation('org.apache.commons:commons-lang3:3.6')
    
        implementation 'org.springframework.boot:spring-boot-starter-web'
        //implementation 'com.alibaba.cloud:spring-cloud-starter-alibaba-nacos-config'
        implementation 'com.alibaba.cloud:spring-cloud-starter-alibaba-nacos-discovery'
        implementation 'com.alibaba.cloud:spring-cloud-starter-dubbo'
        //implementation 'com.alibaba.cloud:spring-cloud-starter-alibaba-sentinel'
    
        //implementation project('com.chenye:api:1.0.0')
        //implementation 'com.chenye:api:1.0.0'
        //implementation group: 'org.apache.dubbo', name: 'dubbo-registry-nacos', version: '3.0.0.preview'
        //implementation group: 'org.apache.dubbo', name: 'dubbo-registry-nacos', version: '2.7.11'
    
    
        compileOnly 'org.projectlombok:lombok'
        developmentOnly 'org.springframework.boot:spring-boot-devtools'
        annotationProcessor 'org.projectlombok:lombok'
        testImplementation('org.springframework.boot:spring-boot-starter-test') {
            exclude group: 'org.junit.vintage', module: 'junit-vintage-engine'
        }
    }
    ext {
        springCloudAlibabaVersion = '2.2.5.RELEASE'
        springCloudVersion = '2020.0.2'
    }
    dependencyManagement {
        imports {
            mavenBom "com.alibaba.cloud:spring-cloud-alibaba-dependencies:${springCloudAlibabaVersion}"
            mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
        }
    }
    test {
        useJUnitPlatform()
    }

server:
      port: 8081
    spring:
      application:
        name: demo-provider1
      main:
        allow-bean-definition-overriding: true
      cloud:
        nacos:
          discovery:
            server-addr: 127.0.0.1:8848
    #      config:
    #        server-addr: 127.0.0.1:8848
    
    management:
      endpoints:
        web:
          exposure:
            include: '*'
    
    dubbo:
      application:
        id: demo-provider1
        name: demo-provider1
        #version: 1.0.0
      scan:
        base-packages: com.example.demo.dubbo
      #  protocol:
      #    port: 12348
      protocols:
        dubbo:
          name: dubbo
          port: -1
      #    rest:
      #      name: rest
      #      port: 9090
      #      server: netty
      registry:
        #   The Spring Cloud Dubbo's registry extension
        # address: spring-cloud://localhost
        #   The traditional Dubbo's registry
        #address: zookeeper://127.0.0.1:2181
        address: nacos://127.0.0.1:8848?username=nacos&password=nacoschenye
        #address: spring-cloud://localhost
    #feign:
    #  hystrix:
    #    enabled: true

package com.example.demo.dubbo;
    
    import com.example.demo.api.HelloService;
    import org.apache.dubbo.config.annotation.DubboService;
    
    //@org.apache.dubbo.config.annotation.Service(version = "1.0.0", protocol = { "dubbo", "rest" })
    //@DubboService(version = "1.0.0", protocol = { "dubbo", "rest" })
    //@DubboService(version = "1.0.0", protocol = "dubbo")
    @DubboService
    public class HelloServiceImpl implements HelloService {
        @Override
        public String sayHello(String name) {
            return "Hello " + name;
        }
    }

consumer代码

package com.example.demo.controller;
    
    import com.example.demo.api.HelloService;
    import org.apache.dubbo.config.annotation.DubboReference;
    import org.springframework.http.ResponseEntity;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class SayHelloController {
    
        //@DubboReference(version = "1.0.0", url = "dubbo://192.168.31.66:20880")
        //@DubboReference(version = "1.0.0", protocol = "dubbo", check = false)
        @DubboReference
        HelloService helloService;
    
        @GetMapping("/hello")
        public ResponseEntity hello() {
            String a = helloService.sayHello("chenye");
            return ResponseEntity.ok(a);
        }
    
        @GetMapping("/test")
        public ResponseEntity test() {
            return ResponseEntity.ok("test");
        }
    }

package com.example.demo;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    /**
     * @author chenye
     */
    @EnableDiscoveryClient
    @SpringBootApplication//(scanBasePackages = {"com.example.demo"})
    public class DubboConsumerServiceConsumer {
    
        public static void main(String[] args) {
            SpringApplication.run(DubboConsumerServiceConsumer.class, args);
        }
    
    }

server:
      port: 8082
    spring:
      application:
        name: demo-consumer1
      main:
        allow-bean-definition-overriding: true
    
      # default disable all
      cloud:
        nacos:
    #      config:
    #        server-addr: 127.0.0.1:8848?username=nacos&password=nacoschenye
          discovery:
            enabled: true
            register-enabled: true
            server-addr: 127.0.0.1:8848
            username: nacos
            password: nacoschenye
        zookeeper:
          enabled: false
          connect-string: 127.0.0.1:2181
    
    dubbo:
      scan:
        base-packages: com.example.demo.controller
      application:
        #environment: v1
        #version: 1.0.0
        id: demo-consumer1
        name: demo-consumer1
      #  protocol:
    #    port: 20811
      registry:
        #   The Spring Cloud Dubbo's registry extension
        ##  the default value of dubbo-provider-services is "*", that means to subscribe all providers,
        ##  thus it's optimized if subscriber specifies the required providers.
        #address: spring-cloud://localhost
        #address: spring-cloud://localhost
      #   The traditional Dubbo's registry also is supported
        #address: zookeeper://127.0.0.1:2181
        address: nacos://127.0.0.1:8848?username=nacos&password=nacoschenye
        check: false
      cloud:
        # The subscribed services in consumer side
        #subscribed-services: ${provider.application.name}
        subscribed-services: demo-provider1
    
      consumer:
        check: false
        #version: 1.0.0

settings.gradle

pluginManagement {
        repositories {
            maven { url 'https://repo.spring.io/milestone' }
            maven { url 'https://repo.spring.io/snapshot' }
            gradlePluginPortal()
        }
        resolutionStrategy {
            eachPlugin {
                if (requested.id.id == 'org.springframework.boot') {
                    useModule("org.springframework.boot:spring-boot-gradle-plugin:${requested.version}")
                }
            }
        }
    }
    rootProject.name = 'consumer'
    includeFlat('api')

源码地址

[https://gitee.com/stylesmile/springcloud-alibaba-study/tree/master/spring-cloud-alibaba-dubbo-demo][https_gitee.com_stylesmile_springcloud-alibaba-study_tree_master_spring-cloud-alibaba-dubbo-demo]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0ODc0Nzg0_size_16_color_FFFFFF_t_70]: /images/20221014/d156ee37729043a596409cd122e7581a.png
[https_gitee.com_stylesmile_springcloud-alibaba-study_tree_master_spring-cloud-alibaba-dubbo-demo]: https://gitee.com/stylesmile/springcloud-alibaba-study/tree/master/spring-cloud-alibaba-dubbo-demo