优化了压力测试对内存的占用

lib/testCase/FlvPressureTest.py

 #coding: utf-8
 import json
+import os
 import re
 import threading
 import time
@@ -72,6 +73,7 @@ class FlvPressureTest():
 
 
     # 使用openvc去拉流
+    '''
     def testServicePull(self, mobile,threadName):
         pullUrl = self.getPlayUrl(mobile,self.channel)
         # pullUrl = self.replaceHost(pullUrl, "video-test.vandyo.com:")
@@ -93,21 +95,25 @@ class FlvPressureTest():
             self.threadInfoPull["threadObj"].pop(threadName)
             return
         self.threadInfoPull["threadObj"].pop(threadName)
+    '''
 
 
-    '''
     # 使用requests去拉流
     def testServicePull(self,mobile,threadName):
         pullUrl = self.getPlayUrl(mobile, self.channel)
         # pullUrl = self.replaceHost(pullUrl, "video-test.vandyo.com:")
         try:
-            requests.get(pullUrl)
+            r = requests.get(pullUrl,stream=True)
+            with open(os.devnull, 'w') as f:
+                for chunk in r.iter_content(chunk_size=512):
+                    if chunk:
+                        f.write(str(chunk))
         except:
             traceback.print_exc()
             self.threadInfoPull["threadObj"].pop(threadName)
             return
         self.threadInfoPull["threadObj"].pop(threadName)
-    '''
+
 
     ################################################
     #      启动推流线程

run.py

@@ -34,13 +34,13 @@ def getPressTestObj():
     test = FlvPressureTest()
     test.setHost("10.100.11.125")
     test.setPort(1078)
-    test.setMobileStart(50000000000)                  # 开始的设备号 （累加）
+    test.setMobileStart(90000000000)                  # 开始的设备号 （累加）
     test.setChannel(1)                                # 设置频道号
-    test.setTerNum(30)                                 # 要启动的推拉流线程
+    test.setTerNum(1)                                 # 要启动的推拉流线程
     test.setIsOpenPullStream(1)                       # 设置是否开启拉流
     test.setIsShowFrame(0)                            # 拉流是否显示预览画面     （压力测试都应该填：0）
     test.setSendDur(0.007)                            # 设置socket 发送数据间隔
-    test.setFlvPath("flv/aaa3.flv")                   # 设置视频路劲
+    test.setFlvPath("flv/yyy.flv")                   # 设置视频路劲
     test.start()
     return test