這里有幾個(gè)不同的隊(duì)列 名字沒(méi)有什么規(guī)則 就是xxx.xxx exchange也是和隊(duì)列的名字一樣的

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);

}

}

}

向上面的消費(fèi)者 寫了兩個(gè)監(jiān)聽(tīng)，根據(jù)隊(duì)列名 監(jiān)聽(tīng)指定的隊(duì)列。 但是現(xiàn)在隊(duì)列是動(dòng)態(tài)生成的 根本不知道有多少個(gè)隊(duì)列，也不知道隊(duì)列名字 反正隊(duì)列名生成規(guī)則就是XXX.XXX(用戶名.xxx類型)。 能不能只寫一個(gè)消費(fèi)去消費(fèi)此mq服務(wù)器所有的隊(duì)列？ 像那種#.# 怎么配置的 就是消費(fèi)所有的意思 怎么消費(fèi)所有？

與50位技術(shù)專家面對(duì)面20年技術(shù)見(jiàn)證，附贈(zèng)技術(shù)全景圖

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。