Connection connection = factory.newConnection();
Channel channel = connection.createChannel();

// 聲明隊(duì)列
String queueName = "simpleQueue";
channel.queueDeclare(queueName, false, false, false, null);

// 發(fā)送消息
String message = "Hello, RabbitMQ!";
channel.basicPublish("", queueName, null, message.getBytes("UTF-8"));
System.out.println("Sent message: " + message);

// 接收消息
boolean autoAck = true;
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("Received message: " + message);
    }
};
channel.basicConsume(queueName, autoAck, consumer);

// 創(chuàng)建連接和通道
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();

// 聲明隊(duì)列
String queueName = "workQueue";
channel.queueDeclare(queueName, false, false, false, null);

// 發(fā)送消息
String message = "Hello, RabbitMQ!";
channel.basicPublish("", queueName, null, message.getBytes("UTF-8"));
System.out.println("Sent message: " + message);

// 設(shè)置每個(gè)消費(fèi)者在接收到確認(rèn)前只能處理一條消息
channel.basicQos(1);

// 接收消息
boolean autoAck = false;
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("Received message: " + message);
        // 手動(dòng)發(fā)送消息確認(rèn)
        channel.basicAck(envelope.getDeliveryTag(), false);
    }
};
channel.basicConsume(queueName, autoAck, consumer);

// 創(chuàng)建連接和通道
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();

// 聲明交換器
String exchangeName = "publishSubscribeExchange";
channel.exchangeDeclare(exchangeName, "fanout");

// 創(chuàng)建隨機(jī)隊(duì)列并綁定到交換器
String queueName = channel.queueDeclare().getQueue();
channel.queueBind(queueName, exchangeName, "");

// 發(fā)送消息
String message = "Hello, RabbitMQ!";
channel.basicPublish(exchangeName, "", null, message.getBytes("UTF-8"));
System.out.println("Sent message: " + message);

// 接收消息
boolean autoAck = true;
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("Received message: " + message);
    }
};
channel.basicConsume(queueName, autoAck, consumer);

// 創(chuàng)建連接和通道
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();

// 聲明交換器
String exchangeName = "routingExchange";
channel.exchangeDeclare(exchangeName, "direct");

// 綁定隊(duì)列到交換器，并指定路由鍵
String queueName = "routingQueue";
String routingKey = "important";
channel.queueDeclare(queueName, false, false, false, null);
channel.queueBind(queueName, exchangeName, routingKey);

// 發(fā)送消息
String message = "Important message!";
channel.basicPublish(exchangeName, routingKey, null, message.getBytes("UTF-8"));
System.out.println("Sent message: " + message);

// 接收消息
boolean autoAck = true;
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("Received message: " + message);
    }
};
channel.basicConsume(queueName, autoAck, consumer);

// 創(chuàng)建連接和通道
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();

// 聲明交換器
String exchangeName = "topicExchange";
channel.exchangeDeclare(exchangeName, "topic");

// 綁定隊(duì)列到交換器，并指定匹配模式
String queueName = "topicQueue";
String routingKeyPattern = "com.example.*";
channel.queueDeclare(queueName, false, false, false, null);
channel.queueBind(queueName, exchangeName, routingKeyPattern);

// 發(fā)送消息
String routingKey = "com.example.news";
String message = "Important news!";
channel.basicPublish(exchangeName, routingKey, null, message.getBytes("UTF-8"));
System.out.println("Sent message: " + message);

// 接收消息
boolean autoAck = true;
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("Received message: " + message);
    }
};
channel.basicConsume(queueName, autoAck, consumer);