RabbitMQ消息模型之Sample

本文介绍: 这种模式适合于消息任务不是很密集，并且处理任务不算太过耗时的场景。消费者消费的速度赶得上生产者生产的速度。Hello Worl d是官网给出的第一个模型，使用的交换机类型是直连direct，也是默认的交换机类型。此模型中只有一个生产者、一个队列、一个消费者。

Hello World

Hello World是官网给出的第一个模型，使用的交换机类型是直连direct，也是默认的交换机类型。

在上图的模型中，有以下概念：

P：生产者，也就是要发送消息的程序
C：消费者：消息的接受者，会一直等待消息到来。
Que ue：消息队列，图中红色部分。类似一个邮箱，可以缓存消息；生产者向其中投递消息，消费者从其中取出消息。

此模型中只有一个生产者、一个队列、一个消费者。

这种模式适合于消息任务不是很密集，并且处理任务不算太过耗时的场景。消费者消费的速度赶得上生产者生产的速度。

创建生产者

public class MyProducer {

    @Test
    public void test() throws Exception {
        // 队列名称
        String queue = "xw_queue";
        String message = "Hello World -&gt; ";

        // 创建工厂
        ConnectionFactory factory = new ConnectionFactory();
        factory.setVirtualHost("/");
        factory.setHost("xuewei.world");
        factory.setUsername("xuewei");
        factory.setPassword("123456");
        factory.setPort(5672);

        // 创建连接和通道
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();
        for (int i = 0; i < 10; i++) {
            // 发布消息
            channel.basicPublish("xw_exchange", queue, null, (message + i).getBytes());
        }
    }
}

创建消费者

public class MyConsumer {

    public static void main(String[] args) throws Exception {
        // 队列名称
        String queue = "xw_queue";

        // 创建工厂
        ConnectionFactory factory = new ConnectionFactory();
        factory.setVirtualHost("/");
        factory.setHost("xuewei.world");
        factory.setUsername("xuewei");
        factory.setPassword("123456");
        factory.setPort(5672);

        // 创建连接和通道
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();
        channel.queueDeclare(queue, true, false, false, null);
        channel.queueBind("", "xw_exchange", queue);
        channel.basicConsume(queue, true, new DefaultConsumer(channel) {
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                System.out.println("接收到消息: " + new String(body));
              	// TODO 业务处理
            }
        });
    }
}