数据传输接口装置和数据传输方法.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号(10)申请公布号CNCN103945013103945013A(43)申请公布日2014.07.23(21)申请号201310018321.X(22)申请日2013.01.17(71)申请人方正宽带网络服务股份有限公司地址100088北京市海淀区学院南路15号院北发大厦B座5层(72)发明人吴雨果聂志李晓阳朱庆昌(74)专利代理机构北京友联知识产权代理事务所(普通合伙)11343代理人尚志峰汪海屏(51)Int.Cl.H04L29/10(2006.01)H04L29/08(2006.01)G06F17/30(2006.01)权权利要求书2页利要求书2页说明书7页说明书7页附图5页附图5页(54)发明名称数据传输接口装置和数据传输方法(57)摘要本发明提供了一种数据传输接口装置，所述数据传输接口装置连接在缓存系统和数据库之间，包括：数据接收单元，用于接收来自所述缓存系统的消息数据；数据解析单元，用于对所述消息数据进行解析，以获取消息内容；数据写入单元，用于将所述消息内容写入所述数据库。本发明还提出了一种数据传输方法。通过本发明的技术方案，可以通过独立的数据传输接口实现缓存数据向数据库的写入，避免数据写入速度对缓存系统造成性能限制。CN103945013ACN103945ACN103945013A权利要求书1/2页1.一种数据传输接口装置，其特征在于，所述数据传输接口装置连接在缓存系统和数据库之间，包括：数据接收单元，用于接收来自所述缓存系统的消息数据；数据解析单元，用于对所述消息数据进行解析，以获取消息内容；数据写入单元，用于将所述消息内容写入所述数据库。2.根据权利要求1所述的数据传输接口装置，其特征在于，所述数据接收单元采用进程间通信的方式接收所述消息数据。3.根据权利要求1或2所述的数据传输接口装置，其特征在于，所述数据接收单元还建立消息队列，并将接收到的所述消息数据加入所述消息队列中，以由所述数据解析单元从所述消息队列中获取所述消息数据。4.根据权利要求1或2所述的数据传输接口装置，其特征在于，还包括：数据暂存单元，用于将所述消息内容存储至临时表中，以由所述数据写入单元按照预设时间间隔将所述临时表中指定位置的消息内容写入所述数据库。5.根据权利要求4所述的数据传输接口装置，其特征在于，所述临时表包含多个节点，则所述数据暂存单元包括：节点确定子单元，用于在所述多个节点中确定每条消息内容的当前插入节点；数据插入子单元，用于将所述消息内容存储至所述当前插入节点；以及所述数据写入单元将所述多个节点中的头节点内的消息内容写入所述数据库，并依次将其余节点的位置前移以填充所述头节点。6.根据权利要求5所述的数据传输接口装置，其特征在于，还包括：数量记录单元，用于在所述数据写入单元将所述消息内容写入所述数据库前后，分别记录所述临时表中的节点总数；以及时间间隔调整单元，用于根据前后记录的节点总数之差，调整所述时间间隔的大小。7.根据权利要求4所述的数据传输接口装置，其特征在于，还包括：数据转换单元，用于将所述消息内容转换为符合所述数据库的存储特性的数据结构，以由所述数据暂存单元将转换后的数据结构存储至所述临时表中。8.一种数据传输方法，其特征在于，包括：步骤202，接收来自缓存系统的消息数据；步骤204，对所述消息数据进行解析，以获取消息内容；步骤206，将所述消息内容写入数据库。9.根据权利要求8所述的数据传输方法，其特征在于，所述步骤202包括：采用进程间通信的方式接收所述消息数据。10.根据权利要求8或9所述的数据传输方法，其特征在于，所述步骤202还包括：建立消息队列，将所述消息数据加入所述消息队列中；以及所述步骤204还包括：从所述消息队列中获取所述消息数据，以供解析出所述消息内容。11.根据权利要求8或9所述的数据传输方法，其特征在于，所述步骤204之后，还包括：将所述消息内容存储至临时表中；以及2CN103945013A权利要求书2/2页所述步骤206包括：按照预设时间间隔将所述临时表中指定位置的消息内容写入所述数据库。12.根据权利要求11所述的数据传输方法，其特征在于，所述临时表包含多个节点，则所述将所述消息内容存储至临时表中的步骤包括：在所述多个节点中确定每条消息内容的当前插入节点，并将所述消息内容存储至所述当前插入节点；以及在所述步骤206中，将所述多个节点中的头节点内的消息内容写入所述数据库，并依次将其余节点的位置前移以填充所述头节点。13.根据权利要求12所述的数据传输方法，其特征在于，还包括：在所述步骤206前后，分别记录所述临时表中的节点总数，并根据前后记录的节点总数之差，调整所述时间间隔的大小。14.根据权利要求11所述的数据传输方