• Home
  • Categories
  • WIKI
  • LANGUAGE: en
    • GStreamer笔记
    社区开发 4703 views · 1 replies ·
    Tofloor
    poster avatar
    z85525006
    deepin
    2012-09-18 23:40
    Author
    由于本人在使用和学习GStreamer,所以作了个笔记来翻查,请各位见谅,误喷.

       
    '''
    gst.Bin
    是GStreamer框架中的容器元件，它通常被用来容纳其它的元件对象，
    但由于其自身也是一个GstElement对象，因此实际上也能够被用来容纳其它的箱柜对象。
    利用箱柜可以将需要处理的多个元件组合成一个逻辑元件，
    由于不再需要对箱柜中的元件逐个进行操作，
    因此能够很容易地利用它来构造更加复杂的管道。
    在GStreamer框架中使用箱柜还有另外一个优点，那就是它会试着对数据流进行优化，
    这对于多媒体应用来讲是很具吸引力的.
    ==================================================
    在GStreamer应用程序中使用的箱柜主要有两种类型：
    [] GstPipeline 管道是最常用到的容器，
       对于一个GStreamer应用程序来讲，其顶层箱柜必须是一条管道。
    [] GstThread 线程的作用在于能够提供同步处理能力，
       如果GStreamer应用程序需要进行严格的音视频同步，一般都需要用到这种类型的箱柜。
    ===================================================
    GStreamer框架提供了两种方法来创建箱柜：一种是借助工厂方法，另一种则是使用特定的函数。
    下面的代码示范了如何使用工厂方法创建线程对象，以及如何使用特定函数来创建管道对象：

    gst.Pipeline(\"pipeline_name\") # 创建管道对象

    element = gst.element_factory_make(\"...\", ..) #
    bin = gst.Bin(\"bin_name\")
    bin.add(element)

    # 这种方式是为了解决 Bin与其它带来的问题.
    bin.add_pad() # 输入衬垫 和 输出衬垫
    '''


    代码分析:
    2. import gst
    3. import gobject
    5. class VideoFade(gst.Bin):
    6.     """
    7.     Simple video fade element
    8.     """
    10.     def __init__(self, position=0, duration=2 * gst.SECOND, fadefromblack=True):
    11.         gst.Bin.__init__(self)
    12.         self.incsp = gst.element_factory_make("ffmpegcolorspace", "incsp")
    13.         self.outcsp = gst.element_factory_make("ffmpegcolorspace", "outcsp")
    14.         self.alpha = gst.element_factory_make("alpha", "alpha")
    15.         self.vmix = gst.element_factory_make("videomixer", "videomix")
    16.         self.vmix.set_property("background", 1)
    17.         self.add(self.incsp, self.alpha, self.vmix, self.outcsp)
    18.         gst.element_link_many(self.incsp, self.alpha, self.vmix, self.outcsp)
    20.         self._sinkpad = gst.GhostPad("sink", self.incsp.get_pad("sink"))
    21.         self._sinkpad.set_active(True)
    22.         self._srcpad = gst.GhostPad("src", self.outcsp.get_pad("src"))
    23.         self._srcpad.set_active(True)
    25.         self.add_pad(self._sinkpad)
    26.         self.add_pad(self._srcpad)
    28.         self.startposition = position
    29.         self.duration = duration
    30.         self.fadefromblack = fadefromblack
    32.         self.alphacontrol = gst.Controller(self.alpha, "alpha")
    33.         self.alphacontrol.set_interpolation_mode("alpha", gst.INTERPOLATE_LINEAR)
    35.         self._resetControllerValues()
    37.     def setStartPosition(self, position):
    38.         """ Set the position at which the fade should start """
    39.         if position == self.startposition:
    40.             return
    41.         self.startposition = position
    42.         self._resetControllerValues()
    44.     def setDuration(self, duration):
    45.         """ Set the duration (in ns) of the fade """
    46.         if self.duration == duration:
    47.             return
    48.         self.duration = duration
    49.         self._resetControllerValues()
    51.     def setFadeFromBlack(self, fromblack):
    52.         """ Set which directio we should use.
    53.         True : From Black
    54.         False : To Black
    55.         """
    56.         if self.fadefromblack == fromblack:
    57.             return
    58.         self.fadefromblack = fromblack
    59.         self._resetControllerValues()
    61.     def _resetControllerValues(self):
    62.         self.alphacontrol.unset_all("alpha")
    63.         if self.fadefromblack:
    64.             start = 0.0
    65.             stop = 1.0
    66.         else:
    67.             start = 1.0
    68.             stop = 0.0
    69.         self.alphacontrol.set("alpha",
    70.                               self.startposition,
    71.                               start)
    72.         self.alphacontrol.set("alpha",
    73.                               self.startposition + self.duration,
    74.                               stop)
    76. gobject.type_register(VideoFade)
    Copy the Code

    1.输入型组件 source element. 这种组件会向管道提供媒体数据，比如文件访问组件，声音获取组件等。
    2.过滤型组件 filter element, 它把输入型组件(souce element)中获取的媒体数据进行处理，比如格式转换，解复用 demuser, 复用muxer, 编解码codec等。
    3.输出型组件 sink element, 这类组件负责媒体数据的最后的输出，比如输出到音频设备，视频设备，以及输出到文件，网络等。



    读取XML文件:
    3. #coding:utf-8
    5. import xml.etree.ElementTree
    7. tree = xml.etree.ElementTree.parse("n900.xml")
    9. for child in tree.getroot().getchildren():
    10.     if child.tag == "make":   
    11.         print "%s" % child.text.strip()
    12.     elif child.tag == "version":
    13.         print "%s" % child.text.strip()
    14.     elif child.tag == "author":
    15.         for child in child.getchildren():
    16.             if child.tag == "name":
    17.                 print "%s:" % child.tag
    18.             elif child.tag == "email":
    19.                 print "%s:" % child.tag
    Copy the Code


    小例子:
    2. #coding:utf-8
    4. import gst
    6. # 创建用来容纳元件的新管道.
    7. pipeline = gst.Pipeline("pipeline")
    8. #
    9. # 依次创建各个元件,并将各个元件添加到管道中.
    10. #
    11. # 创建源元件用来从v412驱动中获取视频流.
    12. source = gst.element_factory_make("gconfvideosrc", "v412src")
    13. pipeline.add(source)
    15. # 创建过滤器元件, 解码视频流.
    16. ffmpeng1 = gst.element_factory_make("ffmpegcolorspace",
    17.                                     "ffmpegcolorspace")
    18. pipeline.add(ffmpeng1)
    20. # 创建过滤器元件, 解码视频流.
    21. ffmpeng2 = gst.element_factory_make("ffmpegcolorspace",
    22.                                     "ffmpegcolorspace2")
    23. pipeline.add(ffmpeng2)
    25. # 创建过滤器元件, 解码视频流.
    26. ffmpeng3 = gst.element_factory_make("ffmpegcolorspace",
    27.                                     "ffmpegcolorspace3")
    28. pipeline.add(ffmpeng3)
    30. # 依次连接各个组件.
    Copy the Code

    由于解码的文件比较多,可以对照一个表.
    gstreamer使用进阶 - android_lee的专栏 - 博客频道 - CSDN.NET.html.tar.gz


          # 监视消息. 有点像 WINDOW写 SDK或者是XLIB的样子,在循环消息里面 进行类型判断,看是那种消息.
           bus = self.pipeline.get_bus() # pipeline get_bus() 得到一个管道的 gstBUS
           bus.add_watch(self.on_message)


          #
           self.fileoutput = gst.element_factory_make("filesink", "fileoutput")
           self.fileoutput.set_property("location", "文件路径名")


    3. { 'Ogg' : "application/ogg",
    4.         'Matroska' : "video/x-matroska",
    5.         'MXF' : "application/mxf",
    6.         'AVI' : "video/x-msvideo",
    7.         'Quicktime' : "video/quicktime,variant=apple",
    8.         'MPEG4' : "video/quicktime,variant=iso",
    9.         'MPEG PS' : "video/mpeg,mpegversion=2,systemstream=true",
    10.         'MPEG TS' : "video/mpegts,systemstream=true,packetsize=188",
    11.         'AVCHD/BD' : "video/mpegts,systemstream=true,packetsize=192",
    12.         'FLV' : "video/x-flv",
    13.         '3GPP' : "video/quicktime,variant=3gpp", \
    14.         'ASF' : "video/x-ms-asf, parsed=true", \
    15.         'WebM' : "video/webm", \
    16.         'No container' : False }
    18.   { 'Ogg' : ".ogg", \
    19.         'Matroska' : ".mkv", \
    20.         'MXF' : ".mxf", \
    21.         'AVI' : ".avi", \
    22.         'Quicktime' : ".mov", \
    23.         'MPEG4' : ".mp4", \
    24.         'MPEG PS' : ".mpg", \
    25.         'MPEG TS' : ".ts", \
    26.         'AVCHD/BD' : ".m2ts", \
    27.         'FLV' : ".flv", \
    28.         '3GPP' : ".3gp",
    29.         'ASF' : ".asf", \
    30.         'WebM' : ".webm", \
    31.         'No container' : ".null" }
    33.   { 'Ogg' : ".ogg", \
    34.         'Matroska' : ".mkv", \
    35.         'MXF' : ".mxf", \
    36.         'AVI' : ".avi", \
    37.         'Quicktime' : ".m4a",
    38.         'MPEG4' : ".mp4", \
    39.         'MPEG PS' : ".mpg", \
    40.         'MPEG TS' : ".ts", \
    41.         'FLV' : ".flv", \
    42.         '3GPP' : ".3gp", \
    43.         'ASF' : ".wma", \
    44.         'WebM' : ".webm" }
    46. {
    47.          'audio/mpeg, mpegversion=(int)1, layer=(int)3' : ".mp3", \
    48.          'audio/mpeg, mpegversion=(int)4, stream-format=(string)adts' : ".aac", \
    49.          'audio/x-flac' : ".flac" }
    51. { 'Vorbis' : "audio/x-vorbis", \
    52.         'FLAC' : "audio/x-flac", \
    53.         'mp3' : "audio/mpeg, mpegversion=(int)1, layer=(int)3", \
    54.         'AAC' : "audio/mpeg,mpegversion=4", \
    55.         'AC3' : "audio/x-ac3", \
    56.         'Speex' : "audio/x-speex",
    57.         'Celt Ultra' : "audio/x-celt", \
    58.         'ALAC' : "audio/x-alac", \
    59.         'Windows Media Audio 2' : "audio/x-wma, wmaversion=(int)2", \
    60.         'Theora' : "video/x-theora", \
    61.         'Dirac' : "video/x-dirac", \
    62.         'H264' : "video/x-h264", \
    63.         'MPEG2' : "video/mpeg,mpegversion=2,systemstream=false", \
    64.         'MPEG4' : "video/mpeg,mpegversion=4", \
    65.         'xvid' : "video/x-xvid", \
    66.         'Windows Media Video 2' : "video/x-wmv,wmvversion=2", \
    67.         'dnxhd' : "video/x-dnxhd", \
    68.         'divx5' : "video/x-divx,divxversion=5", \
    69.         'divx4' : "video/x-divx,divxversion=4", \
    70.         'AMR-NB' : "audio/AMR", \
    71.         'H263+' : "video/x-h263,variant=itu,h263version=h263p", \
    72.         'On2 vp8' : "video/x-vp8", \
    73.         'mp2' : "audio/mpeg,mpegversion=(int)1, layer=(int)2", \
    74.         'MPEG1' : "video/mpeg,mpegversion=(int)1,systemstream=false"}
    Copy the Code

    gst.Caps(*args, *kwargs)
    如果没有参数传给构造函数,一个空的caps将会创建,否则你可以传递一个字符串或者一个结构.
    Reply Favorite View the author
    All Replies
    z85525006
    deepin
    2012-09-19 10:55
    #1
    Reply View the author