這里有幾個不同的隊列 名字沒有什么規則 就是xxx.xxx exchange也是和隊列的名字一樣的

package com.monitor.receiver.queue;

import java.util.List;

import java.util.Map;

import org.springframework.amqp.rabbit.annotation.RabbitListener;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.retry.annotation.Recover;

import org.springframework.stereotype.Component;

import com.monitor.receiver.jpush.PushUtil;

import com.monitor.receiver.pojo.SysWarnInfo;

import com.monitor.receiver.service.SysWarnInfoService;

@Recover

@Component

public class Receive {

@Autowired

SysWarnInfoService sysWarnInfoService;

@RabbitListener(queues="Adine.One")

public void process_sys_warn1(Map msg) {

if(msg!=null){

List< SysWarnInfo>list=sysWarnInfoService.findAccountList(msg);

PushUtil.jiguangPush(list);

}

}

@RabbitListener(queues="lous.wqui")

public void process_sys_warn2(Map msg) {

if(msg!=null){

List< SysWarnInfo>list=sysWarnInfoService.findAccountList(msg);

PushUtil.jiguangPush(list);

}

}

}

向上面的消費者 寫了兩個監聽，根據隊列名 監聽指定的隊列。 但是現在隊列是動態生成的 根本不知道有多少個隊列，也不知道隊列名字 反正隊列名生成規則就是XXX.XXX(用戶名.xxx類型)。 能不能只寫一個消費去消費此mq服務器所有的隊列？ 像那種#.# 怎么配置的 就是消費所有的意思 怎么消費所有？

與50位技術專家面對面20年技術見證，附贈技術全景圖

總結

以上是生活随笔為你收集整理的java rabbitmq topic_java rabbitmq 发送消息是topic模式， 消费者 怎么消费多个不同名字的队列？...的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。