SpringBoot整合dubbo（xml配置dubbo）

Love The Way You Lie 2022-01-05 04:41 453阅读 0赞

源码

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

准备

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-dubbo02

项目目录结构如下图：
在这里插入图片描述
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-dubbo02-api-web</module>
  9.     <module>springboot-dubbo02-service-impl</module>
  10.     <module>springboot-dubbo02-service</module>
  11. </modules>
  • 新建模块，命名为springboot-dubbo02–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-dubbo02-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>com.alibaba</groupId>
  37.         <artifactId>dubbo</artifactId>
  38.         <version>2.5.3</version>
  39.         <exclusions>
  40.             <exclusion>
  41.                 <groupId>org.springframework</groupId>
  42.                 <artifactId>spring</artifactId>
  43.             </exclusion>
  44.         </exclusions>
  45.     </dependency>
  46.     <!-- zookeeper -->
  47.     <dependency>
  48.         <groupId>org.apache.zookeeper</groupId>
  49.         <artifactId>zookeeper</artifactId>
  50.         <version>3.4.6</version>
  51.         <exclusions>
  52.             <exclusion>
  53.                 <groupId>org.slf4j</groupId>
  54.                 <artifactId>slf4j-log4j12</artifactId>
  55.             </exclusion>
  56.             <exclusion>
  57.                 <groupId>log4j</groupId>
  58.                 <artifactId>log4j</artifactId>
  59.             </exclusion>
  60.         </exclusions>
  61.     </dependency>
  62.     <dependency>
  63.         <groupId>com.github.sgroschupf</groupId>
  64.         <artifactId>zkclient</artifactId>
  65.         <version>0.1</version>
  66.     </dependency>
  67.     <!-- 项目依赖 -->
  68.     <dependency>
  69.         <groupId>com.wyj</groupId>
  70.         <artifactId>springboot-dubbo02-service</artifactId>
  71.         <version>0.0.1-SNAPSHOT</version>
  72.     </dependency>
  73.     <!-- 日志 -->
  74.     <dependency>
  75.         <groupId>org.slf4j</groupId>
  76.         <artifactId>slf4j-log4j12</artifactId>
  77.     </dependency>
  78. </dependencies>
  80. <build>
  81.     <finalName>springboot-dubbo02-service-impl</finalName>
  82.     <plugins>
  83.         <plugin>
  84.             <groupId>org.springframework.boot</groupId>
  85.             <artifactId>spring-boot-maven-plugin</artifactId>
  86.         </plugin>
  87.     </plugins>
  88. </build>

dubbo-provider.xml：

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
  3.     <!-- 提供方应用信息，用于计算依赖关系 -->
  4.     <dubbo:application name="${dubbo.application.name}"/>
  5.     <!-- 使用zookeeper注册中心暴露服务地址 -->
  6.     <dubbo:registry id="register" address="${dubbo.registry.address}"/>
  7.     <dubbo:registry id="local" address="zookeeper://127.0.0.1:2181"/>
  8.     <!-- 用dubbo协议在20880端口暴露服务 -->
  9.     <dubbo:protocol name="${dubbo.protocol.name}" port="${dubbo.protocol.port}"/>
  11.     <!-- 声明需要暴露的服务接口（注意是接口,不是实现类） -->
  12.     <!-- 这里是具体实现类,id和上面的暴露的服务接口ref要一致,dubbo就是通过这个来注册对应的服务 -->
  13.     <!-- 同模块的registry使用local，不同模块的使用远程的register -->
  14.     <dubbo:service registry="register" interface="com.wyj.service.DemoService" ref="demoService"/>
  16.     <!-- 消费dubbo服务 -->
  17.     <!--<dubbo:reference registry="register" interface="" id=""/>-->
  18. </beans>

DemoServiceImpl：

这个@Service是spring提供的注解

  1. @Service("demoService")
  2. public class DemoServiceImpl implements DemoService { 
  3.     @Autowired
  4.     private DemoMapper demoMapper;
  6.     @Override
  7.     public List<Message> findMessage() { 
  8.         return demoMapper.findMessage();
  9.     }
  10. }

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

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

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

  1. <parent>
  2.     <groupId>com.wyj</groupId>
  3.     <artifactId>springboot-dubbo02</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>
  14.     <!-- springboor-->
  15.     <dependency>
  16.         <groupId>org.springframework.boot</groupId>
  17.         <artifactId>spring-boot-starter-web</artifactId>
  18.     </dependency>
  19.     <dependency>
  20.         <groupId>org.springframework.boot</groupId>
  21.         <artifactId>spring-boot-starter</artifactId>
  22.     </dependency>
  23.     <dependency>
  24.         <groupId>org.springframework.boot</groupId>
  25.         <artifactId>spring-boot-starter-test</artifactId>
  26.         <scope>test</scope>
  27.     </dependency>
  29.     <!-- dubbo -->
  30.     <dependency>
  31.         <groupId>com.alibaba</groupId>
  32.         <artifactId>dubbo</artifactId>
  33.         <version>2.5.3</version>
  34.         <exclusions>
  35.             <exclusion>
  36.                 <groupId>org.springframework</groupId>
  37.                 <artifactId>spring</artifactId>
  38.             </exclusion>
  39.         </exclusions>
  40.     </dependency>
  42.     <!-- zookeeper -->
  43.     <dependency>
  44.         <groupId>org.apache.zookeeper</groupId>
  45.         <artifactId>zookeeper</artifactId>
  46.         <version>3.4.6</version>
  47.         <exclusions>
  48.             <exclusion>
  49.                 <groupId>org.slf4j</groupId>
  50.                 <artifactId>slf4j-log4j12</artifactId>
  51.             </exclusion>
  52.             <exclusion>
  53.                 <groupId>log4j</groupId>
  54.                 <artifactId>log4j</artifactId>
  55.             </exclusion>
  56.         </exclusions>
  57.     </dependency>
  58.     <dependency>
  59.         <groupId>com.github.sgroschupf</groupId>
  60.         <artifactId>zkclient</artifactId>
  61.         <version>0.1</version>
  62.     </dependency>
  64.     <!-- 项目依赖 -->
  65.     <dependency>
  66.         <groupId>com.wyj</groupId>
  67.         <artifactId>springboot-dubbo02-service</artifactId>
  68.         <version>0.0.1-SNAPSHOT</version>
  69.     </dependency>
  70. </dependencies>
  72. <build>
  73.     <finalName>springboot-dubbo02-api-web</finalName>
  74.     <plugins>
  75.         <plugin>
  76.             <groupId>org.springframework.boot</groupId>
  77.             <artifactId>spring-boot-maven-plugin</artifactId>
  78.         </plugin>
  79.     </plugins>
  80. </build>

dubbo-consumer.xml：

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
  3.     <!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->
  4.     <dubbo:application name="${dubbo.application.name}"/>
  5.     <dubbo:registry id="register" address="${dubbo.registry.address}"/>
  6.     <dubbo:registry id="local" address="zookeeper://127.0.0.1:2181"/>
  7.     <dubbo:protocol name="${dubbo.protocol.name}"/>
  8.     <!-- 生成远程服务代理，可以和本地bean一样调用 -->
  9.     <!-- 同模块的registry使用local，不同模块的使用远程的register -->
  10.     <dubbo:reference registry="register" id="demoService" interface="com.wyj.service.DemoService"/>
  12. </beans>

DemoController：

  1. @RestController
  2. public class DemoController { 
  3.     @Autowired
  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. dubbo.application.name=demo-consumer
  5. dubbo.registry.address=zookeeper://127.0.0.1:2181
  6. dubbo.protocol.name=dubbo

测试

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

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

查看监控中心

  • 访问dubbo-admin

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

发表评论

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

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

相关阅读

    相关 springboot整合dubbo

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

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

    相关 SpringBoot整合dubbo

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

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