CN108173915A - Call chain processing method and processing device - Google Patents
Call chain processing method and processing device Download PDFInfo
- Publication number
- CN108173915A CN108173915A CN201711391196.1A CN201711391196A CN108173915A CN 108173915 A CN108173915 A CN 108173915A CN 201711391196 A CN201711391196 A CN 201711391196A CN 108173915 A CN108173915 A CN 108173915A
- Authority
- CN
- China
- Prior art keywords
- service end
- log information
- jstorm
- service
- sent
- 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
Links
Classifications
-
- 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/50—Network services
- H04L67/60—Scheduling or organising the servicing of application requests, e.g. requests for application data transmissions using the analysis and optimisation of the required network resources
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Telephonic Communication Services (AREA)
Abstract
The embodiment of the present invention provides a kind of call chain processing method and processing device.This method includes：First service end obtains the service request of user terminal；Service request allocation identification information is given at first service end；The calling at the identification information of service request and first service end mark is sent to second service end by first service end, so that calling mark generation service request corresponding call chain tracking information of the second service end according to the identification information and first service end of service request.The embodiment of the present invention obtains the service request of user terminal by first service end, give service request allocation identification information, the calling at the identification information of service request and first service end mark is sent to second service end, so that calling mark generation service request corresponding call chain tracking information of the second service end according to the identification information and first service end of service request, improve the accuracy for calling D-chain trace, it when a problem occurs, can fast and accurately orientation problem point.
Description
Technical field
The present embodiments relate to field of communication technology more particularly to a kind of call chain processing method and processing devices.
Background technology
In the prior art, the completion of service request will call the service of multiple subsystems on different server, be called
Service will also call other services, and along with the access of Database Systems multiple to bottom or file system mostly.
In face of the call relation of various complexity, when a problem occurs, under traditional centralized application architecture the problem of, diagnoses
Method will be unable to fast and accurately orientation problem point.
Invention content
The embodiment of the present invention provides a kind of call chain processing method and processing device, to improve the accuracy for calling D-chain trace, when
It when something goes wrong, can fast and accurately orientation problem point.
The one side of the embodiment of the present invention is to provide a kind of call chain processing method, including：
First service end obtains the service request of user terminal；
The service request allocation identification information is given at the first service end；
The calling at the identification information of the service request and the first service end is identified and sent by the first service end
Second service end is given, so that the second service end is according to the identification information of the service request and the tune at the first service end
The corresponding call chain tracking information of the service request is generated with mark；
Wherein, the calling at the first service end identifies to represent that the second service end is called at the first service end
Service, the call chain tracking information include the first service end calling mark and the second service end calling mark
Know.
The other side of the embodiment of the present invention is to provide a kind of call chain processing unit, applied to first service end, packet
It includes：
Acquisition module, for obtaining the service request of user terminal；
Distribution module, for the service request allocation identification information；
Sending module, for the calling at the identification information of the service request and first service end mark to be sent to
Second service end, so that the second service end is according to the identification information of the service request and the calling at the first service end
Mark generates the corresponding call chain tracking information of the service request；
Wherein, the calling at the first service end identifies to represent that the second service end is called at the first service end
Service, the call chain tracking information include the first service end calling mark and the second service end calling mark
Know.
Call chain processing method and processing device provided in an embodiment of the present invention obtains the clothes of user terminal by first service end
Business request, to the service request allocation identification information, by the identification information of the service request and the first service end
Mark is called to be sent to second service end, so that the second service end is according to the identification information of the service request and described the
The calling mark of one server-side generates the corresponding call chain tracking information of the service request, improves and calls the accurate of D-chain trace
Property, when a problem occurs, can fast and accurately orientation problem point.
Description of the drawings
Attached drawing herein is incorporated into specification and forms the part of this specification, shows the implementation for meeting the disclosure
Example, and for explaining the principle of the disclosure together with specification.
Fig. 1 is the schematic diagram of communication system provided in an embodiment of the present invention；
Fig. 2 is call chain process flow figure provided in an embodiment of the present invention；
Fig. 3 is the call chain process flow figure that another embodiment of the present invention provides；
Fig. 4 is the call chain process flow figure that another embodiment of the present invention provides；
Fig. 5 is the structure chart of call chain processing unit provided in an embodiment of the present invention；
Fig. 6 is the structure chart of call chain processing unit that another embodiment of the present invention provides.
Pass through above-mentioned attached drawing, it has been shown that the specific embodiment of the disclosure will be hereinafter described in more detail.These attached drawings
The range for limiting the disclosure by any mode and conceiving is not intended to word description, but is by reference to specific embodiment
Those skilled in the art illustrate the concept of the disclosure.
Specific embodiment
Here exemplary embodiment will be illustrated in detail, example is illustrated in the accompanying drawings.Following description is related to
During attached drawing, unless otherwise indicated, the same numbers in different attached drawings represent the same or similar element.Following exemplary embodiment
Described in embodiment do not represent all embodiments consistent with the disclosure.On the contrary, they be only with it is such as appended
The example of the consistent device and method of some aspects be described in detail in claims, the disclosure.
Call chain processing method provided by the invention, can be adapted for communication system shown in FIG. 1.As shown in Figure 1, this is logical
Letter system includes：Access network equipment 11, user terminal 12, server 13, server 14, server 15, server 16, server
17.It only schematically illustrates herein, not the concrete form of the number of Limited service device and communication system.
It should be noted that communication system shown in FIG. 1 can be adapted for different network formats, for example, can be applicable in
In global system for mobile telecommunications (Global System of Mobile communication, abbreviation GSM), CDMA (Code
Division Multiple Access, abbreviation CDMA), wideband code division multiple access (Wideband Code Division
Multiple Access, abbreviation WCDMA), TD SDMA (Time Division-Synchronous Code
Division Multiple Access, abbreviation TD-SCDMA), long term evolution (Long Term Evolution, abbreviation LTE)
The network formats such as the 5G in system and future.Optionally, above-mentioned communication system can be that highly reliable low time delay leads in 5G communication systems
Believe in the scene of (Ultra-Reliable and Low Latency Communications, abbreviation URLLC) transmission and be
System.
So optionally, above-mentioned access network equipment 11 can be base station (the Base Transceiver in GSM or CDMA
Station, abbreviation BTS) and/or base station (NodeB, abbreviation NB) in base station controller or WCDMA and/or wireless
Network controller (Radio Network Controller, abbreviation RNC), can also be the evolved base station in LTE
(Evolutional Node B, abbreviation eNB or eNodeB) either base in relay station or access point or future 5G networks
Stand (gNB) etc., and the present invention does not limit herein.
Above-mentioned user terminal 12 can be that wireless terminal can also be catv terminal.Wireless terminal can be directed to user and carry
For voice and/or the equipment of other business datum connectivity, there is the portable equipment of wireless connecting function or be connected to wireless
Other processing equipments of modem.Wireless terminal can be through wireless access network (Radio Access Network, abbreviation
RAN it) communicates with one or more equipments of the core network, wireless terminal can be mobile terminal, as mobile phone (or is
" honeycomb " phone) and with mobile terminal computer, for example, it may be portable, pocket, hand-held, built-in computer
Or vehicle-mounted mobile device, they exchange language and/or data with wireless access network.For another example wireless terminal can be with
It is personal communication service (Personal Communication Service, abbreviation PCS) phone, wireless phone, session setup
Agreement (Session Initiation Protocol, abbreviation SIP) phone, wireless local loop (Wireless Local
Loop, abbreviation WLL) it stands, the equipment such as personal digital assistant (Personal Digital Assistant, abbreviation PDA).It is wireless whole
End is referred to as system, subscriber unit (Subscriber Unit), subscriber station (Subscriber Station), movement station
(Mobile Station), mobile station (Mobile), distant station (Remote Station), remote terminal (Remote
Terminal), access terminal (Access Terminal), user terminal (User Terminal), user agent (User
Agent), user equipment (User Device or User Equipment), is not limited thereto.Optionally, above-mentioned user is whole
End 12 can also be the equipment such as smartwatch, tablet computer.
Optionally, user terminal 12 sends service request by access network equipment 11 to server 13, and server 13 receives
To after the service request, which is handled, when server 13 handles the service request, may be also needed to
Service on invoking server 14 and server 15, server 15 may also need to the clothes on invoking server 16 and server 17
Business only schematically illustrates, does not limit the number of server, when the number of server is more, call relation can become herein
Complex, when a problem occurs, diagnostic method will be unable to fast and accurately fixed the problem of under traditional centralized application architecture
Position problem points, for the problem, present embodiments provide a kind of call chain processing method, with reference to specific embodiment to this
Call chain processing method is introduced.
Call chain processing method provided by the invention, it is intended to solve the as above technical problem of the prior art.
How the technical solution of technical scheme of the present invention and the application is solved with specifically embodiment below above-mentioned
Technical problem is described in detail.These specific embodiments can be combined with each other below, for the same or similar concept
Or process may repeat no more in certain embodiments.Below in conjunction with attached drawing, the embodiment of the present invention is described.
Fig. 2 is call chain process flow figure provided in an embodiment of the present invention.The embodiment of the present invention is directed to the prior art
As above technical problem, provide call chain processing method, this method is as follows：
Step 201, first service end obtain the service request of user terminal.
In the present embodiment, first service end can be specifically server 13 as shown in Figure 1, and second service end specifically may be used
To be server 14 as shown in Figure 1 or server 15, as shown in Figure 1, user terminal 12 by access network equipment 11 to service
Device 13 sends service request.
The service request allocation identification information is given at step 202, the first service end.
After server 13 receives the service request of the transmission of user terminal 12, the service request allocation identification information is given, it should
Identification information is denoted as TraceID, and TraceID can be globally unique identifier, can have been connected by TraceID and entirely called
Chain.One TraceID corresponds to a service request.
Step 203, the first service end are by the identification information of the service request and the calling at the first service end
Mark is sent to second service end, so that identification information and first clothes of the second service end according to the service request
The calling mark at business end generates the corresponding call chain tracking information of the service request.
Wherein, the calling at the first service end identifies to represent that the second service end is called at the first service end
Service, the call chain tracking information include the first service end calling mark and the second service end calling mark
Know.
If server 13 handles the service request, it is also necessary to the clothes on invoking server 14 and server 15
It is engaged in, then server 13 can also generate one and call mark, and calling mark is denoted as SpanID, which calls for record
Set membership.For example, the SpanID of server 13 is 1, and when the service on 13 invoking server 15 of server, server 13
The SpanID of TraceID and server 13 are sent to server 15, represent what server 13 was identified to handle TraceID
Service request needs the service on invoking server 15.
Server 15 receive server 13 transmission TraceID and server 13 SpanID when, by server 13
For SpanID as ParentID, i.e., the ParentID that server 15 generates is 1, meanwhile, server 15 also generates oneself
SpanID, the SpanID that server 15 generates can be 2.When server 15 calls the service on other servers, other clothes
Business device can also generate corresponding ParentID and SpanID, for example, during service on 15 invoking server 16 of server, service
The SpanID of TraceID and server 15 are sent to server 16 by device 15, server 16 using the SpanID of server 15 as
The ParentID of ParentID, i.e. server 16 generation is 2, meanwhile, server 16 also generates the SpanID of oneself, server 16
The SpanID of generation can be 3, and so on.Each server can record ParentID and SpanID, each server
The ParentID and SpanID recorded respectively can be used as call chain tracking information.It is recorded respectively by each server
ParentID and SpanID may be constructed the set membership of primary complete call chain.
The embodiment of the present invention obtains the service request of user terminal by first service end, distributes and marks to the service request
Know information, the calling at the identification information of the service request and first service end mark is sent to second service end, with
Make the second service end according to the identification information of the service request and the calling mark generation at the first service end
The corresponding call chain tracking information of service request improves the accuracy for calling D-chain trace, when a problem occurs, can be quick and precisely
Orientation problem point.
Fig. 3 is the call chain process flow figure that another embodiment of the present invention provides.On the basis of above-described embodiment,
Call chain processing method provided in this embodiment can also specifically include the following steps：
Step 301, the first service end obtain the corresponding service invocation information of the service request.
As shown in Figure 1, user terminal 12 sends service request by access network equipment 11 to server 13, server 13 connects
After receiving the service request, which is handled, when server 13 handles the service request, may also be needed
The service on invoking server 14 and server 15 is wanted, server 15 may be also needed on invoking server 16 and server 17
Service.
Optionally, server 15 receives the service invocation information that server 16 and server 17 are fed back, and server 15 will take
The service invocation information that business device 16 and server 17 are fed back is sent to server 13, and similarly, server 14 is fed back to server 13
Service invocation information, after server 13 obtains the service invocation information that server 15 and server 14 are fed back, generation service letter
Breath, and information on services is sent to user terminal 12 by access network equipment 11, which is server 13 to user
The service request that terminal 12 is sent carries out treated handling result.
In addition, server 13 can also generate Service name, take, be passed to parameter, creation time, TraceID, SpanID etc.
Related data.
Step 302, the first service end generate log information according to the service invocation information.
After the completion of server 13 is to the service call on server 15 and server 14, service invocation information is stored in this
In ground journal file, in addition, each server is also equipped with log collection program, each server can pass through its installation
Log collection program collector journal file.
The log information is sent to JStorm streaming computing frames by step 303, the first service end, so that
JStorm streaming computings frame carries out analytical decomposition to the log information.
As shown in figure 4, using N can be application or same clothes on different server using 1, using 2 ...
The different application being engaged on device, each application can carry out service invocation information by Java Agent bytecode enhancing, and will
In the enhanced service invocation information deposit local log file of bytecode, further by log collection program collector journal file
In service invocation information.
In addition, as shown in figure 4, application 1 on different server, log information can also be sent using N using 2 ...
JStorm streaming computing frames are given, JStorm streaming computings frame can carry out analytical decomposition to the log information.
Optionally, the log information is sent to JStorm streaming computing frames by the first service end, so that
JStorm streaming computings frame carries out analytical decomposition to the log information, including：The first service end is believed by the daily record
Breath is sent to JStorm streaming computing frames, so that JStorm streaming computings frame carries out analytical decomposition to the log information,
And the log information needed for different business scene is stored in different storage systems.
As shown in figure 4, the log information needed for different business scene can be stored in not by JStorm streaming computings frame
Same storage system, for example, by the log information storage to MySQL after analytical decomposition.
Optionally, the log information is sent to JStorm streaming computing frames by the first service end, so that
JStorm streaming computings frame carries out analytical decomposition to the log information, and the log information needed for different business scene is deposited
It stores up in different storage systems, including：The log information is sent to JStorm streaming computing frames by the first service end,
So that JStorm streaming computings frame carries out analytical decomposition to the log information, and the log information of real-time statistics is stored in
In Hbase.
As shown in figure 4, the log information needed for different business scene can be stored in not by JStorm streaming computings frame
Same storage system, for example, the log information of real-time statistics is stored in Hbase.
Optionally, the log information is sent to JStorm streaming computing frames by the first service end, so that
JStorm streaming computings frame carries out analytical decomposition to the log information, and the log information needed for different business scene is deposited
It stores up in different storage systems, including：The log information is sent to JStorm streaming computing frames by the first service end,
So that JStorm streaming computings frame carries out the log information analytical decomposition, and convergence index is stored in ES.
As shown in figure 4, the log information needed for different business scene can be stored in not by JStorm streaming computings frame
Same storage system, for example, convergence index is stored in ES.
In addition, as shown in figure 4, the api interface that various Web Development Frameworks can also be carried by accessing ES carries out data and shows
Show.
The embodiment of the present invention obtains the service request of user terminal by first service end, distributes and marks to the service request
Know information, the calling at the identification information of the service request and first service end mark is sent to second service end, with
Make the second service end according to the identification information of the service request and the calling mark generation at the first service end
The corresponding call chain tracking information of service request improves the accuracy for calling D-chain trace, when a problem occurs, can be quick and precisely
Orientation problem point.
Fig. 5 is the structure chart of call chain processing unit provided in an embodiment of the present invention.Calling provided in an embodiment of the present invention
Chain processing unit can perform the process flow of call chain processing method embodiment offer, as shown in figure 5, call chain processing unit
50 include：Acquisition module 51, distribution module 52, sending module 53；Acquisition module 51 is used to obtain the service request of user terminal；
Distribution module 52 is used for the service request allocation identification information；Sending module 53 is used to believe the mark of the service request
The calling at breath and first service end mark is sent to second service end, so that the second service end please according to the service
The identification information and the calling mark at the first service end asked generate the corresponding call chain tracking information of the service request；Its
In, the calling at the first service end identifies to represent that the service at the second service end, institute are called in the first service end
It states call chain tracking information and includes the calling mark at the first service end and the calling mark at the second service end.
Call chain processing unit provided in an embodiment of the present invention can be specifically used for performing the method reality that above-mentioned Fig. 2 is provided
Example is applied, details are not described herein again for concrete function.
The embodiment of the present invention obtains the service request of user terminal by first service end, distributes and marks to the service request
Know information, the calling at the identification information of the service request and first service end mark is sent to second service end, with
Make the second service end according to the identification information of the service request and the calling mark generation at the first service end
The corresponding call chain tracking information of service request improves the accuracy for calling D-chain trace, when a problem occurs, can be quick and precisely
Orientation problem point.
Fig. 6 is the structure chart of call chain processing unit that another embodiment of the present invention provides.On the basis of above-described embodiment
On, call chain processing unit 50 further includes：Generation module 54, acquisition module 51 are additionally operable to：It is corresponding to obtain the service request
Service invocation information；Generation module 54 is used to generate log information according to the service invocation information；Sending module 53 is additionally operable to：
The log information is sent to JStorm streaming computing frames so that JStorm streaming computings frame to the log information into
Row analytical decomposition.
Optionally, the log information is sent to JStorm streaming computing frames by sending module 53, so that JStorm flows
When formula Computational frame carries out analytical decomposition to the log information, it is specifically used for：The log information is sent to JStorm streams
Formula Computational frame, so that JStorm streaming computings frame carries out analytical decomposition to the log information, and by different business scene
Required log information is stored in different storage systems.
Optionally, the log information is sent to JStorm streaming computing frames by sending module 53, so that JStorm flows
Formula Computational frame carries out analytical decomposition to the log information, and the log information needed for different business scene is stored in difference
Storage system when, be specifically used for：The log information is sent to JStorm streaming computing frames, so that JStorm streaming meters
It calculates frame and analytical decomposition is carried out to the log information, and the log information of real-time statistics is stored in Hbase.
Optionally, the log information is sent to JStorm streaming computing frames by sending module 53, so that JStorm flows
Formula Computational frame carries out analytical decomposition to the log information, and the log information needed for different business scene is stored in difference
Storage system when, be specifically used for：The log information is sent to JStorm streaming computing frames, so that JStorm streaming meters
It calculates frame and analytical decomposition is carried out to the log information, and convergence index is stored in ES.
Call chain processing unit provided in an embodiment of the present invention can be specifically used for performing the method reality that above-mentioned Fig. 3 is provided
Example is applied, details are not described herein again for concrete function.
The embodiment of the present invention obtains the service request of user terminal by first service end, distributes and marks to the service request
Know information, the calling at the identification information of the service request and first service end mark is sent to second service end, with
Make the second service end according to the identification information of the service request and the calling mark generation at the first service end
The corresponding call chain tracking information of service request improves the accuracy for calling D-chain trace, when a problem occurs, can be quick and precisely
Orientation problem point.
In conclusion the embodiment of the present invention obtains the service request of user terminal by first service end, to the service
Allocation identification information is asked, the calling at the identification information of the service request and first service end mark is sent to second
Server-side, so that the second service end is identified according to the identification information of the service request and the calling at the first service end
The corresponding call chain tracking information of the service request is generated, improves the accuracy for calling D-chain trace, it when a problem occurs, can
Fast and accurately orientation problem point.
In several embodiments provided by the present invention, it should be understood that disclosed device and method can pass through it
Its mode is realized.For example, the apparatus embodiments described above are merely exemplary, for example, the division of the unit, only
Only a kind of division of logic function can have other dividing mode in actual implementation, such as multiple units or component can be tied
It closes or is desirably integrated into another system or some features can be ignored or does not perform.Another point, it is shown or discussed
Mutual coupling, direct-coupling or communication connection can be the INDIRECT COUPLING or logical by some interfaces, device or unit
Letter connection can be electrical, machinery or other forms.
The unit illustrated as separating component may or may not be physically separate, be shown as unit
The component shown may or may not be physical unit, you can be located at a place or can also be distributed to multiple
In network element.Some or all of unit therein can be selected according to the actual needs to realize the mesh of this embodiment scheme
's.
In addition, each functional unit in each embodiment of the present invention can be integrated in a processing unit, it can also
That each unit is individually physically present, can also two or more units integrate in a unit.Above-mentioned integrated list
The form that hardware had both may be used in member is realized, can also be realized in the form of hardware adds SFU software functional unit.
The above-mentioned integrated unit realized in the form of SFU software functional unit, can be stored in one and computer-readable deposit
In storage media.Above-mentioned SFU software functional unit is stored in a storage medium, is used including some instructions so that a computer
It is each that equipment (can be personal computer, server or the network equipment etc.) or processor (processor) perform the present invention
The part steps of embodiment the method.And aforementioned storage medium includes：USB flash disk, mobile hard disk, read-only memory (Read-
Only Memory, ROM), random access memory (Random Access Memory, RAM), magnetic disc or CD etc. it is various
The medium of program code can be stored.
Those skilled in the art can be understood that, for convenience and simplicity of description, only with above-mentioned each function module
Division progress for example, in practical application, can be complete by different function modules by above-mentioned function distribution as needed
Into the internal structure of device being divided into different function modules, to complete all or part of function described above.On
The specific work process of the device of description is stated, the corresponding process in preceding method embodiment can be referred to, details are not described herein.
Finally it should be noted that：The above embodiments are only used to illustrate the technical solution of the present invention., rather than its limitations；To the greatest extent
Pipe is described in detail the present invention with reference to foregoing embodiments, it will be understood by those of ordinary skill in the art that：Its according to
Can so modify to the technical solution recorded in foregoing embodiments either to which part or all technical features into
Row equivalent replacement；And these modifications or replacement, various embodiments of the present invention technology that it does not separate the essence of the corresponding technical solution
The range of scheme.
Claims (10)
1. a kind of call chain processing method, which is characterized in that including：
First service end obtains the service request of user terminal；
The service request allocation identification information is given at the first service end；
The calling at the identification information of the service request and first service end mark is sent to the by the first service end
Two server-sides, so that the second service end is according to the identification information of the service request and the calling mark at the first service end
Know and generate the corresponding call chain tracking information of the service request；
Wherein, the calling at the first service end identifies to represent that the clothes at the second service end are called at the first service end
Business, the call chain tracking information includes the calling mark at the first service end and the calling at the second service end identifies.
2. it according to the method described in claim 1, it is characterized in that, further includes：
The first service end obtains the corresponding service invocation information of the service request；
The first service end generates log information according to the service invocation information；
The log information is sent to JStorm streaming computing frames by the first service end, so that JStorm streaming computing frames
Frame carries out analytical decomposition to the log information.
3. according to the method described in claim 2, it is characterized in that, the log information is sent to by the first service end
JStorm streaming computing frames, so that JStorm streaming computings frame carries out analytical decomposition to the log information, including：
The log information is sent to JStorm streaming computing frames by the first service end, so that JStorm streaming computing frames
Frame carries out analytical decomposition to the log information, and the log information needed for different business scene is stored in different storage systems
System.
4. according to the method described in claim 3, it is characterized in that, the log information is sent to by the first service end
JStorm streaming computing frames, so that JStorm streaming computings frame carries out analytical decomposition to the log information, and will be different
Log information needed for business scenario is stored in different storage systems, including：
The log information is sent to JStorm streaming computing frames by the first service end, so that JStorm streaming computing frames
Frame carries out analytical decomposition to the log information, and the log information of real-time statistics is stored in Hbase.
5. according to the method described in claim 3, it is characterized in that, the log information is sent to by the first service end
JStorm streaming computing frames, so that JStorm streaming computings frame carries out analytical decomposition to the log information, and will be different
Log information needed for business scenario is stored in different storage systems, including：
The log information is sent to JStorm streaming computing frames by the first service end, so that JStorm streaming computing frames
Frame carries out the log information analytical decomposition, and convergence index is stored in ES.
6. a kind of call chain processing unit, applied to first service end, which is characterized in that including：
Acquisition module, for obtaining the service request of user terminal；
Distribution module, for the service request allocation identification information；
Sending module, for the calling at the identification information of the service request and first service end mark to be sent to second
Server-side, so that the second service end is identified according to the identification information of the service request and the calling at the first service end
Generate the corresponding call chain tracking information of the service request；
Wherein, the calling at the first service end identifies to represent that the clothes at the second service end are called at the first service end
Business, the call chain tracking information includes the calling mark at the first service end and the calling at the second service end identifies.
7. call chain processing unit according to claim 6, which is characterized in that further include：Generation module；
The acquisition module is additionally operable to：Obtain the corresponding service invocation information of the service request；
The generation module, for generating log information according to the service invocation information；
The sending module is additionally operable to：The log information is sent to JStorm streaming computing frames, so that JStorm streamings
Computational frame carries out analytical decomposition to the log information.
8. call chain processing unit according to claim 7, which is characterized in that the sending module is by the log information
Be sent to JStorm streaming computing frames so that JStorm streaming computings frame to the log information carry out analytical decomposition when,
It is specifically used for：
The log information is sent to JStorm streaming computing frames, so that JStorm streaming computings frame believes the daily record
Breath carries out analytical decomposition, and the log information needed for different business scene is stored in different storage systems.
9. call chain processing unit according to claim 8, which is characterized in that the sending module is by the log information
JStorm streaming computing frames are sent to, so that JStorm streaming computings frame carries out the log information analytical decomposition, and
Log information needed for different business scene is stored in different storage systems, is specifically used for：
The log information is sent to JStorm streaming computing frames, so that JStorm streaming computings frame believes the daily record
Breath carries out analytical decomposition, and the log information of real-time statistics is stored in Hbase.
10. call chain processing unit according to claim 8, which is characterized in that the sending module believes the daily record
Breath is sent to JStorm streaming computing frames, so that JStorm streaming computings frame carries out analytical decomposition to the log information,
And store the log information needed for different business scene in different storage systems, it is specifically used for：
The log information is sent to JStorm streaming computing frames, so that JStorm streaming computings frame believes the daily record
Breath carries out analytical decomposition, and convergence index is stored in ES.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201711391196.1A CN108173915A (en) | 2017-12-21 | 2017-12-21 | Call chain processing method and processing device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201711391196.1A CN108173915A (en) | 2017-12-21 | 2017-12-21 | Call chain processing method and processing device |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN108173915A true CN108173915A (en) | 2018-06-15 |
Family
ID=62522866
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201711391196.1A Pending CN108173915A (en) | 2017-12-21 | 2017-12-21 | Call chain processing method and processing device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN108173915A (en) |
Cited By (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109286608A (en) * | 2018-08-20 | 2019-01-29 | 中国平安人寿保险股份有限公司 | Call chain processing method, device and storage equipment, computer equipment |
| CN109542718A (en) * | 2018-10-22 | 2019-03-29 | 中国平安人寿保险股份有限公司 | Monitoring method, device, storage medium and the server of service call |
| CN109922123A (en) * | 2018-12-27 | 2019-06-21 | 北京奥鹏远程教育中心有限公司 | The methods of exhibiting of call relation and displaying device between server |
| CN110351126A (en) * | 2019-06-26 | 2019-10-18 | 中信百信银行股份有限公司 | Log rank method of adjustment, device and electronic equipment |
| WO2020024343A1 (en) * | 2018-07-30 | 2020-02-06 | 网宿科技股份有限公司 | Method invoke chain tracing method, electronic apparatus, and computer-readable storage medium |
| WO2020147336A1 (en) * | 2019-01-18 | 2020-07-23 | 苏宁易购集团股份有限公司 | Micro-service full-link monitoring system and method |
| CN112383415A (en) * | 2020-10-30 | 2021-02-19 | 上海蜜度信息技术有限公司 | Server side marking method and equipment |
| CN114301988A (en) * | 2021-12-22 | 2022-04-08 | 中国电信股份有限公司 | Distributed calling method and device, storage medium and electronic equipment |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20150063102A1 (en) * | 2013-08-30 | 2015-03-05 | Cisco Technology, Inc. | Flow Based Network Service Insertion |
| CN106790718A (en) * | 2017-03-16 | 2017-05-31 | 北京搜狐新媒体信息技术有限公司 | Service call link analysis method and system |
-
2017
- 2017-12-21 CN CN201711391196.1A patent/CN108173915A/en active Pending
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20150063102A1 (en) * | 2013-08-30 | 2015-03-05 | Cisco Technology, Inc. | Flow Based Network Service Insertion |
| CN106790718A (en) * | 2017-03-16 | 2017-05-31 | 北京搜狐新媒体信息技术有限公司 | Service call link analysis method and system |
Cited By (13)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US11099889B2 (en) | 2018-07-30 | 2021-08-24 | Wangsu Science & Technology Co., Ltd. | Method-call-chain tracking method, electronic device, and computer readable storage medium |
| WO2020024343A1 (en) * | 2018-07-30 | 2020-02-06 | 网宿科技股份有限公司 | Method invoke chain tracing method, electronic apparatus, and computer-readable storage medium |
| CN109286608B (en) * | 2018-08-20 | 2022-08-12 | 中国平安人寿保险股份有限公司 | Call chain processing method and device, storage device and computer device |
| CN109286608A (en) * | 2018-08-20 | 2019-01-29 | 中国平安人寿保险股份有限公司 | Call chain processing method, device and storage equipment, computer equipment |
| CN109542718A (en) * | 2018-10-22 | 2019-03-29 | 中国平安人寿保险股份有限公司 | Monitoring method, device, storage medium and the server of service call |
| CN109542718B (en) * | 2018-10-22 | 2023-02-07 | 中国平安人寿保险股份有限公司 | Service call monitoring method and device, storage medium and server |
| CN109922123A (en) * | 2018-12-27 | 2019-06-21 | 北京奥鹏远程教育中心有限公司 | The methods of exhibiting of call relation and displaying device between server |
| CN109922123B (en) * | 2018-12-27 | 2022-01-11 | 北京奥鹏远程教育中心有限公司 | Display method and display device for call relation between servers |
| CN111464373A (en) * | 2019-01-18 | 2020-07-28 | 苏宁易购集团股份有限公司 | Micro-service full-link monitoring system and method |
| WO2020147336A1 (en) * | 2019-01-18 | 2020-07-23 | 苏宁易购集团股份有限公司 | Micro-service full-link monitoring system and method |
| CN110351126A (en) * | 2019-06-26 | 2019-10-18 | 中信百信银行股份有限公司 | Log rank method of adjustment, device and electronic equipment |
| CN112383415A (en) * | 2020-10-30 | 2021-02-19 | 上海蜜度信息技术有限公司 | Server side marking method and equipment |
| CN114301988A (en) * | 2021-12-22 | 2022-04-08 | 中国电信股份有限公司 | Distributed calling method and device, storage medium and electronic equipment |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN108173915A (en) | Call chain processing method and processing device | |
| CN108810119A (en) | block chain processing method, device and block chain node | |
| CN109067724A (en) | Block chain data trade method, apparatus, equipment and storage medium | |
| CN109118360A (en) | Block chain account checking method, device, equipment and storage medium | |
| CN107197059B (en) | DNS (Domain name Server) analysis method and device | |
| CN108712506A (en) | block chain node communication method, device and block chain node | |
| CN110247848A (en) | Send method, the network equipment and the computer readable storage medium of message | |
| CN110267343A (en) | A kind of paging management method, network data analysis function and network side equipment | |
| CN109152005A (en) | A kind of uplink beam indicating means, UE, base station and storage medium | |
| CN108200568A (en) | Mobile communication electronics SIM card data processing method and device | |
| CN109873857A (en) | Mobile terminal method of data synchronization and device under a kind of no network state | |
| CN108810120A (en) | block chain node communication method, device and block chain node | |
| CN106128468A (en) | Audio communication method and device | |
| CN107769934B (en) | Rate processing method and processing device | |
| CN108683727A (en) | Block processes method and host node | |
| CN109087096A (en) | Block chain account checking method, device, equipment and storage medium | |
| CN108876611A (en) | Exchange information processing method, device and block chain node | |
| CN108985765A (en) | Enterprise user information processing method, equipment and storage medium | |
| CN108777710A (en) | Block chain communication method between nodes, device and block chain node | |
| CN108769144A (en) | Storage processing method, transaction node, memory node and communication equipment | |
| CN108848144A (en) | Block chain interior joint access method, device and block chain node | |
| CN108765150A (en) | Exchange information processing method and memory node | |
| CN108881392A (en) | The update method and device of service characteristic data base | |
| CN106506176A (en) | A kind of strategy and charging regulation generation method and system | |
| CN110674234B (en) | Map data acquisition method, apparatus and storage medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| WD01 | Invention patent application deemed withdrawn after publication |
Application publication date: 20180615 |
|
| WD01 | Invention patent application deemed withdrawn after publication |