手机版
你好,游客 登录 注册
背景:
阅读新闻

RabbitMQ远程调用测试用例

[日期:2014-10-12] 来源:Linux社区  作者:dwf07223 [字体: ]

RabbitMQ远程调用测试,使用外部机器192.168.174.132上的RabbitMQ,使用之前需要对远程调用进行配置,操作过程见另一篇“解决RabbitMQ远程不能访问的问题http://www.linuxidc.com/Linux/2014-10/107917.htm

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:

RabbitMQ远程调用测试用例RabbitMQ远程调用测试用例

CentOS 5.6 安装RabbitMQ http://www.linuxidc.com/Linux/2013-02/79508.htm

RabbitMQ客户端C++安装详细记录 http://www.linuxidc.com/Linux/2012-02/53521.htm

Python尝试RabbitMQ http://www.linuxidc.com/Linux/2011-12/50653.htm

RabbitMQ集群环境生产实例部署 http://www.linuxidc.com/Linux/2012-10/72720.htm

Ubuntu下PHP + RabbitMQ使用 http://www.linuxidc.com/Linux/2010-07/27309.htm

在CentOS上安装RabbitMQ流程 http://www.linuxidc.com/Linux/2011-12/49610.htm

RabbitMQ 的详细介绍请点这里
RabbitMQ 的下载地址请点这里

本文永久更新链接地址http://www.linuxidc.com/Linux/2014-10/107916.htm

linux
相关资讯       RabbitMQ 
本文评论   查看全部评论 (0)
表情: 表情 姓名: 字数

       

评论声明
  • 尊重网上道德,遵守中华人民共和国的各项有关法律法规
  • 承担一切因您的行为而直接或间接导致的民事或刑事法律责任
  • 本站管理人员有权保留或删除其管辖留言中的任意内容
  • 本站有权在网站内转载或引用您的评论
  • 参与本评论即表明您已经阅读并接受上述条款