分表分库 多线程性能测试

loit-shardingsphere-seata-nacos-feign-provider-main/src/main/java/com/loit/shardingsphere/seata/nacos/feign/controller/DemoController.java

@@ -2,7 +2,9 @@ package com.loit.shardingsphere.seata.nacos.feign.controller;
 
 
 import com.loit.shardingsphere.seata.nacos.feign.modules.entity.OrderEntity;
+import com.loit.shardingsphere.seata.nacos.feign.modules.entity.OrderItemEntity;
 import com.loit.shardingsphere.seata.nacos.feign.modules.service.IBusinessService;
+import com.loit.shardingsphere.seata.nacos.feign.modules.service.IOrderItemService;
 import com.loit.shardingsphere.seata.nacos.feign.modules.service.IOrderService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -21,15 +23,18 @@ import java.util.List;
 public class DemoController {
 
     @Resource(name = "businessService")
-    IBusinessService businessService;
+    private IBusinessService businessService;
 
     @Resource(name = "orderService")
-    IOrderService orderService;
+    private IOrderService orderService;
+
+    @Resource(name = "orderItemService")
+    private IOrderItemService orderItemService;
 
     @GetMapping("purchase")
     public void purchase() {
         long startTime = System.currentTimeMillis(); //获取开始时间
-        for (long i = 10000000; i <= 20000000; i++) {
+        for (long i = 20000005; i <= 30000000; i++) {
             try {
                 businessService.purchase(i);
             } catch (Exception e) {
@@ -56,6 +61,18 @@ public class DemoController {
         log.info("success");
     }
 
+    @GetMapping("findOrderItemPage")
+    public void findOrderItemPage(Long orderId) {
+
+        long startTime = System.currentTimeMillis(); //获取开始时间
+        List<OrderItemEntity> pageList = orderItemService.findPage(orderId, 0l, 20l);
+        log.info(pageList.toString());
+        long endTime = System.currentTimeMillis(); //获取结束时间
+
+        log.error("程序运行时间：" + (endTime - startTime) + "ms"); //输出程序运行时间
+        log.info("success");
+    }
+
     @GetMapping("getById")
     public void getById(String orderId) {
 

loit-shardingsphere-seata-nacos-feign-provider-main/src/main/java/com/loit/shardingsphere/seata/nacos/feign/modules/service/IOrderItemService.java

@@ -4,6 +4,12 @@ package com.loit.shardingsphere.seata.nacos.feign.modules.service;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.loit.shardingsphere.seata.nacos.feign.modules.entity.OrderItemEntity;
 
+import java.util.List;
+
 public interface IOrderItemService extends IService<OrderItemEntity> {
+
+
     void insertOrderItem(OrderItemEntity orderItemEntity);
+
+    List<OrderItemEntity> findPage(Long orderId, Long pageNum, Long pageSize);
 }

loit-shardingsphere-seata-nacos-feign-provider-main/src/main/java/com/loit/shardingsphere/seata/nacos/feign/modules/service/IOrderService.java

@@ -7,6 +7,7 @@ import java.util.List;
 
 
 public interface IOrderService extends IService<OrderEntity> {
+
     void insertOrder(OrderEntity orderEntity);
 
 

loit-shardingsphere-seata-nacos-feign-provider-main/src/main/java/com/loit/shardingsphere/seata/nacos/feign/modules/service/impl/OrderItemServiceImpl.java

 package com.loit.shardingsphere.seata.nacos.feign.modules.service.impl;
 
 
-
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.loit.shardingsphere.seata.nacos.feign.modules.entity.OrderItemEntity;
 import com.loit.shardingsphere.seata.nacos.feign.modules.mapper.OrderItemMapper;
 import com.loit.shardingsphere.seata.nacos.feign.modules.service.IOrderItemService;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
 
-@Service
+@Service("orderItemService")
 public class OrderItemServiceImpl extends ServiceImpl<OrderItemMapper, OrderItemEntity> implements IOrderItemService {
 
     @Override
+    @Transactional
     public void insertOrderItem(OrderItemEntity orderItemEntity) {
         baseMapper.insert(orderItemEntity);
     }
+
+    @Override
+    public List<OrderItemEntity> findPage(Long orderId, Long pageNum, Long pageSize) {
+        QueryWrapper<OrderItemEntity> queryWrapper = new QueryWrapper<>();
+
+        queryWrapper.eq("order_id", orderId);
+        queryWrapper.orderByAsc("id");
+        Page<OrderItemEntity> page = new Page<>(pageNum, pageSize);
+        //分页数据
+        IPage<OrderItemEntity> pageInfo = this.page(page, queryWrapper);
+        return pageInfo.getRecords();
+    }
 }

loit-shardingsphere-seata-nacos-feign-provider-main/src/main/java/com/loit/shardingsphere/seata/nacos/feign/modules/service/impl/OrderServiceImpl.java

@@ -3,29 +3,54 @@ package com.loit.shardingsphere.seata.nacos.feign.modules.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.loit.shardingsphere.seata.nacos.feign.modules.entity.OrderEntity;
+import com.loit.shardingsphere.seata.nacos.feign.modules.entity.OrderItemEntity;
 import com.loit.shardingsphere.seata.nacos.feign.modules.mapper.OrderMapper;
+import com.loit.shardingsphere.seata.nacos.feign.modules.service.IOrderItemService;
 import com.loit.shardingsphere.seata.nacos.feign.modules.service.IOrderService;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
+import javax.annotation.Resource;
 import java.util.List;
 
 @Service("orderService")
 public class OrderServiceImpl extends ServiceImpl<OrderMapper, OrderEntity> implements IOrderService {
 
+    @Resource(name = "orderItemService")
+    private IOrderItemService orderItemService;
+
+    /**
+     * 测试插入 orderItem
+     */
     @Override
+    @Transactional
     public void insertOrder(OrderEntity orderEntity) {
         baseMapper.insert(orderEntity);
+
+        Long orderId = orderEntity.getOrderId();
+
+        for (int i = 0; i < 31; i++) {
+            OrderItemEntity orderItem = new OrderItemEntity();
+            orderItem.setOrderId(orderId);
+            orderItem.setOrderItemId(Long.valueOf(i));
+            orderItem.setStatus(orderEntity.getStatus());
+            orderItem.setUserId(orderEntity.getUserId());
+            orderItemService.insertOrderItem(orderItem);
+        }
+
     }
 
     @Override
     public List<OrderEntity> findPage(Long pageNum, Long pageSize) {
         QueryWrapper<OrderEntity> queryWrapper = new QueryWrapper<>();
 
+
         queryWrapper.orderByAsc("id");
         Page<OrderEntity> page = new Page<>(pageNum, pageSize);
+
+
         //分页数据
         IPage<OrderEntity> pageInfo = this.page(page, queryWrapper);
         return pageInfo.getRecords();

loit-shardingsphere-seata-nacos-feign-provider-main/src/main/resources/application-sharding-tables.yml

@@ -28,7 +28,7 @@ spring:
         jdbc-url: jdbc:mysql://39.98.202.173:3306/demo_ds?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC
         url: jdbc:mysql://39.98.202.173:3306/demo_ds?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC
         filters: stat,wall,log4j
-        maxActive: 20
+        maxActive: 40
         initialSize: 1
         maxWait: 60000
         minIdle: 1
@@ -39,7 +39,7 @@ spring:
         testOnBorrow: false
         testOnReturn: false
         poolPreparedStatements: true
-        maxOpenPreparedStatements: 20
+        maxOpenPreparedStatements: 40
         connection-properties: druid.stat.merggSql=ture;druid.stat.slowSqlMillis=5000
     sharding:
       tables: