SpringBoot整合dubbo（注解配置dubbo）

爱被打了一巴掌 2022-01-05 04:23 468阅读 0赞

源码

GitHub：https://github.com/291685399/springboot-learning/tree/master/springboot-dubbo01

准备

1、在服务器或者本地搭建好zookeeper，具体可参考文章：https://blog.csdn.net/qq\_35620501/article/details/87519306
2、在服务器或者本地搭建好dubbo-admin，具体可参考文章：https://blog.csdn.net/qq\_35620501/article/details/89037354

代码

  • 新建空的maven工程，命名为springboot-dubbo01

项目目录结构如下图：
在这里插入图片描述
pom.xml：

  1. <parent>
  2.     <groupId>org.springframework.boot</groupId>
  3.     <artifactId>spring-boot-starter-parent</artifactId>
  4.     <version>2.0.0.RELEASE</version>
  5. </parent>
  7. <modules>
  8.     <module>springboot-dubbo01-api-web</module>
  9.     <module>springboot-dubbo01-service-impl</module>
  10.     <module>springboot-dubbo01-service</module>
  11. </modules>
  • 新建模块，命名为springboot-dubbo01–service

service主要是用来存放在实体类、Enum、工具类、service等

项目结构如下图：
在这里插入图片描述
DemoService：

  1. public interface DemoService { 
  2.     public List<Message> findMessage();
  3. }

Message:

  1. public class Message implements Serializable { 
  2.     private int id;
  3.     private String city;
  4.     private String time;
  5.     private String weather;
  7.     public Message() { }
  8.     public int getId() { return id;}
  9.     public void setId(int id) { this.id = id;}
  10.     public String getCity() { return city;}
  11.     public void setCity(String city) { this.city = city;}
  12.     public String getTime() { return time;}
  13.     public void setTime(String time) { this.time = time;}
  14.     public String getWeather() { return weather;}
  15.     public void setWeather(String weather) { this.weather = weather;}
  16. }

ApiResponse：

  1. public class ApiResponse implements Serializable { 
  2.     private int code;
  3.     private String msg;
  4.     private Object data;
  6.     public ApiResponse() { }
  7.     public ApiResponse(int code, String msg) { 
  8.         this.code = code;
  9.         this.msg = msg;
  10.     }
  11.     public ApiResponse(int code, String msg, Object data) { 
  12.         this.code = code;
  13.         this.msg = msg;
  14.         this.data = data;
  15.     }
  16.     public int getCode() { return code;}
  17.     public void setCode(int code) { this.code = code;}
  18.     public String getMsg() { return msg;}
  19.     public void setMsg(String msg) { this.msg = msg;}
  20.     public Object getData() { return data;}
  21.     public void setData(Object data) { this.data = data;}
  22. }
  • 新建模块，命名为springboot-dubbo01-service-impl

service-impl主要是存放service接口实现类、持久层的实现

项目结构如下图：
在这里插入图片描述
pom.xml：

  1. <parent>
  2.     <groupId>com.wyj</groupId>
  3.     <artifactId>springboot-dubbo01</artifactId>
  4.     <version>0.0.1-SNAPSHOT</version>
  5. </parent>
  7. <dependencies>
  8.     <!-- mybatis -->
  9.     <dependency>
  10.         <groupId>org.mybatis.spring.boot</groupId>
  11.         <artifactId>mybatis-spring-boot-starter</artifactId>
  12.         <version>2.0.1</version>
  13.     </dependency>
  14.     <!-- mysql -->
  15.     <dependency>
  16.         <groupId>mysql</groupId>
  17.         <artifactId>mysql-connector-java</artifactId>
  18.         <scope>runtime</scope>
  19.     </dependency>
  20.     <!-- springboot -->
  21.     <dependency>
  22.         <groupId>org.springframework.boot</groupId>
  23.         <artifactId>spring-boot-starter-test</artifactId>
  24.         <scope>test</scope>
  25.     </dependency>
  26.     <dependency>
  27.         <groupId>org.springframework.boot</groupId>
  28.         <artifactId>spring-boot-starter</artifactId>
  29.     </dependency>
  30.     <dependency>
  31.         <groupId>org.springframework.boot</groupId>
  32.         <artifactId>spring-boot-starter-web</artifactId>
  33.     </dependency>
  34.     <!-- dubbo -->
  35.     <dependency>
  36.         <groupId>io.dubbo.springboot</groupId>
  37.         <artifactId>spring-boot-starter-dubbo</artifactId>
  38.         <version>1.0.0</version>
  39.     </dependency>
  40.     <!-- 项目依赖 -->
  41.     <dependency>
  42.         <groupId>com.wyj</groupId>
  43.         <artifactId>springboot-dubbo01-service</artifactId>
  44.         <version>0.0.1-SNAPSHOT</version>
  45.     </dependency>
  46.     <!-- 日志 -->
  47.     <dependency>
  48.         <groupId>org.slf4j</groupId>
  49.         <artifactId>slf4j-api</artifactId>
  50.         <version>1.7.25</version>
  51.     </dependency>
  52.     <dependency>
  53.         <groupId>org.slf4j</groupId>
  54.         <artifactId>log4j-over-slf4j</artifactId>
  55.     </dependency>
  56. </dependencies>
  58. <build>
  59.     <finalName>springboot-dubbo01-service-impl</finalName>
  60.     <plugins>
  61.         <plugin>
  62.             <groupId>org.springframework.boot</groupId>
  63.             <artifactId>spring-boot-maven-plugin</artifactId>
  64.         </plugin>
  65.     </plugins>
  66. </build>

DemoServiceImpl：

  1. @Service(timeout = 6000)//这个service是dubbo的service
  2. public class DemoServiceImpl implements DemoService { 
  4.     @Autowired
  5.     private DemoMapper demoMapper;
  7.     @Override
  8.     public List<Message> findMessage() { 
  9.         return demoMapper.findMessage();
  10.     }
  11. }

DemoMapper：

  1. public interface DemoMapper { 
  2.     public List<Message> findMessage();
  3. }

DemoMappe.xml：

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
  3. <mapper namespace="com.wyj.mapper.DemoMapper">
  4.     <select id="findMessage" resultType="com.wyj.entity.po.Message">
  5.         select * from message
  6.     </select>
  7. </mapper>

application.properties：

  1. # tomcat
  2. server.port=8081
  3. # dubbo
  4. spring.dubbo.application.name=demo-provider
  5. spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
  6. spring.dubbo.protocol.name=dubbo
  7. spring.dubbo.protocol.port=20880
  8. spring.dubbo.scan=com.wyj.service.impl
  9. # dataBase
  10. spring.datasource.driver-class-name=com.mysql.jdbc.Driver
  11. spring.datasource.url=jdbc:mysql://127.0.0.1:3306/springboot-dubbo01?allowMultiQueries=true&useUnicode=true&useSSL=false&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull
  12. spring.datasource.username=root
  13. spring.datasource.password=root
  14. spring.datasource.max-idle=10
  15. spring.datasource.max-wait=10000
  16. spring.datasource.min-idle=5
  17. spring.datasource.initial-size=5
  18. # mybatis
  19. mybatis.mapper-locations=classpath:mapper/*.xml
  • 新建模块，命名为springboot-dubbo01-api-web

api主要是用来存放controller、handler、interceptor

项目结构如下图：
在这里插入图片描述
pom.xml：

  1. <parent>
  2.     <groupId>com.wyj</groupId>
  3.     <artifactId>springboot-dubbo01</artifactId>
  4.     <version>0.0.1-SNAPSHOT</version>
  5. </parent>
  7. <dependencies>
  8.     <!-- thymeleaf -->
  9.     <dependency>
  10.         <groupId>org.springframework.boot</groupId>
  11.         <artifactId>spring-boot-starter-thymeleaf</artifactId>
  12.     </dependency>
  13.     <!-- springboor-->
  14.     <dependency>
  15.         <groupId>org.springframework.boot</groupId>
  16.         <artifactId>spring-boot-starter-web</artifactId>
  17.     </dependency>
  18.     <dependency>
  19.         <groupId>org.springframework.boot</groupId>
  20.         <artifactId>spring-boot-starter</artifactId>
  21.     </dependency>
  22.     <dependency>
  23.         <groupId>org.springframework.boot</groupId>
  24.         <artifactId>spring-boot-starter-test</artifactId>
  25.         <scope>test</scope>
  26.     </dependency>
  27.     <!-- dubbo -->
  28.     <dependency>
  29.         <groupId>io.dubbo.springboot</groupId>
  30.         <artifactId>spring-boot-starter-dubbo</artifactId>
  31.         <version>1.0.0</version>
  32.     </dependency>
  33.     <!-- 项目依赖，去除springboot整合mybatis的jar包原因是该jar包中会自动注入sqlsession，需要在api层配置DataSource相关参数 -->
  34.     <dependency>
  35.         <groupId>com.wyj</groupId>
  36.         <artifactId>springboot-dubbo01-service-impl</artifactId>
  37.         <version>0.0.1-SNAPSHOT</version>
  38.         <exclusions>
  39.             <exclusion>
  40.                 <groupId>org.mybatis.spring.boot</groupId>
  41.                 <artifactId>mybatis-spring-boot-starter</artifactId>
  42.             </exclusion>
  43.             <exclusion>
  44.                 <groupId>mysql</groupId>
  45.                 <artifactId>mysql-connector-java</artifactId>
  46.             </exclusion>
  47.         </exclusions>
  48.     </dependency>
  49. </dependencies>
  51. <build>
  52.     <finalName>springboot-dubbo01-api-web</finalName>
  53.     <plugins>
  54.         <plugin>
  55.             <groupId>org.springframework.boot</groupId>
  56.             <artifactId>spring-boot-maven-plugin</artifactId>
  57.         </plugin>
  58.     </plugins>
  59. </build>

DemoController：

注意：

这里不能使用@Autowired注入bean，要使用dubbo中的注解@Reference注入bean和dubbo接口

  1. @RestController
  2. public class DemoController { 
  3.     @Reference
  4.     private DemoService demoService;
  6.     @RequestMapping(value = "/query")
  7.     public ApiResponse demo() { 
  8.         try { 
  9.             List<Message> messageList = demoService.findMessage();
  10.             return new ApiResponse(200, "操作成功", messageList);
  11.         } catch (Exception e) { 
  12.             e.printStackTrace();
  13.             return new ApiResponse(500, "系统异常");
  14.         }
  15.     }
  16. }

application.properties：

  1. # tomcat
  2. server.port=8080
  3. # dubbo
  4. spring.dubbo.application.name=demo-consumer
  5. spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
  6. spring.dubbo.scan=com.wyj.controller

测试

  • 先运行service-impl的服务，再启动api的服务，原则上是先启动service-impl的
  • 访问

浏览器访问：http://127.0.0.1:8080/query
在这里插入图片描述

查看监控中心

  • 访问dubbo-admin

在这里插入图片描述
点击服务治理中的服务
在这里插入图片描述
从监控中心可以看到com.wyj.service.DemoService这个接口能够正常注册到zookeeper中，并被api给消费

发表评论

表情：
评论列表 （有 0 条评论，468人围观）

还没有评论，来说两句吧...

相关阅读

    相关 springboot整合dubbo

    本文主要通过代码示例来说明springboot和dubbo的整合方式 以下是核心代码示例，其他的资源整合配置和spring+Dubbo相同 声明下：dubbo网址在下面配

    心已赠人心已赠人/ 0 赞/ 374 阅读

    相关 SpringBoot整合dubbo

    1.什么是Dubbo Dubbo是Alibaba开源的分布式服务框架，它最大的特点是按照分层的方式来架构，使用这种方式可以使各个层之间解耦合（或者最大限度地松耦合）。从服

    女爷i女爷i/ 0 赞/ 1124 阅读