RabbitMQ远程调用测试用例

阳光穿透心脏的1/2处 2022-01-11 18:05 156阅读 0赞

RabbitMQ远程调用测试，使用外部机器192.168.174.132上的RabbitMQ，使用之前需要对远程调用进行配置，操作过程见博文“[解决RabbitMQ远程不能访问的问题][RabbitMQ]”。

**SendTest：**

package com.mq.rabbitmq.rabbitmqtest;
    
    import java.util.Date;
    
    import com.rabbitmq.client.ConnectionFactory;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.QueueingConsumer;
    
    public class ReceiveTest {
    	private final static String QUEUE_NAME = "ftpAgent";
    	private final static String userName = "admin";
    	private final static String password = "admin";
    	private final static String virtualHost = "/";
    	private final static int portNumber = 5672;
    	private final static String hostName = "master";
    	private final static String host = "192.168.174.132";
    
    	public static void main(String[] argv) throws java.io.IOException,
    			java.lang.InterruptedException {
    
    		ConnectionFactory factory = new ConnectionFactory();
    //	    factory.setHost("192.168.174.160");
    	    factory.setUsername(userName);
    	    factory.setPassword(password);
    //	    factory.setVirtualHost(virtualHost);
    	    factory.setHost(host);
    	    factory.setPort(portNumber);
    	    Connection connection = factory.newConnection();
    	    Channel channel = connection.createChannel();
    //	    channel.queueDeclare(QUEUE_NAME, false, false, false, null);
    
    		System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
    		
    		QueueingConsumer consumer = new QueueingConsumer(channel);
    	    channel.basicConsume(QUEUE_NAME, true, consumer);
    
    	    Date nowTime = new Date();
    	    
    	    while (true) {
    	      QueueingConsumer.Delivery delivery = consumer.nextDelivery();
    	      String message = new String(delivery.getBody());
    	      System.out.println("RecieveTime: " + nowTime);
    	      System.out.println(" [x] Received '" + message + "'");
    	    }
    
    	}
    }

**ReceiveTest：**

**运行结果：**

**SendTest：**

[![wKioL1QFJQuThFCJAADsngw7JYs780.jpg][]][wKioL1QFJQuThFCJAADsngw7JYs780.jpg]

**ReceiveTest：**

**[![wKioL1QFJVWBPv7YAAD\_Zh5tZzU367.jpg][wKioL1QFJVWBPv7YAAD_Zh5tZzU367.jpg]][wKioL1QFJVWBPv7YAAD_Zh5tZzU367.jpg]**

转载于:https://blog.51cto.com/dwf07223/1547686

[RabbitMQ]: http://dwf07223.blog.51cto.com/8712758/1547226
[wKioL1QFJQuThFCJAADsngw7JYs780.jpg]: /images/20220110/e786a49e652d40609d83c5aacf6e4dc5.png
[wKioL1QFJVWBPv7YAAD_Zh5tZzU367.jpg]: /images/20220110/dc84af9d89d84378a257f4db9d68b554.png