在FISCO BCOS区块链系统中使用Java SDK进行压力测试

这篇具有很好参考价值的文章主要介绍了在FISCO BCOS区块链系统中使用Java SDK进行压力测试。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

FISCO BCOS的Java SDK Demo介绍

  • Java SDK Demo是FISCO BCOS团队基于Java SDK的基准测试集合,能够对FISCO BCOS节点进行压力测试。Java SDK Demo提供有合约编译功能,能够将Solidity合约文件转换成Java合约文件,此外还提供了针对转账合约、CRUD合约以及AMOP功能的压力测试示例程序

环境准备

  • Java SDK Demo中的测试程序能够在部署有JDK 1.8 ~ JDK 14的环境中运行,执行测试程序前请先确保已安装所需版本的JDK。以在Ubuntu系统中安装OpenJDK 11为例:
# 安装open JDK 11
sudo apt install openjdk-11-jdk
# 验证Java版本
java --version
# 输出以下内容:
# openjdk 11.0.10 2021-01-19
# OpenJDK Runtime Environment (build 11.0.10+9-Ubuntu-0ubuntu1.20.04)
# OpenJDK 64-Bit Server VM (build 11.0.10+9-Ubuntu-0ubuntu1.20.04, mixed mode, sharing)

编译源码

# 下载源码
git clone https://github.com/FISCO-BCOS/java-sdk-demo
cd java-sdk-demo
# 切换到2.0版本
git checkout main-2.0
# 编译源码
./gradlew build 
#当网络无法访问GitHub时,请从https://gitee.com/FISCO-BCOS/java-sdk-demo处的main-2.0分支下载源码。

配置Demo

  • 使用Java SDK Demo之前,需要进行证书拷贝以及区块链节点端口的配置,我的区块链环境是按照FISCO BCOS开发文档配置的本地四节点联盟链,以下操作以此环境为基础
cd dist
# 拷贝证书(假设SDK证书位于~/fisco/nodes/127.0.0.1/sdk目录,请根据实际情况更改路径)
cp -r ~/fisco/nodes/127.0.0.1/sdk/* conf

# 拷贝配置文件
# 注:
#   默认搭建的FISCO BCOS区块链系统Channel端口是20200,若修改了该端口,请同步修改config.toml中的[network.peers]配置选项
cp conf/config-example.toml conf/config.toml
  • 由于我的区块链环境具有四个节点,所以应该修改java-sdk-demo/dist/conf/config.toml下的network.peers配置

java sdk fisco bcos 压力测试,区块链学习,区块链,java,压力测试,学习

执行压力测试程序

  • Java SDK Demo提供了一系列压测程序,包括串行转账合约压测、并行转账合约压测、AMOP压测等,具体使用方法如下:
# 进入dist目录
cd dist

# 将需要转换为java代码的sol文件拷贝到dist/contracts/solidity路径下
# 转换sol, 其中${packageName}是生成的java代码包路径
# 生成的java代码位于 /dist/contracts/sdk/java目录下
java -cp "apps/*:lib/*:conf/" org.fisco.bcos.sdk.demo.codegen.DemoSolcToJava ${packageName}

# 压测串行转账合约:
# count: 压测的交易总量
# tps: 压测QPS
# groupId: 压测的群组ID
java -cp 'conf/:lib/*:apps/*' org.fisco.bcos.sdk.demo.perf.PerformanceOk [count] [tps] [groupId]

# 压测并行转账合约
# --------------------------
# 基于Solidity并行合约parallelok添加账户:
# groupID: 压测的群组ID
# count: 压测的交易总量
# tps: 压测QPS
# file: 保存生成账户的文件名
java -cp 'conf/:lib/*:apps/*' org.fisco.bcos.sdk.demo.perf.ParallelOkPerf [parallelok] [groupID] [add] [count] [tps] [file]
# 基于Precompiled并行合约precompiled添加账户
# (参数含义同上)
java -cp 'conf/:lib/*:apps/*' org.fisco.bcos.sdk.demo.perf.ParallelOkPerf [precompiled] [groupID] [add] [count] [tps] [file]
# --------------------------
# 基于Solidity并行合约parallelok发起转账交易压测
# groupID: 压测的群组ID
# count: 压测的交易总量
# tps: 压测的QPS
# file: 转账用户文件
java -cp 'conf/:lib/*:apps/*' org.fisco.bcos.sdk.demo.perf.ParallelOkPerf [parallelok] [groupID] [transfer] [count] [tps] [file]
# 基于Precompiled并行合约Precompiled发起转账压测
java -cp 'conf/:lib/*:apps/*' org.fisco.bcos.sdk.demo.perf.ParallelOkPerf [precompiled] [groupID] [transfer] [count] [tps] [file]


# CRUD合约压测
# 压测CRUD insert
# count: 压测的交易总量
# tps: 压测QPS
# groupId: 压测群组
java -cp 'conf/:lib/*:apps/*' org.fisco.bcos.sdk.demo.perf.PerformanceTable [insert] [count] [tps] [groupId]
# 压测CRUD update
# (参数解释同上)
java -cp 'conf/:lib/*:apps/*' org.fisco.bcos.sdk.demo.perf.PerformanceTable [update] [count] [tps] [groupId]
# 压测CRUD remove
# (参数解释同上)
java -cp 'conf/:lib/*:apps/*' org.fisco.bcos.sdk.demo.perf.PerformanceTable [remove] [count] [tps] [groupId]
# 压测CRUD query
# (参数解释同上)
java -cp 'conf/:lib/*:apps/*' org.fisco.bcos.sdk.demo.perf.PerformanceTable [query] [count] [tps] [groupId]

压测自定义合约

  • 在现实生产中,我们需要对自己定义的智能合约进行压力测试,因此需要将自己编写的智能合约加入Java SDK Demo中,同时还要编写相应的压力测试程序,来测试合约中指定的功能。
  • 压测自定义合约的开发均在Java SDK Demo中进行,我们需要开发三个文件,分别是:
    1. 待压测的智能合约:HelloWorld.sol
    2. 带压测的智能合约所编译出的Java类:HelloWorld.java(可以使用FISCO BCOS控制台的脚本进行智能合约到Java代码的自动转换,具体操作方式见FISCO BCOS系统开发文档中Java SDK的引入)
    3. 压力测试程序:PerformanceHelloWorld.java

项目的存放路径

  • 以上三个文件的存放路径如下

    java-sdk-demo/src/main/java/org/fisco/bcos/sdk/demo
                                                  ├── contract
                                                  │   ├── HelloWorld.java
                                                  │   └── sol
                                                  │       └── HelloWorld.sol
                                                  └── perf
                                                      └── PerformanceHelloWorld.java
    

以HelloWorld合约为例,开发压测程序

  • 压力测试程序的写法可以根据Java SDK Demo中提供的示例程序进行修改,这里展示基于HelloWorld合约写出的压力测试程序,测试的是HelloWorld合约中的set方法

    1. HelloWorld.sol

      pragma solidity>=0.4.24 <0.6.11;
      
      contract HelloWorld {
          string name;
      
          constructor() public {
              name = "Hello, World!";
          }
      
          function get() public view returns (string memory) {
              return name;
          }
      
          function set(string memory n) public {
              name = n;
          }
      }
      
    2. HelloWorld.java(使用脚本根据HelloWorld.sol自动生成,生成完毕后需要修改文件第一行为package org.fisco.bcos.sdk.demo.contract,这里不做展示)

    3. PerformanceHelloWorld.java

      /**
       * Copyright 2014-2020 [fisco-dev]
       *
       * <p>Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file
       * except in compliance with the License. You may obtain a copy of the License at
       *
       * <p>http://www.apache.org/licenses/LICENSE-2.0
       *
       * <p>Unless required by applicable law or agreed to in writing, software distributed under the
       * License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
       * express or implied. See the License for the specific language governing permissions and
       * limitations under the License.
       */
      package org.fisco.bcos.sdk.demo.perf;
      
      import com.google.common.util.concurrent.RateLimiter;
      import java.math.BigInteger;
      import java.net.URL;
      import java.util.concurrent.atomic.AtomicInteger;
      import org.fisco.bcos.sdk.BcosSDK;
      import org.fisco.bcos.sdk.BcosSDKException;
      import org.fisco.bcos.sdk.client.Client;
      import org.fisco.bcos.sdk.demo.contract.HelloWorld;
      import org.fisco.bcos.sdk.demo.perf.callback.PerformanceCallback;
      import org.fisco.bcos.sdk.demo.perf.collector.PerformanceCollector;
      import org.fisco.bcos.sdk.model.ConstantConfig;
      import org.fisco.bcos.sdk.model.TransactionReceipt;
      import org.fisco.bcos.sdk.transaction.model.exception.ContractException;
      import org.fisco.bcos.sdk.utils.ThreadPoolService;
      import org.slf4j.Logger;
      import org.slf4j.LoggerFactory;
      
      public class PerformanceHelloWorld {
          private static Logger logger = LoggerFactory.getLogger(PerformanceHelloWorld.class);
          private static AtomicInteger sendedTransactions = new AtomicInteger(0);
      
          private static void Usage() {
              System.out.println(" Usage:");
              System.out.println(
                      " \t java -cp 'conf/:lib/*:apps/*' org.fisco.bcos.sdk.demo.perf.PerformanceHelloWorld [count] [tps] [groupId].");
          }
      
          public static void main(String[] args) {
              try {
                  String configFileName = ConstantConfig.CONFIG_FILE_NAME;
                  URL configUrl = PerformanceOk.class.getClassLoader().getResource(configFileName);
      
                  if (configUrl == null) {
                      System.out.println("The configFile " + configFileName + " doesn't exist!");
                      return;
                  }
                  if (args.length < 3) {
                      Usage();
                      return;
                  }
                  Integer count = Integer.valueOf(args[0]);
                  Integer qps = Integer.valueOf(args[1]);
                  Integer groupId = Integer.valueOf(args[2]);
                  System.out.println(
                          "====== PerformanceOk trans, count: "
                                  + count
                                  + ", qps:"
                                  + qps
                                  + ", groupId: "
                                  + groupId);
      
                  String configFile = configUrl.getPath();
                  BcosSDK sdk = BcosSDK.build(configFile);
      
                  // build the client
                  Client client = sdk.getClient(groupId);
      
                  // deploy the HelloWorld
                  System.out.println("====== Deploy Ok ====== ");
                  HelloWorld helloWorld = HelloWorld.deploy(client, client.getCryptoSuite().getCryptoKeyPair());
                  System.out.println(
                          "====== Deploy HelloWorld succ, address: " + helloWorld.getContractAddress() + " ====== ");
      
                  PerformanceCollector collector = new PerformanceCollector();
                  collector.setTotal(count);
                  RateLimiter limiter = RateLimiter.create(qps);
                  Integer area = count / 10;
                  final Integer total = count;
      
                  System.out.println("====== PerformanceOk trans start ======");
      
                  ThreadPoolService threadPoolService =
                          new ThreadPoolService(
                                  "PerformanceHelloWorld",
                                  sdk.getConfig().getThreadPoolConfig().getMaxBlockingQueueSize());
      
                  for (Integer i = 0; i < count; ++i) {
                      limiter.acquire();
                      threadPoolService
                              .getThreadPool()
                              .execute(
                                      new Runnable() {
                                          @Override
                                          public void run() {
                                              PerformanceCallback callback = new PerformanceCallback();
                                              callback.setTimeout(0);
                                              callback.setCollector(collector);
                                              try {
                                                  helloWorld.set("Hello, fisco", callback);
                                              } catch (Exception e) {
                                                  TransactionReceipt receipt = new TransactionReceipt();
                                                  receipt.setStatus("-1");
                                                  callback.onResponse(receipt);
                                                  logger.info(e.getMessage());
                                              }
                                              int current = sendedTransactions.incrementAndGet();
                                              if (current >= area && ((current % area) == 0)) {
                                                  System.out.println(
                                                          "Already sended: "
                                                                  + current
                                                                  + "/"
                                                                  + total
                                                                  + " transactions");
                                              }
                                          }
                                      });
                  }
                  // wait to collect all the receipts
                  while (!collector.getReceived().equals(count)) {
                      Thread.sleep(1000);
                  }
                  threadPoolService.stop();
                  System.exit(0);
              } catch (BcosSDKException | ContractException | InterruptedException e) {
                  System.out.println(
                          "====== PerformanceOk test failed, error message: " + e.getMessage());
                  System.exit(0);
              }
          }
      }
      

HelloWorld合约的压力测试

  • 将上述三个文件放入对应的目录后,执行以下操作对HelloWorld合约进行压力测试(如果提示找不到主类,则可以重新编译一下项目再进入dist目录进行执行)

    cd /java-sdk-demo/dist
    #200000代表总测试量为200000   10000代表每秒向区块链系统发送10000次请求   1代表区块链系统的groupId
    java -cp 'conf/:lib/*:apps/*' org.fisco.bcos.sdk.demo.perf.PerformanceHelloWorld 200000 10000 1
    
  • 压力测试结果如下,可以看到本机的四节点区块链系统对HelloWorld合约里set方法的TPS为1797.67

java sdk fisco bcos 压力测试,区块链学习,区块链,java,压力测试,学习文章来源地址https://www.toymoban.com/news/detail-795999.html

到了这里,关于在FISCO BCOS区块链系统中使用Java SDK进行压力测试的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • FISCO BCOS 六、通过Caliper进行压力测试程序(及常见问题)

    目录 1. 环境要求 第一步. 配置基本环境(这里我使用的是Ubuntu20.04) 第二步. 安装NodeJS 第三步. 部署Docker 第四步. 安装Docker Compose 2. Caliper部署 第一步. 部署 第二步. 绑定 第三步. 快速体验FISCO BCOS基准测试 3.常见问题 问题1:dial unix /var/run/docker.sock: connect: permission denied​编辑

    2024年02月08日
    浏览(38)
  • Java SDK部署和调用FISCO BCOS区块链智能合约

    使用WeBASE合约管理导出Java项目 启动FISCO节点和webase-front,部署服务详情可参考官方文档: link 1.编写智能合约 一个简单的例子: Table 合约:该合约负责维护候选人的信息。每个候选人都有一个唯一的标识符sign_key,以及与之相关联的其他属性,包括活动名称activity_name、参与

    2024年03月22日
    浏览(56)
  • 区块链-FISCO BCOS Go SDK使用(一)

    上一章,介绍了智能合约的编译和部署,这一章,介绍fisco-bcos go-sdk的用法,首先,先下载go-sdk源码到本地 Go开发环境 Golang = 1.17 基本开发组件 Git(Windows、Linux及MacOS需要) Git bash(仅Windows需要) 如果用的是fisco-bcos2.x.使用以下命令 如果是fisco-bcos3.x 如果缺少库,可以提示安

    2024年01月20日
    浏览(55)
  • FISCO BCOS(十七)利用脚本进行区块链系统监控

    要利用脚本进行区块链系统监控,你可以使用各种编程语言编写脚本,如Python、Shell等 利用脚本进行区块链系统监控可以提高系统的稳定性、可靠性,并帮助及时发现和解决潜在问题,从而确保区块链网络的正常运行。本文可以利用脚本来解决两个问题 1.编写脚本 1,每隔

    2024年02月22日
    浏览(41)
  • FISCO BCOS(十七)——— go SDK的使用

    1、创建一个工作目录 2、下载go-sdk

    2024年02月12日
    浏览(63)
  • 在kubernetes(k8s)集群上部署FISCO BCOS区块链系统

    三台ubuntu22.04主机(分别为 ubuntu:192.168.3.54 ; worker1:192.168.3.57 ; worker2:192.168.3.58 ) 安装docker,kubernetes 三台主机加入同一kubernetes集群 使用上篇文章《使用Docker容器化部署FISCO-BCOS区块链系统》中的第二个方法,在ubuntu这台主机上生成运行在三台主机上的区块链节点 分别进入

    2024年02月05日
    浏览(37)
  • FISCO BCOS区块链系统新增节点时无法同步数据的原因及解决方法

    最近在搭建FISCO BCOS区块链系统,但是在一个旧的区块链上新增一个区块链节点时出现了一些问题 目前的区块链拥有三个节点,区块链中已经部署了一些合约,产生了一些交易,因此最新的块高为21。现在我想要在这个区块链系统中新增一个节点,而且需要它同步之前产生的一

    2024年02月02日
    浏览(42)
  • 搭建第一个区块链网络(Fisco-Bcos),启动并使用控制台

    1.安装依赖 centos7 Ubuntu 2.创建操作目录, 下载安装脚本 3. 搭建单群组4节点联盟链 搭建成功截图如下  4.启动FISCO BCOS链 启动成功截图如下  5.检查进程 检查进程是否启动  输出结果如下,如果进程数不为4,则进程没有启动(一般是端口被占用导致的)  6.检查日志输出 查看节

    2024年02月04日
    浏览(54)
  • FISCO BCOS入门(十二)使用Docker部署区块链和多群组部署

    使用Docker部署区块链可以简化部署过程、提供环境一致性、增加可移植性、提升灵活性和可扩展性,并提供一定的安全性保障。这些好处使得Docker成为一种流行的部署方式,广泛应用于区块链开发和生产环境中。 前两步跟之前一样 1.安装 curl, openssl依赖 2.下载build_chain.sh脚本

    2024年03月15日
    浏览(59)
  • Fisco Bcos区块链一(搭建单群组FISCO BCOS联盟链)

    技术文档:https://fisco-bcos-documentation.readthedocs.io/zh_CN/latest/index.html 1、搭建单群组FISCO BCOS联盟链 1. 安装centos依赖包 安装依赖包openssl、curl 2. 创建操作目录, 下载安装脚本 如果因为网络问题导致长时间无法下载build_chain.sh脚本,请尝试 3. 搭建单群组4节点联盟链 在fisco目录下执

    2024年02月10日
    浏览(49)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包