服务器流量收发测试-续篇

文章目录

一、概述
二、普通java工程
- 1，pom文件
- 2，定时任务
- 3，打包
- 4，jar运行
三、打包docker镜像
- 1，镜像打包配置docker环境：
- 2，连接远程镜像仓库
四、部署运行
- 1. 容器运行
- 2. 单容器多次运行jar
- 3. 容器多实例运行
五、完整代码

一、概述

接上回书服务器流量收发测试
我们借助以下2种方式简单实现了构造http请求，实现流量收发测试：

springboot定时任务
crontab + curl
同时，我们也发现，springboot定时任务方式太过重量级，crontab + curl则需要比较高的权限，并需要安装 crontab 系统服务。

那么有没一种轻量级的方法，实现同样的功能呢？

答案是肯定的，下面我们使用普通java工程来实现相同的功能。

二、普通java工程

1，pom文件

引入 unirest

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.fly</groupId><artifactId>unirest-show</artifactId><version>0.0.1</version><name>unirest-show</name><url>http://maven.apache.org</url><packaging>jar</packaging><properties><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><docker.hub>registry.cn-shanghai.aliyuncs.com</docker.hub><java.version>1.8</java.version><skipTests>true</skipTests></properties><dependencies><!-- unirest --><dependency><groupId>com.mashape.unirest</groupId><artifactId>unirest-java</artifactId><version>1.4.9</version></dependency><dependency><groupId>org.apache.logging.log4j</groupId><artifactId>log4j-slf4j-impl</artifactId><version>2.12.1</version></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-lang3</artifactId><version>3.5</version></dependency><dependency><groupId>commons-io</groupId><artifactId>commons-io</artifactId><version>2.5</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.12</version><scope>provided</scope></dependency></dependencies><build><finalName>${project.artifactId}-${project.version}</finalName><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><version>3.8.1</version><configuration><source>1.8</source><target>1.8</target></configuration></plugin><!-- 方式一：带dependencies运行包 --><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-assembly-plugin</artifactId><version>3.5.0</version><configuration><appendAssemblyId>false</appendAssemblyId><archive><manifest><mainClass>com.fly.simple.MainRun</mainClass></manifest></archive><descriptorRefs><!--将所有外部依赖JAR都加入生成的JAR包--><descriptorRef>jar-with-dependencies</descriptorRef></descriptorRefs></configuration><executions><execution><!-- 配置执行器 --><id>make-assembly</id><phase>package</phase><!-- 绑定到package阶段 --><goals><goal>single</goal><!-- 只运行一次 --></goals></execution></executions></plugin><!-- 添加docker-maven插件 --><plugin><groupId>io.fabric8</groupId><artifactId>docker-maven-plugin</artifactId><version>0.40.0</version><executions><execution><phase>package</phase><goals><goal>build</goal><goal>push</goal></goals></execution></executions><configuration><!-- 连接到带docker环境的linux服务器编译image --><!--<dockerHost>http://192.168.182.10:2375</dockerHost>--><!-- Docker 推送镜像仓库地址 --><pushRegistry>${docker.hub}</pushRegistry><images><image><name>${docker.hub}/00fly/${project.artifactId}:${project.version}</name><build><dockerFileDir>${project.basedir}</dockerFileDir></build></image></images></configuration></plugin></plugins></build>
</project>

2，定时任务

使用ScheduledThreadPoolExecutor 实现

import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import java.util.stream.Stream;import org.apache.commons.io.FileUtils;
import org.apache.commons.lang3.StringUtils;import com.mashape.unirest.http.HttpResponse;
import com.mashape.unirest.http.JsonNode;
import com.mashape.unirest.http.Unirest;
import com.mashape.unirest.http.exceptions.UnirestException;import lombok.extern.slf4j.Slf4j;@Slf4j
public class MainRun
{private static String uploadUrl = "http://124.71.129.204:8083/post";private static File file;/*** 线程池保证程序一直运行* * @param args*/public static void main(String[] args){log.info("################################################################################################");log.info("to start please run: java -jar unirest-show-0.0.1.jar --server.url=http://124.71.129.204:8083/post");log.info("################################################################################################");if (args.length > 0){String url = Stream.of(args).filter(arg -> arg.contains("--server.url")).map(arg -> StringUtils.substringAfter(arg, "=")).collect(Collectors.joining());if (StringUtils.isNotBlank(url)){log.info("server.url={}", url);uploadUrl = url;}}init();ScheduledExecutorService service = new ScheduledThreadPoolExecutor(1);long delay = 60000L - System.currentTimeMillis() % 60000L - 1; // 计算延迟（微调1ms），保证准时启动log.info("initialDelay {} Seconds", delay / 1000.0);service.scheduleAtFixedRate(() -> {post();}, delay, 60000L, TimeUnit.MILLISECONDS);}private static void init(){String protocol = MainRun.class.getResource("").getProtocol();log.info("protocol: {}", protocol);if ("jar".equals(protocol)){try (InputStream is = MainRun.class.getResourceAsStream("/data/nginx-1.25.3.tar.gz")){file = new File("nginx-1.25.3.tar.gz");FileUtils.copyInputStreamToFile(is, file);log.info("{}", file.getCanonicalPath());}catch (IOException e){log.error(e.getMessage(), e);}}else{String path = MainRun.class.getResource("/data/nginx-1.25.3.tar.gz").getPath();log.info("{}", path);file = new File(path);}}/*** Unirest发送post请求<br>* https://kong.github.io/unirest-java/#requests*/private static void post(){try{log.info("Unirest start");HttpResponse<JsonNode> jsonResponse = Unirest.post(uploadUrl).header("accept", "application/json").field("id", System.currentTimeMillis() % 1000).field("file", file) // 文件.asJson();log.info("###### Response status：{}", jsonResponse.getStatus());}catch (UnirestException e){log.error(e.getMessage(), e);}}
}

3，打包

输入以下命令执行打包，生成unirest-show-0.0.1.jar 只有5M不到，并且此jar可独立运行。此功能借助plugin maven-assembly-plugin 实现，具体请参考pom文件

mvn clean package

4，jar运行

nohup java -jar unirest-show-0.0.1.jar &

三、打包docker镜像

在pom文件种，我们已经配置了 docker-maven-plugin 来实现docker镜像打包。

1，镜像打包配置docker环境：

本地windows可安装 docker desktop
远程docker需要打开dockerHost标签配置docker远程地址

同时，我们在package阶段绑定了 docker build、docker push 需要保证docker push时能连上远程镜像仓库 registry.cn-shanghai.aliyuncs.com/00fly/

2，连接远程镜像仓库

有3种方式：

maven中配置
参考容器镜像生成记
项目pom.xml中配置
具体操作为，在插件io.fabric8.docker-maven-plugin configuration节点新增

	<authConfig><!--认证配置,用于私有镜像仓库registry认证 --><username>${docker.username}</username><password>${docker.password}</password></authConfig>

这边${docker.username}、${docker.password}请替换为docker镜像仓库实际账号/密码.

手工登录
不做任何实际配置，推送镜像前，执行手工登录操作，如：
docker login --username=${docker.username} registry.cn-shanghai.aliyuncs.com
这边${docker.username}请替换为docker镜像仓库实际账号

四、部署运行

1. 容器运行

cd docker
sh restart.sh

2. 单容器多次运行jar

cd docker
sh n-restart.sh

运行结果


2024-06-25 21:18:57.613 [main] INFO  com.fly.simple.MainRun - protocol: jar
2024-06-25 21:18:57.616 [main] INFO  com.fly.simple.MainRun - /nginx-1.25.3.tar.gz
2024-06-25 21:18:57.616 [main] INFO  com.fly.simple.MainRun - initialDelay 2.383 Seconds
2024-06-25 21:18:57.622 [main] INFO  com.fly.simple.MainRun - /nginx-1.25.3.tar.gz
2024-06-25 21:18:57.623 [main] INFO  com.fly.simple.MainRun - initialDelay 2.376 Seconds
2024-06-25 21:19:00.000 [pool-2-thread-1] INFO  com.fly.simple.MainRun - Unirest start
2024-06-25 21:19:00.001 [pool-2-thread-1] INFO  com.fly.simple.MainRun - Unirest start
2024-06-25 21:19:00.002 [pool-2-thread-1] INFO  com.fly.simple.MainRun - Unirest start
2024-06-25 21:19:01.700 [pool-2-thread-1] INFO  com.fly.simple.MainRun - ###### Response status：200
2024-06-25 21:19:01.721 [pool-2-thread-1] INFO  com.fly.simple.MainRun - ###### Response status：200
2024-06-25 21:19:02.988 [pool-2-thread-1] INFO  com.fly.simple.MainRun - ###### Response status：200

3. 容器多实例运行

cd docker
sh scale.sh

运行结果

sh scale.sh
[+] Running 3/3✔ Container docker_unirest-show_3  Started                                                                                              1.1s ✔ Container docker_unirest-show_1  Started                                                                                              0.6s ✔ Container docker_unirest-show_2  Started