RabbitMQ学习（一） Hello World！

时间：2017-07-13 10:33:08 阅读：128 评论：0 收藏：0 [点我收藏+]

标签：通道 false 消息 cell throw on() 页管理 top alt

1．简述RabbitMQ

技术分享

RabbitMQ使用结构图

Rabbit使用主要包含3个对象：

生产者（Producter）：产生消息，发送到队列中

队列（Queue）:接受生产者传输的消息，等待消费者取走

消费者（Consumer）：从队列中获取消息，进行下一步处理

2．做一个简单的实现

引入jar包

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

创建生产者

public class Producter {

    //队列名称

    private final static String QUEUE_NAME = "first_try";

    public static void main(String[] args) throws IOException, TimeoutException {

        //配置rabbitmq服务器地址

        ConnectionFactory factory = new ConnectionFactory();

        factory.setHost("localhost");

        factory.setPort(5672);

        factory.setUsername("starktan");

        factory.setPassword("starktan");

        factory.setVirtualHost("/");

        //建立连接和通道

        Connection connection = factory.newConnection();

        Channel channel = connection.createChannel();

        //声明队列

        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        //发送消息

        String message = "RabbitMQ Test Message "+System.currentTimeMillis();

        channel.basicPublish("",QUEUE_NAME,true,null,message.getBytes());

        //关闭连接

        channel.close();

        connection.close();

    }

}

创建消费者

public class Consumer {

    //队列名称

    private final static String QUEUE_NAME = "first_try";

    public static void main(String[] args) throws IOException, InterruptedException, TimeoutException {

        //创建连接和通道

        ConnectionFactory factory = new ConnectionFactory();

        factory.setHost("localhost");

        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("获取到消息 " + message + "‘");

        }

    }

}