[发明专利]一种用于云存储系统的消息处理方法和装置

摘要

本发明提供一种用于云存储系统的消息处理方法和装置，其中方法包括：当接收到消息时，确定接收的消息的类型及该类型对应的消息队列，若该消息队列不为空，则将该接收的消息添加至该消息队列中，若该消息队列为空，则还将该消息队列的实际优先级恢复默认值，当调用消息时，选取实际优先级最高的消息队列，得到选定队列，从该选定队列中调用消息，当在该选定队列中调用的消息的数目大于预设阈值时，更新该选定队列的实际优先级，直至该选定队列的实际优先级小于预设优先级，重新选取优先级最高的消息队列。具有较高的消息添加效率，降低了消息队列长度过长问题的可能，保证优先级较高的消息先被调用的同时，还可避免优先级较低的消息被积压。

主权项

1.一种用于云存储系统的消息处理方法，其特征在于，包括：当接收到消息时，确定接收的消息的类型及所述类型相对应的消息队列，其中，每个消息队列均具有默认优先级和实际优先级，判断所述消息队列是否为空，若不为空，则将所述接收的消息添加至所述消息队列中，若为空，则将该接收的消息添加至所述消息队列中，并将所述消息队列的默认优先级作为所述消息队列的实际优先级；当调用消息时，在所有消息队列中选取实际优先级最高的消息队列，得到选定队列，从所述选定队列中调用消息，当在所述选定队列中调用的消息的数目大于预设阈值时，更新所述选定队列的实际优先级，直至所述选定队列的实际优先级小于预设优先级，重新在所有消息队列中选取优先级最高的消息队列；在所述当接收到消息时，确定接收的消息的类型及所述类型相对应的消息队列之前，还包括：确定所有可接收消息，并确定每个可接收消息的类型；将所有可接收消息的类型进行整合，得到类型集合；对所述类型集合中每个类型均对应创建一相对应的消息队列，并根据所述类型集合中各类型的重要程序为每个消息队列设置一默认优先级。