RabbitMQ : 게시 할 큐를 지정하는 방법은 무엇입니까?

Question

RabbitMQ의 Channel#basicConsume 방법은 우리에게 다음 인수를 제공합니다

channel.basicConsume(queueName, autoAck, consumerTag, noLocal, 
    exclusive, arguments, callback); 

우리에게 정확히 우리가에서 소비 할 대기열에있는 RabbitMQ를 말할 수있는 능력을 부여.

channel.basicPublish(exchangeName, routingKey, mandatory, immediateFlag, 
    basicProperties, messageAsBytes); 

가 왜 큐를 지정할 수 없습니다 여기까지 게시 :

그러나 Channel#basicPublish는 그런 동등성이 없다?!? logging이라는 대기열에 Channel 게시를 게시하려면 어떻게해야합니까? 미리 감사드립니다!

Answer 1

기본적으로 큐는 라우팅 키를 기반으로 교환기에 바인딩 될 수 있습니다.

3 명의 다른 게시자가 있다고 가정합니다. 당신은 메시지를 사용 소비자를 가질 수

routingKey "일자리"로 교환 "작업"routingKey와
Publisher3 보내는 메시지를 교환하는 "이벤트"routingKey와
Publisher2 보내는 메시지를 교환하는 메시지를 전송
Publisher1 특정 routhingKey와 함께. 예를 들어
당신이 '#의'와 같이 라우팅 줄 교환에 오는 모든 메시지를 사용하려면이

channel.queueBind(queueName, exchangeName, "events"); 

같이 선언 "이벤트"메시지에 대한 소비자를하기 위해

즉, 제가 말할 수있는 것은 짧습니다.
1. 메시지는 거래소에 게시됩니다.
2. 큐는 routingKeys를 기반으로 교환하도록 바인딩됩니다.
3. RabbitMQ는 일치하는 라우팅 키가있는 메시지를 해당 대기열로 전달합니다.

자습서를 참조하십시오 - http://www.rabbitmq.com/tutorials/tutorial-three-java.html

RabbitMQ에서 메시징 모델의 핵심 아이디어는 생산자가 큐에 직접 메시지를 전송하지 않을 것입니다. 사실, 생산자는 메시지가 어떤 대기열에 전달되는지 전혀 모릅니다. 대신 제작자는 교환기에게만 메시지를 보낼 수 있습니다.

Answer 2

이 시도하십시오 : 그것은 내 프로젝트에 대한 일

channel.basicPublish("", yourQueueName, null, 
     message.getBytes((Charset.forName("UTF-8")))); 

.

Answer 3

@Tien Nguyen의 대답을 확장하려면 RabbitMQ에 "속임수"가있어 효과적으로 대기열에 게시 할 수 있습니다. 각 대기열은 AMQP 기본 교환에 자동으로 바인드되며 대기열의 이름은 라우팅 키로 사용됩니다. 기본 교환은 "이름이없는 교환"이라고도 알려져 있습니다. 즉 이름이 빈 문자열입니다. 따라서 대기열 이름과 동일한 라우팅 키를 사용하여 ""이라는 교환기에 게시하는 경우 메시지는 해당 대기열로 이동합니다. @ 존 (John)이 말했듯이 그것은 교환을 통해 진행됩니다. 그것은 당신이 선언하거나 자신을 묶을 필요가없는 것입니다.

Java 클라이언트를이 코드를 사용해보기에 편리하지 않지만 제대로 작동합니다.

channel.basicPublish("", myQueueName, false, false, null, myMessageAsBytes); 

그러나 이것이 RabbitMQ의 작동 원리와 반대되는 내용입니다. 일반적인 응용 프로그램 흐름의 경우 교환을 선언하고 바인딩해야합니다. 그러나 예외적 인 경우에는 "속임수"가 유용 할 수 있습니다. 예를 들어, Rabbit 관리 콘솔을 사용하여 Exchange 생성 및 바인딩 의식없이 메시지를 수동으로 큐에 게시 할 수 있습니다. 당신이 원하는 무엇