Spring Boot中使用Dubbo

高并发下Redis会出现的问题：

  • 缓存穿透
  • 缓存雪崩
  • 热点缓存

一、定义commons工程11-dubboCommons

（1） 创建工程

创建Maven的Java工程，并命名为11-dubboCommons

（2） 定义pom文件

  1. <groupId>com.abc</groupId>
  2. <artifactId>11-dubboCommons</artifactId>
  3. <version>1.0-SNAPSHOT</version>
  4.  
  5. <properties>
  6. 	<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  7. 	<maven.compiler.source>1.8</maven.compiler.source>
  8. 	<maven.compiler.target>1.8</maven.compiler.target>
  9. </properties>
  10.  
  11. <dependencies>
  12. 	<dependency>
  13. 		<groupId>org.projectlombok</groupId>
  14. 		<artifactId>lombok</artifactId>
  15. 		<version>1.18.4</version>
  16. 		<scope>provided</scope>
  17. 	</dependency>
  18. </dependencies>

（3） 定义实体类

（4） 定义业务接口

（5） 将工程安装到本地库

运行Maven的install命令，将工程安装到本地版本库，以备其它工程使用

二、定义提供者11-provider-springboot

（1） 创建工程

创建一个Spring Boot工程，并重命名为11-provider-springboot

（2） 定义pom文件

A、添加dubbo与spring boot整合依赖
B、添加zkClient依赖
C、其它依赖

  • dubboCommons依赖
  • spring boot与redis整合依赖
  • mybatis与spring boot整合依赖
  • 数据源Druid依赖
  • mysql驱动依赖
  • slf4j-log4j12依赖
  • spring-boot-starter-web依赖
  1. <groupId>com.abc</groupId>
  2.     <artifactId>11-provider-springboot</artifactId>
  3.     <version>0.0.1-SNAPSHOT</version>
  4.  
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.1.5.RELEASE</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.  
  12.     <properties>
  13.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  14.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  15.         <java.version>1.8</java.version>
  16.     </properties>
  17.  
  18.     <dependencies>
  19.         <!--dubbo与spring boot整合依赖-->
  20.         <dependency>
  21.             <groupId>com.alibaba.spring.boot</groupId>
  22.             <artifactId>dubbo-spring-boot-starter</artifactId>
  23.             <version>2.0.0</version>
  24.         </dependency>
  25.         <!-- zk客户端依赖：zkclient -->
  26.         <dependency>
  27.             <groupId>com.101tec</groupId>
  28.             <artifactId>zkclient</artifactId>
  29.             <version>0.10</version>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>com.abc</groupId>
  33.             <artifactId>11-dubboCommons</artifactId>
  34.             <version>1.0-SNAPSHOT</version>
  35.         </dependency>
  36.         <!--Spring Boot与Redis整合依赖-->
  37.         <dependency>
  38.             <groupId>org.springframework.boot</groupId>
  39.             <artifactId>spring-boot-starter-data-redis</artifactId>
  40.         </dependency>
  41.         <!--mybatis与Spring Boot整合依赖-->
  42.         <dependency>
  43.             <groupId>org.mybatis.spring.boot</groupId>
  44.             <artifactId>mybatis-spring-boot-starter</artifactId>
  45.             <version>1.3.2</version>
  46.         </dependency>
  47.         <!--数据源Druid依赖-->
  48.         <dependency>
  49.             <groupId>com.alibaba</groupId>
  50.             <artifactId>druid</artifactId>
  51.             <version>1.1.10</version>
  52.         </dependency>
  53.         <!--MySQL驱动依赖-->
  54.         <dependency>
  55.             <groupId>mysql</groupId>
  56.             <artifactId>mysql-connector-java</artifactId>
  57.             <version>5.1.47</version>
  58.         </dependency>
  59.         <dependency>
  60.             <groupId>org.slf4j</groupId>
  61.             <artifactId>slf4j-log4j12</artifactId>
  62.             <version>1.7.25</version>
  63.             <scope>test</scope>
  64.         </dependency>
  65.         <dependency>
  66.             <groupId>org.springframework.boot</groupId>
  67.             <artifactId>spring-boot-starter-web</artifactId>
  68.         </dependency>
  69.         <dependency>
  70.             <groupId>org.springframework.boot</groupId>
  71.             <artifactId>spring-boot-starter-test</artifactId>
  72.             <scope>test</scope>
  73.         </dependency>
  74.     </dependencies>
  75.  
  76.     <build>
  77.         <plugins>
  78.             <plugin>
  79.                 <groupId>org.springframework.boot</groupId>
  80.                 <artifactId>spring-boot-maven-plugin</artifactId>
  81.             </plugin>
  82.         </plugins>
  83.  
  84.         <resources>
  85.             <!--注册dao包下mybatis映射文件为资源目录-->
  86.             <resource>
  87.                 <directory>src/main/java</directory>
  88.                 <includes>
  89.                     <include>**/*.xml</include>
  90.                 </includes>
  91.             </resource>
  92.         </resources>
  93.     </build>

（3） 定义Service实现类

  1. import com.abc.bean.Employee;
  2. import com.abc.dao.EmployeeDao;
  3. import com.alibaba.dubbo.config.annotation.Service;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.cache.annotation.CacheEvict;
  6. import org.springframework.cache.annotation.Cacheable;
  7. import org.springframework.data.redis.core.BoundValueOperations;
  8. import org.springframework.data.redis.core.RedisTemplate;
  9. import org.springframework.stereotype.Component;
  10. import org.springframework.transaction.annotation.Transactional;
  11.  
  12. import java.util.concurrent.TimeUnit;
  13.  
  14. @Service   // Dubbo的注解  <dubbo:service/>
  15. @Component
  16. public class EmployeeServiceImpl implements EmployeeService {
  17.     @Autowired
  18.     private EmployeeDao dao;
  19.     @Autowired
  20.     private RedisTemplate<Object, Object> redisTemplate;
  21.  
  22.     // 当有对象插入时会清空realTimeCache缓存空间
  23.     @CacheEvict(value="realTimeCache", allEntries = true)
  24.     @Transactional(rollbackFor = Exception.class)
  25.     @Override
  26.     public void addEmployee(Employee employee) {
  27.         dao.insertEmployee(employee);
  28.     }
  29.  
  30.     // 一旦有了查询结果，则会将此结果写入到realTimeCache缓存
  31.     // key是employee_加上方法参数
  32.     @Cacheable(value = {"realTimeCache"}, key = "'employee_'+#id")
  33.     @Override
  34.     public Employee findEmployeeById(int id) {
  35.         // 从DB查询
  36.         System.out.println("从DB查询id = " + id);
  37.         return dao.selectEmployeeById(id);
  38.     }
  39.  
  40.     private volatile Object count;
  41.     // 双重检测锁机制解决Reids的热点缓存问题
  42.     @Override
  43.     public Integer findEmployeeCount() {
  44.         // 获取Redis操作对象
  45.         BoundValueOperations<Object, Object> ops = redisTemplate.boundValueOps("count");
  46.         // 从缓存获取数据
  47.         count = ops.get();
  48.         if(count == null) {
  49.            synchronized (this) {
  50.                 count = ops.get();
  51.                 if(count == null) {
  52.                     System.out.println("从DB中查询");
  53.                     // 从DB中查询
  54.                     count = dao.selectEmployeeCount();
  55.                     // 将查询结果存放到Redis
  56.                     ops.set(count, 10, TimeUnit.SECONDS);
  57.                 }
  58.             }
  59.         }
  60.         return (Integer) count;
  61.     }
  62. }

（4） 定义Dao接口

（5） 定义映射文件

（6） 修改启动类

在启动类上必须要添加@EnableDubboConfiguration注解，开启Dubbo的自动配置功能

（7） 修改主配置文件

  1. server:
  2.   port: 8888
  3.  
  4. mybatis:
  5.   # 注册mybatis中实体类的别名
  6.   type-aliases-package: com.abc.bean
  7.   # 注册映射文件
  8.   mapper-locations: classpath:com/abc/dao/*.xml
  9.  
  10. spring:
  11.   # 注册数据源
  12.   datasource:
  13.     # 指定数据源类型为Druid
  14.     type: com.alibaba.druid.pool.DruidDataSource
  15.     driver-class-name: com.mysql.jdbc.Driver
  16.     url: jdbc:mysql:///test?useUnicode=true&amp;characterEncoding=utf8
  17.     username: root
  18.     password: root
  19.  
  20.   # 连接Redis服务器
  21.   redis:
  22.     host: 39.97.176.160
  23.     port: 6379
  24.  
  25.   # 连接Redis高可有集群
  26.   #  redis:
  27.   #    sentinel:
  28.   #      master: mymaster
  29.   #      nodes:
  30.   #        - sentinelOS1:26379
  31.   #        - sentinelOS2:26379
  32.   #        - sentinelOS3:26379
  33.  
  34.   # 配置缓存
  35.   cache:
  36.     type: redis # 指定缓存类型
  37.     cache-names: realTimeCache  # 指定缓存区域名称
  38.  
  39.  
  40.   # 功能等价于spring-boot配置文件中的<dubbo:application/>
  41.   application:
  42.     name: 11-provider-springboot
  43.   # 指定zk注册中心
  44.   dubbo:
  45.     registry: zookeeper://39.97.176.160:2181
  46.   # zk集群作注册中心
  47.   # registry: zookeeper://zkOS1:2181?backup=zkOS2:2181,zkOS3:2181

三、定义消费者11-consumer-springboot

（1） 创建工程

创建一个Spring Boot工程，并重命名为11-consumer-springboot

（2） 定义pom文件

  • dubbo与spring boot整合依赖
  • zkClient依赖
  • dubboCommons依赖
  • JSP引擎jasper依赖
  • slf4j-log4j12依赖
  • spring-boot-starter-web依赖

（3） 修改主配置文件

  1. spring:
  2.   # 功能等价于spring-dubbo配置文件中的<dubbo:application/>
  3.   application:
  4.     name: 11-consumer-springboot
  5.   # 指定zk注册中心
  6.   dubbo:
  7.     registry: zookeeper://39.97.176.160:2181
  8.     # zk集群作注册中心
  9.     # registry: zookeeper://zkOS1:2181?backup=zkOS2:2181,zkOS3:2181

（4） 创建index.jsp页面

在src/main/webapp目录下定义index.jsp文件

（5） 定义处理器

  1. package com.abc.controller;
  2.  
  3. import com.abc.bean.Employee;
  4. import com.abc.service.EmployeeService;
  5. import com.alibaba.dubbo.config.annotation.Reference;
  6. import org.springframework.stereotype.Controller;
  7. import org.springframework.ui.Model;
  8. import org.springframework.web.bind.annotation.PathVariable;
  9. import org.springframework.web.bind.annotation.PostMapping;
  10. import org.springframework.web.bind.annotation.RequestMapping;
  11. import org.springframework.web.bind.annotation.ResponseBody;
  12.  
  13. @Controller
  14. @RequestMapping("/consumer/employee")
  15. public class SomeController {
  16.  
  17.     // @Autowired
  18.     @Reference   // Dubbo的注解   <dubbo:reference />
  19.     private EmployeeService employeeService;
  20.  
  21.     @PostMapping("/register")
  22.     public String someHandle(Employee employee, Model model) {
  23.         employeeService.addEmployee(employee);
  24.         model.addAttribute("employee", employee);
  25.         return "/welcome.jsp";
  26.     }
  27.  
  28.     @RequestMapping("/find/{id}")
  29.     @ResponseBody
  30.     public Employee findHandle(@PathVariable("id") int id) {
  31.         return employeeService.findEmployeeById(id);
  32.     }
  33.  
  34.     @RequestMapping("/count")
  35.     @ResponseBody
  36.     public Integer countHandle() {
  37.         return employeeService.findEmployeeCount();
  38.     }
  39.  
  40. }

（6） 定义welcome.jsp页面

（7） 修改入口类

四、测试

当有对象插入时会清空realTimeCache缓存空间
一旦有了查询结果，则会将此结果写入到realTimeCache缓存

http://localhost:8080/index.jsp  首页

http://localhost:8080//consumer/employee/find/2 根据Id查找

http://localhost:8080//consumer/employee/count 查找总数

【推广】 免费学中医，健康全家人
原文地址：https://www.cnblogs.com/edda/p/13260451.html