java rabbitmq BasicCancel代码示例

以下是Java RabbitMQ中BasicCancel的代码示例：

import com.rabbitmq.client.*;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class Consumer {
    private final static String QUEUE_NAME = "queue_name";

    public static void main(String[] args) throws IOException, TimeoutException {
        // 创建连接和通道
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        // 声明队列
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        // 创建消费者
        String consumerTag = channel.basicConsume(QUEUE_NAME, false, "myConsumerTag",
                new DefaultConsumer(channel) {
                    public void handleDelivery(String consumerTag, Envelope envelope,
                                               AMQP.BasicProperties properties, byte[] body) throws IOException {
                        String message = new String(body, "UTF-8");
                        System.out.println("Received '" + message + "'");
                        channel.basicAck(envelope.getDeliveryTag(), false);
                    }
                });

        // 取消订阅
        channel.basicCancel(consumerTag);
    }
}

在这个示例中，我们首先创建了一个连接和通道，然后声明了一个队列。接下来，我们创建了一个消费者，并订阅了队列。最后，我们使用`basicCancel()`方法取消了订阅。