统一消息平台




class Message {
String content;
long timestamp;
int importanceScore;
public Message(String content, long timestamp, int importanceScore) {
this.content = content;
this.timestamp = timestamp;
this.importanceScore = importanceScore;
}
public double getRankingFactor() {
// 计算综合得分
return (double) importanceScore / (System.currentTimeMillis() - timestamp);
}
}
]]>
import java.util.PriorityQueue;
public class MessageManager {
private PriorityQueue
public MessageManager() {
this.messageQueue = new PriorityQueue<>((m1, m2) -> Double.compare(m2.getRankingFactor(), m1.getRankingFactor()));
}
public void addMessage(Message message) {
messageQueue.add(message);
}
public Message getNextMessage() {
return messageQueue.poll();
}
}
]]>