1.pom

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>3.6.5</version>
</dependency>

2.code

1.Send.java

package com.caicongyang.mq.hello;

import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

/**
 * 消息发送
 * @author caicongyang1
 * @version id: Send, v 0.1 16/9/30 上午10:24 caicongyang1 Exp $$
 */
public class Send {

    // 消息队列名称
    private final static String QUEUE_NAME = "helloword";

    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        //设置MabbitMQ所在主机ip或者主机名
        factory.setHost("192.168.236.103");
        //指定用户 密码
        factory.setUsername("admin");
        factory.setPassword("admin");

        //指定端口
        factory.setPort(AMQP.PROTOCOL.PORT);
        //创建一个连接
        Connection connection = factory.newConnection();
        //创建一个频道
        Channel channel = connection.createChannel();
        //指定一个队列
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        //发送的消息
        String message = "hello world!";
        for (int i = 0; i < 10; i++) {
            //往队列中发出一条消息
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
            System.out.println("Sent Message：'" + message + "'");
            Thread.sleep(1000);
        }
        //关闭频道和连接
        channel.close();
        connection.close();
    }

}

package com.caicongyang.mq.hello;

import com.rabbitmq.client.*;

/**
 * 消息结束
 * @author caicongyang1
 * @version id: receive, v 0.1 16/9/30 上午10:29 caicongyang1 Exp $$
 */
public class Receive {

    // 消息队列名称
    private final static String QUEUE_NAME = "helloword";

    public static void main(String[] args) throws Exception {

        ConnectionFactory factory = new ConnectionFactory();
        //设置MabbitMQ所在主机ip或者主机名
        factory.setHost("192.168.236.103");
        //指定用户 密码
        factory.setUsername("admin");
        factory.setPassword("admin");

        //指定端口
        factory.setPort(AMQP.PROTOCOL.PORT);

        //创建一个连接
        Connection connection = factory.newConnection();
        //创建一个频道
        Channel channel = connection.createChannel();
        //声明队列，主要为了防止消息接收者先运行此程序，队列还不存在时创建队列。
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        //创建队列消费者
        QueueingConsumer consumer = new QueueingConsumer(channel);
        //指定消费队列
        channel.basicConsume(QUEUE_NAME, true, consumer);
        while (true)
        {
            //nextDelivery是一个阻塞方法（内部实现其实是阻塞队列的take方法）
            QueueingConsumer.Delivery delivery = consumer.nextDelivery();
            String message = new String(delivery.getBody());
            System.out.println("Received Message：'" + message + "'");
        }

    }
}

更多精彩内容请继续关注我的博客：http://blog.csdn.NET/caicongyang
 
 

  
  记录与分享，你我共成长 -from 
  
  caicongyang
 
 
 
 


 
 

最后

以上就是单薄翅膀为你收集整理的RabbitMq之Helloworld1.pom2.code的全部内容，希望文章能够帮你解决RabbitMq之Helloworld1.pom2.code所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。