springboot整合dubbo的简单案例

来源：cnblogs　　作者：那个帅气的程序猿　　时间：2019/6/6 9:21:52　　对本文有异议

使用框架：

　　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

坐标：

<groupId>com.example</groupId>
<artifactId>spring-boot-demo-dubbo-interface</artifactId>
<version>0.0.1-SNAPSHOT</version>

添加spring-data-jpa 依赖：

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>

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

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

<dependency>
<groupId>com.alibaba.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>0.2.0</version>
</dependency>

二、开发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>
        
        
        <!-- 加入springboot与dubbo集成的起步依赖 -->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>
 
        <!-- 由于使用了zookeeper作为注册中心，则需要加入zookeeper的客户端jar包： -->
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.10</version>
        </dependency>
        
        <!-- spring-data-jpa -->
        <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的信息：

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
# WEB\u670D\u52A1\u7AEF\u53E3
server.port=8081
# dubbo\u914D\u7F6E
dubbo.application.name=springboot-dubbo-consumer
dubbo.registry.address=zookeeper://192.168.146.128:2181

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

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

原文链接：http://www.cnblogs.com/qq99514925/p/10980041.html

友情链接：直通硅谷　点职佳　北美留学生论坛

Spring Boot热门文章

史上最详 Thymeleaf 使用教程

Spring Boot如何通过java -jar启动

Spring Boot 2.x（六）：优雅的统一返回值

Springboot使用Logback实现日志配置与异常记录

使用SpringBoot+EasyExcel+Vue实现excel表格的导入和导出详解

spring boot上传文件超出大小异常无法捕获问题

paging组件的用法和意义

springboot2.0集成rabbitmq的示例代码

Spring MVC学习step1——框架熟悉

spring boot ${}占位符不起作用的解决方案

Spring Boot推荐文章

3分钟带你搞定Spring Boot中Schedule

不单独部署注册中心，又要具备注册中心的功能，我能上天！

从零开始学Spring Boot系列-集成Spring Security实现用户认证与授权

不单独部署注册中心，又要具备注册中心的功能，咋不让我上天？

EasyExcel 无法读取图片？用poi写了一个工具类

【进阶篇】使用 Stream 流对比两个集合的常用操作分享

关于DDD和COLA的一些总结和思考

SnakeYaml反序列化分析

RestTemplate进行https请求时适配信任证书

Kryo反序列化链分析