消息处理的方法和装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113778321A(43)申请公布日2021.12.10(21)申请号202110054031.5G06F9/54(2006.01)(22)申请日2021.01.15(71)申请人北京沃东天骏信息技术有限公司地址100176北京市北京经济技术开发区科创十一街18号院2号楼4层A402室申请人北京京东世纪贸易有限公司(72)发明人戴旭檀兵(74)专利代理机构中原信达知识产权代理有限责任公司11219代理人王志远王安娜(51)Int.Cl.G06F3/06(2006.01)G06F16/242(2019.01)G06F16/23(2019.01)G06F16/248(2019.01)权利要求书2页说明书10页附图8页(54)发明名称消息处理的方法和装置(57)摘要本发明公开了消息处理的方法和装置，涉及计算机技术领域。该方法的一具体实施方式包括：接收从服务端发送的消息；对消息进行一次查重，确认消息是否处于等待处理或正在处理的状态；在消息未处于等待处理或正在处理的状态时，基于消息到达的顺序将消息并入消息队列，并对消息队列中的消息按顺序进行处理；以及将完成处理的消息显示于显示页面。该实施方式降低高并发消息处理的系统开销，提升高并发消息处理的效率，同时降低即时通讯在高并发消息处理中的崩溃问题。CN113778321ACN113778321A权利要求书1/2页1.一种消息处理的方法，其特征在于，包括：接收服务端发送的消息；对所述消息进行一次查重，确认该消息是否处于等待处理或正在处理的状态；在所述消息未处于等待处理或正在处理的状态时，基于所述消息到达的顺序将所述消息并入消息队列，并对消息队列中的消息按所述顺序进行处理；以及将完成处理的消息显示于显示页面。2.根据权利要求1所述的消息处理的方法，其特征在于，在将所述完成处理的消息显示于所述显示页面之前，进行存储，并且所述存储包括将所述完成处理的消息先后存储于内存缓存和数据库中。3.根据权利要求2所述的消息处理的方法，其特征在于，在对所述消息队列中的消息进行处理之前，进行二次查重，确认该消息是否已经存储在所述内存缓存中；在所述消息未存储在所述内存缓存中时，进行三次查重，确认所述消息是否已经存储在所述数据库中；并且在所述消息未存储在所述数据库中时，对该消息进行处理。4.根据权利要求2所述的消息处理的方法，其特征在于，所述数据库为SQLite，且将SQLite的写入模式设定为WAL模式。5.根据权利要求2所述的消息处理的方法，其特征在于，在将所述完成处理的消息显示于所述显示页面之前，提取目标消息，在所述内存缓存中查询所述目标消息，在查询到该目标消息时，将该目标消息显示在所述显示页面上；在所述内存缓存中没有找到所述目标消息时，进一步在所述数据库中进行查询，并将查询到的所述目标消息显示在所述显示页面上。6.根据权利要求1所述的消息处理的方法，其特征在于，将所述完成处理的消息发送至所述显示页面的显示队列，并根据所述完成处理的消息到达所述显示队列的时间点距离上一次刷新的时间差和预定的刷新阈值进行显示页面刷新操作。7.根据权利要求6所述的消息处理的方法，其特征在于，根据所述时间差和预定的刷新阈值进行显示页面刷新操作包括：在所述时间差大于或等于所述刷新阈值时，直接进行所述显示页面刷新操作；并且在所述时间差小于所述刷新阈值且所述时间差与预定的延迟时长之和大于所述刷新阈值时，在从所述上一次刷新经过所述刷新阈值的时间点进行所述显示页面刷新操作。8.根据权利要求6所述的消息处理的方法，其特征在于，根据所述时间差和预定的刷新阈值进行显示页面刷新操作包括：在所述时间差小于所述刷新阈值且所述时间差与预定的延迟时长之和小于所述刷新阈值时，生成延迟刷新指令并在从所述完成处理的消息到达所述显示队列的时间点起经过预定的延迟时长的时间点进行所述显示页面刷新操作，其中，在进行所述显示页面刷新操作时，取消已经生成的其他延迟刷新指令。9.根据权利要求6至8任一项所述的消息处理的方法，其特征在于，当使用者滑动所述显示页面时，不进行所述显示页面刷新操作。10.根据权利要求1所述的消息处理的方法，其特征在于，对通过所述一次查重确认未2CN113778321A权利要求书2/2页处于等待处理或正在处理的状态的消息增加一个标记，用于后续操作中的检索。11.一种消息处理的装置，其特征在于，包括：接收模块，用于接收从服务端发送的消息；一次查重模块，用于对所述消息进行一次查重，确认该消息是否处于等待处理或正在处理的状态；队列模块，在所述消息未处于等待处理或正在处理的状态上，该队列模块基于所述消息到达所述接收模块的顺序将所述消息并入消息队列，并对消息队列中的消息按所述顺序进行处理；以