JMS规范的Pub/Sub消息模型的消息生产消费方法

摘要

本发明公开了一种JMS规范的Pub/Sub消息模型的消息生产消费方法，包括：接收当前消息；获取当前消息的权效向量和权效值；消息主题未满时：将当前消息的权效向量加入到权效向量空间，并将当前消息放入消息主题；消息主题已满时：获取当前权效向量空间中所有消息的权效值和权效阈值；将权效值低于权效阈值的消息进行标记；若当前消息的权效值大于权效阈值，则从消息主题中删除一条已标记消息并删除该条已标记消息的权效向量；将当前消息的权效向量加入到权效向量空间，并将当前消息放入所述消息主题。本发明的方法在JMS规范的Pub/Sub消息模型中可有效的避免消息阻塞，保证了消息的实效性，并且避免了重要消息丢失的风险。