rabbitmq(2)简单队列

以你之姓@ 2022-05-29 13:59 422阅读 0赞

### 1、模型 ###

一个生产者对应一个消费者：  
![这里写图片描述][20180325153739995]

### 2、代码 ###

#### 2.1、生产者 ####

private final static String QUEUE_NAME = "hello";
    
    public static void main(String[] args) throws Exception {
    
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("192.168.1.7");
        factory.setUsername("root");
        factory.setPassword("123456");
    
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();
    
        /* * rabbitmq是否将该队列中的消息进行持久化,保证rabbitmq中的消息不会应为rabbitmq重启而丢失 * 已经存在的队列不可以修改该参数,除非进rabbitmq删除该队列,否则会抛出异常 * Caused by: com.rabbitmq.client.ShutdownSignalException: * channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED * - inequivalent arg 'durable' for queue 'hello' in vhost '/': received 'true' but current is 'false', class-id=50, method-id=10) */
        boolean durable = true;
        channel.queueDeclare(QUEUE_NAME, durable, false, false, null);
        String message = "Hello World!";
        channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
        System.out.println(" [1] Sent '" + message + "'");
    
        channel.close();
        connection.close();
    }

#### 2.2、消费者 ####

private final static String QUEUE_NAME = "hello";
    
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("192.168.1.7");
        factory.setUsername("root");
        factory.setPassword("123456");
    
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();
    
        boolean durable = true;
        channel.queueDeclare(QUEUE_NAME, durable, false, false, null);
        System.out.println(" [*] Waiting for messages.");
        Consumer consumer = new DefaultConsumer(channel) {
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties,
                    byte[] body) throws IOException {
                String message = new String(body, "UTF-8");
                System.out.println(" [1] Received '" + message + "'");
            }
        };
        channel.basicConsume(QUEUE_NAME, true, consumer);
    }

[20180325153739995]: /images/20220529/1f0d5a4c63de4f18845232f635fa0858.png