spring-rabbit集成

<rabbit:connection-factory id="connectionFactory" virtual-host="vhostSJJ" 
        username="uname" password="upass" host="13.20.22.20" port="5972"  />

    <!--通过指定下面的admin信息，当前producer中的exchange和queue会在rabbitmq服务器上自动生成 -->
    <rabbit:admin id="connectAdmin" connection-factory="connectionFactory" />

    <!--定义queue -->
    <rabbit:queue name="queueTest" durable="true" auto-delete="false" exclusive="false" declared-by="connectAdmin" />

    <!-- 定义direct exchange，绑定queueTest -->
    <rabbit:direct-exchange name="exchangeTest"
        durable="true" auto-delete="false" declared-by="connectAdmin">
        <rabbit:bindings>
            <rabbit:binding queue="queueTest" key="queueTestKey"></rabbit:binding>
        </rabbit:bindings>
    </rabbit:direct-exchange>

通过queueTestKey将name=queueTest的队列和名称为exchangeTest的交换机进行绑定。

@Service
public class MessageProducer {
    private Logger logger = LoggerFactory.getLogger(MessageProducer.class);  

    @Resource(name="amqpTemplate")  
    private AmqpTemplate amqpTemplate;  

    @Resource(name="amqpTemplate2")  
    private AmqpTemplate amqpTemplate2;  

    public void sendMessage(Object message) throws IOException {  
        logger.info("to send message:{}", message);  
        amqpTemplate.convertAndSend("queueTestKey", message);  

    }  
}