Background technology
Numerous content suppliers（Content Provider, hereinafter referred to as CP）The media resource information that will be produced is needed,The large batch of Broadcast Control platform for being injected into broadcasting and TV.
The operation flow of broadcast control system that matchmaker's standing breath is injected into broadcasting and TV is by existing CP：
1, house show is organized into data work order by CP according to the C2 interface specifications of CCTV standard.
2, CP calls the content reception interface of broadcasting and TV, and injection message is issued to the Broadcast Control platform of broadcasting and TV.
3, the Broadcast Control platform of broadcasting and TV lines up a queue by message is injected, and is parsed, handled, is put in storage one by one.
4, the work order information that processing is completed is fed back to CP platforms by the Broadcast Control platform of broadcasting and TV.Complete injection task.
With the gradual development of the business such as IPTV, above traditional the drawbacks of injecting flow, gradually appears.It is primarily present as followsProblem：
1, current system can only support the framework of single server, after server goes wrong down machines, need O＆M peopleMember enables standby server manually, can lead to the loss of business lull and data.
2, single server provides support, is limited to the performance of server, extends the ability of this business there is also bottleneck,And with the increase of portfolio, the ability that can not carry out smoothly expands.
3, since a data queue can only be handled, for high matched server, its property also can not maximumlly be utilizedCan, it results in waste of resources.
4, it since system processes data ability is not high, when more CP inject content to broadcasting and TV platform simultaneously, can causeThe obstruction of mass data influences the normal work of broadcasting and TV editorial staff.
5, since various regions CP development situations are inconsistent, although using same set of interface standard, according to the different industry in various regionsBusiness needs, and interface can carry out special adjustment to Database field, when docking, need developer to change interface code, to be adapted toThe special data of different geographical, difference CP, improves docking cost, takes, effort, is unfavorable for stability and the extension of codeProperty.
For the problems in the relevant technologies, currently no effective solution has been proposed.
Invention content
For above-mentioned technical problem in the related technology, the present invention proposes a kind of based on IPTV high loads, Auto-matchingMatchmaker provides docking system, can carry out equilibrium allocation to load according to server service condition, promote data-handling capacity.
To realize the above-mentioned technical purpose, the technical proposal of the invention is realized in this way：
A kind of matchmaker's money docking system based on IPTV high loads, Auto-matching, including CP modules, load balancing module, interface clothesModule of being engaged in and server module,
The CP modules are used to store, manage the media resource of content supplier, and send content to the load balancing moduleInject request message；
The load balancing module is used to receive the content injection request message from the CP modules, and injects content to requestAssign corresponding server；
The interface service module is for starting multithreading, initialization data queue, according to the appointment of the load balancing module,By the work order data from CP modules according to built queue assignment to server module；
The server module parses work order data for receiving the work order data from the interface service moduleAnd preservation.
Further, which further comprises that management backstage module, the management backstage module are used for work order dataIt checked, managed, sorted.
Further, the CP modules include the Content Management System and storage service system of several content suppliers.
Further, the interface service module includes several interface servers, for according to the load balancing moduleAppointment, work order data are allocated.
Further, the content injection request message includes upstream ID, this platform ID, work order ID, work order address.
Further, the work order data are using XML file as transmission medium.
Further, the work order data include program, poster, entity, the more acute heads of collection of classification and all kinds of matching relationships.
Beneficial effects of the present invention：It is adjusted at any time according to the concrete configuration of server by carrying out load balancing to serverThread Count whole, setting is concurrent；Meanwhile for different geographical, the particular service demand of CP, administration page flexible configuration can be passed throughField.It can realize the smooth performance for expanding, adequately utilizing server of service ability, while to greatest extent departing from dockingIn the process to the dependence of technical staff, it is truly realized commercialization.
Specific implementation mode
Following will be combined with the drawings in the embodiments of the present invention, and technical solution in the embodiment of the present invention carries out clear, completeSite preparation describes, it is clear that described embodiments are only a part of the embodiments of the present invention, instead of all the embodiments.It is based onEmbodiment in the present invention, the every other embodiment that those of ordinary skill in the art are obtained belong to what the present invention protectedRange.
A kind of matchmaker based on IPTV high loads, Auto-matching provides docking system according to embodiments of the present invention, includingCP modules, load balancing module, interface service module and server module；
The CP modules are used to store, manage the media resource of content supplier, and send content to the load balancing moduleInject request message；
The load balancing module is used to receive the content injection request message from the CP modules, and injects content to requestAssign corresponding server；
The interface service module is for starting multithreading, initialization data queue, according to the appointment of the load balancing module,By the work order data from CP modules according to built queue assignment to server module；
The server module parses work order data for receiving the work order data from the interface service moduleAnd preservation.
Further, which further comprises that management backstage module, the management backstage module are used for work order dataIt checked, managed, sorted.
Further, the CP modules include the Content Management System and storage service system of several content suppliers.
Further, the interface service module includes several interface servers, for according to the load balancing moduleAppointment, work order data are allocated.
Further, the content injection request message includes upstream ID, this platform ID, work order ID, work order address.
Further, the work order data are using XML file as transmission medium.
Further, the work order data include program, poster, entity, the more acute heads of collection of classification and all kinds of matching relationships.
In order to facilitate understand the present invention above-mentioned technical proposal, below by way of in specifically used mode to the present invention it is above-mentionedTechnical solution is described in detail.
It is as shown in Figure 1 a kind of modular structure schematic diagram of specific embodiment of the present invention, overall plan framework is divided into negativeCarry equalizing sections, interface process part, management backstage part composition.Overall system architecture design is as follows：
1, according to different province business needs, upstream can dock more CP, and each CP is according to the resource situation of itself, while to wideElectricity sends content injection request.
2, load balancing part, can be by hardware load equipment, or builds software nginx and realize, is responsible for upstream numberAccording to the distribution of message.Such as：In configuration file epg.conf, configuration needs the interface server address information distributed, service1 10.10.8.121 of device:8080；2 10.10.8.122 of server:8080；And the access weight of each server： checkinterval=3000 rise=2 fall=5 timeout=1000;check_http_expect_alive http_2xxhttp_3xx;Pressure will be uniformly accessed to share on all interface servers.When wherein an interface server is askedAfter inscribing down machines, access can be distributed on the server of other normal operations by load balancing, can't be made to business on lineAt influence.After the server restores normal, load balancing is restored to its task assignment.
3, after specific single server receives the appointment task of load balancing, Interface Engineering starts, to the number of distributionAccording to the operations such as being downloaded, parse, be put in storage.Realize the Core Feature to content reception.
4, it is browsable in all progress or completed in the management backstage page after Interface Engineering obtains appointment taskBusiness.And the function of providing and all tasks are managed, sort, the sequence of data processing is adjusted by manually at any time, is made moreNeed the data shown in time, priority processing.
It is illustrated in figure 2 a kind of sequential circulation schematic diagram of specific embodiment of the present invention, detailed process is as follows：
1, broadcasting and TV are sent a message to by standard C2 specifications in upstream CP；Interface protocol is：HTTP SOAP include mainlyLSPID（Upstream ID）、CSPID（This platform ID）、CorrelateID（Work order ID）、ContentMngXMLURL（Work order address）Etc. information.
2, the object of specific work order（object）Including to program（program）, poster（picture）, entity（movie）, classification（category）, the more acute head of collection（series）And all kinds of matching relationships（mapping）.Pass through XML fileAs transmission medium, injected to broadcasting and TV platform.
3, broadcasting and TV utilize load-balancing technique, and all information distribution is assigned to physical interface server；Interface Engineering opensDynamic multithreading, initializes a plurality of data queue.
4, Interface Engineering inquires and is all assigned to the tasks of the server, and is arranged according to founding the team, with this by data intoRow distribution.For example, interface inquires pending data 10 altogether, 5 queues are initialized, then the 1st, 6 datas deliver firstQueue processing；2nd, 7 datas deliver Article 2 queue processing the 3rd, 8 datas deliver the 4th, 9 article of Article 3 queue processingData deliver Article 4 queue processing the 5th, 10 datas deliver Article 5 queue processing.Thus the load of cooperation last layer time is equalWeighing apparatus, all information is uniformly digested in all thread queues of Servers-all, greatly improves efficiency and hardware clothesThe utilization rate of business device.
5, after single thread queue receives the task of specific work order, work order XML file is first downloaded into server local,Then XML file is opened, and to work order object（object）Parsed, specific data structure and service logic, by film,The information such as classification and matching relationship are put in storage preservation respectively.
6, after being put in storage successfully, by result information, HTTP soap protocol forms is still utilized to notify upstream CP platforms, includingLSPID（Upstream ID）、CSPID（This platform ID）、CorrelateID（Work order ID）、ContentMngXMLURL（Work order address）.After upstream CP platforms receive message, it is believed that this is injected successfully.
7, in the management backstage of broadcasting and TV, provide to all carry out in and be completed task check and management function.
8, since the content injection message received simultaneously is too many, editorial staff is may require that sometimes to being lined up content rearwardHigh priority data processing, reaches the standard grade in advance to more valuable content to realize.In management backstage, such number can be selectedAccording to click priority processing, background system extracts selected data from regular queue, is pushed to green channel threadIn queue, and then realizes and preferentially parse, be put in storage, reaching the standard grade.
9, simultaneously, management backstage can also view the work order of injection failure, and click is handled again, and background system is heavy by itsIt newly brings into regular queue, re-executes each link logic.
When specifically used, a kind of matchmaker's money docking system based on IPTV high loads, Auto-matching according to the present inventionSystem, operation maintenance personnel is balanced by multiple servers configuration load, disposes this system.Editorial staff in the management backstage of this system,Information configuration is carried out to more CP, including：Whether coding title, returns to message addresses, whether downloads entity file, audit, examineThe inferior information of core grade.Meanwhile having given tacit consent to the fields match relationship of Various types of data work order, if without specific demand, preserve silentRecognize configuration, if there is specific demand, voluntarily increases in the page, changes field, complete configuration.
After programme information is issued to broadcasting and TV platform by CP, system by all information into distribution, be lined up.Editorial staff canBy the management backstage page, priority adjustment is carried out to whole queuing datas.
In conclusion by means of the above-mentioned technical proposal of the present invention, by carrying out load balancing to server, according to serviceThe concrete configuration of device adjusts, concurrent Thread Count is arranged at any time；It, can meanwhile for different geographical, the particular service demand of CPPass through administration page flexible configuration field.It can realize the smooth performance for expanding, adequately utilizing server of service ability, simultaneouslyTo greatest extent departing from, to the dependence of technical staff, being truly realized commercialization in docking operation.
The foregoing is merely illustrative of the preferred embodiments of the present invention, is not intended to limit the invention, all essences in the present inventionWith within principle, any modification, equivalent replacement, improvement and so on should all be included in the protection scope of the present invention god.