响应式网站建设平台,嘉兴企业网站设计哪家好,西安网站建设哪里好,网站建设税费文章目录 1. 如何防⽌消息丢失2. 如何防⽌重复消费3. 如何做到消息的顺序消费4. 如何解决消息积压问题4.1 消息积压问题的出现4.2 消息积压的解决⽅案 5. 实现延时队列的效果5.1 应用场景5.2 具体方案 1. 如何防⽌消息丢失
⽣产者#xff1a;1#xff09;使⽤同步发送 21使⽤同步发送 2把ack设成1或者all并且设置同步的分区数2消费者把⾃动提交改成⼿动提交
2. 如何防⽌重复消费
在防⽌消息丢失的⽅案中如果⽣产者发送完消息后因为⽹络抖动没有收到ack但实际上broker已经收到了。此时⽣产者会进⾏重试于是broker就会收到多条相同的消息⽽造成消费者的重复消费。
怎么解决
⽣产者关闭重试会造成丢消息不建议消费者解决⾮幂等性消费问题 所谓的幂等性多次访问的结果是⼀样的。对于rest的请求get幂等、post⾮幂 等、put幂等、delete幂等 解决⽅案 1.在数据库中创建联合主键防⽌相同的主键 创建出多条记录 2.使⽤分布式锁以业务id为锁。保证只有⼀条记录能够创建成功 3. 如何做到消息的顺序消费
⽣产者保证消息按顺序消费且消息不丢失——使⽤同步的发送ack设置成⾮0的值。消费者主题只能设置⼀个分区消费组中只能有⼀个消费者
kafka的顺序消费使⽤场景不多因为牺牲掉了性能但是⽐如rocketmq在这⼀块有专⻔的功能已设计好。
4. 如何解决消息积压问题
4.1 消息积压问题的出现
消息的消费者的消费速度远赶不上⽣产者的⽣产消息的速度导致kafka中有⼤量的数据没有被消费。随着没有被消费的数据堆积越多消费者寻址的性能会越来越差最后导致整个kafka对外提供的服务的性能很差从⽽造成其他服务也访问速度变慢造成服务雪崩。
4.2 消息积压的解决⽅案
在这个消费者中使⽤多线程充分利⽤机器的性能进⾏消费消息。通过业务的架构设计提升业务层⾯消费的性能。创建多个消费组多个消费者部署到其他机器上⼀起消费提⾼消费者的消费速度创建⼀个消费者该消费者在kafka另建⼀个主题配上多个分区多个分区再配上多个 消费者。该消费者将poll下来的消息不进⾏消费直接转发到新建的主题上。此时新 的主题的多个分区的多个消费者就开始⼀起消费了。——不常⽤
5. 实现延时队列的效果
5.1 应用场景
订单创建后超过30分钟没有⽀付则需要取消订单这种场景可以通过延时队列来实现
5.2 具体方案 kafka中创建创建相应的主题消费者消费该主题的消息轮询消费者消费消息时判断消息的创建时间和当前时间是否超过30分钟前提是订单没⽀付 如果是去数据库中修改订单状态为已取消。 如果否记录当前消息的offset并不再继续消费之后的消息。等待1分钟后再次向kafka拉取该offset及之后的消息继续进⾏判断以此反复。
