SpringBoot整合dubbo（一）

第一次整合，使用无注册中心方式

一、首先，项目分为三个模块，如下图，dubbo-interface（要发布的接口）、dubbo-provider（接口的具体实现，服务提供者）、dubbo-consumer（客户端，服务消费者）

二、dubbo-interface模块，普通的springboot项目，只需要写接口，即需要向外提供的服务接口

如上图中的UserService。

三、dubbo-provider模块，它是dubbo-interface模块中接口的具体实现，服务提供者。

3.1、pom.xml文件

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--接口模块-->
        <dependency>
            <groupId>com.xice.dubbo</groupId>
            <artifactId>dubbo-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <!--引入dubbo-->
        <dependency>
            <groupId>io.dubbo.springboot</groupId>
            <artifactId>spring-boot-starter-dubbo</artifactId>
            <version>1.0.0</version>
        </dependency>

3.2、application.properties文件，配置dubbo

server.port=8080
spring.dubbo.application.name=dubbo-provider
# N/A表示不使用注册中心
spring.dubbo.registry.address=N/A
# dubbo协议
spring.dubbo.protocol.name=dubbo
# duboo端口号
spring.dubbo.protocol.port=20882
# 发布到dubbo的接口所在包位置
spring.dubbo.scan=com.xice.dubbo

3.3、接口具体实现

/**
 * @author xice
 * @date 2022-11-14
 */
@Service(version = "1.0.0")
public class UserServiceImpl implements UserService {

    SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");

    @Override
    public String say(String username, String msg) {
        return username + " say: "+msg+"  --"+dateFormat.format(new Date());
    }
}

四、dubbo-consumer客户端，服务消费者。

4.1、pom.xml文件与服务端一样，需要引入dubbo-interface模块、dubbo

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.xice.dubbo</groupId>
            <artifactId>dubbo-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>io.dubbo.springboot</groupId>
            <artifactId>spring-boot-starter-dubbo</artifactId>
            <version>1.0.0</version>
        </dependency>

4.2、application.properties文件，配置dubbo，spring.dubbo.scan包可不完全一样，比如

• 服务端配置spring.dubbo.scan=com，客户端配置com、com.xice、com.xice.dubbo都可以
• 服务端配置spring.dubbo.scan=com.xice.dubbo，客户端配置com、com.xice、com.xice.dubbo也都可以
• 但是如果服务端配置spring.dubbo.scan=com.xice.dubbo，客户端配置cn、cn.xice等不行，即一级目录必须相同

# 应用名称
server.port=8099
spring.dubbo.application.name=dubbo-consumer
# N/A表示不使用注册中心
spring.dubbo.registry.address=N/A
# 发布到dubbo的接口所在包位置
spring.dubbo.scan=com.xice.dubbo

4.3、调用服务，注入UserService时不是使用SpringBoot中的@Autowired，而是使用@Reference （com.alibaba.dubbo.config.annotation.Reference），其中version为dubbo-provider服务中的版本号，url为服务提供者的ip和配置的端口号

/**
 * @author xice
 * @date 2022-11-15
 */
@RestController
public class UserController {

    @Reference(version = "1.0.0",url = "dubbo://127.0.0.1:20882")
    UserService userService;

    @RequestMapping("say")
    public String say(){
        String say = userService.say("admin", "早上好");
        System.out.println(say);
        return say;
    }
}

五、先启动dubbo-provider、再启动dubbo-consumer，需要按顺序启动！如果先启动客户端就无法调用到服务。启动后访问客户端http://localhost:8099/say