性能工具之JMeter Dubbo 脚本开发

简介: 【5月更文挑战第13天】性能工具之JMeter Dubbo 脚本开发

前言

Apache Dubbo 是一款高性能、轻量级的开源Java RPC框架,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现。

IDEA 环境项目部署

工程整个目录结果

image.png

主要包括:

  • API 接口与实体类
  • Provider数据提供者
  • Consumer消费者

API 关键接口代码

UserInfoService:

package com.dunshan.api.service;

import com.dunshan.api.pojo.UserInfo;

import java.util.HashMap;
import java.util.List;

/**
 * @author 7DGroup
 * @version 1.0
 * @Date: 2021-05-04 11:51
 * @Description: rpc接口调用
 */
public interface UserInfoService {
   
   

    List<UserInfo> queryList();

    HashMap<String, Object> queryMap(String name);
}

Provider 关键代码

package com.dunshan.provider.Impl;

import com.dunshan.api.pojo.UserInfo;
import com.dunshan.api.service.UserInfoService;
import org.apache.dubbo.config.annotation.Service;

import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;

/**
 * @author 7DGroup
 * @version 1.0
 * @Date: 2021-05-04 12:03
 * @Description: 提供者实现类
 */
@Service
public class UserInfoServiceImpl implements UserInfoService {
   
   
    @Override
    public List<UserInfo> queryList() {
   
   
        // 初始化数据
        UserInfo testDTO1 = new UserInfo();
        testDTO1.setId(1);
        testDTO1.setName("学生");
        testDTO1.setNumber(100);
        testDTO1.setCreateTime(new Date());
        UserInfo testDTO2 = new UserInfo();
        testDTO2.setId(2);
        testDTO2.setName("7D-RESAR-性能测试");
        testDTO2.setNumber(101);
        testDTO2.setCreateTime(new Date());
        // 组装数据
        List<UserInfo> list = new ArrayList<>();
        list.add(testDTO1);
        list.add(testDTO2);
        return list;
    }

    @Override
    public HashMap<String, Object> queryMap(String name) {
   
   
        HashMap<String, Object> map = new HashMap<>(2);
        map.put(name, "7D-RESAR-初级工具班");
        map.put("nacos", "注册中心,配置管理中心");
        map.put("date", System.currentTimeMillis());
        return map;
    }
}

配置文件 application.yml:

server:
  port: 8861
dubbo:
  # 配置服务信息
  application:
    name: dubbo-provider
    # 禁用QOS同一台机器可能会有端口冲突现象
    qos-enable: false
    qos-accept-foreign-ip: false
  # 配置注册中心
  registry:
    address: nacos://127.0.0.1:8848
  # 设置协议-协议由提供方指定消费方被动接受
  protocol:
    name: dubbo
    port: 20880
spring:
  main:
    # 解决Bean重复定义问题
    allow-bean-definition-overriding: true

Consumer 关键代码

ConsumerController:

package com.dunshan.consumer.controller;

import com.dunshan.api.pojo.ResultVO;
import com.dunshan.api.pojo.UserInfo;
import com.dunshan.api.service.UserInfoService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import java.util.HashMap;
import java.util.List;

/**
 * @author 7DGroup
 * @version 1.0
 * @Date: 2021-05-04 11:54
 * @Description: 消费测试接口
 */
@RestController
@RequestMapping("/api")
public class ConsumerController {
   
   

    /**
     * Dubbo远程调用注解
     */
    @Reference
    private UserInfoService userInfoService;

    @RequestMapping(value = "/list", method = RequestMethod.GET)
    public ResultVO getList() {
   
   
        List<UserInfo> providerTestDTOList = userInfoService.queryList();
        return new ResultVO.Builder<>().code(200).message("success").data(providerTestDTOList).build();
    }

    /**
     * 查询查询
     * @param name
     * @return
     */
    @GetMapping("/api/query")
    public ResultVO query(String name) {
   
   
        HashMap<String, Object> map = userInfoService.queryMap(name);
        return new ResultVO.Builder<>().code(200).message("success").data(map).build();
    }

}

application.yml:

server:
  port: 8862
dubbo:
  # 配置服务信息
  application:
    name: dubbo-consumer
    # 禁用QOS同一台机器可能会有端口冲突现象
    qos-enable: false
    qos-accept-foreign-ip: false
  # 配置注册中心
  registry:
    address: nacos://127.0.0.1:8848
  # 设置超时时间
  consumer:
    timeout: 4000
spring:
  main:
    # 解决Bean重复定义问题
    allow-bean-definition-overriding: true

验证结果

image.png

Nacos 环境部署

下载 nacos

下载链接:https://nacos.io/zh-cn/docs/quick-start.html

启动:

sh startup.sh -m standalone

image.png

页面显示如下:
image.png

项目启动后,nacos显示如下:
image.png

dubbo 插件部署

1、下载: https://gitee.com/liselotte/spring-boot-dubbo-demo.git

2、IDEA 中编译 Jar 包
image.png

3、打成 Jar 包放入 ${JMETER_HOME}\lib\ext 路径下,重启即可

image.png

image.png

4、重启 JMeter 查看插件

image.png

添加成功如:
image.png

测试 dubbo 接口

有上面的环境,并且 JMeter 中也有 Dubbo 插件,那么剩下的就是通过插件完成今天的接口开发,接下来看下需要测试的接口有哪些,这些只模拟无参接口与有参数接口。

下面是这次做测试 Dubbo 接口

package com.dunshan.api.service;

import com.dunshan.api.pojo.UserInfo;
import java.util.HashMap;
import java.util.List;

/**
 * @author 7DGroup
 * @version 1.0
 * @Date: 2021-05-04 11:51
 * @Description: rpc接口调用
 */
public interface UserInfoService {
   
   

    List<UserInfo> queryList();
    HashMap<String, Object> queryMap(String name);

不带参数请求

添加 Dubbo Sample 请求,并且根据上面需要测试的接口,在 Get Provider LIst 中的 Interface 中输入接口名字,与方法名称点击获取即可把需要测试的全部方法名称用列表显示出来。

image.png

添加结果查看树进行结果验证:
image.png

带参参数请求

添加 Dubbo Sample 请求

image.png

验证结果:
image.png

总结

有上面认识后自己搭建环境学习也好,办理事情也好,都会慢慢按步骤一步一步去实现。

源码地址:

目录
相关文章
|
26天前
|
前端开发 Java Linux
性能工具之 Jmeter 通过 SpringBoot 工程启动
【5月更文挑战第22天】性能工具之 Jmeter 通过 SpringBoot 工程启动
36 8
性能工具之 Jmeter 通过 SpringBoot 工程启动
|
25天前
|
监控 数据可视化 测试技术
性能工具之JMeter+InfluxDB+Grafana打造压测可视化实时监控
【5月更文挑战第23天】性能工具之JMeter+InfluxDB+Grafana打造压测可视化实时监控
69 6
性能工具之JMeter+InfluxDB+Grafana打造压测可视化实时监控
|
28天前
|
JSON JavaScript Java
性能工具之Jmeter压测Thrift RPC服务
【5月更文挑战第21天】性能工具之Jmeter压测Thrift RPC服务
32 1
|
29天前
|
IDE Java Maven
性能工具之Jmeter扩展配置元件插件
【5月更文挑战第20天】性能工具之Jmeter扩展配置元件插件
35 1
|
1月前
|
Dubbo Java 应用服务中间件
微服务学习 | Springboot整合Dubbo+Nacos实现RPC调用
微服务学习 | Springboot整合Dubbo+Nacos实现RPC调用
|
7月前
|
负载均衡 Dubbo 应用服务中间件
微服务技术系列教程(31) - Dubbo-原理及负载均衡分析
微服务技术系列教程(31) - Dubbo-原理及负载均衡分析
61 0
|
7月前
|
Dubbo Java 应用服务中间件
微服务技术系列教程(30) - Dubbo-SpringCloud与Dubbo区别
微服务技术系列教程(30) - Dubbo-SpringCloud与Dubbo区别
53 0
|
1月前
|
Dubbo Java 应用服务中间件
阿里巴巴资深架构师深度解析微服务架构设计之SpringCloud+Dubbo
软件架构是一个包含各种组织的系统组织,这些组件包括Web服务器,应用服务器,数据库,存储,通讯层),它们彼此或和环境存在关系。系统架构的目标是解决利益相关者的关注点。
|
27天前
|
Dubbo Cloud Native 应用服务中间件
【阿里云云原生专栏】云原生环境下的微服务治理:阿里云 Dubbo 与 Nacos 的深度整合
【5月更文挑战第25天】阿里云Dubbo和Nacos提供微服务治理的强大工具,整合后实现灵活高效的治理。Dubbo是高性能RPC框架,Nacos则负责服务发现和配置管理。整合示例显示,通过Nacos注册中心,服务能便捷注册发现,动态管理配置。简化部署,提升适应性,但也需注意服务稳定性和策略规划。这种整合为云原生环境的微服务架构带来强大支持,未来应用前景广阔。
215 2
|
1月前
|
Dubbo Java 应用服务中间件
Spring Cloud Dubbo: 微服务通信的高效解决方案
【4月更文挑战第28天】在微服务架构的发展中,服务间的高效通信至关重要。Spring Cloud Dubbo 提供了一种基于 RPC 的通信方式,使得服务间的调用就像本地方法调用一样简单。本篇博客将探讨 Spring Cloud Dubbo 的核心概念,并通过具体实例展示其在项目中的实战应用。
32 2