RabbitMQ SpringAMQP xml 配置

Question

我正在尝试创建一个使用 RabbitMQ 的小型应用程序，其中我的发送方使用 Spring AMQP xml 配置编写，接收方使用 PIKA 使用 python 编写。如果我的方法正确，请告诉我。

这是我的发件人文件-

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class SpringAMQPRabbitSender {
    private final static String SENDER_XML = "springamqp-rabbit-sender-context.xml";
    public static void main(String[] args) throws Exception {
      AmqpTemplate amqpTemplate = (AmqpTemplate)(new ClassPathXmlApplicationContext(SENDER_XML)).getBean("amqpTemplate");
      int messagCount = 0;
      while (messagCount < 10){
        amqpTemplate.convertAndSend("tp.routingkey.1", "Message # " + messagCount++);
      }
      System.out.println( messagCount + " message(s) sent successfully.");
    }
}

这是我的 springamqp-rabbit-sender-context.xml 文件

<?xml version="1.0" encoding="utf-8" ?>
<beans xmlns="http://www.springframework.org/schema/beans"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xmlns:rabbit="http://www.springframework.org/schema/rabbit"
  xsi:schemaLocation="http://www.springframework.org/schema/beans 
  http://www.springframework.org/schema/beans/spring-beans-3.1.xsd 
  http://www.springframework.org/schema/rabbit 
  http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd">

<rabbit:connection-factory id="connectionFactory" 
host="localhost" username="guest" password="guest"/>

<rabbit:admin connection-factory="connectionFactory"/>

<rabbit:template id="amqpTemplate" connection-factory="connectionFactory"
exchange="tpExchange"/> 
</beans>

现在这是我的 python 接收器-

#!/usr/bin/env python
import pika
import sys

connection = pika.BlockingConnection(pika.ConnectionParamet(host='localhost'))
channel = connection.channel()

channel.exchange_declare(exchange='tpExchange',
                     exchange_type='topic')

channel.queue_declare(queue = "tpQueue")

key = "tp.routingkey.1"
channel.queue_bind(exchange='tpExchange',
                   queue="tpQueue",
                   routing_key="tp.routingkey.1")

print(' [*] Waiting for logs. To exit press CTRL+C')

def callback(ch, method, properties, body):
    print(" [x] %r:%r" % (key, body))

channel.basic_consume(callback,
                  queue="tpQueue",
                  no_ack=True)

channel.start_consuming()

这是正确的吗？？我错过了什么吗？请提出建议。

提前致谢。

Answer 1

But since in few examples I saw the queue exchange binding configured at sender side also..So I wanted to clarify.

不，您绝对不需要在发件人方面这样做。只需要知道 exchange 和 routing key。队列及其绑定甚至不是接收方的问题，但我们通常在那里进行绑定。

正常的做法当然是Broker端配置。

RabbitMQ SpringAMQP xml 配置

RabbitMQ SpringAMQP xml configuration

xml

rabbitmq

pika

spring-amqp