springboot整合dubbo的简单案例

超、凢脫俗 2022-10-01 06:56 192阅读 0赞

**使用框架：**

jdk 1.8

springboot-2.1.3

dubbo-2.6

spring-data-jpa-2.1.5

**一、开发dubbo服务接口：**

按照Dubbo官方开发建议，创建一个接口项目，该项目只定义接口和model类；

1、创建springboot工程 spring-boot-demo-dubbo-interface

坐标：

com.example  
spring-boot-demo-dubbo-interface  
0.0.1-SNAPSHOT

添加spring-data-jpa 依赖：

org.springframework.boot spring-boot-starter-data-jpa

2、创建model

package com.example.demo.model;
    
    @Entity
    public class User implements Serializable{
        private static final long serialVersionUID = 1L;
        
        @Id @GeneratedValue
        private long id;
        private String userName;
        private String password;
        private int age;
        public long getId() {
            return id;
        }
    //省略set get 方法

3、创建接口：

package com.example.demo.service;
    
    import com.example.demo.model.User;
    
    public interface UserService {
        
        public void save(User user);
        
        public String sayHello(String word);
    }

4、使用命令  clean install   打包安装到maven仓库。

阿里巴巴提供的dubbo集成springboot开源项目；

参考文档：

**[https://github.com/apache/dubbo-spring-boot-project/blob/0.2.x/README\_CN.md][https_github.com_apache_dubbo-spring-boot-project_blob_0.2.x_README_CN.md]**

本工程采用该项目的jar包进行继承：

com.alibaba.boot dubbo-spring-boot-starter 0.2.0

**二、开发dubbo服务提供者:**

1、创建一个Springboot项目spring-boot-demo-dubbo-provider并配置好相关的依赖；

pom.xml

<dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            
            
            
            <dependency>
                <groupId>com.alibaba.boot</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>0.2.0</version>
            </dependency>
    
            
            <dependency>
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>0.10</version>
            </dependency>
            
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-jpa</artifactId>
            </dependency>
    
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <scope>runtime</scope>
            </dependency>
            
            
            <dependency>
                <groupId>com.example</groupId>
                <artifactId>spring-boot-demo-dubbo-interface</artifactId>
                <version>0.0.1-SNAPSHOT</version>
            </dependency>
        </dependencies>

2、在Springboot的核心配置文件application.properties中配置dubbo的信息：

spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
    spring.datasource.url=jdbc:mysql://localhost:3306/test?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=true
    spring.datasource.username=root
    spring.datasource.password=root
    
    spring.jpa.properties.hibernate.hbm2ddl.auto=create
    spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL5InnoDBDialect
    spring.jpa.properties.hibernate.format_sql=true
    spring.jpa.show-sql=true
    
    # 访问端口
    server.port=8080
    # dubbo配置
    dubbo.application.name=springboot-dubbo-provider
    dubbo.registry.address=zookeeper://192.168.146.128:2181

3、开发编写Dubbo的接口实现类：

package com.example.demo.service;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    import com.alibaba.dubbo.config.annotation.Service;
    import com.example.demo.model.User;
    import com.example.demo.repository.UserRepository;
    
    @Component //注册为spring bean
    @Service // 这注解是dubbo提供的 
    public class UserServiceImpl implements UserService {
        
        @Autowired
        private UserRepository userRepository;
    
        @Override
        public void save(User user) {
            userRepository.save(user);
        }
    
        @Override
        public String sayHello(String word) {
            return word;
        }
    }

4、入口main程序启动Dubbo服务提供者：添加注解 @EnableDubbo

package com.example.demo;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
    
    @SpringBootApplication
    @EnableDubbo
    public class SpringBootDemoDubboProviderApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(SpringBootDemoDubboProviderApplication.class, args);
        }
    
    }

启动main ，服务发布到zookeeper 注册中心。

**三、开发dubbo服务消费者：**

1、创建一个Springboot项目spring-boot-demo-dubbo-consumer并配置好相关的依赖；

2、加入springboot与dubbo集成的起步依赖：(pom.xml 配置同上)

\*\* 注意： 服务提供者 和 消费者都要配置 服务接口依赖\*\*

3、在Springboot的核心配置文件application.properties中配置dubbo的信息：

4、编写一个Controller类，调用远程的Dubbo服务：

package com.example.demo.controller;
    
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import com.alibaba.dubbo.config.annotation.Reference;
    import com.example.demo.model.User;
    import com.example.demo.service.UserService;
    
    @RestController
    public class UserController {
        
        @Reference //该注解是dubbo提供的
        private UserService userService;
        
        @RequestMapping("/say")
        public String sayHello(String name) {
            return userService.sayHello(name);
        }
        
        @RequestMapping("/save")
        public void save() {
            User u = new User();
            u.setAge(20);
            u.setPassword("123");
            u.setUserName("zheng");
            userService.save(u);
        }
    }

5、启动类添加 开启dubbo 注解 @EnableDubbo

package com.example.demo;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
    
    @SpringBootApplication
    @EnableDubbo
    public class SpringBootDemoDubboConsumerApplication {
        public static void main(String[] args) {
            SpringApplication.run(SpringBootDemoDubboConsumerApplication.class, args);
        }
    }

6、启动main方法。

7、调用远程接口：

[http://localhost:8081/say?name=hello][http_localhost_8081_say_name_hello]

一个简单的springboot基于dubbo的服务接口开发完成。

[https_github.com_apache_dubbo-spring-boot-project_blob_0.2.x_README_CN.md]: https://github.com/apache/dubbo-spring-boot-project/blob/0.2.x/README_CN.md
[http_localhost_8081_say_name_hello]: http://localhost:8081/say?name=hello