devbox
酷酷是懒虫
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Dubbo + SpringBoot + Nacos 部署服务_dubbo nacos启动了很多服务

作者：酷酷是懒虫 | 2024-06-30 21:09:35

赞

踩

dubbo nacos启动了很多服务

目录

服务发现示意图

版本信息

项目结构

spring-boot-dubbo-base

pom.xml

User

UserService

spring-boot-dubbo-consumer

pom.xml

application.yml

SpringBootDubboConsumerApplication

userController

spring-boot-dubbo-provider

pom.xml

UserServiceImpl

SpringBootDubboProviderApplication

application.yml

测试

服务发现示意图

不恰当的比喻Provider（购房者）、Container（中介手机号）、Registry（中介）、Consumer（卖房者）、Monitor（房产局）

Container启动，Provider 注册地址到注册中心，Consumer 从注册中心异步读取和订阅 Provider 地址列表，当Provider服务下单或宕机时，Registry也会异步通知Consumer，当Consumer消费服务时，使用Registry订阅的地址访问访问Provider，Consumer、Provider同时会向Monitor异步传输调用信息。

版本信息

  • springboot  2.5.4
  • maven 3.3.9
  • nacos 2.0.3
  • dubbo 2.7.0

项目结构

  1. |-- spring-boot-dubbo (父级工程)
  2.     |-- spring-boot-dubbo-base (基础工程)
  3.     |-- spring-boot-dubbo-consumer (消费者)
  4.     |-- spring-boot-dubbo-provider (生产者)

spring-boot-dubbo-base

pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.5.4</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.example</groupId>
  12.     <artifactId>spring-boot-dubbo-base</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>spring-boot-dubbo-base</name>
  15.     <description>Demo project for Spring Boot</description>
  16.     <properties>
  17.         <java.version>1.8</java.version>
  18.         <spring-cloud.version>2020.0.3</spring-cloud.version>
  19.     </properties>
  20.     <dependencies>
  21.         <dependency>
  22.             <groupId>org.springframework.boot</groupId>
  23.             <artifactId>spring-boot-starter-web</artifactId>
  24.         </dependency>
  25.  
  26.         <dependency>
  27.             <groupId>org.projectlombok</groupId>
  28.             <artifactId>lombok</artifactId>
  29.             <optional>true</optional>
  30.         </dependency>
  31.  
  32.     </dependencies>
  33.     <dependencyManagement>
  34.         <dependencies>
  35.             <dependency>
  36.                 <groupId>org.springframework.cloud</groupId>
  37.                 <artifactId>spring-cloud-dependencies</artifactId>
  38.                 <version>${spring-cloud.version}</version>
  39.                 <type>pom</type>
  40.                 <scope>import</scope>
  41.             </dependency>
  42.         </dependencies>
  43.     </dependencyManagement>
  44.  
  45.     <build>
  46.         <plugins>
  47.             <plugin>
  48.                 <groupId>org.springframework.boot</groupId>
  49.                 <artifactId>spring-boot-maven-plugin</artifactId>
  50.             </plugin>
  51.         </plugins>
  52.     </build>
  53.  
  54. </project>

User

User由于需要网络传输，必须实现序列化

  1. package com.example.base.model;
  2.  
  3. import lombok.Builder;
  4. import lombok.Data;
  5. import java.io.Serializable;
  6.  
  7. @Data
  8. @Builder
  9. public class User implements Serializable {
  10.     private Integer id;
  11.     private String name;
  12. }

UserService

  1. package com.example.base.service;
  2.  
  3. import com.example.base.model.User;
  4.  
  5. public interface UserService {
  6.  
  7.     //查询用户
  8.     User findById(Integer id);
  9. }

spring-boot-dubbo-consumer

pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.5.4</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.example</groupId>
  12.     <artifactId>spring-boot-dubbo-consumer</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>spring-boot-dubbo-consumer</name>
  15.     <description>Demo project for Spring Boot</description>
  16.     <properties>
  17.         <java.version>1.8</java.version>
  18.         <spring-cloud.version>2020.0.3</spring-cloud.version>
  19.     </properties>
  20.     <dependencies>
  21.         <dependency>
  22.             <groupId>org.springframework.boot</groupId>
  23.             <artifactId>spring-boot-starter-web</artifactId>
  24.         </dependency>
  25.  
  26.         <dependency>
  27.             <groupId>org.projectlombok</groupId>
  28.             <artifactId>lombok</artifactId>
  29.             <optional>true</optional>
  30.         </dependency>
  31.  
  32.         <!--nacos-->
  33.         <dependency>
  34.             <groupId>com.alibaba.cloud</groupId>
  35.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  36.             <version>2.1.1.RELEASE</version>
  37.         </dependency>
  38.  
  39.  
  40.         <!--继承api-->
  41.         <dependency>
  42.             <groupId>com.example</groupId>
  43.             <artifactId>spring-boot-dubbo-base</artifactId>
  44.             <version>0.0.1-SNAPSHOT</version>
  45.         </dependency>
  46.  
  47.         <dependency>
  48.             <groupId>org.apache.dubbo</groupId>
  49.             <artifactId>dubbo-spring-boot-starter</artifactId>
  50.             <version>2.7.5</version>
  51.             <exclusions>
  52.                 <exclusion>
  53.                     <artifactId>org.apache.dubbo</artifactId>
  54.                     <groupId>dubbo</groupId>
  55.                 </exclusion>
  56.             </exclusions>
  57.         </dependency>
  58.  
  59.         <dependency>
  60.             <groupId>org.apache.dubbo</groupId>
  61.             <artifactId>dubbo</artifactId>
  62.             <version>2.7.5</version>
  63.         </dependency>
  64.  
  65.  
  66.     </dependencies>
  67.     <dependencyManagement>
  68.         <dependencies>
  69.             <dependency>
  70.                 <groupId>org.springframework.cloud</groupId>
  71.                 <artifactId>spring-cloud-dependencies</artifactId>
  72.                 <version>${spring-cloud.version}</version>
  73.                 <type>pom</type>
  74.                 <scope>import</scope>
  75.             </dependency>
  76.         </dependencies>
  77.     </dependencyManagement>
  78.  
  79.     <build>
  80.         <plugins>
  81.             <plugin>
  82.                 <groupId>org.springframework.boot</groupId>
  83.                 <artifactId>spring-boot-maven-plugin</artifactId>
  84.             </plugin>
  85.         </plugins>
  86.     </build>
  87.  
  88. </project>

application.yml

  1. server:
  2.   port: 9012
  3. dubbo:
  4.   # 配置服务信息
  5.   application:
  6.     name: dubbo-consumer
  7.     # 禁用QOS同一台机器可能会有端口冲突现象
  8.     qos-enable: false
  9.     qos-accept-foreign-ip: false
  10.   # 配置注册中心
  11.   registry:
  12.     address: nacos://192.168.14.1:8848

SpringBootDubboConsumerApplication

@EnableDubbo不能少

  1. package com.example.consumer;
  2.  
  3. import org.apache.dubbo.config.spring.context.annotation.DubboComponentScan;
  4. import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
  5. import org.springframework.boot.SpringApplication;
  6. import org.springframework.boot.autoconfigure.SpringBootApplication;
  7.  
  8. @SpringBootApplication
  9. @EnableDubbo //开启dubbo的注解支持
  10. public class SpringBootDubboConsumerApplication {
  11.  
  12.     public static void main(String[] args) {
  13.         SpringApplication.run(SpringBootDubboConsumerApplication.class, args);
  14.     }
  15.  
  16. }

userController

  • 如果提供服务者@Service拥有版本号，@Reference也必须拥有版本号，用于解决server多实现。
  • check=false可以不用验证生产者是否可用，如果使用默认true，如果生产者不可用，dubbo会阻止springboot启动
  1. package com.example.consumer.controller;
  2.  
  3. import com.example.base.model.User;
  4. import com.example.base.service.UserService;
  5. import org.apache.dubbo.config.annotation.Reference;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.RequestMapping;
  8. import org.springframework.web.bind.annotation.RestController;
  9.  
  10. @RestController
  11. @RequestMapping
  12. public class UserController {
  13.  
  14. //    @Reference(version = "1.0.0",group = "UserGroup",interfaceClass = UserService.class)
  15.     @Reference(check=false)
  16.     UserService userService;
  17.  
  18.     @GetMapping("/user")
  19.     public User getUser(){
  20.         User user = userService.findById(1);
  21.         return user;
  22.     }
  23. }

spring-boot-dubbo-provider

pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.5.4</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.example</groupId>
  12.     <artifactId>spring-boot-dubbo-provider</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>spring-boot-dubbo-provider</name>
  15.     <description>Demo project for Spring Boot</description>
  16.     <properties>
  17.         <java.version>1.8</java.version>
  18.         <spring-cloud.version>2020.0.3</spring-cloud.version>
  19.     </properties>
  20.     <dependencies>
  21.         <dependency>
  22.             <groupId>org.springframework.boot</groupId>
  23.             <artifactId>spring-boot-starter-web</artifactId>
  24.         </dependency>
  25.  
  26.         <!--nacos-->
  27.         <dependency>
  28.             <groupId>com.alibaba.cloud</groupId>
  29.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  30.             <version>2.1.1.RELEASE</version>
  31.         </dependency>
  32.  
  33.         <dependency>
  34.             <groupId>org.projectlombok</groupId>
  35.             <artifactId>lombok</artifactId>
  36.             <optional>true</optional>
  37.         </dependency>
  38.  
  39.         <!--继承api-->
  40.         <dependency>
  41.             <groupId>com.example</groupId>
  42.             <artifactId>spring-boot-dubbo-base</artifactId>
  43.             <version>0.0.1-SNAPSHOT</version>
  44.         </dependency>
  45.  
  46.         <!-- Dubbo依赖 -->
  47.         <dependency>
  48.             <groupId>org.apache.dubbo</groupId>
  49.             <artifactId>dubbo-spring-boot-starter</artifactId>
  50.             <version>2.7.5</version>
  51.             <exclusions>
  52.                 <exclusion>
  53.                     <artifactId>org.apache.dubbo</artifactId>
  54.                     <groupId>dubbo</groupId>
  55.                 </exclusion>
  56.             </exclusions>
  57.         </dependency>
  58.  
  59.         <dependency>
  60.             <groupId>org.apache.dubbo</groupId>
  61.             <artifactId>dubbo</artifactId>
  62.             <version>2.7.5</version>
  63.         </dependency>
  64.  
  65.  
  66.     </dependencies>
  67.     <dependencyManagement>
  68.         <dependencies>
  69.             <dependency>
  70.                 <groupId>org.springframework.cloud</groupId>
  71.                 <artifactId>spring-cloud-dependencies</artifactId>
  72.                 <version>${spring-cloud.version}</version>
  73.                 <type>pom</type>
  74.                 <scope>import</scope>
  75.             </dependency>
  76.         </dependencies>
  77.     </dependencyManagement>
  78.  
  79.     <build>
  80.         <plugins>
  81.             <plugin>
  82.                 <groupId>org.springframework.boot</groupId>
  83.                 <artifactId>spring-boot-maven-plugin</artifactId>
  84.             </plugin>
  85.         </plugins>
  86.     </build>
  87.  
  88. </project>

UserServiceImpl

注：此处的@Service是dubbo的，不能选错

  1. package com.example.provider.serviceImpl;
  2.  
  3. import com.example.base.model.User;
  4. import com.example.base.service.UserService;
  5. import org.apache.dubbo.config.annotation.Service;
  6.  
  7. //@Service(version = "1.0.0",group = "UserGroup",interfaceClass = UserService.class)
  8. @Service
  9. public class UserServiceImpl implements UserService {
  10.  
  11.     @Override
  12.     public User findById(Integer id) {
  13.         User user = User.builder()
  14.                 .id(1)
  15.                 .name("向先生")
  16.                 .build();
  17.         return user;
  18.     }
  19.  
  20. }

SpringBootDubboProviderApplication

注：不能少@EnableDubbo //开启Dubbo的注解支持

  1. package com.example.provider;
  2.  
  3. import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
  4. import org.springframework.boot.SpringApplication;
  5. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6.  
  7. @EnableDubbo //开启Dubbo的注解支持
  8. @SpringBootApplication
  9. public class SpringBootDubboProviderApplication {
  10.  
  11.     public static void main(String[] args) {
  12.         SpringApplication.run(SpringBootDubboProviderApplication.class, args);
  13.     }
  14.  
  15. }

application.yml

  1. server:
  2.   port: 9011
  3. dubbo:
  4.   # 配置服务信息
  5.   application:
  6.     name: dubbo-consumer
  7.     # 禁用QOS同一台机器可能会有端口冲突现象
  8.     qos-enable: false
  9.     qos-accept-foreign-ip: false
  10.   # 配置注册中心
  11.   registry:
  12.     address: nacos://192.168.14.1:8848

测试

 http://localhost:9012/user

结果

{"id":1,"name":"向先生"}

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/酷酷是懒虫/article/detail/774001
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号