[go: up one dir, main page]

CN104811827A - 报文发送方法、码流处理方法及装置 - Google Patents

报文发送方法、码流处理方法及装置 Download PDF

Info

Publication number
CN104811827A
CN104811827A CN201510188537.XA CN201510188537A CN104811827A CN 104811827 A CN104811827 A CN 104811827A CN 201510188537 A CN201510188537 A CN 201510188537A CN 104811827 A CN104811827 A CN 104811827A
Authority
CN
China
Prior art keywords
server
code stream
message
information
sending
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Pending
Application number
CN201510188537.XA
Other languages
English (en)
Inventor
陈安庆
熊伟
陈颖川
丁毅
张晓渠
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
ZTE Corp
Original Assignee
ZTE Corp
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by ZTE Corp filed Critical ZTE Corp
Priority to CN201510188537.XA priority Critical patent/CN104811827A/zh
Publication of CN104811827A publication Critical patent/CN104811827A/zh
Priority to PCT/CN2016/079770 priority patent/WO2016169482A1/zh
Priority to US15/568,057 priority patent/US10575065B2/en
Priority to EP16782629.6A priority patent/EP3288276A4/en
Pending legal-status Critical Current

Links

Classifications

    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04N—PICTORIAL COMMUNICATION, e.g. TELEVISION
    • H04N21/00—Selective content distribution, e.g. interactive television or video on demand [VOD]
    • H04N21/60—Network structure or processes for video distribution between server and client or between remote clients; Control signalling between clients, server and network components; Transmission of management data between server and client, e.g. sending from server to client commands for recording incoming content stream; Communication details between server and client 
    • H04N21/63—Control signaling related to video distribution between client, server and network components; Network processes for video distribution between server and clients or between remote clients, e.g. transmitting basic layer and enhancement layers over different transmission paths, setting up a peer-to-peer communication via Internet between remote STB's; Communication protocols; Addressing
    • H04N21/647—Control signaling between network components and server or clients; Network processes for video distribution between server and clients, e.g. controlling the quality of the video stream, by dropping packets, protecting content from unauthorised alteration within the network, monitoring of network load, bridging between two different networks, e.g. between IP and wireless
    • H04N21/64723—Monitoring of network processes or resources, e.g. monitoring of network load
    • H04N21/6473—Monitoring network processes errors
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F11/00—Error detection; Error correction; Monitoring
    • G06F11/07—Responding to the occurrence of a fault, e.g. fault tolerance
    • G06F11/16—Error detection or correction of the data by redundancy in hardware
    • G06F11/20—Error detection or correction of the data by redundancy in hardware using active fault-masking, e.g. by switching out faulty elements or by switching in spare elements
    • G06F11/202—Error detection or correction of the data by redundancy in hardware using active fault-masking, e.g. by switching out faulty elements or by switching in spare elements where processing functionality is redundant
    • G06F11/2023—Failover techniques
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L12/00—Data switching networks
    • H04L12/02—Details
    • H04L12/16—Arrangements for providing special services to substations
    • H04L12/18—Arrangements for providing special services to substations for broadcast or conference, e.g. multicast
    • H04L12/1813—Arrangements for providing special services to substations for broadcast or conference, e.g. multicast for computer conferences, e.g. chat rooms
    • H04L12/1827—Network arrangements for conference optimisation or adaptation
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L12/00—Data switching networks
    • H04L12/02—Details
    • H04L12/16—Arrangements for providing special services to substations
    • H04L12/18—Arrangements for providing special services to substations for broadcast or conference, e.g. multicast
    • H04L12/1863—Arrangements for providing special services to substations for broadcast or conference, e.g. multicast comprising mechanisms for improved reliability, e.g. status reports
    • H04L12/1868—Measures taken after transmission, e.g. acknowledgments
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L12/00—Data switching networks
    • H04L12/02—Details
    • H04L12/16—Arrangements for providing special services to substations
    • H04L12/18—Arrangements for providing special services to substations for broadcast or conference, e.g. multicast
    • H04L12/1863—Arrangements for providing special services to substations for broadcast or conference, e.g. multicast comprising mechanisms for improved reliability, e.g. status reports
    • H04L12/1877—Measures taken prior to transmission
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
    • H04L41/06—Management of faults, events, alarms or notifications
    • H04L41/0654—Management of faults, events, alarms or notifications using network fault recovery
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L45/00—Routing or path finding of packets in data switching networks
    • H04L45/28—Routing or path finding of packets in data switching networks using route fault recovery
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L65/00—Network arrangements, protocols or services for supporting real-time applications in data packet communication
    • H04L65/60—Network streaming of media packets
    • H04L65/61—Network streaming of media packets for supporting one-way streaming services, e.g. Internet radio
    • H04L65/612—Network streaming of media packets for supporting one-way streaming services, e.g. Internet radio for unicast
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/01—Protocols
    • H04L67/10—Protocols in which an application is distributed across nodes in the network
    • H04L67/1001—Protocols in which an application is distributed across nodes in the network for accessing one among a plurality of replicated servers
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/01—Protocols
    • H04L67/10—Protocols in which an application is distributed across nodes in the network
    • H04L67/1001—Protocols in which an application is distributed across nodes in the network for accessing one among a plurality of replicated servers
    • H04L67/1004—Server selection for load balancing
    • H04L67/1023—Server selection for load balancing based on a hash applied to IP addresses or costs
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
    • H04L69/16—Implementation or adaptation of Internet protocol [IP], of transmission control protocol [TCP] or of user datagram protocol [UDP]
    • H04L69/161—Implementation details of TCP/IP or UDP/IP stack architecture; Specification of modified or new header fields
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
    • H04L69/40—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass for recovering from a failure of a protocol instance or entity, e.g. service redundancy protocols, protocol state redundancy or protocol service redirection
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04N—PICTORIAL COMMUNICATION, e.g. TELEVISION
    • H04N21/00—Selective content distribution, e.g. interactive television or video on demand [VOD]
    • H04N21/20—Servers specifically adapted for the distribution of content, e.g. VOD servers; Operations thereof
    • H04N21/21—Server components or server architectures
    • H04N21/218—Source of audio or video content, e.g. local disk arrays
    • H04N21/2181—Source of audio or video content, e.g. local disk arrays comprising remotely distributed storage units, e.g. when movies are replicated over a plurality of video servers
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04N—PICTORIAL COMMUNICATION, e.g. TELEVISION
    • H04N21/00—Selective content distribution, e.g. interactive television or video on demand [VOD]
    • H04N21/60—Network structure or processes for video distribution between server and client or between remote clients; Control signalling between clients, server and network components; Transmission of management data between server and client, e.g. sending from server to client commands for recording incoming content stream; Communication details between server and client 
    • H04N21/63—Control signaling related to video distribution between client, server and network components; Network processes for video distribution between server and clients or between remote clients, e.g. transmitting basic layer and enhancement layers over different transmission paths, setting up a peer-to-peer communication via Internet between remote STB's; Communication protocols; Addressing
    • H04N21/64—Addressing
    • H04N21/6405—Multicasting
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04N—PICTORIAL COMMUNICATION, e.g. TELEVISION
    • H04N7/00—Television systems
    • H04N7/08—Systems for the simultaneous or sequential transmission of more than one television signal, e.g. additional information signals, the signals occupying wholly or partially the same frequency band, e.g. by time division
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06F—ELECTRIC DIGITAL DATA PROCESSING
    • G06F11/00—Error detection; Error correction; Monitoring
    • G06F11/07—Responding to the occurrence of a fault, e.g. fault tolerance
    • G06F11/16—Error detection or correction of the data by redundancy in hardware
    • G06F11/20—Error detection or correction of the data by redundancy in hardware using active fault-masking, e.g. by switching out faulty elements or by switching in spare elements
    • G06F11/202—Error detection or correction of the data by redundancy in hardware using active fault-masking, e.g. by switching out faulty elements or by switching in spare elements where processing functionality is redundant
    • G06F11/2038—Error detection or correction of the data by redundancy in hardware using active fault-masking, e.g. by switching out faulty elements or by switching in spare elements where processing functionality is redundant with a single idle spare processing component
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L61/00—Network arrangements, protocols or services for addressing or naming
    • H04L61/59—Network arrangements, protocols or services for addressing or naming using proxies for addressing
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L65/00—Network arrangements, protocols or services for supporting real-time applications in data packet communication
    • H04L65/60—Network streaming of media packets
    • H04L65/61—Network streaming of media packets for supporting one-way streaming services, e.g. Internet radio
    • H04L65/611—Network streaming of media packets for supporting one-way streaming services, e.g. Internet radio for multicast or broadcast
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
    • H04L69/22—Parsing or analysis of headers
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04N—PICTORIAL COMMUNICATION, e.g. TELEVISION
    • H04N21/00—Selective content distribution, e.g. interactive television or video on demand [VOD]
    • H04N21/60—Network structure or processes for video distribution between server and client or between remote clients; Control signalling between clients, server and network components; Transmission of management data between server and client, e.g. sending from server to client commands for recording incoming content stream; Communication details between server and client 
    • H04N21/63—Control signaling related to video distribution between client, server and network components; Network processes for video distribution between server and clients or between remote clients, e.g. transmitting basic layer and enhancement layers over different transmission paths, setting up a peer-to-peer communication via Internet between remote STB's; Communication protocols; Addressing
    • H04N21/643—Communication protocols
    • H04N21/64322—IP

Landscapes

  • Engineering & Computer Science (AREA)
  • Signal Processing (AREA)
  • Multimedia (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Computer Security & Cryptography (AREA)
  • General Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • Databases & Information Systems (AREA)
  • Quality & Reliability (AREA)
  • Physics & Mathematics (AREA)
  • General Physics & Mathematics (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)

Abstract

本发明提供了报文发送方法、码流处理方法及装置，其中，报文发送方法包括：第一服务器获取与第二服务器相同的码流并进行缓存；该第一服务器获取发送上述码流的初始位置；该第一服务器在第二服务器停止发送码流之后，构造上述码流所对应的报文并在上述初始位置根据第二服务器的源IP地址发送报文。通过本发明，解决了相关技术中存在的无法实现在不中断业务的情况下进行组播频道的迁移的问题，进而实现了在不中断业务的情况下进行组播频道的迁移的效果。

Description

报文发送方法、码流处理方法及装置
技术领域
本发明涉及通信领域，具体而言，涉及一种报文发送方法、码流处理方法及装置。
背景技术
随着科技的发展，各种各样的终端给人们的生活带来了很大的便利，以交互式网络电视(Internet Protocol Television，简称为IPTV)为例，IPTV是一种利用宽带网，集互联网、多媒体、通讯等技术于一体，向家庭用户提供包括数字电视在内的多种交互式服务的崭新技术。目前的技术让用户在家里除了能观看传统的直播频道之外，还可以点播等操作，而这些，都是由服务提供商(Internet Service Provider，简称为ISP)的服务器来提供服务的。
当发现频道码流的发送服务器有问题后，比如需要更换内存条，更换操作系统所在硬盘，升级替换软件版本等等，这些情况下都需要中止业务，将该频道删除，然后将频道码流重建到另外一台服务器上来提供服务，该操作的持续时间一般是5-10分钟。在这个期间，因为没有码流在组播组中，用户的体验就是黑屏。为了避免影响太大，一般会提前在终端上显示，这个就是大家经常会看到的在终端上显示的一段话：本台需要在某个时间段维护，暂时无法提供服务之类的，其实就是得中断业务。
从以上技术方案可以看出，相关技术中的中断业务的方法会存在以下缺点：
1.由于出现了黑屏，给用户带来很差的观看体验。
2.操作时间段受限。为了控制黑屏的影响范围，必须在观看用户数量少的时刻进行操作，所以一般选在凌晨2-3点，虽然重建的时间一般很短，但出于风险防范的角度，一般受影响的时间往往会超过10分钟，而且需要人工干预，以防止业务异常导致中断时间过长。
3.业务受损，虽然在观看用户数量少的时刻进行操作，但是如果处于在广告时间段的话，广告收入也同样会受损。
由此可知，在相关技术中，在进行组播频道的迁移时，会造成业务中断。
针对相关技术中存在的无法实现在不中断业务的情况下进行组播频道的迁移的问题，目前尚未提出有效的解决方案。
发明内容
本发明提供了一种报文发送方法、码流处理方法及装置，以至少解决相关技术中存在的无法实现在不中断业务的情况下进行组播频道的迁移的问题。
根据本发明的一个方面，提供了一种报文发送方法，包括：第一服务器获取与第二服务器相同的码流并进行缓存；所述第一服务器获取发送所述码流的初始位置；所述第一服务器在所述第二服务器停止发送码流之后，构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文。
进一步地，所述第一服务器根据所述第二服务器的源IP地址发送所述报文包括：所述第一服务器增加本地路由，以利用所述第二服务器的源IP地址发送所述报文；或者，所述第一服务器将所述第二服务器的源IP地址填入所述报文的IP地址字段，并发送所述报文。
进一步地，所述第一服务器获取与所述第二服务器相同的码流并进行缓存之前，还包括：所述第一服务器接收服务控制单元SCU发送的通知消息，其中，所述通知消息用于通知所述第一服务器获取码流信息，所述码流信息用于所述第一服务器获取所述码流并进行缓存，所述码流信息包括如下信息至少之一：所述码流的源头、所述码流的协议类型、开始缓存所述码流的位置、所述第二服务器的信息。
进一步地，所述第一服务器获取与所述第二服务器相同的码流并进行缓存之后，还包括：所述第一服务器将获取所述码流的获取结果通知给服务控制单元SCU，其中，所述获取结果用于所述SCU判断是否需要重新选择用于替换所述第二服务器的服务器，并在确定不需要重新选择服务器之后，将所述第一服务器的信息发送给所述第二服务器。
进一步地，所述第一服务器构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文之后，还包括：所述第一服务器将发送所述报文的发送结果上报给服务控制单元SCU。
进一步地，所述第一服务器获取与所述第二服务器相同的码流包括以下至少之一：所述第一服务器从除所述第二服务器之外的其他服务器中获取所述码流；所述第一服务器从用于存储所述码流的存储设备中获取所述码流。
进一步地，所述第一服务器获取发送所述码流的初始位置包括以下至少之一：所述第一服务器通过与所述第二服务器协商的方式获取所述初始位置；所述第一服务器获取预先设置的所述初始位置。
根据本发明的另一方面，提供了一种码流处理方法，包括：第二服务器接收服务控制单元SCU发送的消息，其中，所述消息用于通知所述第二服务器由第一服务器接替所述第二服务器发送码流；所述第二服务器获取所述第一服务器发送所述码流的初始位置；所述第二服务器根据所述初始位置停止发送所述码流。
进一步地，所述第二服务器获取所述第一服务器发送所述码流的初始位置包括：所述第二服务器通过和所述第一服务器协商的方式获取所述初始位置。
进一步地，所述第二服务器接收所述SCU发送的消息包括：所述第二服务器通过与所述SCU交互码流实时信息的方式接收所述SCU发送的所述消息，其中，所述码流实时信息还用于所述SCU向第一服务器发送通知消息；所述通知消息用于所述第一服务器获取与所述第二服务器相同的码流并进行缓存，获取发送所述码流的初始位置，在所述第二服务器停止发送码流之后，构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文。
进一步地，所述通知消息通过通知所述第一服务器获取码流信息的方式通知所述第一服务器获取与所述第二服务器相同的码流并进行缓存，所述码流信息包括如下信息至少之一：所述码流的源头、所述码流的协议类型、开始缓存所述码流的位置、所述第二服务器的信息。
根据本发明的另一方面，提供了一种码流处理方法，包括：服务控制单元SCU通知第一服务器获取并缓存与第二服务器相同的码流；所述SCU在接收到所述第一服务器发送的获取码流正常的信息后，将所述第一服务器的信息发送给所述第二服务器，其中，所述第一服务器的信息用于确定所述第一服务器发送所述码流的初始位置。
进一步地，在确定所述初始位置时是由所述第二服务器根据所述第一服务器的信息与所述第一服务器进行协商所确定的。
进一步地，所述SCU通知所述第一服务器获取并缓存与所述第二服务器相同的所述码流包括：所述SCU与所述第二服务器交互码流实时信息；所述SCU根据码流实时信息向所述第一服务器发送通知消息，其中，所述通知消息用于通知所述第一服务器获取并缓存与所述第二服务器相同的码流，所述通知消息还用于通知所述第一服务器获取发送所述码流的初始位置，在所述第二服务器停止发送码流之后，构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文。
进一步地，所述通知消息通过通知所述第一服务器获取码流信息的方式通知所述第一服务器获取与所述第二服务器相同的码流并进行缓存，其中，所述码流信息包括如下信息至少之一：所述码流的源头、所述码流的协议类型、开始缓存所述码流的位置、所述第二服务器的信息。
进一步地，所述方法还包括：所述SCU在接收到所述第一服务器发送的获取码流异常的信息后，选择新的用于接替所述第二服务器的服务器。
进一步地，所述SCU将所述第一服务器的信息发送给所述第二服务器之后，还包括：接收所述第一服务器上报的发送结果，其中，所述发送结果为所述第一服务器发送所述报文的发送结果。
根据本发明的另一方面，提供了一种报文发送装置，所述装置应用于第一服务器中，包括：第一获取模块，用于获取与第二服务器相同的码流并进行缓存；第二获取模块，用于获取发送所述码流的初始位置；第一发送模块，用于在所述第二服务器停止发送码流之后，构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文。
进一步地，所述第一发送模块包括：所述第一服务器增加本地路由，以利用所述第二服务器的源IP地址发送所述报文；或者，所述第一服务器将所述第二服务器的源IP地址填入所述报文的IP地址字段，并发送所述报文。
进一步地，所述装置还包括：第一接收模块，用于接收服务控制单元SCU发送的通知消息，其中，所述通知消息用于通知所述第一服务器获取码流信息，所述码流信息用于所述第一服务器获取所述码流并进行缓存，所述码流信息包括如下信息至少之一：所述码流的源头、所述码流的协议类型、开始缓存所述码流的位置、所述第二服务器的信息。
进一步地，所述装置还包括：第一通知模块，用于将获取所述码流的获取结果通知给服务控制单元SCU，其中，所述获取结果用于所述SCU判断是否需要重新选择用于替换所述第二服务器的服务器，并在确定不需要重新选择服务器之后，将所述第一服务器的信息发送给所述第二服务器。
进一步地，所述装置还包括：上报模块，用于将发送所述报文的发送结果上报给服务控制单元SCU。
进一步地，所述第一获取模块包括以下至少之一：所述第一服务器从除所述第二服务器之外的其他服务器中获取所述码流；所述第一服务器从用于存储所述码流的存储设备中获取所述码流。
进一步地，所述第二获取模块包括以下至少之一：所述第一服务器通过与所述第二服务器协商的方式获取所述初始位置；所述第一服务器获取预先设置的所述初始位置。
根据本发明的另一方面，提供了一种码流处理装置，所述装置应用于第二服务器中，包括：第二接收模块，用于接收服务控制单元SCU发送的消息，其中，所述消息用于通知所述第二服务器由第一服务器接替所述第二服务器发送码流；第三获取模块，用于获取所述第一服务器发送所述码流的初始位置；停止模块，用于根据所述初始位置停止发送所述码流。
进一步地，所述第三获取模块包括：通过和所述第一服务器协商的方式获取所述初始位置。
进一步地，所述第二接收模块包括：通过与所述SCU交互码流实时信息的方式接收所述SCU发送的所述消息，其中，所述码流实时信息还用于所述SCU向第一服务器发送通知消息；所述通知消息用于所述第一服务器获取与所述第二服务器相同的码流并进行缓存，获取发送所述码流的初始位置，在所述第二服务器停止发送码流之后，构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文。
进一步地，所述通知消息通过通知所述第一服务器获取码流信息的方式通知所述第一服务器获取与所述第二服务器相同的码流并进行缓存，所述码流信息包括如下信息至少之一：所述码流的源头、所述码流的协议类型、开始缓存所述码流的位置、所述第二服务器的信息。
根据本发明的另一方面，提供了一种码流处理装置，所述装置应用于服务控制单元SCU中，包括：第二通知模块，用于通知第一服务器获取并缓存与第二服务器相同的码流；第二发送模块，用于在接收到所述第一服务器发送的获取码流正常的信息后，将所述第一服务器的信息发送给所述第二服务器，其中，所述第一服务器的信息用于确定所述第一服务器发送所述码流的初始位置。
进一步地，在确定所述初始位置时是由所述第二服务器根据所述第一服务器的信息与所述第一服务器进行协商所确定的。
进一步地，所述第二通知模块包括：交互单元，用于与所述第二服务器交互码流实时信息；发送单元，用于根据码流实时信息向所述第一服务器发送通知消息，其中，所述通知消息用于通知所述第一服务器获取并缓存与所述第二服务器相同的码流，所述通知消息还用于通知所述第一服务器获取发送所述码流的初始位置，在所述第二服务器停止发送码流之后，构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文。
进一步地，所述通知消息通过通知所述第一服务器获取码流信息的方式通知所述第一服务器获取与所述第二服务器相同的码流并进行缓存，其中，所述码流信息包括如下信息至少之一：所述码流的源头、所述码流的协议类型、开始缓存所述码流的位置、所述第二服务器的信息。
进一步地，所述装置还包括：选择模块，用于在接收到所述第一服务器发送的获取码流异常的信息后，选择新的用于接替所述第二服务器的服务器。
进一步地，所述装置还包括：第三接收模块，用于接收所述第一服务器上报的发送结果，其中，所述发送结果为所述第一服务器发送所述报文的发送结果。
通过本发明，采用第一服务器获取与第二服务器相同的码流并进行缓存；所述第一服务器获取发送所述码流的初始位置；所述第一服务器在所述第二服务器停止发送码流之后，构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文，解决了相关技术中存在的无法实现在不中断业务的情况下进行组播频道的迁移的问题，进而实现了在不中断业务的情况下进行组播频道的迁移的效果。
附图说明
此处所说明的附图用来提供对本发明的进一步理解，构成本申请的一部分，本发明的示意性实施例及其说明用于解释本发明，并不构成对本发明的不当限定。在附图中：
图1是根据本发明实施例的报文发送方法的流程图；
图2是根据本发明实施例的第一种码流处理方法的流程图；
图3是根据本发明实施例的第二种码流处理方法的流程图；
图4是根据本发明实施例的报文发送装置的结构框图；
图5是根据本发明实施例的报文发送装置的优选结构框图一；
图6是根据本发明实施例的报文发送装置的优选结构框图二；
图7是根据本发明实施例的报文发送装置的优选结构框图三；
图8是根据本发明实施例的第一种码流处理装置的结构框图；
图9是根据本发明实施例的第二种码流处理装置的结构框图；
图10是根据本发明实施例的第二种码流处理装置中第二通知模块92的结构框图；
图11是根据本发明实施例的第二种码流处理装置的优选结构框图一；
图12是根据本发明实施例的第二种码流处理装置的优选结构框图二；
图13是根据本发明实施例的组播出频道引入码流示意图；
图14是根据本发明实施例的组播出频道迁移的示意图。
具体实施方式
下文中将参考附图并结合实施例来详细说明本发明。需要说明的是，在不冲突的情况下，本申请中的实施例及实施例中的特征可以相互组合。
需要说明的是，本发明的说明书和权利要求书及上述附图中的术语“第一”、“第二”等是用于区别类似的对象，而不必用于描述特定的顺序或先后次序。
在本实施例中提供了一种报文发送方法，图1是根据本发明实施例的报文发送方法的流程图，如图1所示，该流程包括如下步骤：
步骤S102，第一服务器获取与第二服务器相同的码流并进行缓存；
步骤S104，该第一服务器获取发送上述码流的初始位置；
步骤S106，该第一服务器在第二服务器停止发送码流之后，构造上述码流所对应的报文并在上述初始位置根据第二服务器的源IP地址发送报文。
通过上述步骤，在需要替换掉第二服务器时，第一服务器根据该第二服务器的原IP地址发送码流对应的报文，从而实现了组播频道的无缝迁移，解决了相关技术中存在的无法实现在不中断业务的情况下进行组播频道的迁移的问题，进而实现了在不中断业务的情况下进行组播频道的迁移的效果。
实现组播频道的无缝迁移的关键在于源IP，源IP不发生变化能够保证码流的稳定性，在一个可选的实施例中，上述第一服务器根据第二服务器的源IP地址发送报文包括：第一服务器增加本地路由，以利用第二服务器的源IP地址发送报文；或者，第一服务器将第二服务器的源IP地址填入报文的IP地址字段，并发送报文。当然，除了上述两种方式外，还可以利用其他的方式进行根据第二服务器的源IP发送报文的处理。
第一服务器在获取并缓存码流时，可以根据服务控制单元SCU发送的通知消息来执行相关操作，在一个可选的实施例中，上述第一服务器获取与第二服务器相同的码流并进行缓存之前，还包括：该第一服务器接收SCU发送的通知消息，其中，该通知消息用于通知第一服务器获取码流信息，该码流信息用于第一服务器获取码流并进行缓存，该码流信息可以包括如下信息至少之一：码流的源头、码流的协议类型、开始缓存码流的位置、第二服务器的信息。
从上述实施例可知，当第二服务器停止发送码流后，是由第一服务器接替该第二服务器的工作继续发送码流的，而该第一服务器能够接替第二服务器的前提是，该第一服务器能够获取到与第二服务器相同的码流，若该第一服务器不能获取上述码流，则需要利用其他的服务器接替第二服务器的工作。在一个可选的实施例中，第一服务器获取与第二服务器相同的码流并进行缓存之后，还包括：第一服务器将获取码流的获取结果通知给服务控制单元SCU，其中，该获取结果用于SCU判断是否需要重新选择用于替换第二服务器的服务器，并在确定不需要重新选择服务器之后，将第一服务器的信息发送给第二服务器。
在一个可选的实施例中，上述的第一服务器构造码流所对应的报文并在初始位置根据第二服务器的源IP地址发送报文之后，还包括：该第一服务器将发送报文的发送结果上报给服务控制单元SCU。至此，完成了频道的迁移过程，之后的码流可以全部由第一服务器提供。当第二服务器恢复正常后，该第二服务器可以继续进行码流的发送，即，恢复正常之后的第二服务器可以接替第一服务器的工作，其接替操作同上述的过程。
其中，上述的第一服务器获取与第二服务器相同的码流时，可以有多种获取方式，在一个可选的实施例中，可以通过如下方式获取：该第一服务器从除第二服务器之外的其他服务器中获取上述码流；该第一服务器从用于存储码流的存储设备中获取上述码流。
上述第一服务器获取发送码流的初始位置可以有多种获取方式，在一个可选的实施例中，可以通过如下方式获取初始位置：该第一服务器通过与第二服务器协商的方式获取上述初始位置；该第一服务器获取预先设置的初始位置。
图2是根据本发明实施例的第一种码流处理方法的流程图，如图2所示，该流程包括如下步骤：
步骤S202，第二服务器接收服务控制单元SCU发送的消息，其中，该消息用于通知第二服务器由第一服务器接替第二服务器发送码流；
步骤S204，第二服务器获取第一服务器发送码流的初始位置；
步骤S206，第二服务器根据初始位置停止发送码流。
通过上述步骤，在需要替换第二服务器后，由第一服务器接替第二服务器发送的码流，并获取发送码流的初始位置，由第一服务器在该初始位置上发送码流，从而实现了组播频道的无缝迁移，解决了相关技术中存在的无法实现在不中断业务的情况下进行组播频道的迁移的问题，进而实现了在不中断业务的情况下进行组播频道的迁移的效果。
其中，上述的获取发送码流的初始位置的方式可以为多种，在一个可选的实施例中，可以通过由第一服务器和第二服务器协商的方式获取上述初始位置。
在一个可选的实施例中，上述的第二服务器接收SCU发送的消息可以包括：第二服务器通过与SCU交互码流实时信息的方式接收SCU发送的消息；其中，该码流实时信息还用于SCU向第一服务器发送通知消息；该通知消息用于第一服务器获取与第二服务器相同的码流并进行缓存，获取发送该码流的初始位置，在第二服务器停止发送码流之后，构造码流所对应的报文并在初始位置根据第二服务器的源IP地址发送报文。
在一个可选的实施例中，上述的通知消息可以通过通知第一服务器获取码流信息的方式通知第一服务器获取与第二服务器相同的码流并进行缓存，该码流信息可以包括如下信息至少之一：码流的源头、码流的协议类型、开始缓存码流的位置、第二服务器的信息。
图3是根据本发明实施例的第二种码流处理方法的流程图，如图3所示，该流程包括如下步骤：
步骤S302，服务控制单元SCU通知第一服务器获取并缓存与第二服务器相同的码流；
步骤S304，该SCU在接收到第一服务器发送的获取码流正常的信息后，将第一服务器的信息发送给第二服务器。
通过上述步骤，在需要替换掉第二服务器时，SCU会通知第一服务器去获取并缓存与第二服务器相同的码流，并且第一服务器会在确定的发送码流的初始位置上发送码流，从而实现了组播频道的无缝迁移，解决了相关技术中存在的无法实现在不中断业务的情况下进行组播频道的迁移的问题，进而实现了在不中断业务的情况下进行组播频道的迁移的效果。
在一个可选的实施例中，在确定发送码流的初始位置时，是由第二服务器根据第一服务器的信息与第一服务器进行协商所确定的。
SCU通知第一服务器获取并缓存与第二服务器相同的码流时，可以通过如下方式实现：SCU与第二服务器交互码流实时信息；SCU根据码流实时信息向第一服务器发送通知消息，其中，该通知消息用于通知第一服务器获取并缓存与第二服务器相同的码流，通知消息还用于通知第一服务器获取发送码流的初始位置，在第二服务器停止发送码流之后，构造码流所对应的报文并在初始位置根据第二服务器的源IP地址发送报文。
在一个可选的实施例中，上述通知消息通过通知第一服务器获取码流信息的方式通知第一服务器获取与第二服务器相同的码流并进行缓存，其中，该码流信息包括如下信息至少之一：码流的源头、码流的协议类型、开始缓存码流的位置、第二服务器的信息。
SCU会选择用于替换第二服务器的服务器，当选择了一个无法承接第二服务器的业务的服务器之后，还可以重新进行选择，在一个可选的实施例中，SCU在接收到第一服务器发送的获取码流异常的信息后，选择新的用于接替该第二服务器的服务器。
在一个可选的实施例中，上述SCU将第一服务器的信息发送给第二服务器之后，还包括：接收第一服务器上报的发送结果，其中，该发送结果为第一服务器发送报文的发送结果。至此，整个频道迁移过程结束，之后的码流由第一服务器提供。当第二服务器恢复正常后，可以继续由第二服务器进行码流的发送。
通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到根据上述实施例的方法可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件，但很多情况下前者是更佳的实施方式。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质(如ROM/RAM、磁碟、光盘)中，包括若干指令用以使得一台终端设备(可以是手机，计算机，服务器，或者网络设备等)执行本发明各个实施例的方法。
在本实施例中还提供了一种报文发送装置，该装置用于实现上述实施例及优选实施方式，已经进行过说明的不再赘述。如以下所使用的，术语“模块”可以实现预定功能的软件和/或硬件的组合。尽管以下实施例所描述的装置较佳地以软件来实现，但是硬件，或者软件和硬件的组合的实现也是可能并被构想的。
图4是根据本发明实施例的报文发送装置的结构框图，如图4所示，该装置应用于第一服务器中，包括第一获取模块42、第二获取模块44和第一发送模块46，下面对该装置进行说明。
第一获取模块42，用于获取与第二服务器相同的码流并进行缓存；第二获取模块44，连接至上述第一获取模块42，用于获取发送码流的初始位置；第一发送模块46，连接至上述第二获取模块44，用于在第二服务器停止发送码流之后，构造该码流所对应的报文并在初始位置根据第二服务器的源IP地址发送报文。
在一个可选的实施例中，上述第一发送模块46可以包括：第一服务器增加本地路由，以利用第二服务器的源IP地址发送报文；或者，第一服务器将第二服务器的源IP地址填入报文的IP地址字段，并发送报文。
图5是根据本发明实施例的报文发送装置的优选结构框图一，如图5所示，该装置除包括图4所示的所有模块外，还包括第一接收模块52，下面对该装置进行说明。
第一接收模块52，连接至上述的第一获取模块42，用于接收服务控制单元SCU发送的通知消息，其中，该通知消息用于通知第一服务器获取码流信息，该码流信息用于第一服务器获取码流并进行缓存，该码流信息包括如下信息至少之一：码流的源头、码流的协议类型、开始缓存码流的位置、第二服务器的信息。
图6是根据本发明实施例的报文发送装置的优选结构框图二，如图6所示，该装置除包括图4所示的所有模块外，还包括第一通知模块62，下面对该装置进行说明。
第一通知模块62，连接至上述第一获取模块42，用于将获取码流的获取结果通知给服务控制单元SCU，其中，该获取结果用于SCU判断是否需要重新选择用于替换第二服务器的服务器，并在确定不需要重新选择服务器之后，将第一服务器的信息发送给第二服务器。
图7是根据本发明实施例的报文发送装置的优选结构框图三，如图7所示，该装置除包括图4所示的所有模块外，还包括上报模块72，下面对该装置进行说明。
上报模块72，连接至上述第一发送模块46，用于将发送报文的发送结果上报给服务控制单元SCU。
在一个可选的实施例中，上述第一获取模块42包括以下至少之一：第一服务器从除第二服务器之外的其他服务器中获取码流；第一服务器从用于存储码流的存储设备中获取码流。
在一个可选的实施例中，上述第二获取模块44包括以下至少之一：第一服务器通过与第二服务器协商的方式获取初始位置；第一服务器获取预先设置的初始位置。
图8是根据本发明实施例的第一种码流处理装置的结构框图，如图8所示，该装置应用于第二服务器中，包括第二接收模块82、第三获取模块84和停止模块86，下面对该装置进行说明。
第二接收模块82，用于接收服务控制单元SCU发送的消息，其中，该消息用于通知第二服务器由第一服务器接替第二服务器发送码流；第三获取模块84，连接至上述第二获取模块82，用于获取第一服务器发送码流的初始位置；停止模块86，连接至上述第三获取模块84，用于根据上述初始位置停止发送码流。
在一个可选的实施例中，上述的第三获取模块84包括：通过和第一服务器协商的方式获取初始位置。
上述的第二接收模块82包括通过与所述SCU交互码流实时信息的方式接收所述SCU发送的所述消息，其中，该码流实时信息还用于SCU向第一服务器发送通知消息；该通知消息用于第一服务器获取与第二服务器相同的码流并进行缓存，获取发送码流的初始位置，在第二服务器停止发送码流之后，构造码流所对应的报文并在初始位置根据第二服务器的源IP地址发送报文。
在一个可选的实施例中，上述通知消息通过通知第一服务器获取码流信息的方式通知第一服务器获取与第二服务器相同的码流并进行缓存，该码流信息包括如下信息至少之一：码流的源头、码流的协议类型、开始缓存码流的位置、第二服务器的信息。
图9是根据本发明实施例的第二种码流处理装置的结构框图，如图9所示，该装置应用于服务控制单元SCU中，包括第二通知模块92和第二发送模块94，下面对该装置进行说明。
第二通知模块92，用于通知第一服务器获取并缓存与第二服务器相同的码流；第二发送模块94，连接至上述第二通知模块92，用于在接收到第一服务器发送的获取码流正常的信息后，将第一服务器的信息发送给第二服务器，其中，该第一服务器的信息用于确定第一服务器发送码流的初始位置。
在一个可选的实施例中，在确定上述初始位置时是由第二服务器根据第一服务器的信息与第一服务器进行协商所确定的。
图10是根据本发明实施例的第二种码流处理装置中第二通知模块92的结构框图，如图10所示，该第二通知模块92包括交互单元102和发送单元104，下面对该第二通知模块92进行说明。
交互单元102，用于与第二服务器交互码流实时信息；发送单元104，连接至上述交互单元102，用于根据码流实时信息向第一服务器发送通知消息，其中，该通知消息用于通知第一服务器获取与第二服务器相同的码流，该通知消息还用于通知第一服务器获取发送码流的初始位置，在第二服务器停止发送码流之后，构造码流所对应的报文并在初始位置根据第二服务器的源IP地址发送报文。
在一个可选的实施例中，上述通知消息通过通知第一服务器获取码流信息的方式通知第一服务器获取与第二服务器相同的码流并进行缓存，其中，该码流信息包括如下信息至少之一：码流的源头、码流的协议类型、开始缓存码流的位置、第二服务器的信息。
图11是根据本发明实施例的第二种码流处理装置的优选结构框图一，如图11所示，该装置除包括图9所示的所有模块外，还包括选择模块112，下面对该装置进行说明。
选择模块112，连接至上述第二通知模块92，用于在接收到第一服务器发送的获取码流异常的信息后，选择新的用于接替该第二服务器的服务器。
图12是根据本发明实施例的第二种码流处理装置的优选结构框图二，如图12所示，该装置除包括图9所示的所有模块外，还包括第三接收模块122，下面对该装置进行说明。
第三接收模块122，连接至上述第二发送模块94，用于接收第一服务器上报的发送结果，其中，该发送结果为第一服务器发送报文的发送结果。
图13是根据本发明实施例的组播出频道引入码流示意图，如图13所示，该流程包括如下步骤：
步骤S1302，SCU通知服务器A(同上述的第二服务器)创建频道，频道的出向信息的IP和端口号，频道的入向可以是单播引入的码流，此时需要码流源的IP和端口以及协议接入方式，也可以是组播码流，需要组播组的IP和端口，也可以是一份静态文件，需要的是文件路径及读取方式等信息。
步骤S1304，服务器A根据SCU给予的信息，开始执行引入码流的操作。
步骤S1306，服务器A正常接收码流之后，开始进行码流处理，比如转码或者录制，并将码流组播的形式发送出去。
步骤S1308，服务器A在获取码流正常后，给SCU回复创建频道的结果，SCU记录该结果。
步骤S1310，SCU和服务器A交互码流的信息，比如时间戳，码流重要性描述信息等。其中，该重要性描述信息，可以是服务器A分析的结果，也可以是SCU静态赋予的，也可以是动态时间戳交互的，不限制方式。
本发明实施例中还提供了一种组播频道无缝迁移方法，利用组播码流不需要保持连接的特点，待承接服务的服务器B(同上述的第一服务器)通过获取原服务器A(同上述的第二服务器)(两个服务器在一个集群内)协商出的码流位置，从该位置构造报文，模拟服务器A的源IP作为源ip或者二层发包的方式来继续发包，保证中间链路的(S，G)不变化，由于组播的无连接性，而且报文又是连续的，接受码流的一方就会感知不到任何变化。下面对该实施例进行说明。
图14是根据本发明实施例的组播出频道迁移的示意图，如图14所示，该流程包括如下步骤：
步骤S1402，SCU与服务器A交互码流实时信息，该码流可以是一份实时码流，比如是编码器的出向码流，也可以是一份静止码流，比如某个静态文件。
步骤S1404，SCU通知服务器B加入对应的码流，保证服务器B的接入的码流和服务器A相同。该步骤可以包括：服务控制单元SCU通知服务器B去获取码流，包括码流的源头(IP和端口)，方式(协议类型)，对应位置(开始缓存的大概位置)以及服务器A的信息，服务器B根据该通知去获取和服务器A相同的原始码流进行缓存，该码流可以是动态从其它服务器获得，比如从编码器出向的组播流中或者单播流中获取，也可以从存储系统中获取，比如从磁盘中偏移到某个位置读取某个文件等。
步骤S1406，服务器B获取码流，并进行缓存。
步骤S1408，服务器B获取正常之后给SCU进行回复，如果异常，则放弃，SCU重新选择其他服务器来进行接替。
步骤S1410，SCU根据回复告知服务器A它的接替者信息。准备工作完成。
步骤S1412，服务器A根据可选择的码流位置，一般选择码流重要性低的位置，与服务器B进行协商，服务器B则开始进行模拟发包前的工作，比如添加lo路由。与ip routeadd local IP_A dev lo tab local类似，其中IP_A就是服务器A提供频道服务的源ip地址。由于两者在同一个集群，出向网络相同，服务器B具备了利用IP_A发包的能力；或者服务器B使用构造二层报文的方式，源ip填入服务器A的码流ip来模拟服务器A发包。服务器A返回各频道的最后待发送一个原始udp报文的校验和以及对应的出向码流的最后rtp序号给服务器B。其中，上述的协商的服务重要性低下的位置可以是电视剧或者比赛的片尾或者片头，可以是1个或多个报文，以便增加服务交接时的稳定性和鲁棒性。码流位置权重表，是码流重要性描述信息，可以是静态的，如分析好的指定文件偏移，或者动态的，随时间戳变化，不限定形式和内容。
步骤S1414，服务器A停止发送码流。
步骤S1416，服务器B，在自己的缓存区中，根据频道源IP，源端口，目的IP，目的端口找到对应该频道的报文缓存，然后再根据校验和找到缓存中对应入向原始码流对应的udp包，然后对其转码，使用获取的rtp报文，利用IPa和scu指定的port，发送出转码后的码流。
步骤S1418，服务器B上报结果给SCU，这份码流延续了服务器A的IP和端口，所以用户端感受不到变化。整个频道迁移过程结束，之后的码流全部由服务器B来提供，等服务器A正常之后，可以重复步骤S1402-S1418将码流迁移回去。
整个过程中，组播路由器的(S,G)条目不变化，用户能感知到的源IP和源端口也不变化，整个码流就像从来没有改变过一样，直接保证了码流稳定性，提高了用户体验。通过上述各实施例中的技术方案，可以方便地进行组播出频道的迁移。只要是使用组播方式提供服务的业务，比如直接提供直播服务的组播频道，以及提供码流中继的组播频道等，都可以使用该方式。码流接收方也不受到上层服务调整的影响，取得很好的码流接收效果。
需要说明的是，上述各个模块是可以通过软件或硬件来实现的，对于后者，可以通过以下方式实现，但不限于此：上述模块均位于同一处理器中；或者，上述模块分别位于多个处理器中。
本发明的实施例还提供了一种存储介质。可选地，在本实施例中，上述存储介质可以被设置为存储用于执行以下步骤的程序代码：
S1，第一服务器获取与第二服务器相同的码流并进行缓存；
S2，该第一服务器获取发送上述码流的初始位置；
S3，该第一服务器在第二服务器停止发送码流之后，构造上述码流所对应的报文并在上述初始位置根据第二服务器的源IP地址发送报文。
可选地，存储介质还被设置为存储用于执行以下步骤的程序代码：
S1，第二服务器接收服务控制单元SCU发送的消息，其中，该消息用于通知第二服务器由第一服务器接替第二服务器发送码流；
S2，第二服务器获取第一服务器发送码流的初始位置；
S3，第二服务器根据初始位置停止发送码流。
可选地，存储介质还被设置为存储用于执行以下步骤的程序代码：
S1，服务控制单元SCU通知第一服务器获取并缓存与第二服务器相同的码流；
S2，该SCU在接收到第一服务器发送的获取码流正常的信息后，将第一服务器的信息发送给第二服务器。
可选地，在本实施例中，上述存储介质可以包括但不限于：U盘、只读存储器(ROM，Read-Only Memory)、随机存取存储器(RAM，Random Access Memory)、移动硬盘、磁碟或者光盘等各种可以存储程序代码的介质。
可选地，本实施例中的具体示例可以参考上述实施例及可选实施方式中所描述的示例，本实施例在此不再赘述。
显然，本领域的技术人员应该明白，上述的本发明的各模块或各步骤可以用通用的计算装置来实现，它们可以集中在单个的计算装置上，或者分布在多个计算装置所组成的网络上，可选地，它们可以用计算装置可执行的程序代码来实现，从而，可以将它们存储在存储装置中由计算装置来执行，并且在某些情况下，可以以不同于此处的顺序执行所示出或描述的步骤，或者将它们分别制作成各个集成电路模块，或者将它们中的多个模块或步骤制作成单个集成电路模块来实现。这样，本发明不限制于任何特定的硬件和软件结合。
以上所述仅为本发明的优选实施例而已，并不用于限制本发明，对于本领域的技术人员来说，本发明可以有各种更改和变化。凡在本发明的精神和原则之内，所作的任何修改、等同替换、改进等，均应包含在本发明的保护范围之内。

Claims (34)

1.一种报文发送方法，其特征在于，包括：
第一服务器获取与第二服务器相同的码流并进行缓存；
所述第一服务器获取发送所述码流的初始位置；
所述第一服务器在所述第二服务器停止发送码流之后，构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文。
2.根据权利要求1所述的方法，其特征在于，所述第一服务器根据所述第二服务器的源IP地址发送所述报文包括：
所述第一服务器增加本地路由，以利用所述第二服务器的源IP地址发送所述报文；或者，
所述第一服务器将所述第二服务器的源IP地址填入所述报文的IP地址字段，并发送所述报文。
3.根据权利要求1所述的方法，其特征在于，所述第一服务器获取与所述第二服务器相同的码流并进行缓存之前，还包括：
所述第一服务器接收服务控制单元SCU发送的通知消息，其中，所述通知消息用于通知所述第一服务器获取码流信息，所述码流信息用于所述第一服务器获取所述码流并进行缓存，所述码流信息包括如下信息至少之一：所述码流的源头、所述码流的协议类型、开始缓存所述码流的位置、所述第二服务器的信息。
4.根据权利要求1所述的方法，其特征在于，所述第一服务器获取与所述第二服务器相同的码流并进行缓存之后，还包括：
所述第一服务器将获取所述码流的获取结果通知给服务控制单元SCU，其中，所述获取结果用于所述SCU判断是否需要重新选择用于替换所述第二服务器的服务器，并在确定不需要重新选择服务器之后，将所述第一服务器的信息发送给所述第二服务器。
5.根据权利要求1所述的方法，其特征在于，所述第一服务器构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文之后，还包括：
所述第一服务器将发送所述报文的发送结果上报给服务控制单元SCU。
6.根据权利要求1至5中任意一项所述的方法，其特征在于，所述第一服务器获取与所述第二服务器相同的码流包括以下至少之一：
所述第一服务器从除所述第二服务器之外的其他服务器中获取所述码流；
所述第一服务器从用于存储所述码流的存储设备中获取所述码流。
7.根据权利要求1至6中任意一项所述的方法，其特征在于，所述第一服务器获取发送所述码流的初始位置包括以下至少之一：
所述第一服务器通过与所述第二服务器协商的方式获取所述初始位置；
所述第一服务器获取预先设置的所述初始位置。
8.一种码流处理方法，其特征在于，包括：
第二服务器接收服务控制单元SCU发送的消息，其中，所述消息用于通知所述第二服务器由第一服务器接替所述第二服务器发送码流；
所述第二服务器获取所述第一服务器发送所述码流的初始位置；
所述第二服务器根据所述初始位置停止发送所述码流。
9.根据权利要求8所述的方法，其特征在于，所述第二服务器获取所述第一服务器发送所述码流的初始位置包括：
所述第二服务器通过和所述第一服务器协商的方式获取所述初始位置。
10.根据权利要求8所述的方法，其特征在于，所述第二服务器接收所述SCU发送的消息包括：
所述第二服务器通过与所述SCU交互码流实时信息的方式接收所述SCU发送的所述消息，其中，所述码流实时信息还用于所述SCU向第一服务器发送通知消息；所述通知消息用于所述第一服务器获取与所述第二服务器相同的码流并进行缓存，获取发送所述码流的初始位置，在所述第二服务器停止发送码流之后，构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文。
11.根据权利要求10所述的方法，其特征在于，所述通知消息通过通知所述第一服务器获取码流信息的方式通知所述第一服务器获取与所述第二服务器相同的码流并进行缓存，所述码流信息包括如下信息至少之一：所述码流的源头、所述码流的协议类型、开始缓存所述码流的位置、所述第二服务器的信息。
12.一种码流处理方法，其特征在于，包括：
服务控制单元SCU通知第一服务器获取并缓存与第二服务器相同的码流；
所述SCU在接收到所述第一服务器发送的获取码流正常的信息后，将所述第一服务器的信息发送给所述第二服务器，其中，所述第一服务器的信息用于确定所述第一服务器发送所述码流的初始位置。
13.根据权利要求12所述的方法，其特征在于，在确定所述初始位置时是由所述第二服务器根据所述第一服务器的信息与所述第一服务器进行协商所确定的。
14.根据权利要求12所述的方法，其特征在于，所述SCU通知所述第一服务器获取并缓存与所述第二服务器相同的所述码流包括：
所述SCU与所述第二服务器交互码流实时信息；
所述SCU根据码流实时信息向所述第一服务器发送通知消息，其中，所述通知消息用于通知所述第一服务器获取并缓存与所述第二服务器相同的码流，所述通知消息还用于通知所述第一服务器获取发送所述码流的初始位置，在所述第二服务器停止发送码流之后，构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文。
15.根据权利要求14所述的方法，其特征在于，所述通知消息通过通知所述第一服务器获取码流信息的方式通知所述第一服务器获取与所述第二服务器相同的码流并进行缓存，其中，所述码流信息包括如下信息至少之一：所述码流的源头、所述码流的协议类型、开始缓存所述码流的位置、所述第二服务器的信息。
16.根据权利要求12所述的方法，其特征在于，还包括：
所述SCU在接收到所述第一服务器发送的获取码流异常的信息后，选择新的用于接替所述第二服务器的服务器。
17.根据权利要求14所述的方法，其特征在于，所述SCU将所述第一服务器的信息发送给所述第二服务器之后，还包括：
接收所述第一服务器上报的发送结果，其中，所述发送结果为所述第一服务器发送所述报文的发送结果。
18.一种报文发送装置，其特征在于，应用于第一服务器中，包括：
第一获取模块，用于获取与第二服务器相同的码流并进行缓存；
第二获取模块，用于获取发送所述码流的初始位置；
第一发送模块，用于在所述第二服务器停止发送码流之后，构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文。
19.根据权利要求18所述的装置，其特征在于，所述第一发送模块包括：
所述第一服务器增加本地路由，以利用所述第二服务器的源IP地址发送所述报文；或者，
所述第一服务器将所述第二服务器的源IP地址填入所述报文的IP地址字段，并发送所述报文。
20.根据权利要求18所述的装置，其特征在于，还包括：
第一接收模块，用于接收服务控制单元SCU发送的通知消息，其中，所述通知消息用于通知所述第一服务器获取码流信息，所述码流信息用于所述第一服务器获取所述码流并进行缓存，所述码流信息包括如下信息至少之一：所述码流的源头、所述码流的协议类型、开始缓存所述码流的位置、所述第二服务器的信息。
21.根据权利要求18所述的装置，其特征在于，还包括：
第一通知模块，用于将获取所述码流的获取结果通知给服务控制单元SCU，其中，所述获取结果用于所述SCU判断是否需要重新选择用于替换所述第二服务器的服务器，并在确定不需要重新选择服务器之后，将所述第一服务器的信息发送给所述第二服务器。
22.根据权利要求18所述的装置，其特征在于，还包括：
上报模块，用于将发送所述报文的发送结果上报给服务控制单元SCU。
23.根据权利要求18至22中任意一项所述的装置，其特征在于，所述第一获取模块包括以下至少之一：
所述第一服务器从除所述第二服务器之外的其他服务器中获取所述码流；
所述第一服务器从用于存储所述码流的存储设备中获取所述码流。
24.根据权利要求18至23中任意一项所述的装置，其特征在于，所述第二获取模块包括以下至少之一：
所述第一服务器通过与所述第二服务器协商的方式获取所述初始位置；
所述第一服务器获取预先设置的所述初始位置。
25.一种码流处理装置，其特征在于，应用于第二服务器中，包括：
第二接收模块，用于接收服务控制单元SCU发送的消息，其中，所述消息用于通知所述第二服务器由第一服务器接替所述第二服务器发送码流；
第三获取模块，用于获取所述第一服务器发送所述码流的初始位置；
停止模块，用于根据所述初始位置停止发送所述码流。
26.根据权利要求25所述的装置，其特征在于，所述第三获取模块包括：
通过和所述第一服务器协商的方式获取所述初始位置。
27.根据权利要求25所述的装置，其特征在于，所述第二接收模块包括：
通过与所述SCU交互码流实时信息的方式接收所述SCU发送的所述消息，其中，所述码流实时信息还用于所述SCU向第一服务器发送通知消息；所述通知消息用于所述第一服务器获取与所述第二服务器相同的码流并进行缓存，获取发送所述码流的初始位置，在所述第二服务器停止发送码流之后，构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文。
28.根据权利要求27所述的装置，其特征在于，所述通知消息通过通知所述第一服务器获取码流信息的方式通知所述第一服务器获取与所述第二服务器相同的码流并进行缓存，所述码流信息包括如下信息至少之一：所述码流的源头、所述码流的协议类型、开始缓存所述码流的位置、所述第二服务器的信息。
29.一种码流处理装置，其特征在于，应用于服务控制单元SCU中，包括：
第二通知模块，用于通知第一服务器获取并缓存与第二服务器相同的码流；
第二发送模块，用于在接收到所述第一服务器发送的获取码流正常的信息后，将所述第一服务器的信息发送给所述第二服务器，其中，所述第一服务器的信息用于确定所述第一服务器发送所述码流的初始位置。
30.根据权利要求29所述的装置，其特征在于，在确定所述初始位置时是由所述第二服务器根据所述第一服务器的信息与所述第一服务器进行协商所确定的。
31.根据权利要求29所述的装置，其特征在于，所述第二通知模块包括：
交互单元，用于与所述第二服务器交互码流实时信息；
发送单元，用于根据码流实时信息向所述第一服务器发送通知消息，其中，所述通知消息用于通知所述第一服务器获取并缓存与所述第二服务器相同的码流，所述通知消息还用于通知所述第一服务器获取发送所述码流的初始位置，在所述第二服务器停止发送码流之后，构造所述码流所对应的报文并在所述初始位置根据所述第二服务器的源IP地址发送所述报文。
32.根据权利要求31所述的装置，其特征在于，所述通知消息通过通知所述第一服务器获取码流信息的方式通知所述第一服务器获取与所述第二服务器相同的码流并进行缓存，其中，所述码流信息包括如下信息至少之一：所述码流的源头、所述码流的协议类型、开始缓存所述码流的位置、所述第二服务器的信息。
33.根据权利要求29所述的装置，其特征在于，还包括：
选择模块，用于在接收到所述第一服务器发送的获取码流异常的信息后，选择新的用于接替所述第二服务器的服务器。
34.根据权利要求31所述的装置，其特征在于，还包括：
第三接收模块，用于接收所述第一服务器上报的发送结果，其中，所述发送结果为所述第一服务器发送所述报文的发送结果。
CN201510188537.XA 2015-04-20 2015-04-20 报文发送方法、码流处理方法及装置 Pending CN104811827A (zh)

Priority Applications (4)

Application Number Priority Date Filing Date Title
CN201510188537.XA CN104811827A (zh) 2015-04-20 2015-04-20 报文发送方法、码流处理方法及装置
PCT/CN2016/079770 WO2016169482A1 (zh) 2015-04-20 2016-04-20 报文发送方法、码流处理方法及装置
US15/568,057 US10575065B2 (en) 2015-04-20 2016-04-20 Message sending method and device, code stream processing method and device
EP16782629.6A EP3288276A4 (en) 2015-04-20 2016-04-20 Message transmission method, code stream processing method and device

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN201510188537.XA CN104811827A (zh) 2015-04-20 2015-04-20 报文发送方法、码流处理方法及装置

Publications (1)

Publication Number Publication Date
CN104811827A true CN104811827A (zh) 2015-07-29

Family

ID=53696239

Family Applications (1)

Application Number Title Priority Date Filing Date
CN201510188537.XA Pending CN104811827A (zh) 2015-04-20 2015-04-20 报文发送方法、码流处理方法及装置

Country Status (4)

Country Link
US (1) US10575065B2 (zh)
EP (1) EP3288276A4 (zh)
CN (1) CN104811827A (zh)
WO (1) WO2016169482A1 (zh)

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2016169482A1 (zh) * 2015-04-20 2016-10-27 中兴通讯股份有限公司 报文发送方法、码流处理方法及装置

Families Citing this family (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN110545486B (zh) * 2019-08-05 2022-04-05 广州珠江数码集团股份有限公司 一种视频信号传输方法、装置、介质及终端设备
CN113992980B (zh) * 2020-07-09 2023-05-26 杭州海康威视数字技术股份有限公司 攻击码流的生成方法、装置及设备
CN117376662B (zh) * 2023-12-08 2024-02-09 杭州领信数科信息技术有限公司 一种集群式视频安全边界交换方法及装置

Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101146215A (zh) * 2007-10-09 2008-03-19 华为技术有限公司 基于组播的视频服务冗余备份方法、装置及系统
CN101252546A (zh) * 2008-04-15 2008-08-27 中国科学技术大学 媒体流在线服务迁移的方法和装置
CN101340428A (zh) * 2007-07-05 2009-01-07 华为技术有限公司 媒体服务器切换过程中提供媒体流的方法及系统

Family Cites Families (13)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US6718390B1 (en) * 1999-01-05 2004-04-06 Cisco Technology, Inc. Selectively forced redirection of network traffic
US7299291B1 (en) * 2000-05-18 2007-11-20 Akamai Technologies, Inc. Client-side method for identifying an optimum server
US6839865B2 (en) * 2000-12-29 2005-01-04 Road Runner System and method for multicast stream failover
US9138644B2 (en) * 2002-12-10 2015-09-22 Sony Computer Entertainment America Llc System and method for accelerated machine switching
US7376859B2 (en) * 2003-10-20 2008-05-20 International Business Machines Corporation Method, system, and article of manufacture for data replication
DE102004031889B4 (de) 2004-06-30 2012-07-12 Infineon Technologies Ag Halbleiterbauteil mit einem Gehäuse und einem teilweise in eine Kunststoffgehäusemasse eingebetteten Halbleiterchip und Verfahren zur Herstellung desselben
US7733808B2 (en) * 2006-11-10 2010-06-08 Microsoft Corporation Peer-to-peer aided live video sharing system
BRPI0721658A2 (pt) * 2007-06-26 2013-01-22 Thomson Licensing migraÇço de fluxo de protocolo em tempo real
CN101729909B (zh) * 2008-10-23 2012-11-21 华为技术有限公司 一种流媒体业务的处理方法、装置及系统
EP2605469A1 (en) * 2011-12-13 2013-06-19 Thomson Licensing Method and apparatus to control a multipath adaptive streaming session
EP2744169B1 (en) 2012-10-22 2016-01-13 Huawei Device Co., Ltd. Method and apparatus for playing streaming media files
CN104717031B (zh) * 2013-12-12 2018-06-26 华为终端（东莞）有限公司 流媒体报文的处理方法、WiFi芯片及移动终端
CN104811827A (zh) * 2015-04-20 2015-07-29 中兴通讯股份有限公司 报文发送方法、码流处理方法及装置

Patent Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN101340428A (zh) * 2007-07-05 2009-01-07 华为技术有限公司 媒体服务器切换过程中提供媒体流的方法及系统
CN101146215A (zh) * 2007-10-09 2008-03-19 华为技术有限公司 基于组播的视频服务冗余备份方法、装置及系统
CN101252546A (zh) * 2008-04-15 2008-08-27 中国科学技术大学 媒体流在线服务迁移的方法和装置

Cited By (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2016169482A1 (zh) * 2015-04-20 2016-10-27 中兴通讯股份有限公司 报文发送方法、码流处理方法及装置
US10575065B2 (en) 2015-04-20 2020-02-25 Xi'an Zhongxing New Software Co., Ltd. Message sending method and device, code stream processing method and device

Also Published As

Publication number Publication date
EP3288276A1 (en) 2018-02-28
WO2016169482A1 (zh) 2016-10-27
US20180146261A1 (en) 2018-05-24
EP3288276A4 (en) 2018-04-04
US10575065B2 (en) 2020-02-25

Similar Documents

Publication Publication Date Title
KR101540878B1 (ko) 파일 전달 방법들을 이용한 ｉｐ 브로드캐스트 스트리밍 서비스 배포
EP3662617B1 (en) Broadcasting, multicasting, or unicasting advertising content based on user context
US9986003B2 (en) Mediating content delivery via one or more services
US11968128B2 (en) Management, by an intermediate device, of the quality of transmission of a data stream to a mobile terminal
US8537992B2 (en) System and method for recording communication activities
CN106488169A (zh) 一种数据传输的方法、系统以及相关设备
US8265003B2 (en) Packet distribution system and packet distribution method
KR20250170596A (ko) Webrtc 미디어 데이터를 통신하기 위한 pdu 세트 및 버스트 종료 마킹의 시그널링 사용
CN104811827A (zh) 报文发送方法、码流处理方法及装置
US20220239601A1 (en) Background data traffic distribution of media data
KR20160138044A (ko) 미디어 데이터를 스트리밍하기 위한 목표된 광고 삽입
US20230362214A1 (en) 5g support for webrtc
KR20230031912A (ko) 단말 디바이스, 인프라스트럭처 장비 및 방법들
US20100040073A1 (en) Apparatus and method for managing a network
US8254546B2 (en) Method and system to proxy phone directories
Adeliyi et al. Fast channel navigation of internet protocol television using adaptive hybrid delivery method
Doumanis et al. Improving video QoE with IP over ICN
CN108616760A (zh) 一种基于浏览器的直播方法、服务器、主播端和用户端
CN105704510A (zh) 视频处理方法及装置
CN100359884C (zh) 一种网络路由控制方法
US9203920B2 (en) Method and node for automatically exchanging network service provider information
Fleury et al. Streaming Media with Peer-to-Peer Networks: Wireless Perspectives: Wireless Perspectives
CN108307149B (zh) 一种视频代理系统及监控方法
Szabó et al. Design considerations of a novel media streaming architecture for heterogeneous access environment
Mayer et al. 001930 BROADWAN Deliverable D25 Summarised conclusions from trials and final recommendations for full coverage

Legal Events

Date Code Title Description
C06 Publication
PB01 Publication
EXSB Decision made by sipo to initiate substantive examination
SE01 Entry into force of request for substantive examination
RJ01 Rejection of invention patent application after publication
RJ01 Rejection of invention patent application after publication

Application publication date: 20150729