Skip to content

S
streamPushPressure
Commit 783a9a57 authored by liyuanhong's avatar liyuanhong
Browse files
Options

第一次提交

parents
Pipeline #342 failed with stages
      Expand all Hide whitespace changes
      Inline Side-by-side
      Showing with 778 additions and 0 deletions
      aac/bbb3.aac 0 → 100644
      View file @ 783a9a57
      File added
      h264/bbb3.h264 0 → 100644
      View file @ 783a9a57
      File added
      lib/protocal/ProtocalFlv_1078.py 0 → 100644
      View file @ 783a9a57
      #coding:utf-8
      import binascii
      import socket
      from ctypes import string_at
      import time
      import cv2
      class Protocal_1078:
      def __init__(self):
      self.frameHeader1078 = "30316364" # JT/T 1078 头 固定为0x30 0x31 0x63 0x64，ASCII码为01cd
      self.V = 2 << 6 # V 固定为2
      self.P = 0 << 5 # P 固定为0
      self.X = 0 << 4 # X RTP头是否需要扩展位，固定为0
      self.CC = 1 # CC 固定为1
      self.M = 1 << 7 # M 标志位，确定是否完整数据帧的边界，因为数据体的最大长度是950字节，而一个视频I帧通道要远远超过950字节，所以视频的一个帧通常会分包
      self.PT = 98 # PT 98:表示H264 99:表示H265
      self.sn = 0 # 包序号 初始为0，每发送一个RTP数据包，序列号加1
      self.sim = "013146201117" # 终端设备SIM卡号
      self.logicC = 1 # 逻辑通道
      self.dataType = 0 << 4 # 数据类型 ， 0000：数据I祯，0001：视频P帧，0010：视频B帧，0011：音频帧，0100：透传数据
      self.pkgTag = 1 # 分包处理 ，0000：原子包，不可拆分等，0001：分包处理时的第一个包，0010：分包处理时的最后一个包，0011：分包处理时的中间包
      self.time = 33 # 时间戳
      self.lastKeyTime = 33 # Last I Frame Interval 该祯与上一个关键祯之间的时间间隔，单位毫秒（ms），当数据类型为非视频祯时，则没有该字段
      self.lastTime = 33 # Last Frame Interval 该祯与上一个祯之间的时间时间，单位毫秒(ms)，当数据类型为非视频祯时，则没有该字段
      self.lenS = 950 # 数据长度
      self.dataBody = "" # 数据体，要发送的帧数据
      # self.host = "10.100.11.125"
      self.host = "10.16.15.85"
      self.port = 1078
      self.BUF_SIZE = 2048
      def setDataBody(self,data):
      self.dataBody = data
      def setM(self,data):
      self.M = data << 7
      def setSim(self,data):
      while len(data) < 12:
      data = "0" + data
      self.sim = data
      def setSn(self,data):
      self.sn = data
      def setTime(self,data):
      self.time = data
      def setLastKeyTime(self,data):
      self.lastKeyTime = data
      def setLastTime(self,data):
      self.lastTime = data
      #####################################################
      # 从帧数据中获取帧类型
      #####################################################
      def getFrameType(self):
      # 0x67 (0 11 00111) SPS 非常重要 type = 7
      # 0x68 (0 11 01000) PPS 非常重要 type = 8
      # 0x65 (0 11 00101) IDR帧 关键帧 非常重要 type = 5
      # 0x61 (0 11 00001) I帧 重要 type=1 非IDR的I帧 不大常见
      # 0x41 (0 10 00001) P帧 重要 type = 1
      # 0x01 (0 00 00001) B帧 不重要 type = 1
      # 0x06 (0 00 00110) SEI 不重要 type = 6
      frameTypeHex = self.dataBody[8:10]
      return frameTypeHex
      #####################################################
      # 数字转换为16进制字符串，通过传入字节数可自动补0
      # 传入数据格式所占字节数
      #####################################################
      def int2hexStringByBytes(self, num,bytescount=1):
      hexStr = hex(num)[2:]
      while len(hexStr) < (bytescount * 2):
      hexStr = "0" + hexStr
      return hexStr
      #####################################################
      # 根据长度分割字符串
      #####################################################
      def splitStrByLen(self,strs,num):
      result = []
      if num > len(strs):
      result.append(strs)
      else:
      result.append(strs[:num])
      strs = strs[num:]
      while len(strs) > num:
      result.append(strs[:num])
      strs = strs[num:]
      if len(strs) > 0:
      result.append(strs)
      return result
      #####################################################
      # 生成单个数据包
      #####################################################
      def genPkg(self,data):
      msg = ""
      msg = self.frameHeader1078
      msg = msg + self.int2hexStringByBytes(self.V + self.P + self.X + self.CC)
      msg = msg + self.int2hexStringByBytes(self.M + self.PT)
      msg = msg + self.int2hexStringByBytes(self.sn,2)
      msg = msg + self.sim
      msg = msg + self.int2hexStringByBytes(self.logicC)
      msg = msg + self.int2hexStringByBytes(self.dataType + self.pkgTag)
      msg = msg + self.int2hexStringByBytes(self.time,8)
      msg = msg + self.int2hexStringByBytes(self.lastKeyTime,2)
      msg = msg + self.int2hexStringByBytes(self.lastTime,2)
      msg = msg + self.int2hexStringByBytes(int(len(data) / 2),2)
      msg = msg + data
      return msg
      #####################################################
      # 生成单个数据包
      #####################################################
      def genAudioPkg(self,data):
      msg = ""
      msg = self.frameHeader1078
      msg = msg + self.int2hexStringByBytes(self.V + self.P + self.X + self.CC)
      self.PT = 19
      msg = msg + self.int2hexStringByBytes(self.M + self.PT)
      msg = msg + self.int2hexStringByBytes(self.sn,2)
      msg = msg + self.sim
      msg = msg + self.int2hexStringByBytes(self.logicC)
      msg = msg + self.int2hexStringByBytes(self.dataType + self.pkgTag)
      msg = msg + self.int2hexStringByBytes(self.time,8)
      msg = msg + self.int2hexStringByBytes(int(len(data) / 2),2)
      msg = msg + data
      return msg
      #####################################################
      # 根据帧数据，生成多个数据包(视频)
      #####################################################
      def genPkgsByFrame(self):
      f_type = self.getFrameType()
      if f_type == "65" or f_type == "61":
      self.dataType = 0 << 4 # 0000
      elif f_type == "41":
      self.dataType = 1 << 4 # 0001
      elif f_type == "01":
      self.dataType = 2 << 4 # 0010
      else:
      self.dataType = 2 << 4 # 0010
      datas = self.splitStrByLen(self.dataBody,1900)
      pkgs = []
      for i in range(0,len(datas)):
      if len(datas) == 1:
      self.pkgTag = 0 # 原子包 0000
      else:
      if i == 0:
      self.pkgTag = 1 # 第一个包 0001
      elif i < (len(datas) - 1):
      self.pkgTag = 3 # 中间包 0011
      else:
      self.pkgTag = 2 # 最后一个包 0010
      pkg = self.genPkg(datas[i])
      pkgs.append(pkg)
      if self.sn >= 65535:
      self.sn = 0
      self.sn = self.sn + 1
      return pkgs
      #####################################################
      # 根据帧数据，生成多个数据包(音频频)
      #####################################################
      def genAudioPkgsByFrame(self):
      self.dataType = 3 << 4
      datas = self.splitStrByLen(self.dataBody,1900)
      pkgs = []
      for i in range(0,len(datas)):
      if len(datas) == 1:
      self.pkgTag = 0 # 原子包 0000
      else:
      if i == 0:
      self.pkgTag = 1 # 第一个包 0001
      elif i < (len(datas) - 1):
      self.pkgTag = 3 # 中间包 0011
      else:
      self.pkgTag = 2 # 最后一个包 0010
      pkg = self.genAudioPkg(datas[i])
      pkgs.append(pkg)
      if self.sn == 65535:
      self.sn = 0
      self.sn = self.sn + 1
      return pkgs
      if __name__ == "__main__":
      pro = Protocal_1078()
      # print(Protocal_1078().genPkg())
      # Protocal_1078().readvideoFile()
      # pro.getFrameType()
      lib/protocal/Protocal_1078.py 0 → 100644
      View file @ 783a9a57
      #coding:utf-8
      import binascii
      import socket
      from ctypes import string_at
      import time
      import cv2
      class Protocal_1078:
      def __init__(self):
      self.frameHeader1078 = "30316364" # JT/T 1078 头 固定为0x30 0x31 0x63 0x64，ASCII码为01cd
      self.V = 2 << 6 # V 固定为2
      self.P = 0 << 5 # P 固定为0
      self.X = 0 << 4 # X RTP头是否需要扩展位，固定为0
      self.CC = 1 # CC 固定为1
      self.M = 1 << 7 # M 标志位，确定是否完整数据帧的边界，因为数据体的最大长度是950字节，而一个视频I帧通道要远远超过950字节，所以视频的一个帧通常会分包
      self.PT = 98 # PT 98:表示H264 99:表示H265
      self.sn = 0 # 包序号 初始为0，每发送一个RTP数据包，序列号加1
      self.sim = "013146201117" # 终端设备SIM卡号
      self.logicC = 1 # 逻辑通道
      self.dataType = 0 << 4 # 数据类型 ， 0000：数据I祯，0001：视频P帧，0010：视频B帧，0011：音频帧，0100：透传数据
      self.pkgTag = 1 # 分包处理 ，0000：原子包，不可拆分等，0001：分包处理时的第一个包，0010：分包处理时的最后一个包，0011：分包处理时的中间包
      self.time = 33 # 时间戳
      self.lastKeyTime = 33 # Last I Frame Interval 该祯与上一个关键祯之间的时间间隔，单位毫秒（ms），当数据类型为非视频祯时，则没有该字段
      self.lastTime = 33 # Last Frame Interval 该祯与上一个祯之间的时间时间，单位毫秒(ms)，当数据类型为非视频祯时，则没有该字段
      self.lenS = 950 # 数据长度
      self.dataBody = "" # 数据体，要发送的帧数据
      # self.host = "10.100.11.125"
      self.host = "10.16.15.85"
      self.port = 1078
      self.BUF_SIZE = 2048
      def setDataBody(self,data):
      self.dataBody = data
      def setM(self,data):
      self.M = data << 7
      def setSim(self,data):
      while len(data) < 12:
      data = "0" + data
      self.sim = data
      def setLogcC(self,data):
      self.logicC = data
      def setSn(self,data):
      self.sn = data
      def setTime(self,data):
      self.time = data
      def setLastKeyTime(self,data):
      self.lastKeyTime = data
      def setLastTime(self,data):
      self.lastTime = data
      #####################################################
      # 从帧数据中获取帧类型
      #####################################################
      def getFrameType(self):
      # 0x67 (0 11 00111) SPS 非常重要 type = 7
      # 0x68 (0 11 01000) PPS 非常重要 type = 8
      # 0x65 (0 11 00101) IDR帧 关键帧 非常重要 type = 5
      # 0x61 (0 11 00001) I帧 重要 type=1 非IDR的I帧 不大常见
      # 0x41 (0 10 00001) P帧 重要 type = 1
      # 0x01 (0 00 00001) B帧 不重要 type = 1
      # 0x06 (0 00 00110) SEI 不重要 type = 6
      frameTypeHex = self.dataBody[8:10]
      return frameTypeHex
      #####################################################
      # 数字转换为16进制字符串，通过传入字节数可自动补0
      # 传入数据格式所占字节数
      #####################################################
      def int2hexStringByBytes(self, num,bytescount=1):
      hexStr = hex(num)[2:]
      while len(hexStr) < (bytescount * 2):
      hexStr = "0" + hexStr
      return hexStr
      #####################################################
      # 根据长度分割字符串
      #####################################################
      def splitStrByLen(self,strs,num):
      result = []
      if num > len(strs):
      result.append(strs)
      else:
      result.append(strs[:num])
      strs = strs[num:]
      while len(strs) > num:
      result.append(strs[:num])
      strs = strs[num:]
      if len(strs) > 0:
      result.append(strs)
      return result
      #####################################################
      # 生成单个数据包
      #####################################################
      def genPkg(self,data):
      msg = ""
      msg = self.frameHeader1078
      msg = msg + self.int2hexStringByBytes(self.V + self.P + self.X + self.CC)
      msg = msg + self.int2hexStringByBytes(self.M + self.PT)
      msg = msg + self.int2hexStringByBytes(self.sn,2)
      msg = msg + self.sim
      msg = msg + self.int2hexStringByBytes(self.logicC)
      msg = msg + self.int2hexStringByBytes(self.dataType + self.pkgTag)
      msg = msg + self.int2hexStringByBytes(self.time,8)
      msg = msg + self.int2hexStringByBytes(self.lastKeyTime,2)
      msg = msg + self.int2hexStringByBytes(self.lastTime,2)
      msg = msg + self.int2hexStringByBytes(int(len(data) / 2),2)
      msg = msg + data
      return msg
      #####################################################
      # 生成单个数据包
      #####################################################
      def genAudioPkg(self,data):
      msg = ""
      msg = self.frameHeader1078
      msg = msg + self.int2hexStringByBytes(self.V + self.P + self.X + self.CC)
      self.PT = 19
      msg = msg + self.int2hexStringByBytes(self.M + self.PT)
      msg = msg + self.int2hexStringByBytes(self.sn,2)
      msg = msg + self.sim
      msg = msg + self.int2hexStringByBytes(self.logicC)
      msg = msg + self.int2hexStringByBytes(self.dataType + self.pkgTag)
      msg = msg + self.int2hexStringByBytes(self.time,8)
      msg = msg + self.int2hexStringByBytes(int(len(data) / 2),2)
      msg = msg + data
      return msg
      #####################################################
      # 根据帧数据，生成多个数据包(视频)
      #####################################################
      def genPkgsByFrame(self):
      f_type = self.getFrameType()
      if f_type == "65" or f_type == "61":
      self.dataType = 0 << 4 # 0000
      elif f_type == "41":
      self.dataType = 1 << 4 # 0001
      elif f_type == "01":
      self.dataType = 2 << 4 # 0010
      else:
      self.dataType = 2 << 4 # 0010
      datas = self.splitStrByLen(self.dataBody,1900)
      pkgs = []
      for i in range(0,len(datas)):
      if len(datas) == 1:
      self.pkgTag = 0 # 原子包 0000
      else:
      if i == 0:
      self.pkgTag = 1 # 第一个包 0001
      elif i < (len(datas) - 1):
      self.pkgTag = 3 # 中间包 0011
      else:
      self.pkgTag = 2 # 最后一个包 0010
      pkg = self.genPkg(datas[i])
      pkgs.append(pkg)
      if self.sn >= 65535:
      self.sn = 0
      self.sn = self.sn + 1
      return pkgs
      #####################################################
      # 根据帧数据，生成多个数据包(音频频)
      #####################################################
      def genAudioPkgsByFrame(self):
      self.dataType = 3 << 4
      datas = self.splitStrByLen(self.dataBody,1900)
      pkgs = []
      for i in range(0,len(datas)):
      if len(datas) == 1:
      self.pkgTag = 0 # 原子包 0000
      else:
      if i == 0:
      self.pkgTag = 1 # 第一个包 0001
      elif i < (len(datas) - 1):
      self.pkgTag = 3 # 中间包 0011
      else:
      self.pkgTag = 2 # 最后一个包 0010
      pkg = self.genAudioPkg(datas[i])
      pkgs.append(pkg)
      if self.sn == 65535:
      self.sn = 0
      self.sn = self.sn + 1
      return pkgs
      if __name__ == "__main__":
      pro = Protocal_1078()
      # print(Protocal_1078().genPkg())
      # Protocal_1078().readvideoFile()
      # pro.getFrameType()
      lib/service/StreamH264.py 0 → 100644
      View file @ 783a9a57
      This diff is collapsed.
      lib/service/StreamH264Flv.py 0 → 100644
      View file @ 783a9a57
      #coding: utf-8
      class StreamH264Flv():
      def __init__(self):
      self.isFileHead = 1 # 读取文件的时候，是否是文件的开头 0：不是 1：是
      self.readSize = 10240 # 读取文件的大小
      def readFlvAndSend(self,fileName):
      with open(fileName, 'rb') as fi:
      con = fi.read(self.readSize)
      self.isFileHead = 0
      data = con.hex()
      if self.isFileHead == 0:
      pass
      else:
      data = data[18:]
      while con:
      con = fi.read(self.readSize)
      data = con.hex()
      tagSize = self.getAVTagSize(data)
      ####################################################
      # 获取TagType
      # 0x08 音频
      # 0x09 视频
      # 0x12 脚本
      ####################################################
      def getTagType(self,tag):
      tagType = tag[8:10]
      return tagType
      ####################################################
      # 获取 flv tag 的数据长度，其实如图里 audio tag 头及其数据长度
      ####################################################
      def getAVTagSize(self,tag):
      tagSize = tag[10:16]
      tagSize = int(tagSize,16)
      return tagSize
      ####################################################
      # 获取相对时间戳
      ####################################################
      def getAVTimeStamp(self,tag):
      timeStamp = tag[16:22]
      timeStamp = int(timeStamp,16)
      return timeStamp
      ####################################################
      # 获取音视频数据
      ####################################################
      def getAVData(self,tag,tagSize):
      flvData = tag[34:(tagSize * 2)]
      lastData = tag[(tagSize * 2):]
      return flvData,lastData
      ####################################################
      # 读取文件（测试程序）
      ####################################################
      def readTest(self,fileName):
      with open(fileName, 'rb') as f2:
      con = f2.read(204800)
      data = con.hex() # 16进制字节码转字符串
      data_H = data.split("00000001")
      for i in range(1,len(data_H)):
      print("00000001" + data_H[i])
      ####################################################
      # 读取文件（测试程序）
      ####################################################
      def readTest2(self,fileName):
      with open(fileName, 'rb') as f2:
      con = f2.read(512)
      data = con.hex()
      print(data)
      ####################################################
      # 读取文件（测试程序），从指定位置开始读取
      ####################################################
      def readTest3(self,fileName):
      with open(fileName, 'rb') as f2:
      f2.seek(4,0)
      con = f2.read(1)
      data = con.hex()
      print(data)
      if __name__ == "__main__":
      StreamH264Flv().readTest2("../../flv/aaa.flv")
      # StreamH264Flv().readTest2("../flv/aaah.h264")
      # aaa = "02000a6f6e4d65746144617461080000001000086475726174696f6e0040695da1cac083120005776964746800407e0000000000000006686569676874004070e00000000000000d766964656f646174617261746500000000000000000000096672616d657261746500403e000000000000000c766964656f636f646563696400401c000000000000000d617564696f6461746172617465000000000000000000000f617564696f73616d706c65726174650040e7700000000000000f617564696f73616d706c6573697a65004030000000000000000673746572656f0101000c617564696f636f6465636964004000000000000000000b6d616a6f725f6272616e6402000469736f6d000d6d696e6f725f76657273696f6e0200033531320011636f6d70617469626c655f6272616e647302001069736f6d69736f32617663316d7034310007656e636f64657202000d4c61766635382e36352e313030000866696c6573697a650041621da1a00000000000090000017f0900003400000000000000170000000001640015ffe1001a67640015acd941e08feb0110000003001000000303c0f162d96001000668ebe3cb22c0fdf8f8000000003f09001f69000000000000001701000043000002ae0605ffffaadc45e9bde6d948b7962cd820d923eeef78323634"
      # print(len(aaa))
      # print(aaa[:744])
      \ No newline at end of file
      lib/service/StreamH264_bat.py 0 → 100644
      View file @ 783a9a57
      This diff is collapsed.
      lib/testCase/H264PresureTest.py 0 → 100644
      View file @ 783a9a57
      # coding:utf-8
      import threading
      import time
      from lib.service.StreamH264 import StreamH264
      class H264PresureTest():
      def __init__(self):
      self.mobileStart = 100000000000 # 开始手机号
      self.channel = 1 # 频道号
      self.terNum = 2 # 要压力测试的线程数
      self.videoPath = "../../h264/bbb3.h264" # 要推流的视频路劲
      self.audioPath = "../../h264/bbb3.aac" # 要推流的音频路劲
      self.host = "10.100.12.3"
      self.port = 1078
      self.threadInfo = {} # 存放线程集
      self.threadInfo["threadObj"] = {}
      self.threadInfo["sucessT"] = {}
      self.threadInfo["failT"] = {}
      def setTerNum(self,data):
      self.terNum = data
      def setMobileStart(self,data="10000000000"):
      self.mobileStart = data
      def setChannel(self,data):
      self.channel = data
      def setVideoPath(self,data):
      self.videoPath = data
      def setAudioPath(self,data):
      self.audioPath = data
      def setHost(self,data):
      self.host = data
      def setPort(self,data):
      self.port = data
      def testService(self,cloudMirror):
      cloudMirror.sendAVStream()
      def run(self,mobile,threadId):
      cloudMirror = StreamH264()
      cloudMirror.setHost(self.host)
      cloudMirror.setPort(self.port)
      cloudMirror.connectServer()
      cloudMirror.setFPSVideo(30)
      cloudMirror.setFPSAudio(47)
      cloudMirror.setSendDur(0)
      cloudMirror.setVideoPath(self.videoPath)
      cloudMirror.setAudioPath(self.audioPath)
      cloudMirror.setMobile(mobile)
      cloudMirror.setChannel(self.channel)
      conThread = threading.Thread(target=self.testService,args=(cloudMirror,))
      self.threadInfo["threadObj"][threadId] = conThread
      conThread.start()
      print(threadId + "启动了：" + mobile + "-" + str(self.channel))
      def start(self):
      for i in range(0,self.terNum):
      mobile = self.mobileStart + i
      mobile = "0" + str(mobile)
      threadId = "threadId__" + str(i)
      self.run(mobile,threadId)
      time.sleep(0.1)
      if __name__ == "__main__":
      test = H264PresureTest()
      test.setHost("10.100.12.3")
      test.setPort(1078)
      test.setMobileStart(10000000000)
      test.setChannel(1)
      test.setTerNum(20)
      test.setVideoPath("../../h264/bbb3.h264")
      test.setAudioPath("../../aac/bbb3.aac")
      test.start()
      \ No newline at end of file
      readH264.py 0 → 100644
      View file @ 783a9a57
      #coding: utf-8
      import binascii
      def readH():
      with open("h264/aaa2.264", 'rb') as f2:
      con = f2.read(2048)
      data = con.hex()
      data2 = data.split("00000001")
      for i in data2:
      print("00000001" + i)
      print(data2)
      with open("h264/tmp.bin", 'wb') as f3:
      f3.write(con)
      if __name__ == "__main__":
      readH()
      \ No newline at end of file
      run.py 0 → 100644
      View file @ 783a9a57
      #coding: utf-8
      from lib.service.StreamH264 import StreamH264
      if __name__ == "__main__":
      StreamH264().readStreamFromFileAndSend("h264/aaa2.264")
      # StreamH264().readTest("h264/aaa2.264")
      temp/res.txt 0 → 100644
      View file @ 783a9a57
      This diff is collapsed.
      temp/tmp1.txt 0 → 100644
      View file @ 783a9a57
      This diff is collapsed.
      test.py 0 → 100644
      View file @ 783a9a57
      # coding: utf-8
      import subprocess
      import threading
      import time
      import os
      VIDEO_PATH = "video" #自动推流视频目录
      # PUSH_URL = "rtmp://192.168.0.108:1935/live/room"
      PUSH_URL = "rtmp://10.100.12.50:1935/live/room" #推流服务地址
      pushThread = {}
      isLoop = 1 #是否循环推流：0：不循环 1：循环
      #############################################
      # 读取当前目录文件
      #############################################
      def readVideoFile(path=VIDEO_PATH):
      videoFiles = os.listdir(VIDEO_PATH)
      return videoFiles
      #############################################
      # 推流方法，被线程调用
      #############################################
      def pushStream(fi,url):
      print(fi + "----推流开始 ")
      m_command = ["ffmpeg.exe",
      "-re",
      "-i", fi,
      "-vcodec", "copy",
      "-f",
      "flv", url]
      print(m_command)
      subprocess.run(m_command)
      print(fi + "----推流结束 ")
      if isLoop == 1:
      time.sleep(0.5)
      pushStream(fi,url)
      else:
      pushThread.pop(fi)
      #############################################
      # 开始推流启动多个线程去推流(使用VIDEO_PATH目录下的有所文件)
      #############################################
      def startPush():
      v_files = readVideoFile()
      i = 1
      for fi in v_files:
      pushFile = VIDEO_PATH + "/" + fi
      pushUrl = PUSH_URL + str(i)
      td = threading.Thread(target=pushStream,args=[pushFile,pushUrl])
      td.start()
      i = i + 1
      pushThread[pushFile] = pushUrl
      time.sleep(1)
      while len(pushThread) > 0:
      for key in pushThread:
      print(key + " 的播放地址为：" + pushThread[key])
      time.sleep(5)
      print("\n")
      print("所有推流全部结束")
      #############################################
      # 开始推流(使用写死的文件地址)
      #############################################
      def pushStreamFixedFile():
      m_command = ["ffmpeg.exe",
      "-re",
      "-i","E:\视频\舞蹈\【かや】Doja Cat - Say So _ KAYA Ver.【踊ってみた】.mp4",
      # "-i", "【かや】thank u, next _ Ariana Grande【踊ってみた _ KAYA Ver.】.mp4",
      "-vcodec", "copy",
      "-f",
      "flv", "rtmp://10.100.12.50:1935/live/room1"]
      subprocess.run(m_command)
      if __name__ == "__main__":
      # startPush()
      pushStreamFixedFile()
      testR.py 0 → 100644
      View file @ 783a9a57
      #coding:utf-8
      import binascii
      import time
      import socket
      from xml.dom.minidom import parse
      #http://10.100.11.125:8085/live?port=1985&app=vandyo&stream=013146201116-4
      # host = "10.100.11.125"
      # host = "10.16.15.85"
      host = "localhost"
      port = 1078
      BUF_SIZE = 2048
      isLoop = 0 #是否循环发送视频流）0：不 1：是
      SIM = "013146201117"
      channel = "03"
      def readFile_M(fileName):
      with open(fileName, 'r') as f1:
      f_content = f1.readlines()
      for con in f_content:
      # print(con)
      with open("temp/res.txt", 'a') as f2:
      f2.write(con.replace("\n",""))
      #####################################################
      # 从帧数据中获取帧类型
      #####################################################
      def getFrameType(data):
      # 0x67 (0 11 00111) SPS 非常重要 type = 7
      # 0x68 (0 11 01000) PPS 非常重要 type = 8
      # 0x65 (0 11 00101) IDR帧 关键帧 非常重要 type = 5
      # 0x61 (0 11 00001) I帧 重要 type=1 非IDR的I帧 不大常见
      # 0x41 (0 10 00001) P帧 重要 type = 1
      # 0x01 (0 00 00001) B帧 不重要 type = 1
      # 0x06 (0 00 00110) SEI 不重要 type = 6
      frameTypeHex = data[68:70]
      return frameTypeHex
      def readFile_M2(fileName):
      with open(fileName, 'r') as f1:
      f_content = f1.read()
      f_content = f_content.split("30316364")
      # print(len(f_content))
      client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
      client.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) # 在客户端开启心跳
      client.connect((host, port))
      for i in range(2,len(f_content)):
      msg = "30316364" + f_content[i]
      msg = msg[:16] + SIM + channel + msg[30:]
      if getFrameType(msg) == "61":
      print("关键帧")
      client.send(binascii.a2b_hex(msg))
      time.sleep(0.01)
      print(msg)
      print("\n\n\n\n 第一波推流完成 --------------------------------")
      client.close()
      time.sleep(5)
      if isLoop == 1:
      readFile_M2("temp/res.txt")
      def paseXml():
      domTree = parse("xml/frame.xml")
      rootNode = domTree.documentElement
      frameSizes = []
      # 所有顾客
      customers = rootNode.getElementsByTagName("frame")
      for customer in customers:
      frameSizes.append(int(customer.getAttribute("pkt_size")))
      with open("aac/aaa.aac", 'rb') as f1:
      client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
      client.setsockopt(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) # 在客户端开启心跳
      client.connect((host, port))
      for i in frameSizes:
      msg = f1.read(i)
      msg = msg.hex()
      print(msg)
      client.send(binascii.a2b_hex(msg))
      time.sleep(0.001)
      client.close()
      if __name__ == "__main__":
      # readFile_M("temp/tmp1.txt")
      # readFile_M2("temp/res.txt")
      # readFile_M("temp/video.txt")
      # readFile_M2("temp/res.txt")
      paseXml()
      \ No newline at end of file
      Markdown is supported
      0% or
      You are about to add 0 people to the discussion. Proceed with caution.
      Finish editing this message first!
      Please register or to comment