如何控制上游应用发送至WebLogic MQ队列的消息数量

针对队列消息堆积问题，WebLogic 12.1.1提供了几种直接控制上游生产者发送速率的配置，以下是具体操作方式：

1. 设置队列的目标阈值限制 #

直接给目标队列设置消息数或字节数上限，当队列达到阈值时，上游生产者会被阻塞（默认行为，不会抛出异常丢失消息），直到队列中有消息被消费、腾出空间后才会继续接收新消息。

• 操作路径：WebLogic控制台 → 服务 → 消息传递 → JMS队列 → 选择目标队列 → 「阈值和限制」标签页
• 配置项：
  • 设置最大消息数：队列允许存储的最大消息条数
  • 设置最大字节数：队列允许存储的总消息字节大小
    两个条件满足其一就会触发阻塞。

2. 配置连接工厂的生产者流量控制 #

通过生产者连接的流量控制参数，限制上游应用每次能发送的消息量，间接降低发送速率。

• 操作路径：WebLogic控制台 → 服务 → 消息传递 → JMS连接工厂 → 选择对应连接工厂 → 「流量控制」标签页
• 配置项：
  • 勾选启用生产者流量控制
  • 设置生产者窗口大小：指定生产者在收到WebLogic的确认前，能发送的最大消息字节数（或消息数，取决于配置单位）。值越小，生产者发送消息的速率越慢。

3. 使用JMS配额（Quota）管理队列容量 #

创建配额资源并关联到队列，配额可以设置全局或队列级别的消息数/字节数上限，相比队列单独的阈值，配额更灵活（比如多个队列共享同一配额）。

• 操作路径：
  1. 控制台 → 服务 → 消息传递 → JMS配额 → 新建配额，设置最大消息数或最大字节数
  2. 回到目标队列的配置页 → 「常规」标签页，在「配额」下拉框中选择刚创建的配额

临时应急方案：暂停队列入站 #

如果需要立即停止接收新消息，优先处理堆积的消息，可以临时暂停队列的入站流量：

• 操作路径：控制台 → 服务 → 消息传递 → JMS队列 → 选择目标队列 → 「控制」标签页 → 点击「暂停入站」按钮
• 待堆积消息处理完成后，点击「恢复入站」即可恢复接收新消息

内容的提问来源于stack exchange，提问作者chaatat