SpringCloud中Rabbitmq的使用

1.pom配置，添加以來jar包

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>

2.配置文件配置

#RabbitMq
spring.rabbitmq.host=${dev.spring.rabbitmq.host}
spring.rabbitmq.port=${dev.spring.rabbitmq.port}
spring.rabbitmq.username=${dev.spring.rabbitmq.username}
spring.rabbitmq.password=${dev.spring.rabbitmq.password}

spring.rabbitmq.exchange=${dev.spring.rabbitmq.exchange}
spring.rabbitmq.routingkey=${dev.spring.rabbitmq.routingkey}
spring.rabbitmq.queue=${dev.spring.rabbitmq.queue}

3.rabbitmq消息發送一

@Autowired 
private AmqpTemplate amqpTemplate;
//key：消息名稱；content：消息內容
public void send(String key,String content) {
    amqpTemplate.convertAndSend(key, content); 
}

4.rabbitmq消息接收一

@Component
@EnableScheduling
public class ClmNeedPaperMqReciever extends ClmBaseMqReciever {
/**
*RabbitListener：rabbitmq監聽；queues = "queues1"：監聽的隊列名*稱；@Payload String orderXML：接收到的消息內容
*/
@RabbitHandler
@RabbitListener(queues = "queues1", containerFactory = "rabbitListenerContainerFactory")
public void process(@Payload String orderXML) {

    //處理內容
}

5.rabbitmq發送二

String MQname ="ClmClose";
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("129.1.9.193");
factory.setUsername("admin");
factory.setPassword("admin");
factory.setPort(5672);
Connection connection;
try {
connection = factory.newConnection();
Channel channel = connection.createChannel();
channel.queueDeclare(MQname, true, false, false, null);
channel.basicPublish("", MQname, null, returnJSON.getBytes("UTF-8"));
channel.close();
connection.close();

6.rabbitmq接收二

/* 建立連接 */
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("129.1.9.193");// MQ的IP
factory.setPort(5672);// MQ端口
factory.setUsername("admin");// MQ用戶名
factory.setPassword("admin");// MQ密碼
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();

/* 聲明要連接的隊列 */
channel.queueDeclare(QUEUE_NAME, true, false, false, null);
System.out.println("等待消息產生：");

/* 創建消費者對象，用於讀取消息 */
QueueingConsumer consumer = new QueueingConsumer(channel);
channel.basicConsume(QUEUE_NAME, true, consumer);

/* 讀取隊列，並且阻塞，即在讀到消息之前在這里阻塞，直到等到消息，完成消息的閱讀后，繼續阻塞循環 */
while (true) {
QueueingConsumer.Delivery delivery = consumer.nextDelivery();
String message = new String(delivery.getBody(),"UTF-8");
System.out.println("收到消息'" + message + "'");
}

7.用接收一的方法去接收發送二的內容時需要轉換，否則會出現亂碼

@Component
@EnableScheduling
public class ClmNeedPaperMqReciever extends ClmBaseMqReciever {

/**
*RabbitListener：rabbitmq監聽；queues = "queues1"：監聽的隊
*列名稱；@Payload String orderXML：接收到的消息內容
*/
@RabbitHandler
@RabbitListener(queues = "queues1", containerFactory = "rabbitListenerContainerFactory")
public void process(@Payload String orderXML) {

//處理內容

// 解析報文對象，將byte數組還原
String[] listStr = orderXML.split(",");
byte[] listByte = new byte[listStr.length];
for (int i = 0; i < listStr.length; i++) {
listByte[i] = new Byte(listStr[i]);
}
orderXML = new String(listByte, "UTF-8");

}