RabbitMQ学习（二）工作队列

public class Producter {
    //队列名称
    private final static String QUEUE_NAME = "Work_Queue";
    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();
        //声明队列，可以手动在mq中创建
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        //写入10条数据（直接循环写入）
        for (int i = 0; i < 10; i++) {
            System.out.println("发送第" + i + "信息！");
            String message = "WorkQueue Message number " + i + " " + System.currentTimeMillis();
            channel.basicPublish("", QUEUE_NAME, true, null, message.getBytes());
        }
        channel.close();
        connection.close();
    }
}

public void getConsum() throws IOException, TimeoutException, InterruptedException {

    //创建连接和通道

    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, false, consumer);

    while (true)

    {

        QueueingConsumer.Delivery delivery = consumer.nextDelivery();

        String message = new String(delivery.getBody());

        System.out.println(" 获取到消息 " + message + "开始处理");

        try{

            Thread.sleep(10000);

        }catch (InterruptedException e){}

        finally {

         channel.basicAck(delivery.getEnvelope().getDeliveryTag()

                    , false);

        }

        System.out.println( message + "处理完成");

    }

}