性能工具之Jmeter压测Hprose RPC服务

简介: 【5月更文挑战第19天】性能工具之Jmeter压测Hprose RPC服务

一、概述

Hprose(High Performance Remote Object Service Engine),国人开发的一个远程方法调用的开源框架。它是一个先进的轻量级的跨语言跨平台面向对象的高性能远程动态通讯中间件,它支持众多语言,例如nodeJs, C++,.NET,Java,Delphi,Objective-C,ActionScript,JavaScript,ASP,PHP,Python, Ruby,Perl等。

二、什么是RPC?

RPC(Remote Procedure Call Protocol)——远程过程调用协议,它是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。
其实简单的说,就是象调用本地的类的方法样来调用服务器端的方法实现。

Hprose特点

  • 支持几乎所有常见语言的实现,包括浏览器中的javascript
  • 成熟稳定,已经在很多项目中得到验证
  • 一直在持续稳步更新
  • 国人开发,有QQ群在线支持,回复比较快速(5分钟之内)
  • 和实体能保持很好的兼容性,实体工作量较小

1、Hprose服务端

Hprose 2.0 for Java 支持多种底层网络协议绑定的服务器,比如:HTTP 服务器,TCP 服务器和 WebSocket 服务器。
HTTP 服务器支持在 HTTP、HTTPS 协议上通讯。
TCP 服务器支持在 TCP 协议上通讯,并且支持全双工和半双工两种模式。
WebSocket 服务器支持在 ws、wss 协议上通讯。

2、Hprose客户端

Hprose 2.0 for Java 支持两种底层网络协议绑定的客户端:HTTP 客户端 和 TCP 客户端。
其中 HTTP 客户端支持跟 HTTP、HTTPS 绑定的 Hprose 服务器通讯。
TCP 客户端支持跟 TCP 绑定的 Hprose 服务器通讯,并且支持全双工和半双工两种模式。
尽管支持这两种不同的底层网络协议,但除了在对涉及到底层网络协议的参数设置上有所不同以外,其它的用法都完全相同。

官网地址:http://hprose.com/

3、实现逻辑

Hprose应用大致就做三件事:

  1. 复制Hprose文件进项目
  2. 写Hprose服务端
  3. 写Hprose客户端

Hprose服务端要做的事就两件:

  1. new一个HproseHttpServer对象
  2. 用这个对象发布服务,包括函数、方法、对象甚至类用这个对象发布服务,包括函数、方法、对象甚至类

Hprose客户端要做的事就两件:

  1. new一个HproseHttpClient对象
  2. 用这个对象调用服务端发布的各种服务用这个对象调用服务端发布的各种服务

4、压测示例

此处我们使用官方自带的HellWorld示例

源代码:https://github.com/hprose/hprose-java

4.1、写Hprose服务端

首先创建一个maven web项目,并引入hprose Stub JAR包

<dependencies>
        <!--引入hprose Stub-->
        <dependency>
            <groupId>org.hprose</groupId>
            <artifactId>hprose-java</artifactId>
            <version>2.0.38</version>
        </dependency>
    </dependencies>

在WebRoot/WEB-INFO/Lib目录下引入servlet和websocket的JAR包
image.png

创建hello服务类,可以写两个很简单的sayHello方法和add方法

/***
 * 服务类
 */

public class Hello {
   
   
    /***
     * 返回hello+客户端传参
     * @param name
     * @return
     */
    public String sayHello(String name) {
   
   
        return "Hello " + name + "!";
    }

    /**
     * 返回两个数字的和
     * @param a
     * @param b
     * @return
     */
    public String add(int a,int b)
    {
   
   
        int c=a+b;
        return "结果是:"+c;
    }
}

编写一个服务发布类WebSocketServer绑定WebSocketServer

/***
 * 服务发布类
 * WebSocket 绑定
 * Hprose RPC也可以工作于WebSocket之上,数据以二进制数据的方式在WebSocket上发送和接收。
 * Hprose RPC添加了4个字节的头作为请求唯一标识(id),服务器端不需要关心请求唯一标识(id)如何编码,只需要在应答中重复它就可以了。
 */

@ServerEndpoint("/wshello")
public class WebSocketServer {
   
   
    private HproseWebSocketService service = new HproseWebSocketService();
    public WebSocketServer() {
   
   
        //new出服务对象,发布类里面所有的公共方法
        service.add(new Hello());
    }
    @OnOpen
    public void onOpen(Session session, EndpointConfig config) {
   
   
        service.setConfig(config);
    }
    @OnMessage
    public void onMessage(ByteBuffer buf, Session session) throws IOException {
   
   
        service.handle(buf, session);
    }
    @OnError
    public void onError(Session session, Throwable error) {
   
   
        service.handleError(session, error);
    }
}

主要工作都完成了,接着需要在web.xml里注册一下

<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
    <servlet>
        <!--注册服务-->
        <servlet-name>HelloServlet</servlet-name>
        <servlet-class>hprose.server.HproseServlet</servlet-class>
        <init-param>
            <param-name>class</param-name>
            <param-value>hprose.hello.server.Hello</param-value>
        </init-param>
        <init-param>
            <param-name>crossDomain</param-name>
            <param-value>true</param-value>
        </init-param>
        </servlet>
    <!--绑定URL-->
    <servlet-mapping>
        <servlet-name>HelloServlet</servlet-name>
        <url-pattern>/Hello</url-pattern>
    </servlet-mapping>
    <session-config>
        <session-timeout>
            30
        </session-timeout>
    </session-config>
    <welcome-file-list>
        <welcome-file>index.html</welcome-file>
        </welcome-file-list>
    </web-app>

完成后运行tomcat,浏览器自动打开http://localhost:8888/Hello,我们可以看到这个服务已经成功发布了。
image.png

4.2、写Hprose客户端

接下我们写HelloClient类测试下服务是否ok

/**
 * Hprose客户端
 */
public class HelloClient {
   
   
    public static void main(String[] args) throws IOException {
   
   
        //new一个HproseHttpClient对象
        HproseHttpClient client = new HproseHttpClient();
        //使用无参构造器创建的客户端,在进行调用前,需要先调用useService方法初始化服务器地址
        client.useService("http://localhost:8080/Hello");
        //使用invoke方法来动态调用服务。
        String result = (String) client.invoke("sayHello", new Object[] {
   
    "Hprose" });
        System.out.println(result);
        result = (String) client.invoke("sayHello", new Object[] {
   
    "7DGroup" });
        System.out.println(result);
        System.out.println(client.invoke("add",new Object[]{
   
   1,6}));
    }
}

测试成功后,我们把hprose jar包拷贝到apache-jmeter-4.0\lib\ext下
image.png

打开Jmeter,设置线程组为5个
image.png

新建一个BeanShell Sampler及察看结果树,拷贝HelloClient代码到BeanShell script内,使用随机数函数对请求的数字进行参数化
image.png

运行并查看Jmeter控制台输出结果
image.png

至此,我们的一个压测Hprose RPC服务的小例子就完成了。

本文源码:

相关实践学习
通过性能测试PTS对云服务器ECS进行规格选择与性能压测
本文为您介绍如何利用性能测试PTS对云服务器ECS进行规格选择与性能压测。
目录
相关文章
|
6天前
|
监控 数据可视化 Java
掌握 JMeter 插件管理器:提升性能测试的利器
Apache JMeter 是一款强大的性能测试工具,其灵活性和扩展性使其在性能测试领域广受欢迎。JMeter 插件管理器(JMeter Plugins Manager)为用户提供了一个方便的平台来安装、更新和管理各种插件,从而大大扩展了 JMeter 的功能。
11 0
|
6天前
|
测试技术 Linux Apache
掌握JMeter参数化技巧:通过CSV文件实现高效登录压测
在本文中,我们将探讨如何使用 Apache JMeter 通过 CSV 数据文件进行登录性能测试参数化。首先创建一个包含用户名和密码的 `users.csv` 文件。接着在 JMeter 中,创建测试计划,添加线程组,配置 CSV 数据集,设置文件路径、编码及变量名。然后,创建 HTTP 请求并添加参数,使用 `${username}` 和 `${password}` 引用 CSV 中的数据。最后,添加监听器如查看结果树和聚合报告以分析测试结果。通过这种方法,能更有效地模拟真实用户行为,提高测试覆盖率,助力性能瓶颈的发现和优化。
15 0
|
12天前
|
监控 测试技术 Linux
性能测试工具
这篇内容介绍了几种性能测试工具和Linux监控命令。`ab`适用于简单接口测试,易用但扩展性差;`JMeter`功能强大,可扩展,但稳定性不足;`LoadRunner`专业稳定,但需付费。此外,还提到了几个Linux监控命令,如`top`、`vmstat`、`pidstat`和`jstat`,用于系统性能监控和内存使用情况检查。
35 0
|
22天前
|
监控 数据可视化 测试技术
性能工具之JMeter+InfluxDB+Grafana打造压测可视化实时监控
【5月更文挑战第23天】性能工具之JMeter+InfluxDB+Grafana打造压测可视化实时监控
65 6
性能工具之JMeter+InfluxDB+Grafana打造压测可视化实时监控
|
23天前
|
前端开发 Java Linux
性能工具之 Jmeter 通过 SpringBoot 工程启动
【5月更文挑战第22天】性能工具之 Jmeter 通过 SpringBoot 工程启动
34 8
性能工具之 Jmeter 通过 SpringBoot 工程启动
|
25天前
|
JSON JavaScript Java
性能工具之Jmeter压测Thrift RPC服务
【5月更文挑战第21天】性能工具之Jmeter压测Thrift RPC服务
32 1
|
1月前
|
负载均衡 Dubbo Java
Dubbo 3.x:探索阿里巴巴的开源RPC框架新技术
随着微服务架构的兴起,远程过程调用(RPC)框架成为了关键组件。Dubbo,作为阿里巴巴的开源RPC框架,已经演进到了3.x版本,带来了许多新特性和技术改进。本文将探讨Dubbo 3.x中的一些最新技术,包括服务注册与发现、负载均衡、服务治理等,并通过代码示例展示其使用方式。
119 9
|
1月前
|
设计模式 负载均衡 网络协议
【分布式技术专题】「分布式技术架构」实践见真知,手把手教你如何实现一个属于自己的RPC框架(架构技术引导篇)
【分布式技术专题】「分布式技术架构」实践见真知,手把手教你如何实现一个属于自己的RPC框架(架构技术引导篇)
69 0
|
9月前
|
消息中间件 负载均衡 Dubbo
如何自己设计一个类似Dubbo的RPC框架?
如何自己设计一个类似Dubbo的RPC框架?
69 0
|
1月前
|
Dubbo Java 应用服务中间件
Rpc编程系列文章第三篇:Hessian RPC一个老的RPC框架
Rpc编程系列文章第三篇:Hessian RPC一个老的RPC框架