【Dubbo笔记整理五】SpringBoot整合Dubbo（Multicast）

心已赠人 2022-09-13 01:59 328阅读 0赞

> 版权声明：本文为 小异常 原创文章，非商用自由转载-保持署名-注明出处，谢谢！  
> 本文网址：[https://sunkuan.blog.csdn.net/article/details/120501599][https_sunkuan.blog.csdn.net_article_details_120501599]

### 文章目录 ###

*  一、搭建 Maven 聚合项目
 *   *  1、创建 dubbo-demo 项目
     *  2、整理 dubbo-demo 项目的 pom
     *  3、创建 dubbo-api、dubbo-server、dubbo-client 子模块
     *  4、目录结构
     *  5、Maven依赖
 *  二、dubbo-api
 *   *  1、pom.xml
     *  2、User 类
     *  3、UserService 接口
 *  三、dubbo-provider
 *   *  1、pom.xml
     *  2、application.yml
     *  3、UserServiceImpl
     *  4、DubboProviderApplication
 *  四、dubbo-consumer
 *   *  1、pom.xml
     *  2、application.yml
     *  3、UserInit
     *  4、DubboConsumerApplication
 *  五、测试程序
 *  六、程序代码

> 终于进入实战环节了，本篇将以 **Spring Boot** 为基础，来整合 **Dubbo** 来实现一个 HelloWorld 小例子。通过上篇博客相信大家也了解到在 **Dubbo** 中有个 **注册中心** 这个东西，官方推荐的虽然是 **Zookeeper**，但由于 **Zookeeper** 东西也比较多，我们本篇博客暂时使用 **Multicast 注册中心** 带大家入门。  
> 　  
> **Multicast** 只适用于学习和测试，非常不推荐用于实际生产，这也是官方说的。  
> 　  
> **Multicast 注册中心** 不需要启动任何中心节点，只要广播地址一样，就可以互相发现。下面是官方提供的结构图：
> 
> ![05Multicast注册中心][05Multicast]

> 1.  提供方启动时广播自己的地址；
> 2.  消费方启动时广播订阅请求；
> 3.  提供方收到订阅请求时，单播自己的地址给订阅者，如果设置了 `unicast=false`，则广播给订阅者；
> 4.  消费方收到提供方地址时，连接该地址进行 **RPC** 调用。  
>     　  
>     由组播受网络结构限制，只适合小规模应用或开发阶段使用。组播地址段: `224.0.0.0` \- `239.255.255.255`。

--------------------

# 一、搭建 Maven 聚合项目 #

## 1、创建 dubbo-demo 项目 ##

![05创建dubbo-demo][05_dubbo-demo]

![05创建dubbo-demo2][05_dubbo-demo2]

![05创建dubbo-demo3][05_dubbo-demo3]

![05创建dubbo-demo4][05_dubbo-demo4]

## 2、整理 dubbo-demo 项目的 pom ##

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <packaging>pom</packaging>
    
        <modules>
            <module>dubbo-provider</module>
            <module>dubbo-consumer</module>
            <module>dubbo-api</module>
        </modules>
    
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.5.4</version>
            <relativePath/> 
        </parent>
    
        <groupId>com.demo</groupId>
        <artifactId>dubbo-demo</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>dubbo-demo</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
            <dubbo.version>2.7.3</dubbo.version>
        </properties>
    
        <dependencyManagement>
            <dependencies>
                
                <dependency>
                    <groupId>org.apache.dubbo</groupId>
                    <artifactId>dubbo-spring-boot-starter</artifactId>
                    <version>${dubbo.version}</version>
                </dependency>
            </dependencies>
        </dependencyManagement>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

## 3、创建 dubbo-api、dubbo-server、dubbo-client 子模块 ##

> 以创建 **dubbo-api** 子模块为例，**dubbo-server** 与 **dubbo-client** 创建方式相同。

![05创建dubbo-api0][05_dubbo-api0]

![05创建dubbo-api][05_dubbo-api]

![05创建dubbo-api2][05_dubbo-api2]

![05创建dubbo-api3][05_dubbo-api3]

## 4、目录结构 ##

![05目录结构][05]

## 5、Maven依赖 ##

![05Maven依赖][05Maven]

--------------------

# 二、dubbo-api #

## 1、pom.xml ##

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <parent>
            <groupId>com.demo</groupId>
            <artifactId>dubbo-demo</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </parent>
    
        <groupId>com.demo</groupId>
        <artifactId>dubbo-api</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>dubbo-api</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

## 2、User 类 ##

public class User implements Serializable {
        
    
        private Integer id;
        private String name;
    
    	// set..() & get..()
        // toString()
        
    }

## 3、UserService 接口 ##

public interface UserService {
        
        User selectUserById(Integer id);
    }

--------------------

# 三、dubbo-provider #

## 1、pom.xml ##

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <parent>
            <groupId>com.demo</groupId>
            <artifactId>dubbo-demo</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </parent>
    
        <groupId>com.demo</groupId>
        <artifactId>dubbo-provider</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>dubbo-provider</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            
            <dependency>
                <groupId>com.demo</groupId>
                <artifactId>dubbo-api</artifactId>
                <version>0.0.1-SNAPSHOT</version>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

## 2、application.yml ##

#防止端口冲突
    server:
      port: 8001
    
    dubbo:
      application:
        # 应用名称
        name: provider
      registry:
        # 注册中心地址
        address: multicast://224.5.6.7:1234
        # 超时时间，单位毫秒
        timeout: 6000
      protocol:
        #协议名称
        name: dubbo
        #协议端口
        port: 20880
      scan:
        #扫描包的位置
        base-packages: com.demo.service

## 3、UserServiceImpl ##

import org.apache.dubbo.config.annotation.Service;
    
    @Service(version = "1.0")
    public class UserServiceImpl implements UserService {
        
    
    	@Override
    	public User selectUserById(Integer id) {
        
    		User user = new User();
    		user.setId(id);
    		user.setName("张三");
    		return user;
    	}
    
    }

## 4、DubboProviderApplication ##

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

--------------------

# 四、dubbo-consumer #

## 1、pom.xml ##

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <parent>
            <groupId>com.demo</groupId>
            <artifactId>dubbo-demo</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </parent>
    
        <groupId>com.demo</groupId>
        <artifactId>dubbo-consumer</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>dubbo-consumer</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            
            <dependency>
                <groupId>com.demo</groupId>
                <artifactId>dubbo-api</artifactId>
                <version>0.0.1-SNAPSHOT</version>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

## 2、application.yml ##

#防止端口冲突
    server:
      port: 8002
    
    dubbo:
      application:
        # 应用名称
        name: consumer
      registry:
        # 注册中心地址
        address: multicast://224.5.6.7:1234

## 3、UserInit ##

@Component
    public class UserInit implements CommandLineRunner {
        
    
    	@Reference(version = "1.0",parameters = {
        "unicast","false"})
    	private UserService userService;
    
    	@Override
    	public void run(String... args) throws Exception {
        
    		System.out.println(userService.selectUserById(2));
    	}
    
    }

## 4、DubboConsumerApplication ##

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

--------------------

# 五、测试程序 #

> 先执行 **DubboProviderApplication** *（ 服务提供者程序）*，再执行 **DubboConsumerApplication** *（ 服务消费者程序）*，执行效果如下：

![05DubboProviderApplication][]

![05DubboConsumerApplication][]

--------------------

# 六、程序代码 #

本文代码的下载链接：[https://download.csdn.net/download/sun8112133/24503038][https_download.csdn.net_download_sun8112133_24503038]

*博客中若有不恰当的地方，请您一定要告诉我。前路崎岖，望我们可以互相帮助，并肩前行！*

[https_sunkuan.blog.csdn.net_article_details_120501599]: https://sunkuan.blog.csdn.net/article/details/120501599
[05Multicast]: /images/20220828/1c45a47400a645d3a091d1752fe88ae3.png
[05_dubbo-demo]: /images/20220828/e1b1978dafeb4a36acdd273c5f1e9907.png
[05_dubbo-demo2]: /images/20220828/5bed0e0260bc4071a7c367dbf4e1fa13.png
[05_dubbo-demo3]: /images/20220828/abd12f7c879d45118a2819ff56936fa7.png
[05_dubbo-demo4]: /images/20220828/645d370c00cd4121ae5a6f41c633a3bb.png
[05_dubbo-api0]: /images/20220828/a5dd1c92bb104407a0f7e993e98aaa08.png
[05_dubbo-api]: /images/20220828/279b444d67cf4a92bdc93bf609ddbad7.png
[05_dubbo-api2]: /images/20220828/50eb2e8fe2b74824ac81f227ba6cd5f5.png
[05_dubbo-api3]: /images/20220828/769387d9edc54c658d341ff47523c30f.png
[05]: /images/20220828/1c06760b8ec7497e9a8fde221695e9bf.png
[05Maven]: /images/20220828/fbbd9efb8ee84ae391ec06c752d67430.png
[05DubboProviderApplication]: /images/20220828/94eaf7f874654c44abac59a2e56d742c.png
[05DubboConsumerApplication]: /images/20220828/032537d2ec644158899d201aedafc797.png
[https_download.csdn.net_download_sun8112133_24503038]: https://download.csdn.net/download/sun8112133/24503038