RabbitMQ再回首--往事如梦

AMQP.BasicProperties.Builder builder = new AMQP.BasicProperties.Builder();
//对应页面上的Properties部分，传入一些预定的参数值。
builder.deliveryMode(MessageProperties.PERSISTENT_TEXT_PLAIN.getDeliveryMode());//持久化
builder.priority(MessageProperties.PERSISTENT_TEXT_PLAIN.getPriority());//持久化
//builder.headers(headers);对应页面上的Headers部分。传入自定义的参数值
builder.build()
AMQP.BasicProperties prop = builder.build();

RabbitMQ持久化机制-CSDN博客

public BasicProperties(
            String contentType,//消息类型如：text/plain
            String contentEncoding,//编码
            Map<String,Object> headers,
            Integer deliveryMode,//1:nonpersistent不持久化 2:persistent持久化
            Integer priority,//优先级
            String correlationId,
            String replyTo,//反馈队列
            String expiration,//expiration到期时间
            String messageId,
            Date timestamp,
            String type,
            String userId,
            String appId,
            String clusterId)

consumer消费消息

• 被动消费：服务器推送，消费者设置缓冲区缓存，效率是高了但是缓冲区可能溢出 一口胖成🪣（这届奥运会的谐音梗 你懂不懂）

String basicConsume(String queue, DeliverCallback deliverCallback, CancelCallback
cancelCallback, ConsumerShutdownSignalCallback shutdownSignalCallback) throws
IOException;
    Callback，可实现handle方法

• 主动消费：拉取msg，需要时拉取 增加消息延迟/降低系统吞吐量；单条 注意啊 单条

       GetResponse response = channel.basicGet(QUEUE_NAME, boolean autoAck);

        autoAck=true，消息被consumer消费成功后，无法再消费，一次性的 懂？

        autoAck=false，需手动调channel.basicAck(),不凋则重复消费 资源多就是这么豪横

消费场景

 他又来了 真的是 大水冲了龙王庙 不是一家人不进一家门

一，pro 送一个 msg 到que，不需要exchange，con按que 消费

二，pro发送msg到que，多con消费同一个队列queue

• con 的autoAck=false，调channel.basicAck通知服务器消息完成，否则重复消费
• msg持久，queue不能被多次定义，一旦接受了durable的设定就守身如玉，及时改了 骨子里还是durable
• channel.basicQos(prefetchCount) ;consumer同时处理msg个数，发送msg前检查发送但未收到basicAck有几个，如超过prefetchCount则换一个consumer；这样始乱终弃当然有问题了，all节点都超了，怎么办？宝宝就问你怎么办？及时发现 添加节点 再者你就换 下一个更乖

// 创建连接和通道
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
 
// 声明交换器
String exchangeName = "publishSubscribeExchange";
channel.exchangeDeclare(exchangeName, "fanout");
 
// 创建随机队列并绑定到交换器
String queueName = channel.queueDeclare().getQueue();
channel.queueBind(queueName, exchangeName, "");
 
// 发送消息
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);