一种消息处理方法和系统.pdf
新槐****公主
亲,该文档总共18页,到这已经超出免费预览范围,如果喜欢就直接下载吧~
相关资料
一种消息处理方法和系统.pdf
本发明实施例公开了一种消息处理方法和队列服务器,其中方法包括,队列服务器接收由业务服务器发送的第一请求消息,按照用户等级从高到低的顺序,将所述第一请求消息排序存储于所述队列服务器的存储区域中;所述队列服务器在签章服务器处于空闲状态时,将第二请求消息发送至所述签章服务器,所述第二请求消息为所述存储区域中存储的排序为第一位的请求消息。通过在业务服务器和签章服务器之间增加队列服务器对业务服务器发送的请求消息进行存储,可以避免业务服务器发送的请求消息因得不到响应而导致内存激增,降低了业务服务器宕机的可能性。
一种消息处理装置、方法和消息推送系统.pdf
本发明公开了一种消息处理装置、方法和消息推送系统。该消息处理装置,包括:推送消息提取模块,从缓存中的待处理消息队列中提取推送消息ID;通道轮询模块,基于接入服务器存有的在线通道列表,轮询在线通道;消息推送模块,提取所述推送消息ID对应的消息内容后,推送至所述在线通道,若确保消息处理的可靠性,提高消息消费者的使用体验。
一种消息处理的方法、装置和系统.pdf
本发明公开了一种消息处理的方法、装置和系统,涉及计算机技术领域。该方法的一具体实施方式包括:响应于获取到待处理消息,根据待处理消息所属的分区将待处理消息添加到分区对应的消息队列中,待处理消息具有序号;响应于从消息队列中取出待处理消息,对待处理消息进行处理;响应于待处理消息处理完成,从消息队列中查找可提交的消息的序号中的最大序号,并将最大序号提交给消息系统其中,消息队列中的消息的序号是从队列头部到队列尾部逐步递增的。该实施方式提升了系统进行消息处理的性能,大幅提高了消息处理的并发性,提高了消息处理速度和效率
消息处理方法和处理系统.pdf
本发明实施例提供一种消息处理方法和处理系统,该方法包括:获取处理发生故障的目标队列消息;获取存储频率,且该存储频率小于业务消息队列的消息处理速率;基于存储频率向业务消息队列存储目标队列消息,且业务消息队列同时接收用户发送的新消息;根据业务消息队列中消息的存储顺序进行消息处理。本发明解决了队列消息发生处理故障后新消息积压的技术问题。
一种消息队列的消息处理方法及系统.pdf
本申请实施例公开了一种消息队列的消息处理方法及系统。本申请实施例提供的技术方案,通过在将消息存储至消息队列时,将对应消息的生产时间戳依序存储至预构建的索引文件中;确定当前需要进行消息处理的指定时间段,基于指定时间段查询索引文件的生产时间戳,确定对应的起始时间戳和终止时间戳,起始时间戳和终止时间戳在指定时间段以内;以起始时间戳和终止时间戳作为数据索引查询消息队列,提取对应位置的消息作为目标消息,对目标消息进行处理。采用上述技术手段,通过构建存储消息生产时间戳的索引文件,可以以此作为消息查询索引,查询到指定时