网站安全管理制度建设,广州从化发布,网站flash,河南省监理协会官方网站建设应用场景#xff1a; 1、解耦 2、削峰填谷 3、异步处理 4、消息通讯
工作模式#xff1a; 一个消息只能被消费一次#xff08;订阅模式除外#xff09;#xff0c;消费者接受到消息会回调业务逻辑#xff0c;消费逻辑写在回调函数里面。 1、简单模式#xff1a;一个生产…应用场景 1、解耦 2、削峰填谷 3、异步处理 4、消息通讯
工作模式 一个消息只能被消费一次订阅模式除外消费者接受到消息会回调业务逻辑消费逻辑写在回调函数里面。 1、简单模式一个生产者对应一个消费者使用阻塞队列生产者发送消息到消息队列消息队列属于生产者生产者声明消息队列消费者来消费这个队列 2、工作队列模式一个生产者多个消费者使用阻塞队列生产者发送消息到消息队列消息队列属于生产者生产者声明消息队列消费者来消费这个队列 默认每个消费者消费消息数量平均但是每个消费者消化速度不一致有的快有的慢可以将prefetchCount设置为1每个消费者同时只能处理一个消息在收到ack之前不会把消息分发给他(必须在手动ack下才生效) 3、发布订阅模式一个生产者多个消费者。生产者发送消息给exchange交换机消费者将队列绑定到交换机上交换机把消息发送给队列。交换机无法存储消息。生产者声明交换机消费者声明自己的消息队列并绑定到声明的交换机上。发布订阅模式无法保证消息只被消费一次无法保证消息的幂等性 交换机发给哪个消费者的消息队列呢 1、广播交换机把消息发送给所有绑定到交换机的消息队列 2、定向交换机发动给制定routing key的消息队列消费者绑定消息队列到交换机的时候可以声明消费队列的routing key。 3、通配符生产者使用通配符发送给符合规则的routing key的消息队列。
如何保证消息不丢失 1、消息确认机制 如果消费者领取消息会向mq发送ackmq收到ack会把消息队列中这个消息删除但是若业务逻辑还没执行完毕就挂掉了消息就丢失了。可以将ack设置为手动领取到消息后业务逻辑执行完最后在发送ack。但是手动ack机制可能会消息一直重复如果这条消息处理过程中抛异常不发送ack这条消息就会不断被消费其他消息就不会被消费。 2、mq挂了所有消息全部丢失。 可以将交换机和消息队列持久化。
幂等性一个方法被执行多次和执行一次产生的效果相同。 订阅模式一个消息被多个消费者消费一个消息被消费多次。 但是普通模式也可能出现一个消息被消费多次比如消费者自动ack或者手动发送ack发送ack超时mq没有接收到ack就不会删除这条消息继续被消费者消费。
如何保证消息的幂等性 给每条消息都加上全局唯一idmq虽然给每个消息都加了messageId但是这个在分布式环境下并不是全局唯一的。把唯一id放到redis如果存在就是被消费过了。或者在数据库层面使用唯一键约束
如何避免消息积压 1、多个消费者监听一个消息队列 2、消费者不断消费消息处理消息使用线程池进行异步处理 3、查看日志是否有消费者异常手动ack模式下不断重复消费一个消息消费消息抛异常没回ack这个消息不断重复消费
