部标JT808车辆定位监控平台单服务器13.6万接入压力测试记录（附源码）-Toy模板网

这篇具有很好参考价值的文章主要介绍了部标JT808车辆定位监控平台单服务器13.6万接入压力测试记录（附源码）。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

之前经常有人问平台能支持多少设备同时在线，由于事情多没时间做。最近刚好有机会做下压力测试。在不间断的连续压测三天，最终结果为13.6万TCP连接，30秒上报频率。

一、测试目的

测试平台同时接入设备数量与并发处理能力。

二、准备环境

一台主服务器用于部署车辆定位平台，是常见的8核16G内存300G硬盘,操作系统为centos 7.9，基础软件mysql8.0、redis3.2、jdk1.8，还有车辆定位平台软件。

三台压力测试服务器，同内网服务器。两台为8核16G，一台为2核4G。操作系统均为centos 7.9。

一台8核16G的服务器模拟6.3万个终端设备。
一台8核16G的服务器模拟5.3万个终端设备。
一台2核4G的服务器模拟2万个终端设备，该服务器由于配置原因模拟2万已是极限。
共模拟13.6万个终端设备，外加2台真实设备。

5.3万的压力服务器还有加压1万的空间，但加压后报异常：java.net.NoRouteToHostException: Cannot assign requested address (Address not available)。

三、编写压力测试程序

压力程序由java编写，用Socket类保持长连接，并收发数据，比较简单两个类。源代码如下：

public class TestApp {

	public static void main(String[] args) {
		String ip=args[0];
		String port=args[1];
		String maxThread=args[2];
		String startIndex="0";
		if(args.length>=4)startIndex=args[3];
		try {
			int sindex=Integer.parseInt(startIndex);
			int eindex=sindex+Integer.parseInt(maxThread);
			for(int i=sindex;i<eindex;i++) {
				System.out.println("启动线程"+i);
				new Thread(new SendJT808Thread(Utils.leftAdd0(String.valueOf(i), 14),ip,Integer.parseInt(port))).start();
			}
		
		} catch (Exception e) {
			e.printStackTrace();
		} 
	}

}


public class SendJT808Thread implements Runnable {
	private String tid="";
	private String ip;
	private int port;
	private Socket socket;
	public SendLhcxThread(String tid,String ip,int port) {
		this.tid=tid;
		this.ip=ip;
		this.port=port;
	}
	
	@Override
	public void run() {
		
		try {
			System.out.println("连接服务器->"+ip+":"+port);
			socket=new Socket(ip,port);
			while(true) {
				Thread.currentThread().sleep(30*1000);
				String time=Utils.getTime();
				String temp="这里生成JT808的0x0200报文";
				socket.getOutputStream().write(Utils.hexToBytes(temp));
				int len=socket.getInputStream().available();
				socket.getInputStream().skip(len);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			try {
				if(socket!=null)
				socket.close();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}

}