CN113808711B

CN113808711B - DICOM file processing method, DICOM file processing device, DICOM file processing computer equipment and DICOM file storage medium

Info

Publication number: CN113808711B
Application number: CN202110923288.XA
Authority: CN
Inventors: 吴咏辉
Original assignee: Wuhan United Imaging Healthcare Co Ltd
Current assignee: Wuhan United Imaging Healthcare Co Ltd
Priority date: 2021-08-12
Filing date: 2021-08-12
Publication date: 2024-09-24
Anticipated expiration: 2041-08-12
Also published as: CN113808711A

Abstract

The application relates to a DICOM file processing method, a DICOM file processing device, a DICOM file processing computer device and a DICOM file storage medium. The method comprises the following steps: receiving a request sent by an opposite terminal, and determining the service type of the request; acquiring a first processing stream; parsing header data in the first processing stream; and writing the parsed header data into a second processing stream, and processing the second processing stream. Because only the header data is needed to be resolved to the memory, and the medical image data is not needed to be resolved to the memory, but is directly written into the second processing flow to be processed, all data can be prevented from being resolved to the memory in the processing process of the DICOM file, and therefore the memory can be maintained to be stably used, and the memory use performance is improved. In addition, the method can ensure that the DICOM file is not limited by the size of the DICOM file when being processed, and does not need to additionally improve hardware configuration for a large-volume DICOM file, thereby expanding the application range and saving the hardware cost.

Description

DICOM file processing method, DICOM file processing device, DICOM file processing computer equipment and DICOM file storage medium

Technical Field

The present application relates to the field of medical document processing technologies, and in particular, to a DICOM document processing method, apparatus, computer device, and storage medium.

Background

In related medical information systems, support for DICOM (DIGITAL IMAGING AND Communications IN MEDICINE, digital image and Communications in medicine) protocols, whether in the underlying implementation of c++, c# or java, is not guaranteed to fully support the reception and transmission of large files. In the related art, when receiving or transmitting a medical image file supporting the DICOM protocol, the DICOM file needs to be completely read into a memory or a local cache file for generating the medical image completely is required to be received or transmitted. The DICOM files generated by different medical imaging devices are different in size, the sizes of a plurality of DICOM files can exceed 500M, and some DICOM files can be quite large and even reach more than a plurality of G.

Since DICOM files are generally large, if the DICOM files are completely read into the memory every time they are processed, the memory consumption increases dramatically as the number of DICOM files increases and the frequency of processing DICOM files increases, and the response of the medical information system becomes slow. Even if the data is read into the local cache, the I/O read-write resource consumption is increased, and the performance is deteriorated. In order to increase the response speed, hardware resources need to be increased, which brings about higher cost.

Disclosure of Invention

In view of the foregoing, it is desirable to provide a DICOM file processing method, apparatus, computer device, and storage medium that can improve response speed.

A DICOM file processing method, the method comprising:

receiving a request sent by an opposite terminal, and determining the service type of the request;

acquiring a first processing stream;

Parsing header data in the first processing stream;

and writing the parsed header data into a second processing stream, wherein the second processing stream comprises medical image data which is not parsed in the first processing stream, and processing the second processing stream.

In one embodiment, the service type is a storage service; correspondingly, the first processing flow is a network flow sent by the opposite end, and the second processing flow is a local file flow.

In one embodiment, the header data includes a recording length of unresolved medical image data; accordingly, before processing the second processing stream, the method further includes:

Determining the actual length of unresolved medical image data;

If the recording length is consistent with the actual length, the unresolved medical image data is acquired from the first processing stream, and the unresolved medical image data is written into the second processing stream.

In one embodiment, the service type is a forwarding service; accordingly, the first processing flow is a network flow sent by the opposite end, and the second processing flow is a network flow forwarded outside.

In one embodiment, before processing the second processing stream, the method further includes:

If the same data content as the unresolved medical image data is stored locally, writing the locally stored medical image data into the second processing flow, and if the same data content as the unresolved medical image data is not stored locally, acquiring the unresolved medical image data from the first processing flow, and writing the unresolved medical image data into the second processing flow.

In one embodiment, the header data includes a recording length of unresolved medical image data; accordingly, obtaining unresolved medical image data from the first processing stream comprises:

Determining the actual length of unresolved medical image data;

If the recording length is consistent with the actual length, the unresolved medical image data is acquired from the first processing stream.

In one embodiment, processing the second processing stream includes:

And sending the second processing flow outwards according to the column storage database instruction.

A DICOM file processing apparatus, the apparatus comprising:

the receiving module is used for receiving the request sent by the opposite terminal and determining the service type of the request;

The first acquisition module is used for acquiring a first processing flow;

The analysis module is used for analyzing the head data in the first processing flow;

The first writing module is used for writing the parsed header data into a second processing stream, wherein the second processing stream comprises medical image data which is not parsed in the first processing stream;

And the processing module is used for processing the second processing flow.

A computer device comprising a memory storing a computer program and a processor which when executing the computer program performs the steps of:

acquiring a first processing stream;

Parsing header data in the first processing stream;

A computer readable storage medium having stored thereon a computer program which when executed by a processor performs the steps of:

acquiring a first processing stream;

Parsing header data in the first processing stream;

The DICOM file processing method, the DICOM file processing device, the computer equipment and the storage medium determine the service type of the request by receiving the request sent by the opposite terminal. And acquiring the first processing stream, and analyzing the head data in the first processing stream. And writing the parsed header data into a second processing stream, and processing the second processing stream. Because only partial data of non-medical image data in the first processing flow, namely header data, is needed to be resolved to the memory, and medical image data is not needed to be resolved to the memory, but can be directly written into the second processing flow to be processed, all data can be prevented from being resolved to the memory in the processing process of the DICOM file, and therefore the memory can be maintained to be used stably, and the usability of the memory is improved. In addition, the method can ensure that the DICOM file is not limited by the size of the DICOM file when being processed, and does not need to additionally improve hardware configuration for a large-volume DICOM file, thereby expanding the application range and saving the hardware cost.

Drawings

FIG. 1 is a flow diagram of a DICOM file processing method in one embodiment;

FIG. 2 is a flow chart of a DICOM file processing method according to another embodiment;

FIG. 3 is a flow chart of a DICOM file processing method in accordance with another embodiment;

FIG. 4 is a flow chart of a DICOM file processing method in accordance with yet another embodiment;

FIG. 5 is a block diagram illustrating a DICOM file processing apparatus in one embodiment;

Fig. 6 is an internal structural diagram of a computer device in one embodiment.

Detailed Description

The present application will be described in further detail with reference to the drawings and examples, in order to make the objects, technical solutions and advantages of the present application more apparent. It should be understood that the specific embodiments described herein are for purposes of illustration only and are not intended to limit the scope of the application.

It will be understood that the terms "first," "second," and the like, as used herein, may be used to describe various terms, but are not limited by these terms unless otherwise specified. These terms are only used to distinguish one term from another. For example, the third and fourth preset thresholds may be the same or different without departing from the scope of the application.

DICOM protocol is an international standard for medical images and related information that defines medical image formats that are available for data exchange with quality meeting clinical needs. In the related art, no matter the bottom implementation of C++, C#, java is guaranteed to fully support the receiving and sending of large files. For the filed DICOM file, a general C-Store SCP (SERVICE CLASS Provider), that is, a server side supporting the DICOM protocol, will parse all the received network streams into the memory, and then write the data in the memory into the disk or the outgoing network streams, so that the memory usage of the server side will increase with the DICOM file size, resulting in the crash of the final server side. For the sent DICOM file, a general C-Store SCU (SERVICE CLASS User, request server), that is, a client terminal supporting the DICOM protocol, will read all the DICOM file into the memory and write it into the network stream, so the memory usage of the client terminal will also increase with the size of the DICOM file, resulting in that the client terminal cannot send the DICOM file normally.

In either case, as DICOM files become larger, hardware resources need to be continuously increased to ensure normal operation of the system, thereby increasing hardware cost. In addition, all data are analyzed into the memory, so that a lot of unused data are analyzed, and the overall performance is low during data storage and subsequent data processing. Therefore, there is an urgent need for a file transfer method that solves the above-mentioned technical problems.

In view of the above problems in the related art, an embodiment of the present application provides a DICOM file processing method, which may be applied to a server. It is to be noted that the number of "plural" and the like mentioned in each embodiment of the present application refers to the number of "at least two", for example, "plural" refers to "at least two".

In connection with the above description, in one embodiment, referring to FIG. 1, a DICOM file processing method is provided. Taking the method as an example, the method is applied to a server, and an execution subject is taken as the server for explanation, and the method comprises the following steps:

101. Receiving a request sent by an opposite terminal, and determining the service type of the request;

102. Acquiring a first processing stream;

103. parsing header data in the first processing stream;

104. and writing the parsed header data into a second processing stream, wherein the second processing stream comprises medical image data which is not parsed in the first processing stream, and processing the second processing stream.

In the above step 101, the peer may refer to a client, and the request may be sent by the client to the server in the form of a processing stream. The processing flow may include a data set and a command set generated based on DICOM protocol format specification, where the data set is the first processing flow. The server side can acquire the service type of the opposite side request according to the command set so as to provide corresponding processing, such as subsequent analysis processing. The service types can be divided into a plurality of types according to actual requirements, and can be query service, storage service, acquisition service, sending service or deleting service, etc., which is not particularly limited in the embodiment of the present invention.

The client and server may establish a network connection prior to step 101. The manner of establishing the network connection with the opposite terminal is not particularly limited in the embodiment of the present invention, including but not limited to: receiving a network connection establishment request sent by an opposite terminal; determining the service type of the opposite terminal request according to the network connection establishment request; judging whether the local supports the service type, if so, returning a determination message to the opposite terminal, and establishing network connection with the opposite terminal. If the server side does not support the service type requested by the opposite side locally, a rejection message is returned to the opposite side, so that network communication connection is not established with the opposite side. The server side can be configured with different running environments in advance to support different service types.

In step 102, the first processing stream may be sent by the opposite end, that is, the client end, where the first processing stream includes medical image data. In step 103, header data in the first processing stream may be parsed based on DICOM protocol format specifications. Wherein the header data is distinguished from the unresolved medical image data in the first processing stream based on the end identifier, such that the header data in the first processing stream may be resolved based on the end identifier. Specifically, (7 fe0, 0010) may be used as the end mark, the data before the end mark may be used as the header data, and the data after the end mark may be used as the medical image data. In the actual implementation process, the parsing can be started from the starting position of the first processing flow until the parsing reaches the ending mark, and the parsed header data can be stored in the memory. In addition, header data is typically 12 bytes and mainly includes file meta-information, i.e., file meta-tag. The file metadata defines the transmission grammar and can record the length of the medical image data in the DICOM file.

In step 104, the type of the second processing flow and the processing manner of the second processing flow correspond to the requested service type. And writing the header data obtained by the analysis in the step 103 into the second processing flow by the memory. Meanwhile, in order to enable the second processing stream to include the unresolved medical image data in the first processing stream, the unresolved medical image data may also be written into the second processing stream. As for the data source of the unresolved medical image data in the second processing stream, the data source may be derived from the first processing stream or may be derived locally, which is not particularly limited in the embodiment of the present invention.

The method provided by the embodiment of the invention determines the service type of the request by receiving the request sent by the opposite terminal. And acquiring the first processing stream, and analyzing the head data in the first processing stream. And writing the parsed header data into a second processing stream, and processing the second processing stream. Because only partial data of non-medical image data in the first processing flow, namely header data, is needed to be resolved to the memory, and medical image data is not needed to be resolved to the memory, but can be directly written into the second processing flow to be processed, all data can be prevented from being resolved to the memory in the processing process of the DICOM file, and therefore the memory can be maintained to be used stably, and the usability of the memory is improved. In addition, the method can ensure that the DICOM file is not limited by the size of the DICOM file when being processed, and does not need to additionally improve hardware configuration for a large-volume DICOM file, thereby expanding the application range and saving the hardware cost.

In combination with the content of the above embodiments, in one embodiment, the service type is a storage service; correspondingly, the first processing flow is a network flow sent by the opposite end, and the second processing flow is a local file flow.

The application scenario corresponding to the storage service is mainly that the client sends the DICOM file to the server, and the server receives and stores the DICOM file. Specifically, the DICOM file may be sent by a client supporting the DICOM protocol to a server via a C-Store send. At this time, the first processing flow refers to a network flow transmitted by the client to the server. The network flow may specifically refer to a socket network flow, and the embodiment of the present invention does not specifically limit a transport protocol used by the network flow. The second processing stream is a local file stream, and local disk dropping of the DICOM file can be realized through the local file stream.

For ease of understanding, in connection with the content of the above embodiments, the implementation of the storage service will now be explained with reference to fig. 2:

(1) The client sends a network connection establishment request a-SSOCIATE-RQ to the server, and the server selectively returns a determination message a-SSOCIATE-AC only if the server can support a plurality of service types requested by the request. At this time, a network connection is established between the server and the client. If the type of service requested by the client is not supported by the server, the server returns a rejection message A-SSOCIATE-RJ.

(2) The client receives the A-SSOCIATE-AC returned by the server, namely, the client and the server are indicated to establish network connection. At this time, the client may send a processing flow P-DATA-TF (RQ) to the server, where the P-DATA-TF (RQ) carries the command set and the DATA set. The P-DATA-TF (RQ) may be specifically a socket network flow, and the server may monitor through a socket port to receive the socket network flow. It should be noted that the socket network flow may be formed by combining data of a Segment, that is, segments each having a maximum length limitation. The socket network stream may be a command set part first and a data set part second. The first Segment may be a command set and a partial data set, and subsequently received segments may be data sets.

It should be further noted that, when the client sends the processing flow P-DATA-TF (RQ) to the server, the processing flow P-DATA-TF may be sent according to a column storage database instruction, and the column storage database may be specifically referred to as a C-Store, which is not limited in this embodiment of the present invention. Wherein the C-Store is a relational database designed for quick query, and for faster query performance, the C-Store stores data in columns, and different columns in the same table may be stored in different and possibly overlapping projects. Where project refers to a collection of data storage columns.

(3) After receiving the P-DATA-TF (RQ), the server may first parse the command set therein to determine the service type requested by the client, so as to process the DATA set, i.e. the first processing flow, subsequently accessed in the P-DATA-TF by using the specific service. In the related art, the processing manner is to write all the received data sets into the memory, which results in excessive consumption of memory resources. Or the data is directly written into the local cache, and then is taken out from the cache for subsequent use, so that I/O (Input/Ouput, input/output) operation is increased sharply, and the system processing performance is reduced.

In order to avoid the two situations, the characteristics of the constituent parts of each data element in the data set of the DICOM file are analyzed mainly based on the specifications of the DICOM standard for the DICOM file format, so that the memory and cache processing are performed on the medical image data describing the information of the image part, namely, the memory and the cache are bypassed, and a pipeline connection is directly established with a real destination, thereby realizing the rapid and efficient processing of the medical image data.

(4) The server acquires a DATA set in the P-DATA-TF (RQ), namely a DATA part (first processing flow) in the socket network flow, and analyzes header DATA in the first processing flow. It should be noted that, in the embodiment of the present invention, the server side actually provides a storage service. In the actual implementation process, the server side can monitor the acquired network data, namely the socket network flow, so as to dynamically acquire the required data. For example, the dynamic acquisition method may be used to acquire the command set and the first processing flow. Because the acquisition of network data is also an I/O operation in practice, both blocking I/O mechanisms and non-blocking I/O mechanisms can be utilized to acquire network data, and synchronous I/O mechanisms and asynchronous I/O mechanisms can also be utilized to acquire network data.

The two concepts of blocking I/O and non-blocking I/O described above are at the program level and are primarily used to describe how a program should handle the problem of requesting operating system I/O operations if the I/O resources are not ready. Specifically, if the I/O resources are not ready, the blocking I/O mechanism will wait, while the non-blocking I/O mechanism will continue to execute, i.e., thread one straight poll will be used, until there are I/O resources ready.

The two concepts of synchronous I/O and asynchronous I/O described above are at the operating system level, and mainly describe how an operating system responds to a program problem after receiving a program request I/O operation if the I/O resource is not ready. Specifically, if the I/O resources are not ready, the synchronous I/O may not respond until the I/O resources are ready. And asynchronous I/O will return a flag to flag the return target of the event after the event trigger for which the subsequent I/O resource is ready. Through the different I/O mechanisms, the server side may parse the first processing stream in segments. Specifically, only header data in the first processing stream is parsed, the header data is typically 12 bytes and does not exceed 16Kb. Thus, the header data may be truncated from the first processing stream by the end identifier mentioned in the above embodiment, and the parsed header data may be recorded and saved.

(5) The server side writes the parsed header data into the second processing stream, i.e., into the file stream local to the server side. Meanwhile, the unresolved medical image data in the first processing stream can also be written into the second processing stream. Finally, the DICOM file may be locally dropped via the second processing stream. So far, the storage service provided by the server end is ended. It should be noted that after this, the server side may optionally return a P-DATA-TF (RSP) to the client to indicate that the storage service is finished in response. The client, upon receiving the P-DATA-TF (RSP), may send a RELEASE network connection request a-RELEASE-RQ to the server. After receiving the a-RELEASE-RQ, the server may return the a-RELEASE-RP to the terminal to indicate that the network connection between the client and the RELEASE is determined.

The above is a specific process when the service type is a storage service, and the brief process may also refer to the following fig. 3, which specifically includes:

(1) Receiving a Socket network stream by a C-Store SCP;

(2) Analyzing a command set in a Socket network stream;

(3) Analyzing a data set in the Socket network flow by taking the tail mark as a demarcation point;

(4) Recording 12 bytes of information of the header data;

(5) And writing the parsed header data and the unresolved medical image data in the Socket network stream into a second processing stream.

According to the method provided by the embodiment of the invention, all received data sets are not required to be written into the memory, so that excessive consumption of memory resources can be avoided. Meanwhile, all received data sets are not required to be written into the local cache and then are taken out of the local cache, so that the problem that the processing performance of the system is reduced due to the fact that I/O operation is increased sharply can be avoided.

In combination with the above embodiments, in one embodiment, the header data includes a recording length of unresolved medical image data; accordingly, before processing the second processing stream, the method further includes: determining the actual length of unresolved medical image data; if the recording length is consistent with the actual length, the unresolved medical image data is acquired from the first processing stream, and the unresolved medical image data is written into the second processing stream.

As can be seen from the foregoing embodiments, the header data and the medical image data in the first processing stream are mainly distinguished by the end identifier. In the embodiment of the invention, statistics can be started from the end mark until the end bit of the medical image data in the first processing flow, so that the actual length of the unresolved medical image data can be determined. The ending bit of the medical image data in the first processing stream may be a preset ending identifier, such as a preset character or a preset fixed byte bit, which is not particularly limited in the embodiment of the present invention.

In the case that the service type is a storage service, the data source of the unresolved medical image data is a first processing flow, so that the unresolved medical image data needs to be acquired from the first processing flow. Therefore, in the above-mentioned process, the recording length may be compared with the actual length, and if the recording length and the actual length are inconsistent, the unresolved medical image data cannot be obtained from the first processing stream. At this point, a resend message may be returned to the client to cause the client to resend the first processing stream. If the two are consistent, the unresolved medical image data can be obtained from the first processing flow, and the unresolved medical image data is written into the second processing flow without passing through a memory or a local cache.

According to the method provided by the embodiment of the invention, the unresolved medical image data is obtained from the first processing flow by determining the actual length of the unresolved medical image data, and if the recorded length is consistent with the actual length, the unresolved medical image data is written into the second processing flow. The judgment result of whether the actual length of the medical image data is consistent with the recording length can be used for indicating whether the medical image data is wrong, so that the wrong medical image data can be prevented from being written into the second processing flow through the judgment process, and the data accuracy in the subsequent local disc dropping process is further ensured.

In combination with the foregoing embodiments, in one embodiment, the service type is a forwarding service; accordingly, the first processing flow is a network flow sent by the opposite end, and the second processing flow is a network flow forwarded outside.

The application scenario corresponding to the forwarding service is mainly that the client sends the DICOM file to the server, and the server receives the DICOM file and forwards the DICOM file to other clients or other server. Specifically, the DICOM file may be sent by a client supporting the DICOM protocol to a server via a C-Store send. At this time, the first processing flow refers to a network flow transmitted by the client to the server. The network flow may also specifically refer to a socket network flow, and the embodiment of the present invention does not specifically limit a transport protocol used by the network flow. The second processing flow is a network flow forwarded by the server end to the outside, and the DICOM file can be forwarded to other clients or the server end through the network flow forwarded to the outside.

In combination with the foregoing embodiment, in one embodiment, before the second processing stream is processed, the method further includes: if the same data content as the unresolved medical image data is stored locally, writing the locally stored medical image data into the second processing flow, and if the same data content as the unresolved medical image data is not stored locally, acquiring the unresolved medical image data from the first processing flow, and writing the unresolved medical image data into the second processing flow.

In the above embodiments, the service type in the embodiments of the present invention is forwarding service, that is, the client sends the DICOM file to a certain server, and the server forwards the DICOM file to other clients or servers. After the client sends the DICOM file to a certain server, the server may not store the DICOM file in advance, or may already store the DICOM file. Thus, there are different processes in embodiments of the present invention for different situations. When judging whether the data content which is the same as the unresolved medical image data is stored locally, the judgment can be performed according to the parsed header data. Specifically, the parsed header data stores identification data, such as tag data, for uniquely corresponding to medical image data, including data of image width, height, data transmission format, patient name, patient birthday, medical record hospital, medical record department, description of illness state, and the like. For a certain medical image data, if it is required to determine whether the medical image data is stored locally, searching whether the medical image data tag data is stored locally. If so, it is indicated that the medical image data is stored locally. If not, it is indicated that the medical image data is not stored locally.

For ease of understanding, in connection with the content of the above embodiments, the implementation procedure of the forwarding service will be explained with reference to fig. 2:

(2) The client receives the A-SSOCIATE-AC returned by the server, namely, the client and the server are indicated to establish network connection. At this time, the client may send a processing flow P-DATA-TF (RQ) to the server, where the P-DATA-TF (RQ) carries the command set and the DATA set. The P-DATA-TF (RQ) may be specifically a socket network flow, and the server may monitor through a socket port to receive the socket network flow. It should be noted that the socket network flow may be formed by combining data of a Segment, that is, segments each having a maximum length limitation. The socket network stream may be a command set part first and a data set part second. The first Segment may be a real command set and a partial data set, and subsequently received segments may be data sets.

It should be further noted that, when the client sends the processing flow P-DATA-TF (RQ) to the server, the processing flow P-DATA-TF may be sent according to a C-Store instruction, which is not limited in particular by the embodiment of the present invention. Wherein the C-Store is a relational database designed for quick query, and for faster query performance, the C-Store stores data in columns, and different columns in the same table may be stored in different and possibly overlapping projects.

(3) After receiving the P-DATA-TF (RQ), the server may first parse the command set therein to determine the service type requested by the client, so as to process the DATA set, i.e. the first processing flow, subsequently accessed in the P-DATA-TF by using the specific service. In the related art, the processing manner is to write all the received data sets into the memory, which results in excessive consumption of memory resources. Or the data is directly written into the local cache, and then is taken out from the cache for subsequent use, so that I/O operation is increased sharply, and the processing performance of the system is reduced.

(4) The DATA set in the P-DATA-TF (RQ), i.e. the DATA part in the socket network flow, is the first processing flow. The unresolved medical image data in the first processing stream may or may not be stored at the server. Therefore, the server side can determine whether the medical image data with the same content as the unresolved medical image data is stored locally according to the parsed header data.

The medical image data may be verified by a verification code, and each medical image data may correspond to a unique verification code. Based on this, the embodiment of the present invention does not specifically limit the manner of determining whether to locally store medical image data having the same content as that of unresolved medical image data according to the parsed header data, including but not limited to: acquiring a check code corresponding to unresolved medical image data; comparing the check code with a check code corresponding to the locally stored medical image data; if the same check code exists, the medical image data which are the same as the unresolved medical image data are determined to be stored locally, and if the same check code does not exist, the medical image data which are the same as the unresolved medical image data are determined to be not stored locally.

(5) If the server determines that the local stored medical image data is the same as the unresolved medical image data, writing the parsed header data into a second processing stream, namely writing the parsed header data into a network stream forwarded from outside, and simultaneously writing the local stored medical image data which is the same as the unresolved medical image data into the second processing stream. If the server determines that the medical image data identical to the unresolved medical image data is not stored locally, writing the parsed header data into a second processing stream, that is, writing the parsed header data into a network stream forwarded from outside, and simultaneously writing the unresolved medical image data in the first processing stream into the second processing stream. After this, the external forwarding of the DICOM file may be achieved through the second processing flow.

So far, the storage service provided by the server end is ended. It should be noted that after this, the server side may optionally return a P-DATA-TF (RSP) to the client to indicate that the storage service is finished in response. The client, upon receiving the P-DATA-TF (RSP), may send a RELEASE network connection request a-RELEASE-RQ to the server. After receiving the a-RELEASE-RQ, the server may return the a-RELEASE-RP to the terminal to indicate that the network connection between the client and the RELEASE is determined.

It should be noted that the above procedure merely indicates that the data transmission between the client and the server ends. The server needs to forward the DICOM file to other clients or other server, so that the server needs to establish a network connection with the destination, and the specific process may refer to the data transmission process between the client and the server, which is not described herein.

The above is a specific process when the service type is forwarding service, taking as an example that the server side locally stores the same medical image data as the unresolved medical image data, and the brief process may refer to the following fig. 4, which specifically includes:

(1) Establishing a DICOM file stream; it should be noted that, since the server end locally stores the same medical image data as the unresolved medical image data, in order to write the medical image data into the second processing stream, a DICOM file stream of the medical image data needs to be established first;

(2) Analyzing file meta-information of the DICOM file stream; it should be noted that, since the network flow is no longer present, the file element is no longer present in the header data.

(3) Writing the unresolved medical image data in the parsed file meta-information and DICOM file stream into a second processing stream; it should be noted that the second processing flow may be a Socket network flow sent to the outside.

(4) The second processing stream is outgoing.

According to the method provided by the embodiment of the invention, all received data sets are not required to be written into the memory, so that excessive consumption of memory resources can be avoided. Meanwhile, all received data sets are not required to be written into the local cache and then are taken out of the local cache, so that the problem that the processing performance of the system is reduced due to the fact that I/O operation is increased sharply can be avoided. In addition, the data source when the medical image data is written into the second processing flow can be selected according to whether the medical image data to be forwarded is stored in the server side serving as the forwarding transfer, so that the fault tolerance rate when the data is forwarded can be improved.

In combination with the above embodiments, in one embodiment, the header data includes a recording length of unresolved medical image data; accordingly, obtaining unresolved medical image data from the first processing stream comprises: determining the actual length of unresolved medical image data; if the recording length is consistent with the actual length, the unresolved medical image data is acquired from the first processing stream.

In the case that the service type is a forwarding service, the data source of the unresolved medical image data is a first processing stream or a local file stream. When the data source does not have the first processing flow, unresolved medical image data needs to be acquired from the first processing flow. Therefore, in the above-mentioned process, the recording length may be compared with the actual length, and if the recording length and the actual length are inconsistent, the unresolved medical image data cannot be obtained from the first processing stream. At this point, a resend message may be returned to the client to cause the client to resend the first processing stream. If the two are consistent, the unresolved medical image data can be obtained from the first processing flow, and the unresolved medical image data is written into the second processing flow without passing through a memory or a local cache.

According to the method provided by the embodiment of the invention, the unresolved medical image data is obtained from the first processing flow by determining the actual length of the unresolved medical image data, and if the recorded length is consistent with the actual length, the unresolved medical image data is written into the second processing flow. The judgment result of whether the actual length of the medical image data is consistent with the recorded length can be used for indicating whether the medical image data is wrong, so that the wrong medical image data can be prevented from being written into the second processing flow through the judgment process, and the data accuracy during the subsequent processing of the second processing flow is further ensured.

In combination with the foregoing embodiments, in one embodiment, regarding the manner in which the second processing stream is processed, embodiments of the present invention are not particularly limited thereto, including, but not limited to: and sending the second processing flow outwards according to the column storage database instruction.

Wherein the column Store database may be a C-Store. In addition, the storage service and the forwarding service can be executed concurrently between different clients and servers, so that in the embodiment of the invention, the concurrency of the C-Store instruction can be continuously improved, and further DICOM files can be rapidly transmitted under the DICOM protocol. At the same time, in combination with the process in the above embodiment, the whole service system composed of the client and the server can achieve higher throughput.

According to the method provided by the embodiment of the invention, the C-Store database is used for storing the DICOM file, and the lengths of the columns of the C-Store database are fixed, so that memory alignment is not considered in database implementation, the situation that the memory is required to be accessed twice for processing data once because the data cross the boundary is avoided, and the data elements can be encoded into the most effective form without being limited by the size of the DICOM file.

It should be understood that, although the steps in the flowcharts of fig. 1 to 4 are sequentially shown as indicated by arrows, these steps are not necessarily sequentially performed in the order indicated by the arrows. The steps are not strictly limited to the order of execution unless explicitly recited herein, and the steps may be executed in other orders. Moreover, at least a portion of the steps of fig. 1-4 may include steps or stages that are not necessarily performed at the same time, but may be performed at different times, nor does the order in which the steps or stages are performed necessarily occur sequentially, but may be performed alternately or alternately with other steps or at least a portion of the steps or stages in other steps.

It should be noted that, in the actual implementation process, the technical solutions described above may be implemented as independent embodiments, or may be implemented as combined embodiments by combining them. In addition, in describing the foregoing embodiments of the present invention, the different embodiments are described in a corresponding order, such as in a data flow direction order, based on a concept that is merely convenient for describing the embodiments, and not limiting the execution order between the different embodiments. Accordingly, in an actual implementation, if multiple embodiments provided by the present invention are required to be implemented, the execution sequence provided when the embodiments are set forth according to the present invention is not necessarily required, but the execution sequence between different embodiments may be arranged according to the requirement.

In combination with the foregoing embodiments, in one embodiment, as shown in fig. 5, there is provided a DICOM file processing apparatus, including: a receiving module 501, an obtaining module 502, a parsing module 503, a first writing module 504 and a processing module 505, wherein:

A receiving module 501, configured to receive a request sent by an opposite end, and determine a service type of the request;

a first obtaining module 502, configured to obtain a first processing flow;

a parsing module 503, configured to parse header data in the first processing stream;

A first writing module 504, configured to write the parsed header data into a second processing stream, where the second processing stream includes medical image data that is not parsed in the first processing stream;

A processing module 505, configured to process the second processing flow.

In one embodiment, the header data includes a record length of unresolved medical image data; correspondingly, the device further comprises:

The first determining module is used for determining the actual length of unresolved medical image data;

And the second writing module is used for acquiring unresolved medical image data from the first processing flow when the recording length is consistent with the actual length, and writing the unresolved medical image data into the second processing flow.

In one embodiment, the apparatus further comprises:

and the third writing module is used for writing the locally stored medical image data into the second processing flow when the data content which is the same as that of the unresolved medical image data is stored locally, acquiring the unresolved medical image data from the first processing flow if the data content which is the same as that of the unresolved medical image data is not stored locally, and writing the unresolved medical image data into the second processing flow.

In one embodiment, the header data includes a record length of unresolved medical image data; correspondingly, the second acquisition module is used for determining the actual length of unresolved medical image data; if the recording length is consistent with the actual length, the unresolved medical image data is acquired from the first processing stream.

In one embodiment, the processing module 505 is configured to send the second processing stream to the outside according to the column store database instruction.

The device provided by the embodiment of the invention determines the service type of the request by receiving the request sent by the opposite terminal. And acquiring the first processing stream, and analyzing the head data in the first processing stream. And writing the parsed header data into a second processing stream, and processing the second processing stream. Because only partial data of non-medical image data in the first processing flow, namely header data, is needed to be resolved to the memory, and medical image data is not needed to be resolved to the memory, but can be directly written into the second processing flow to be processed, all data can be prevented from being resolved to the memory in the processing process of the DICOM file, and therefore the memory can be maintained to be used stably, and the usability of the memory is improved. In addition, the method can ensure that the DICOM file is not limited by the size of the DICOM file when being processed, and does not need to additionally improve hardware configuration for a large-volume DICOM file, thereby expanding the application range and saving the hardware cost.

For specific limitations of the DICOM file processing device, reference may be made to the above limitation of the DICOM file processing method, and the description thereof will not be repeated here. The modules in the DICOM file processing device may be implemented in whole or in part by software, hardware, or a combination thereof. The above modules may be embedded in hardware or may be independent of a processor in the computer device, or may be stored in software in a memory in the computer device, so that the processor may call and execute operations corresponding to the above modules.

In one embodiment, a computer device is provided, which may be a server, the internal structure of which may be as shown in fig. 6. The computer device includes a processor, a memory, and a network interface connected by a system bus. Wherein the processor of the computer device is configured to provide computing and control capabilities. The memory of the computer device includes a non-volatile storage medium and an internal memory. The non-volatile storage medium stores an operating system, computer programs, and a database. The internal memory provides an environment for the operation of the operating system and computer programs in the non-volatile storage media. The database of the computer device is used to store a preset threshold. The network interface of the computer device is used for communicating with an external terminal through a network connection. The computer program when executed by a processor implements a DICOM file processing method.

It will be appreciated by those skilled in the art that the structure shown in FIG. 6 is merely a block diagram of some of the structures associated with the present inventive arrangements and is not limiting of the computer device to which the present inventive arrangements may be applied, and that a particular computer device may include more or fewer components than shown, or may combine some of the components, or have a different arrangement of components.

In one embodiment, a computer device is provided comprising a memory and a processor, the memory having stored therein a computer program, the processor when executing the computer program performing the steps of:

acquiring a first processing stream;

Parsing header data in the first processing stream;

In one embodiment, the processor, when executing the computer program, is of the storage service type; correspondingly, the first processing flow is a network flow sent by the opposite end, and the second processing flow is a local file flow.

In one embodiment, the header data includes a record length of unresolved medical image data; accordingly, the processor when executing the computer program also performs the steps of: determining the actual length of unresolved medical image data; if the recording length is consistent with the actual length, the unresolved medical image data is acquired from the first processing stream, and the unresolved medical image data is written into the second processing stream.

In one embodiment, the processor, when executing the computer program, is of the forwarding service type; accordingly, the first processing flow is a network flow sent by the opposite end, and the second processing flow is a network flow forwarded outside.

In one embodiment, the processor when executing the computer program further performs the steps of: if the same data content as the unresolved medical image data is stored locally, writing the locally stored medical image data into the second processing flow, and if the same data content as the unresolved medical image data is not stored locally, acquiring the unresolved medical image data from the first processing flow, and writing the unresolved medical image data into the second processing flow.

In one embodiment, the header data includes a record length of unresolved medical image data; accordingly, the processor when executing the computer program also performs the steps of: determining the actual length of unresolved medical image data; if the recording length is consistent with the actual length, the unresolved medical image data is acquired from the first processing stream.

In one embodiment, the processor when executing the computer program further performs the steps of: and sending the second processing flow outwards according to the column storage database instruction.

In one embodiment, a computer readable storage medium is provided having a computer program stored thereon, which when executed by a processor, performs the steps of:

acquiring a first processing stream;

Parsing header data in the first processing stream;

In one embodiment, the type of service is a storage service when the computer program is executed by the processor; correspondingly, the first processing flow is a network flow sent by the opposite end, and the second processing flow is a local file flow.

In one embodiment, the header data includes a record length of unresolved medical image data; accordingly, the computer program when executed by the processor also performs the steps of: determining the actual length of unresolved medical image data; if the recording length is consistent with the actual length, the unresolved medical image data is acquired from the first processing stream, and the unresolved medical image data is written into the second processing stream.

In one embodiment, the type of service is a forwarding service when the computer program is executed by the processor; accordingly, the first processing flow is a network flow sent by the opposite end, and the second processing flow is a network flow forwarded outside.

In one embodiment, the computer program when executed by the processor further performs the steps of:

In one embodiment, the header data includes a record length of unresolved medical image data; accordingly, the computer program when executed by the processor also performs the steps of:

Determining the actual length of unresolved medical image data;

In one embodiment, the computer program when executed by the processor further performs the steps of: and sending the second processing flow outwards according to the column storage database instruction.

Those skilled in the art will appreciate that implementing all or part of the above described methods may be accomplished by way of a computer program stored on a non-transitory computer readable storage medium, which when executed, may comprise the steps of the embodiments of the methods described above. Any reference to memory, storage, database, or other medium used in embodiments provided herein may include at least one of non-volatile and volatile memory. The nonvolatile Memory may include Read-Only Memory (ROM), magnetic tape, floppy disk, flash Memory, optical Memory, or the like. Volatile memory can include random access memory (Random Access Memory, RAM) or external cache memory. By way of illustration, and not limitation, RAM can be in various forms such as static random access memory (Static Random Access Memory, SRAM) or dynamic random access memory (Dynamic Random Access Memory, DRAM), etc.

The technical features of the above embodiments may be arbitrarily combined, and all possible combinations of the technical features in the above embodiments are not described for brevity of description, however, as long as there is no contradiction between the combinations of the technical features, they should be considered as the scope of the description.

The above examples illustrate only a few embodiments of the application, which are described in detail and are not to be construed as limiting the scope of the application. It should be noted that it will be apparent to those skilled in the art that several variations and modifications can be made without departing from the spirit of the application, which are all within the scope of the application. Accordingly, the scope of protection of the present application is to be determined by the appended claims.

Claims

1. A DICOM file processing method, the method comprising:

acquiring a first processing stream;

analyzing the header data in the first processing flow to a memory;

Writing the parsed header data into a second processing stream from the memory, wherein the second processing stream comprises medical image data which is not parsed in the first processing stream, and processing the second processing stream corresponding to the service type;

The unresolved medical image data in the second processing flow is acquired from the first processing flow or from medical image data stored locally;

before processing the second processing stream, the method further comprises:

if the data content which is the same as the unresolved medical image data is stored locally, writing the locally stored medical image data into the second processing flow, and if the data content which is the same as the unresolved medical image data is not stored locally, acquiring the unresolved medical image data from the first processing flow, and writing the unresolved medical image data into the second processing flow.

2. The method of claim 1, wherein the service type is a storage service; correspondingly, the first processing flow is a network flow sent by the opposite end, and the second processing flow is the local file flow.

3. The method of claim 2, wherein the header data includes a recording length of the unresolved medical image data; accordingly, before the second processing flow is processed, the method further includes:

Determining an actual length of the unresolved medical image data;

And if the recording length is consistent with the actual length, acquiring the unresolved medical image data from the first processing stream, and writing the unresolved medical image data into the second processing stream.

4. The method of claim 1, wherein the service type is a forwarding service; correspondingly, the first processing flow is a network flow sent by the opposite end, and the second processing flow is a network flow forwarded outside.

5. The method of any one of claims 1-4, wherein the header data includes a recording length of the unresolved medical image data; accordingly, the obtaining the unresolved medical image data from the first processing stream includes:

Determining an actual length of the unresolved medical image data;

And if the recording length is consistent with the actual length, acquiring the unresolved medical image data from the first processing stream.

6. The method of claim 4, wherein said processing said second processing stream comprises:

and sending the second processing flow to the outside according to the column storage database instruction.

7. A DICOM file processing device, the device comprising:

The first acquisition module is used for acquiring a first processing flow;

The analyzing module is used for analyzing the head data in the first processing flow to the memory;

The first writing module is used for writing the parsed header data from the memory into a second processing stream, and the second processing stream contains medical image data which is not parsed in the first processing stream;

the processing module is used for processing the second processing flow corresponding to the service type;

The device is further configured to write the locally stored medical image data into the second processing stream if the same data content as the unresolved medical image data is already stored locally before processing the second processing stream, acquire the unresolved medical image data from the first processing stream if the same data content as the unresolved medical image data is not already stored locally, and write the unresolved medical image data into the second processing stream.

8. A computer device comprising a memory and a processor, the memory storing a computer program, characterized in that the processor implements the steps of the method of any of claims 1 to 6 when the computer program is executed.

9. A computer readable storage medium, on which a computer program is stored, characterized in that the computer program, when being executed by a processor, implements the steps of the method of any of claims 1 to 6.