RabbitMQ远程调用测试用例

RabbitMQ远程调用测试，使用外部机器192.168.174.132上的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：

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 + "'");

}

}

}

运行结果：

SendTest：

CentOS 5.6 安装RabbitMQ

RabbitMQ客户端C++安装详细记录

用Python尝试RabbitMQ

RabbitMQ集群环境生产实例部署

Ubuntu下PHP + RabbitMQ使用

在CentOS上安装RabbitMQ流程