2025 B卷 100分 题型

本文涵盖详细的问题分析、解题思路、代码实现、代码详解、测试用例以及综合分析；
并提供Java、python、JavaScript、C++、C语言、GO六种语言的最佳实现方式！

2025华为OD真题目录+全流程解析/备考攻略/经验分享

华为OD机试真题《模拟消息队列》：

---

---

题目名称：模拟消息队列

---

属性	内容
知识点	事件排序、优先级处理、逻辑处理
时间限制	1秒
空间限制	256MB
限定语言	不限

---

题目描述

模拟一个消息队列的运作，包含一个发布者和若干消费者。发布者在特定时刻发送消息，若此时有消费者订阅，消息将发送给优先级最高的消费者（消费者按输入顺序升序排列，升序即优先级递增）。若没有订阅者，消息被丢弃。消费者在特定时刻订阅或取消订阅，同一时刻的事件处理顺序如下：

• 订阅操作优先于消息发送
• 取消订阅优先于消息发送

输入描述
输入为两行：

1. 第一行：2N个正整数，表示N条消息的发送时刻和内容（时刻不重复，但未按时间排序）。例如：2 22 1 11 4 44代表3条消息，时刻分别为2（内容22）、1（内容11）、4（内容44）。
2. 第二行：2M个正整数，表示M个消费者的订阅和取消订阅时刻。例如：1 7 2 3代表两个消费者，第一个订阅时刻1、取消时刻7；第二个订阅时刻2、取消时刻3。

输出描述
输出M行，每行为对应消费者收到的消息内容（按接收顺序排列），若未收到消息则输出-1。

测试用例

1. 输入

   2 22 1 11 4 44 5 55 3 33  
   1 7 2 3  
   

   输出

   11 33 44 55  
   22  
   

   说明：消息在时刻1、2、3、4、5依次处理，优先级高的消费者（后订阅的）优先接收消息。

2. 输入

   5 64 11 64 9 97  
   9 11 4 9  
   

   输出

   97  
   64  
   

---

Java

问题分析

我们需要模拟消息队列的工作流程，其中发布者在特定时刻发送消息，消费者在特定时刻订阅或取消订阅。消息发送时，优先发送给当前活跃且优先级最高的消费者。优先级由消费者的输入顺序决定，后订阅的消费者优先级更高。

---

解决思路

1. 事件收集与排序：将所有订阅、取消订阅、消息发送事件按时间排序，同一时刻的事件按订阅 → 取消 → 消息的顺序处理。
2. 维护活跃消费者：使用 TreeSet 维护当前活跃的消费者，按优先级（输入顺序的逆序）排序。
3. 消息分发：处理消息事件时，将消息发送给当前优先级最高的消费者。

---

Java 代码实现

import java.util.*;

public class Main {
   
    static class Event implements Comparable<Event> {
   
        int time;       // 事件发生时间
        int type;       // 0:订阅, 1:取消订阅, 2:消息
        int consumerIdx; // 消费者索引（用于订阅/取消）
        int message;     // 消息内容（仅消息事件有效）

        public Event(int time, int type, int consumerIdx, int message) {
   
            this.time = time;
            this.type = type;
            this.consumerIdx = consumerIdx;
            this.message = message;
        }

        @Override
        public int compareTo(Event other) {
   
            if (this.time != other.time) {
   
                return Integer.compare(this.time, other.time);
            } else {
   
                return Integer.compare(this.type, other.type); // 订阅→取消→消息
            }
        }
    }

    public static void main(String[] args) {
   
        Scanner scanner = new Scanner(System.in);

        // 解析消息输入
        String[] msgInput = scanner.nextLine().split(" ");
        List<Event> events = new ArrayList<>();
        for (int i = 0; i < msgInput.length; i += 2) {
   
            int time = Integer.parseInt(msgInput[i]);
            int msg = Integer.parseInt(msgInput[i + 1]);
            events.add(new Event(time, 2, -1, msg)); // 类型2是消息事件
        }

        // 解析消费者输入
        String[] consumerInput = scanner.nextLine().split(" ");
        int m = consumerInput.length / 2;
        List<List<Integer>> consumerMsgs = new ArrayList<>();
        for (int i = 0; i < m; i++) {
   
            int subTime = Integer.parseInt(consumerInput[2 * i]);
            int unsubTime = Integer.parseInt(consumerInput[2 * i + 1]);
            events.add(new Event(subTime, 0, i, -1));  // 订阅事件
            events.add(new Event(unsubTime, 1, i, -1)); // 取消事件
            consumerMsgs.add(new ArrayList<>()); // 初始化消费者的消息列表
        }

        // 按时间排序所有事件
        Collections.sort(events);

        // 维护当前活跃的消费者（按优先级降序排列）
        TreeSet<Integer> activeConsumers = new TreeSet<>(Collections.reverseOrder());

        // 处理所有事件
        for (Event event : events) {
   
            switch (event.type) {
   
                case 0: // 订阅事件
                    activeConsumers.add(event.consumerIdx);
                    break;
                case 1: // 取消订阅事件
                    activeConsumers.remove(event.consumerIdx);
                    break;
                case 2: // 消息事件
                    if (!activeConsumers.isEmpty()) {
   
                        int consumer = activeConsumers.first(); // 最高优先级的消费者
                        consumerMsgs.get(consumer).add(event.message);
                    }
                    break;
            }
        }

        // 输出结果
        for (List<Integer> msgs : consumerMsgs) {
   
            if (msgs.isEmpty()) {
   
                System.out.println(-1);
            } else {
   
                System.out.println(
                    String.join(" ", msgs.stream().map(String::valueOf).toArray(String[]::new))
                );
            }
        }
    }
}

---

代码解析

1. Event 类：

   static class Event implements Comparable<Event> {
        
       int time;       // 事件时间
       int type;       // 0:订阅, 1:取消, 2:消息
       int consumerIdx; // 消费者索引
       int message;     // 消息内容
   }
   

   • 封装事件的时间、类型、消费者索引和消息内容。

2. 事件排序：

   @Override
   public int compareTo(Event other) {
        
       if (this.time != other.time) return time比较结果;
       else return type比较结果; // 同一时间，订阅→取消→消息
   }
   

   • 按时间升序排序，同一时间的事件按订阅 → 取消 → 消息的顺序处理。

3. 解析输入：

   String[] msgInput = scanner.nextLine().split(" ");
   for (int i = 0; i < msgInput.length; i += 2) {
        
       int time = Integer.parseInt(msgInput[i]);
       int msg = Integer.parseInt(msgInput[i + 1]);
       events.add(new Event(time, 2, -1, msg)); // 消息事件
   }
   

   • 将输入拆分为消息时间和内容，生成消息事件。

4. 处理消费者事件：

   String[] consumerInput = scanner.nextLine().split(" ");
   for (int i = 0; i < m; i++) {
        
       int subTime = Integer.parseInt(consumerInput[2*i]);
       int unsubTime = Integer.parseInt(consumerInput[2*i+1]);
       events.add(new Event(subTime, 0, i, -1)); // 订阅事件
       events.add(new Event(unsubTime, 1, i, -1)); // 取消事件
   }
   

   • 解析每个消费者的订阅和取消时间，生成对应事件。

5. 维护活跃消费者：

   TreeSet<Integer> activeConsumers = new TreeSet<>(Collections.reverseOrder());
   

   • 使用 TreeSet 并按逆序排序，确保活跃消费者中优先级最高的（索引最大）排在前面。

6. 处理消息事件：

   if (!activeConsumers.isEmpty()) {
        
       int consumer = activeConsumers.first(); // 最高优先级消费者
       consumerMsgs.get(consumer)