RabbitMq 创建消费者

Posted 2023-03-10

参考技术A import org.springframework.amqp.rabbit.connection.Connection;

import org.springframework.amqp.rabbit.connection.ConnectionFactory;

import org.springframework.amqp.rabbit.core.RabbitTemplate;

import com.rabbitmq.client.*;

@Autowired

private RabbitTemplate rabbitTemplate;

ConnectionFactory connectionFactory =rabbitTemplate.getConnectionFactory();

Connection connection1 = connectionFactory.createConnection();

Channel channel1 = connection1.createChannel(false);

channel1.queueDeclare(RabbitConfig.QUEUE_A,false,false,false,null);

Consumer consumer =new DefaultConsumer(channel1)

@Override

    public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties,byte[] body)

String message =new String(body);

System.out.println("Received: " + message);

// 消息确认

        try

channel1.basicAck(envelope.getDeliveryTag(),false);

catch (IOException e)

e.printStackTrace();





;

// 关闭自动消息确认，autoAck = false

channel1.basicConsume(RabbitConfig.QUEUE_A,false, consumer);