RabbitMQ集群使用说明.doc

文件编号： 版 本 号： V1.0 RabbitMQ集群使用说明编 写： 审 核： 批 准： 文档修改记录版本号修订日期变更概述作者1. Maven配置pom在pom.xml中加入rabbitmq和spring rabbitmq依赖包。com.rabbitmqamqp-client3.5.4org.springframework.amqpspring-rabbit1.4.5.RELEASE2. 使用Java API 直接连接RabbitMQ集群使用官方的Java API（amqp-client-3.5.4.jar）来直接连接RabbitMQ集群。2.1 RabbitMQ发送直接连接RabbitMQ集群，然后发送消息。import com.rabbitmq.client.Address;import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import com.rabbitmq.client.ConnectionFactory;public class RabbitMqSend2 private final static String QUEUE_NAME = storm_up_queue;public static void main(String args) throws Exception Address addrArr = new Address new Address(192.168.17.46, 5672),new Address(192.168.17.47, 5672) ,new Address(192.168.17.48, 5672) ;ConnectionFactory factory = new ConnectionFactory();factory.setUsername(guest);factory.setPassword(guest);factory.setVirtualHost(storm_virtualhost);Connection connection = factory.newConnection(addrArr);Channel channel = connection.createChannel();for (int i = 1; i = 10; i+) String message= +i;channel.basicPublish(, QUEUE_NAME, null, message.getBytes();System.out.println(i + x Sent + message + );Thread.sleep(1);System.exit(0);2.2 RabbitMQ接收直接连接RabbitMQ集群，然后接收消息，注意需要手动打开应答机制，并手动提交确认消息，保证公平调度和消息持久化。import com.rabbitmq.client.Address;import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import com.rabbitmq.client.ConnectionFactory;import com.rabbitmq.client.QueueingConsumer;public class RabbitMqRecv2 private final static String QUEUE_NAME = storm_down_queue;public static void main(String argv) throws Exception Address addrArr = new Address new Address(192.168.17.46, 5672),new Address(192.168.17.47, 5672) ,new Address(192.168.17.48, 5672) ;ConnectionFactory factory = new ConnectionFactory();factory.setUsername(guest);factory.setPassword(guest);factory.setVirtualHost(storm_virtualhost);Connection connection = factory.newConnection(addrArr);Channel channel = connection.createChannel();/ 设置最大服务转发消息数量int prefetchCount = 1;channel.basicQos(prefetchCount);QueueingConsumer consumer = new QueueingConsumer(channel);/ 打开应答机制boolean ack = false; channel.basicConsume(QUEUE_NAME, ack, consumer);while (true) QueueingConsumer.Delivery delivery = consumer.nextDelivery();String message = new String(delivery.getBody();Thread.sleep(1);System.out.println( x Received + message + );channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);3. 使用Spring Xml托管连接RabbitMQ集群使用xml配置，采用amqp-client-3.5.4.jar、spring-rabbit-1.4.5.RELEASE.jar和spring-amqp-1.4.5.REL