/* * Copyright (c) 2016 The ZLMediaKit project authors. All Rights Reserved. * * This file is part of ZLMediaKit(https://github.com/xiongziliang/ZLMediaKit). * * Use of this source code is governed by MIT license that can be found in the * LICENSE file in the root of the source tree. All contributing project authors * may be found in the AUTHORS file in the root of the source tree. */ #include #include #include #include #include "Util/logger.h" #include "Util/onceToken.h" #include "Rtsp/UDPServer.h" #include "Network/sockutil.h" #include "Poller/EventPoller.h" #include "Player/PlayerProxy.h" using namespace std; using namespace toolkit; using namespace mediakit; int main(int argc, char *argv[]) { //设置退出信号处理函数 static semaphore sem; signal(SIGINT, [](int) { sem.post(); });// 设置退出信号 //设置日志 Logger::Instance().add(std::make_shared()); Logger::Instance().setWriter(std::make_shared()); if (argc != 5) { ErrorL << "\r\n测试方法:./test_benchmark player_count play_interval rtxp_url rtp_type\r\n" << "例如你想每隔50毫秒启动共计100个播放器(tcp方式播放rtsp://127.0.0.1/live/0 )可以输入以下命令:\r\n" << "./test_benchmark 100 50 rtsp://127.0.0.1/live/0 0\r\n" << endl; return 0; } list playerList; auto playerCnt = atoi(argv[1]);//启动的播放器个数 atomic_int alivePlayerCnt(0); //由于所有播放器都是再一个timer里面创建的,默认情况下所有播放器会绑定该timer所在的poller线程 //为了提高性能,poller分配策略关闭优先返回当前线程的策略 EventPollerPool::Instance().preferCurrentThread(false); //每隔若干毫秒启动一个播放器(如果一次性全部启动,服务器和客户端可能都承受不了) Timer timer0(atoi(argv[2])/1000.0f,[&]() { MediaPlayer::Ptr player(new MediaPlayer()); player->setOnPlayResult([&](const SockException &ex) { if (!ex) { ++alivePlayerCnt; } }); player->setOnShutdown([&](const SockException &ex) { --alivePlayerCnt; }); (*player)[kBenchmarkMode] = true; (*player)[kRtpType] = atoi(argv[4]); player->play(argv[3]); playerList.push_back(player); return playerCnt--; }, nullptr); Timer timer1(1,[&]() { InfoL << "存活播放器个数:" << alivePlayerCnt.load(); return true; }, nullptr); sem.wait(); return 0; }