CN101211275B - Message pumping method and system - Google Patents
Message pumping method and system Download PDFInfo
- Publication number
- CN101211275B CN101211275B CN 200710125737 CN200710125737A CN101211275B CN 101211275 B CN101211275 B CN 101211275B CN 200710125737 CN200710125737 CN 200710125737 CN 200710125737 A CN200710125737 A CN 200710125737A CN 101211275 B CN101211275 B CN 101211275B
- Authority
- CN
- China
- Prior art keywords
- message
- module
- carry out
- characteristic
- steps
- 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.)
- Expired - Fee Related
Links
Images
Landscapes
- Information Transfer Between Computers (AREA)
Abstract
The invention discloses a message pump method and a system. The method includes the following steps: a first commonness of a message is preset; a head message pointer of a message queue is obtained; a head message is copied to be used as the processing message at present; the message is filtered; whether setting a return mark and/or a releasing mark for each step is judged; the corresponding setting is executed; and then a return judging step is executed. The return judging step includes the following steps: whether the return mark is existed is judged; a releasing judging step is executed ifreturn mark is existed, otherwise the next step is entered if not; the message is preprocessed, the first commonness of the message is processed; the return judging step is executed; the characteristic of the message is processed; and the releasing judging step is executed. The releasing judging step includes the following steps: whether the releasing mark is existed is judged and the head message is removed from the message queue if the releasing mark is existed. With the invention, the classification, ordering and simplification of the message processing are realized, the message processingflow is shortened, the message is preserved in the system or the user message queue when in necessary, and the processing efficiency is greatly improved.
Description
Technical field
The present invention relates to the flow processing of message, in particular, a kind of flexible and efficient message pumping method and system.
Background technology
Present set-top box has powerful interface alternation ability, and its User Interface (UI) structure also becomes increasingly complex.The UI of main flow design now all is based on message in itself, with event-driven operation, i.e. Event triggered type.The flow processing process of message is core the most, and this process often is called as the message pump.
The quality of message pump design is directly connected to the power of UI interaction capabilities, Message Processing flow process complicated and simple.Had only flexible and efficient message pump, could realize powerful user interface interaction ability, improved the rate of code reuse of software.
A message circulation process of UI message pump is generally as follows now:
1, take out a piece of news from system message queue or user message queue;
2, if the message of getting is carried out message conversion earlier, again message is sent to current form or specifies forms;
3, after forms receive message, in forms processing function, with case statements such as switch-case each message is carried out particular procedure, default message is then called the processing function of acquiescence and handled.
The code structure form is schematically as follows:
But there is following defective in prior art:
1, each message must cover a complete cycle flow process, no matter whether this need; And can't short circuit message flow (namely shortening, delete message flow), make it enter next circulation process fast.
2, all be from system or user message queue, to take out Message Processing at every turn, in case take out, system or user message queue have not just had this message, if need this message to drive another forms operation at once, just must re-generate this message earlier, and it is sent to system or Subscriber Queue, and this message is placed on the rearmost position of message queue often, handle this message and must handle all message of its front earlier, just may there be delay in this on sequential, namely it does not possess the property real-time that emergency message is handled.And, when in message A processing procedure, produce an emergency message B if desired, make certain forms in next message circulation, just can obtain emergency message B and handle, also be difficult to for this reason realize.
3, for many message, the major part action that the different forms of possibility are done all is the same, be discrepant and have only seldom run, prior art is carried out owing to Message Processing all is placed in each forms flow process, and do not have public message processing module, and can cause a lot of identical codes to repeat, increase size of code; The general character and the individual character dirigibility that are each forms processing messages are not enough.
Therefore, prior art needs to improve.
Summary of the invention
Technical matters to be solved by this invention is that each message must be covered a complete cycle flow process; Take out after the message, system or user message queue have not just had this message; The general character of each forms processing messages and individual character underaction.
Technical scheme of the present invention is as follows:
A kind of message pumping method, it may further comprise the steps: A1, pre-set first general character of each message; Described general character is the operation that each message of the operation that all need carry out of various dissimilar message or same type all need be carried out; A2, obtain a message pointer of message queue, copy its message pointed, as the message when pre-treatment; A3, described message is carried out filtration treatment, judge whether to return sign and/or discharge sign for this filtration treatment step and subsequent step setting, and carry out relative set, carry out then and return determining step; Described subsequent step comprises pre-treatment step and characteristic treatment step; The described determining step that returns is: judge whether to exist the described sign of returning, be then to carry out the release determining step, otherwise enter next step; A4, described message is carried out pre-service, handle first general character of described message, carry out the described determining step that returns; A5, described message is carried out characteristic handle, carry out and discharge determining step; Described release determining step is: judging whether to exist to discharge sign, is then to remove described message from described message queue; Wherein, the described message pump flow processing process that is message.
Described message pumping method, wherein, before the steps A 4, go back execution in step: according to described first general character, judge whether and need carry out pre-service to described message, otherwise direct execution in step A5.
Described message pumping method, wherein, steps A 1 also comprises: the characteristic that pre-sets each message; Described characteristic is the peculiar operation that various message need be carried out; And, before the steps A 5, go back execution in step: according to described characteristic, judge whether that need carry out characteristic to described message handles, and discharges determining step otherwise directly carry out.
Described message pumping method, wherein, steps A 1 also comprises: second general character that pre-sets each message; In the steps A 3, described subsequent step also comprises post-processing step; Steps A 5 specifically comprises step: described message is carried out characteristic handle, carry out and return determining step; And, also carry out following steps: A6 after the steps A 5, described message is carried out aftertreatment, handle second general character of described message, carry out the release determining step.
Described message pumping method, wherein, this method is further comprising the steps of: A0, generate a stature message for a certain emergency at message queue, or the content of revising message queue head message is described emergency; And, between steps A 2 and the steps A 3, further comprising the steps of: as to judge whether to take place described emergency, be direct execution in step A2 then, or in steps A 3, to when the message of pre-treatment is carried out filtration treatment, for sign is returned in this filtration treatment step and/or subsequent step setting; Otherwise continue execution in step A3.
Described message pumping method wherein, in the steps A 3, only is that this filtration treatment step or arbitrary subsequent step arrange described sign and/or the described release sign returned.
A kind of message pumping system wherein, comprises module, acquisition module, filtering module, pretreatment module, characteristic processing module are set; The described module that arranges is connected with described pretreatment module, is used for arranging first general character of each message; Described general character is the operation that each message of the operation all carried out of various dissimilar message or same type is all carried out; Described acquisition module is connected with described filtering module, described pretreatment module, described characteristic processing module respectively, is used for obtaining a message pointer of message queue, copies its message pointed, as the message when pre-treatment; Described filtering module is connected with described pretreatment module, be used for described message is carried out filtration treatment, judge whether to return sign and/or discharge sign for this filtration treatment step and subsequent step setting, and execution relative set, carry out then and return determining step, the execution of controlled filter treatment step and subsequent step; Described pretreatment module is connected with described characteristic processing module, is used for that described message is carried out first general character and handles; Described characteristic processing module is used for that described message is carried out characteristic and handles; Wherein, the described message pump flow processing process that is message.
Described message pumping system, wherein, this system also comprises post-processing module, it is connected with the described module, described acquisition module, described characteristic processing module of arranging respectively, is used for that described message is carried out second general character and handles; And the described module that arranges is also for characteristic and second general character that each message is set; Described characteristic is the peculiar operation that various message need be carried out.
Described message pumping system, wherein, this system also comprise at least following each judge module one of them: first judge module, be arranged between described filtering module and the described pretreatment module, and be connected with described characteristic processing module, be used for when described message does not need to carry out pre-service, directly being transferred to described characteristic processing module; Second judge module is arranged between described pretreatment module and the described characteristic processing module, and is connected with described post-processing module, is used for directly being transferred to described post-processing module when described message does not need to carry out the characteristic processing; The 3rd judge module is arranged between described filtering module and the described pretreatment module, and is connected with described post-processing module, is used for directly being transferred to described post-processing module when described message does not need to carry out pre-service and characteristic processing; The 4th judge module is arranged between described filtering module and the described pretreatment module, and is connected with described acquisition module, is used for when described message does not need to carry out subsequent treatment, feedback is provided directly for described acquisition module.
Described message pumping system, wherein, described filtering module also arranges judging unit, is used for when the message of system's generation emergency, and the termination of controlled filter treatment step and subsequent step is carried out.
Adopt such scheme, the present invention has realized treatment classificationization, ordering and the simplification of message; Shorten or deleted the Message Processing flow process; Take out after the message, it is standby also to keep this message in system or user message queue in case of necessity; General character and individual character to message are handled respectively, have effectively reduced duplicated code, have improved treatment effeciency greatly.
Description of drawings
Fig. 1 is the process flow diagram of a kind of embodiment of the inventive method;
Fig. 2 is the structural representation of system of the present invention.
Embodiment
Below in conjunction with the drawings and specific embodiments, the present invention is described in detail.
What for Message Processing, can be summed up as substantially: according to the order kind, what determines to carry out handle (namely " doing action "); And according to command parameter, determine how to handle (namely " how doing "); For a lot of message, its " the doing what action " that will cause is the same, and just possibility " how doing " is different, therefore, the present invention is by carrying out message by order kind classification, and making can classify to the processing of message carries out, and the execution of same class order is generally very similar again; Perhaps, extract the operation of the common execution of message institute of different command kind, take same processing mode.So just the treatment classificationization of message, ordering has been oversimplified.The modularization that is conducive to software has also improved the readability of software, extensibility greatly.
Such as 5 to 10 shortcuts are generally arranged in the set-top box, namely wish under any forms, to press the module that this key can both jump to appointment fast, such as playing TV, broadcasting, program guide, NVOD or data broadcasting etc., the characteristics of these operations be " all need redirect; but to jump to different places ", the present invention can be divided into a class to this class message and handle; And as when receiving software upgrading, program updating etc. message, the characteristics of these operations are " need provide information, but the information difference that provides ", the present invention can be divided into a class to this class message again and handle.
Therefore, the invention provides a kind of message pumping method, it may further comprise the steps.
A1, pre-set first general character of each message; Described general character is the operation that each message of the operation that all need carry out of various dissimilar message or same type all need be carried out.
A2, obtain a message pointer of message queue, copy its message pointed, as the message when pre-treatment.
A3, described message is carried out filtration treatment, judge whether to return sign and/or discharge sign for this filtration treatment step and subsequent step setting, and carry out relative set, carry out then and return determining step; Described subsequent step comprises pre-treatment step and characteristic treatment step; This step can only arrange and return sign, can only arrange to discharge sign, also can arrange and return sign and discharge sign.The described determining step that returns is: judge whether to exist the described sign of returning, be then to carry out the release determining step, otherwise enter next step.
Wherein, in the steps A 3, can only be that this filtration treatment step or arbitrary subsequent step arrange described sign and/or the described release sign returned.
Like this, to circulation process length of message, set up control: the level that has increased Message Processing, and carrying out the message screening layer of filtration treatment respectively, pretreatment layer, carry out the forms processing layer that characteristic is handled, judge whether respectively and need return after the aftertreatment layer, just can control the length of message flow here according to actual needs.Such as, under the ideal case, each layer behind the message screening layer all can namely satisfied under the situation of waiting condition by short circuit, shields the execution of other message; Some message may just not need subsequent treatment etc. after pretreatment layer is handled for another example.
A4, described message is carried out pre-service, handle first general character of described message, carry out the described determining step that returns.
Be more preferably, before steps A 4, can also execution in step: according to described first general character, judge whether and need carry out pre-service to described message, otherwise direct execution in step A5.
A5, described message is carried out characteristic handle, carry out and discharge determining step; Described release determining step is: judging whether to exist to discharge sign, is then to remove described message from described message queue.For example, in steps A 5, to professional relevant or have the message of its characteristic business (i.e. individual sexual act) to handle with it, these forms that carry out the characteristic processing are handled the characteristic of various different types of messages, the perhaps characteristic of each different messages in the similar message respectively to each concrete forms respectively.Certainly, in the practical application, these forms also can be handled some possible general character respectively.
Be more preferably, steps A 1 also comprises: the characteristic that pre-sets each message; Described characteristic is the peculiar operation that various message need be carried out; And, before steps A 5, all right execution in step: according to described characteristic, judge whether that need carry out characteristic to described message handles, and discharges determining step otherwise directly carry out.
A preferred example is that steps A 1 also comprises: second general character that pre-sets each message; And in the steps A 3, described subsequent step also comprises post-processing step; And steps A 5 specifically comprises step: described message is carried out characteristic handle, carry out and return determining step; Then, after steps A 5, also carry out following steps: A6, described message is carried out aftertreatment, handle second general character of described message, carry out the release determining step.
Another preferred example is that this method can also may further comprise the steps: A0, generate a stature message for a certain emergency at message queue, or the content of revising message queue head message is described emergency; And, between steps A 2 and the steps A 3, further comprising the steps of: as to judge whether to take place described emergency, whether between steps A 2 and steps A 3 steps A 0 has taken place namely, be direct execution in step A2 then, also can be in steps A 3, to when the message of pre-treatment is carried out filtration treatment, for sign is returned in this filtration treatment step and/or subsequent step setting; If described emergency does not take place, then continue execution in step A3.
Like this, just can realize the property real-time of emergency message: when Message Processing certain layer in the flow process, in when, an emergency having taken place needing certain forms to carry out emergency treatment, can arrange earlier needs to return after Message Processing is finished, be required emergency message by interface function at required emergency message of the first-born one-tenth of message queue or modification message queue head message content then, this emergency message just can obtain handling in the shortest flow process like this, has improved the responding ability real-time of system.
A complete example as shown in Figure 1, it may further comprise the steps:
At first obtain the message pointer of message queue head message, copy its message pointed, as the message when pre-treatment; Then described message is carried out filtration treatment, whether return after judging message screening, be then to carry out the release determining step, namely continue to judge whether from described message queue, to remove described message, it is a message of then removing message queue, otherwise continue to obtain the message pointer of message queue head message, copy its message pointed, as the Message Processing when pre-treatment.Non-return words are then carried out next step, and for example, this example is to carry out pre-service.Need to prove that pre-service is optional step.When judgement obtains need not to carry out pre-treatment step, can directly carry out follow-up characteristic treatment step, post-processing step, or directly return and carry out the release determining step.
Afterwards described message is carried out pre-service, whether return after judging the message pre-service then, be then to continue to judge whether from described message queue, to remove described message, it is a message of then removing message queue, otherwise continue to obtain the message pointer of message queue head message, copy its message pointed, as the Message Processing when pre-treatment.Non-return words are then carried out next step, and for example, this example is to carry out characteristic to handle.Need to prove that it is optional step that characteristic is handled.When judgement obtains need not to carry out the characteristic treatment step, can directly carry out follow-up post-processing step, or directly return and carry out the release determining step.
Again described message being carried out characteristic handles, judge after message characteristics is handled whether return then, be then to continue to judge whether from described message queue, to remove described message, it is a message of then removing message queue, otherwise continue to obtain the message pointer of message queue head message, copy its message pointed, as the Message Processing when pre-treatment.Carry out and discharge determining step; Described release determining step is: judging whether to exist to discharge sign, is then to remove described message from described message queue.Non-return words are then carried out next step, and for example, this example is to carry out aftertreatment.Need to prove that aftertreatment also is optional step.When judgement obtains need not to carry out post-processing step, can directly return, and carry out the release determining step.
Carry out post-processing step afterwards again: described message is carried out aftertreatment, handle second general character of described message, carry out the release determining step.So far finish this example.
Like this, by pre-service and post-processing step, realized general character and the otherness of each forms processing messages: when certain message arrives pretreatment layer, can handle some general character message; In each forms, handle some individual character message; Equally, also can handle some general character message at the aftertreatment layer; Exist two layers can handle general character message, make the sequential of handling in message general character and individual character that bigger alternative and dirigibility be arranged.
Again for several embodiment, the inventive method is elaborated below.
An example is, makes pretreatment layer can do the action of general character separately, and this method is applicable to the few situation of message kind that triggers this general character action.Can be earlier the enforceability of message be checked, and do corresponding processing, such as: when in each forms, seeing TV, if front end has been broadcast a urgent email message, can show this mail at pretreatment layer so.For another example, if received the message of front end program updating or software upgrading, pretreatment layer just can eject corresponding prompting or move accordingly so.At this moment each forms layer and aftertreatment layer need not done action.
Another example is, makes pretreatment layer and aftertreatment layer can finish the work of some general character jointly, and this method is applicable to the many situations of message kind that trigger this general character action.For some message, the action of doing possibly is roughly similar, but parameter has a little difference.Generally have 5 to 10 shortcuts such as set-top box, namely wish under any forms, to press the module that this key can both jump to appointment fast, such as playing TV, or play and broadcast, or program guide, or NVOD, or data broadcasting etc., this situation and characteristic is " all need redirect, but will jump to different places "; As received the NVOD button, or EPG button; Be to jump to NVOD respectively to touch piece or program guide module so.Adopt the inventive method like this, can it be message conversion " needing redirect; jump to NVOD " or " needing redirect; jump to program guide " at pretreatment layer, at this moment in each forms, do not need to handle this message, and as long as unify to handle just passable at the aftertreatment layer to information " need redirect, where jump to ".This mode is: pretreatment layer is done pre-service earlier to message, unifies processing messages by the aftertreatment layer, and each forms does not generally need independent processing.The benefit of bringing like this is that size of code is few, and the intelligibility of code and alterability are all stronger.
Another example is, makes pretreatment layer, and some forms and aftertreatment layer can be finished the work of some general character jointly, but some forms some distinctive additional act of doing possibly again more.Such as on second basis, received the NVOD button, be will jump to NVOD to touch piece so.If be at this moment in the editing saving forms, it preserves edited result down possibly earlier so, jumps in the NVOD module again.After pretreatment layer was done pre-service earlier to message, for example transforming message was so: " need redirect, jump to NVOD "; " need redirect, jump to NVOD " message if receive this at the editing saving forms, just do and preserve the edited result action; When message arrived the aftertreatment layer, just the action of jumping to NVOD was done in unification.And if be forms at other at this moment, the action that it does not have own volume to add will be done, and so just can ignore " need redirect, jump to NVOD " message, when message during to the aftertreatment layer, remains the unified action of jumping to NVOD of doing.The situation of Here it is a last example.
In sum, concrete enforcement of the present invention generally is the operation that is realized general character by pretreatment layer and aftertreatment layer, and each concrete forms is only handled the operation that these forms need independent or extra process.Message screening layer, pretreatment layer and aftertreatment layer do not belong within certain forms and the level of the Message Processing of forms layer also is different.The groundwork of each forms in the forms layer is to demonstrate variant window interfaces, and provides different interaction capabilities thus.Message through pretreatment layer to message classify merge after, simplified the kind of message to be processed in the forms layer; The existence of processing layer then, making does not again need to do the action of general character in the forms layer, and effect also is to have simplified the action that will do in the forms layer, makes like this can be absorbed in the forms layer to demonstrate the different window body interface, and corresponding interaction capabilities is provided.The message screening layer, pretreatment layer and aftertreatment layer are sightless for the user, this is the operation that is in the backstage.The present invention designs filtering layer, pretreatment layer, and the fundamental purpose of aftertreatment layer is exactly to revise in order to simplify the treatment scheme of each forms, can to adapt to fast.Because in software, the modification at interface is the most frequent and loaded down with trivial details.
And as shown in Figure 2, the present invention also provides a kind of message pumping system, and it comprises module, acquisition module, filtering module, pretreatment module, characteristic processing module are set.
The described module that arranges is connected with described pretreatment module, is used for arranging first general character of each message; Described general character is the operation that each message of the operation all carried out of various dissimilar message or same type is all carried out.
Described acquisition module is connected with described filtering module, described pretreatment module, described characteristic processing module respectively, is used for obtaining a message pointer of message queue, copies its message pointed, as the message when pre-treatment.
Described filtering module is connected with described pretreatment module, be used for described message is carried out filtration treatment, judge whether to return sign and/or discharge sign for this filtration treatment step and subsequent step setting, and execution relative set, carry out then and return determining step, the execution of controlled filter treatment step and subsequent step; For example, same as above, after finishing, the controlled filter treatment step directly gets back to acquisition module, continue to obtain message, perhaps carry out subsequent step, comprise pretreatment module, characteristic processing module, the performed processing of post-processing module of back.
Described pretreatment module is connected with described characteristic processing module, is used for that described message is carried out first general character and handles; For example, by the same treatment part of dissimilar message, carry out common processing; To the message of same type, just may there be more same treatment part, can carry out common processing.
Described characteristic processing module is used for respectively described message being carried out characteristic to be handled, and according to the difference of message, characteristic may be independently, also may partly combine as characteristic with above-mentioned same treatment, handles.In concrete the application, can comprise a plurality of characteristic processing modules.
Be more preferably, this system can also comprise post-processing module, and it is connected with the described module, described acquisition module, described characteristic processing module of arranging respectively, is used for that described message is carried out second general character and handles; And the described module that arranges is also for characteristic and second general character that each message is set; Described characteristic is the peculiar operation that various message need be carried out.First general character and second general character can be identical also can be inequality, decide on actual needs.Can also between described pretreatment module and the processing of described characteristic, another judge module be set, be used for when described message does not need to carry out the characteristic processing, directly being transferred to described post-processing module; And, can also between described filtering module and described pretreatment module, another judge module be set, be used for when described message does not need to carry out pre-service and characteristic processing, directly being transferred to described post-processing module.
For example, this system also comprise at least following each judge module wherein one or more: first judge module, be arranged between described filtering module and the described pretreatment module, and be connected with described characteristic processing module, be used for when described message does not need to carry out pre-service, directly being transferred to described characteristic processing module; Second judge module is arranged between described pretreatment module and the described characteristic processing module, and is connected with described post-processing module, is used for directly being transferred to described post-processing module when described message does not need to carry out the characteristic processing; The 3rd judge module is arranged between described filtering module and the described pretreatment module, and is connected with described post-processing module, is used for directly being transferred to described post-processing module when described message does not need to carry out pre-service and characteristic processing; The 4th judge module is arranged between described filtering module and the described pretreatment module, and is connected with described acquisition module, is used for when described message does not need to carry out subsequent treatment, feedback is provided directly for described acquisition module.
And for example, described filtering module can also arrange judging unit, is used for when the message of system's generation emergency, and the termination of controlled filter treatment step and subsequent step is carried out.
To sum up, message pumping system of the present invention and method make the developer can control the length of Message Processing circulation process desirably in the stereovision that treatment scheme increases Message Processing; By designing distinctive message queue, make the developer to insert or to revise the message content in the row in the position of needs; And take into full account general character and the sexual demand of each forms processing messages.So just overcome the deficiency of prior art, realized flexible and efficient message pump.Simultaneously the message queue among the present invention is by the standard C programming, and two functions having only synchronous operation relevant with operating system have strengthened the portability of code greatly.
Should be understood that, for those of ordinary skills, can be improved according to the above description or conversion, and all these improvement and conversion all should belong to the protection domain of claims of the present invention.
Claims (10)
1. message pumping method, it may further comprise the steps:
A1, pre-set first general character of each message; Described general character is the operation that each message of the operation that all need carry out of various dissimilar message or same type all need be carried out;
A2, obtain a message pointer of message queue, copy its message pointed, as the message when pre-treatment;
A3, described message is carried out filtration treatment, judge whether to return sign and/or discharge sign for this filtration treatment step and subsequent step setting, and carry out relative set, carry out then and return determining step; Described subsequent step comprises pre-treatment step and characteristic treatment step; The described determining step that returns is: judge whether to exist the described sign of returning, be then to carry out the release determining step, otherwise enter next step;
A4, described message is carried out pre-service, handle first general character of described message, carry out the described determining step that returns;
A5, described message is carried out characteristic handle, carry out and discharge determining step; Described release determining step is: judging whether to exist to discharge sign, is then to remove described message from described message queue;
Wherein, the described message pump flow processing process that is message.
2. message pumping method according to claim 1 is characterized in that, before the steps A 4, goes back execution in step: according to described first general character, judge whether and need carry out pre-service to described message, otherwise direct execution in step A5.
3. message pumping method according to claim 1 is characterized in that, steps A 1 also comprises: the characteristic that pre-sets each message; Described characteristic is the peculiar operation that various message need be carried out;
And, before the steps A 5, go back execution in step: according to described characteristic, judge whether that need carry out characteristic to described message handles, and discharges determining step otherwise directly carry out.
4. message pumping method according to claim 1 is characterized in that, steps A 1 also comprises: second general character that pre-sets each message;
In the steps A 3, described subsequent step also comprises post-processing step;
Steps A 5 specifically comprises step: described message is carried out characteristic handle, carry out and return determining step;
And, also carry out following steps: A6 after the steps A 5, described message is carried out aftertreatment, handle second general character of described message, carry out the release determining step.
5. message pumping method according to claim 1 is characterized in that, this method is further comprising the steps of: A0, generate a stature message for a certain emergency at message queue, or the content of revising message queue head message is described emergency;
And, between steps A 2 and the steps A 3, further comprising the steps of: as to judge whether to take place described emergency, be direct execution in step A2 then, or in steps A 3, to when the message of pre-treatment is carried out filtration treatment, for sign is returned in this filtration treatment step and/or subsequent step setting; Otherwise continue execution in step A3.
6. according to the arbitrary described message pumping method of claim 1 to 5, it is characterized in that, in the steps A 3, only is that this filtration treatment step or arbitrary subsequent step arrange described sign and/or the described release sign returned.
7. a message pumping system is characterized in that, comprises module, acquisition module, filtering module, pretreatment module, characteristic processing module are set;
The described module that arranges is connected with described pretreatment module, is used for arranging first general character of each message; Described general character is the operation that each message of the operation all carried out of various dissimilar message or same type is all carried out;
Described acquisition module is connected with described filtering module, described pretreatment module, described characteristic processing module respectively, is used for obtaining a message pointer of message queue, copies its message pointed, as the message when pre-treatment;
Described filtering module is connected with described pretreatment module, be used for described message is carried out filtration treatment, judge whether to return sign and/or discharge sign for this filtration treatment step and subsequent step setting, and execution relative set, carry out then and return determining step, the execution of controlled filter treatment step and subsequent step;
Described pretreatment module is connected with described characteristic processing module, is used for that described message is carried out first general character and handles;
Described characteristic processing module is used for that described message is carried out characteristic and handles;
Wherein, the described message pump flow processing process that is message.
8. message pumping system according to claim 7 is characterized in that, this system also comprises post-processing module, and it is connected with the described module, described acquisition module, described characteristic processing module of arranging respectively, is used for that described message is carried out second general character and handles; And the described module that arranges is also for characteristic and second general character that each message is set; Described characteristic is the peculiar operation that various message need be carried out.
9. message pumping system according to claim 8 is characterized in that, this system also comprise at least following each judge module one of them:
First judge module is arranged between described filtering module and the described pretreatment module, and is connected with described characteristic processing module, is used for directly being transferred to described characteristic processing module when described message does not need to carry out pre-service;
Second judge module is arranged between described pretreatment module and the described characteristic processing module, and is connected with described post-processing module, is used for directly being transferred to described post-processing module when described message does not need to carry out the characteristic processing;
The 3rd judge module is arranged between described filtering module and the described pretreatment module, and is connected with described post-processing module, is used for directly being transferred to described post-processing module when described message does not need to carry out pre-service and characteristic processing;
The 4th judge module is arranged between described filtering module and the described pretreatment module, and is connected with described acquisition module, is used for when described message does not need to carry out subsequent treatment, feedback is provided directly for described acquisition module.
10. message pumping system according to claim 7 is characterized in that, described filtering module also arranges judging unit, is used for when the message of system's generation emergency, and the termination of controlled filter treatment step and subsequent step is carried out.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN 200710125737 CN101211275B (en) | 2007-12-25 | 2007-12-25 | Message pumping method and system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN 200710125737 CN101211275B (en) | 2007-12-25 | 2007-12-25 | Message pumping method and system |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN101211275A CN101211275A (en) | 2008-07-02 |
| CN101211275B true CN101211275B (en) | 2013-09-18 |
Family
ID=39611328
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN 200710125737 Expired - Fee Related CN101211275B (en) | 2007-12-25 | 2007-12-25 | Message pumping method and system |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN101211275B (en) |
Families Citing this family (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113535428B (en) * | 2021-07-09 | 2023-05-23 | 中星电子股份有限公司 | Method, device, equipment and medium for processing request message and response message |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1635781A (en) * | 2003-12-29 | 2005-07-06 | 北京中视联数字系统有限公司 | A method for uniform processing of digital television receiver middleware messages |
| CN1700336A (en) * | 2004-02-27 | 2005-11-23 | 索尼株式会社 | Information processing apparatus method and program |
-
2007
- 2007-12-25 CN CN 200710125737 patent/CN101211275B/en not_active Expired - Fee Related
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN1635781A (en) * | 2003-12-29 | 2005-07-06 | 北京中视联数字系统有限公司 | A method for uniform processing of digital television receiver middleware messages |
| CN1700336A (en) * | 2004-02-27 | 2005-11-23 | 索尼株式会社 | Information processing apparatus method and program |
Also Published As
| Publication number | Publication date |
|---|---|
| CN101211275A (en) | 2008-07-02 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN106250100B (en) | Analyzing logic control method and device | |
| CN109684057B (en) | Task processing method, device and storage medium | |
| CN109445886A (en) | A kind of interface display method, system and terminal device | |
| CN101415258A (en) | Method for implementing download of mobile phone downloader | |
| CN105867920A (en) | APP multi-language switching method and system | |
| EP2879046A1 (en) | Voice-assisted editing method and device for terminal | |
| CN101777004A (en) | Method and system for realizing BPEL sub-process multiplexing based on template in service-oriented environment | |
| CN103903292A (en) | Method and system for realizing head portrait editing interface | |
| CN101097619A (en) | System and method for monitoring business flowpath | |
| US9632684B2 (en) | Method, device and terminal for generating logic service for embedded terminal | |
| CN102904738A (en) | Work order processing method and related device and system | |
| CN111221662B (en) | Task scheduling method, system and device | |
| CN110264035A (en) | Configuration method, device, terminal and the storage medium of workflow | |
| CN101211275B (en) | Message pumping method and system | |
| CN110516220A (en) | A kind of report data input method, system and relevant device | |
| CN113485853A (en) | Information interaction method and device and electronic equipment | |
| CN101295243A (en) | Method for one window implementing multiple pages in embedded system | |
| CN102902574A (en) | Cooperative processing method and device of multiple information flow nodes | |
| CN102375668B (en) | Window management method and device for mobile terminal | |
| CN101778487B (en) | Method for automatically starting appointed function of mobile communication terminal when startup | |
| CN109901697A (en) | A kind of method, apparatus, equipment and medium reducing system power dissipation | |
| CN112506613B (en) | Method for automatically identifying Maven change submodule and pushing docker mirror image by Gitlab-ci | |
| CN101788849B (en) | Optical character recognition input method used for mobile communication equipment system | |
| CN106879056A (en) | The electricity saving method and device of a kind of terminal | |
| KR20130126073A (en) | Apparatus for controlling execution of robot task based on hfsm and method thereof |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| C06 | Publication | ||
| PB01 | Publication | ||
| C10 | Entry into substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| C14 | Grant of patent or utility model | ||
| GR01 | Patent grant | ||
| C17 | Cessation of patent right | ||
| CF01 | Termination of patent right due to non-payment of annual fee |
Granted publication date: 20130918 Termination date: 20131225 |