首页
题库
公司真题
专项练习
面试题库
在线编程
面试
面试经验
AI 模拟面试
简历
求职
学习
基础学习课
实战项目课
求职辅导课
专栏&文章
竞赛
我要招人
发布职位
发布职位、邀约牛人
更多企业解决方案
AI面试、笔试、校招、雇品
HR免费试用AI面试
最新面试提效必备
登录
/
注册
每天都说我是过儿
2019-07-31 14:22
已编辑
西北大学 Java
关注
已关注
取消关注
java:生产者和消费者
消息队列的生产者消费者中消费者没有收到消息怎么办,消息有顺序比如1.2.3但是收到的却是1.3.2怎么办?消息发过来的过程中损坏或者出错怎么办?
提示
全部评论
推荐
最新
楼层
薛8
门头沟学院 Java
在生产者端保证顺序就好了,比如消息按顺序都放在一个队列,然后消费者端只用一个线程消费。
点赞
回复
分享
发布于 2019-07-31 13:06
Zwiebeln_Chan
南京理工大学 Java
生产者消费者模型据我所知好像不特别强调消息的有效性和顺序吧?主要是用来同步生产者和消费者之间的顺序的
点赞
回复
分享
发布于 2019-07-31 12:27
星雨诚
招商银行信用卡中心_信息技术部_应用开发
从生产者的角度看,消息队列通过常见的请求确认机制保障消息的可靠传输,因此,当生产者就消息传输到broker中时,需要注意正确处理broker返回的确认或者异常信息,以保证信息可靠传输,生产者一旦收到异常消息,便会重发消息。 从broker的角度看,只要broker正常运行,就不会丢失消息。但是broker进程或者是服务器宕机了,就可能丢失消息。如果可靠性要求较高,那么可以通过设置broker参数来避免因为宕机而丢失消息,例如刷盘和复制的配置项。 从消费者的角度看,也是通过请求确认的机制来保障消息的可靠传输,可以在消费者业务处理逻辑全部结束之后再将确认响应回复给broker,若broker没有收到确认响应,那么下次消费者再次拉取消息时,仍然会拉取未成功拉取的那条消息。
2
回复
分享
发布于 2019-08-01 13:05
星雨诚
招商银行信用卡中心_信息技术部_应用开发
另外,关于消息有序性的问题,如果broker用于接收消息的topic(承载真实数据的逻辑容器)是一个分区,那么有序性是可以得到保障,但是这就会丧失其消息队列高吞吐量的能力,因此topic可以进行多个分区,那么要想保证负载均衡,我们希望尽可能将数据均匀地分散到多个分区中,这个时候设置合适的分区策略也可以保证消息的有序性,例如Key-ordering。
点赞
回复
分享
发布于 2019-08-01 16:28
卑微搬砖工
西安交通大学 Java
听着咋感觉你在说tcp、
点赞
回复
分享
发布于 2019-07-31 14:21
暂无评论,快来抢首评~
相关推荐
06-26 08:54
中国地质大学 Java
北京京东一面,虽然问题常见但是有深度
最近由于三大外卖平台“打仗”,优惠券多到数不过来,一日三餐每个平台各点一单哈哈哈,正好最近组织内部还有朋友在北京的京东面试过,分享一下她的面经(Java岗):1. Kafka消息不丢失问题,Kafka本身会去保证消息的不丢失,为什么还需要存一个本地消息表来保证消息的不丢失呢?Kafka 本身通过副本机制、生产者确认(acks)、消费者手动提交等设计理论上可以实现消息不丢失,但在实际分布式系统中,由于业务逻辑复杂性、中间件与业务操作的原子性难以保障,仍需要引入“本地消息表”等额外机制。以下是具体原因及解决方案的对比分析:Kafka 消息不丢失的机制及其局限性生产者端acks=-1:要求所有 IS...
京东一面337人在聊
点赞
评论
收藏
分享
06-28 01:54
已编辑
门头沟学院 安卓
佬们快来笑我
小厂安卓,记录一下答得不好的音乐的焦点还是啥?听不清。有的api需要token,有的不需要,如何实现注入。面试官说参考spring的aop,忘完了。rxjava的flatmap和map的区别。没用过不会。viewpage嵌套rv,rv内部还有横向滑动的view,如何解决滑动冲突。juc里的countdownlaunch,semaphore,还有个啥听不清,countdownlaunch实现原理。忘完了。那你怎么实现生产者消费者,答reentrantlock+condition。不满意,问怎么用线程池实现(这里他的意思应该是问线程池的底层原理)。lifecycle的原理还是啥啥啥,听不清。协程的原理。答语言实现的,挂起释放子线程避免阻塞。不满意。
查看15道真题和解析
点赞
评论
收藏
分享
06-10 09:36
中国地质大学 Java
字节还是那么喜欢考算法
今天分享的是训练营的朋友在字节跳动的面经,整个面试过程差不多一个小时,一半时间拷打八股,一半时间拷打算法,字节还是那么喜欢考算法。面经详解1 讲讲项目难易点常考的问题,对于自己的项目可以提前准备好话术2 kafka处理消息丢失和消息重复在分布式消息系统如Apache Kafka中,消息丢失和消息重复是两个常见的问题。为了解决这些问题,可以采取一系列的措施和技术手段。以下是一些处理Kafka消息丢失和消息重复的方法:消息丢失确认机制:确保消费者在成功处理完消息后才提交偏移量(offset),这可以通过设置enable.auto.commit=false并手动管理偏移量来实现。持久化配置:设置适当...
点赞
评论
收藏
分享
06-17 12:36
中国科学技术大学 Java
百度二面凉经
1. 介绍项目2. redis预检成功,数据库扣减失败怎么办3. 用过压测吗,有什么指标4. 分布式锁逻辑,底层原理5. 讲讲大模型相关6. 场景题:抖音消息推送架构设计的讨论(抖音大 V 更新视频,需设计架构让大量粉丝收到通知)推模式怎么优化,瓶颈在哪,压力在哪7. 上述生产者消息队列消费者瓶颈,消息积压相关8. 数据库写入压力大怎么优化
查看8道真题和解析
点赞
评论
收藏
分享
06-19 00:26
已编辑
门头沟学院 测试开发
【社招】百度一面
前文:①感觉她是不是在看着题库出题啊,每次我说完了等她的反应都很慢;②她是不是对我不感兴趣啊,业务和项目都没有深挖,我主要负责的也没有深挖1.自我介绍2.项目介绍(但不是我主要负责的,而是跟mt的)3.Java熟悉一些对吧?Java创建线程有哪些方式?4.Java的线程和进程的区别?5.HTTPS和HTTP的区别(心想:这是在校招?怎么全是计算机基础)6.equals和==的区别,什么时候用equals,可以举个例子吗==是地址,equals是值,往往需要重写hashCode方法7.场景题:百度app的搜索功能设计用例因为我没用过百度app,换成:安卓机下,抽奖功能如何设计测试用例8.做个题吧...
牛客创作赏金赛
点赞
评论
收藏
分享
评论
点赞成功,聊一聊 >
点赞
收藏
分享
评论
提到的真题
返回内容
全站热榜
更多
1
...
高德-交易业务-Java日常-面经(OC)
6998
2
...
大家觉得测试还能活多久
4783
3
...
快手凉经
4319
4
...
毕业之后再也没人给我兜底了
4204
5
...
差点忘了以前是干嘛的,这个梗就是2025年最大的一坨
3610
6
...
工资还是得攒着
2633
7
...
女友问我为什么进字节后不理她了
2615
8
...
字节暑期实习刚oc要不要去
2143
9
...
拒offer时hr很生气怎么办
2136
10
...
真想当一辈子的实习生混吃混喝
2122
创作者周榜
更多
正在热议
更多
#
你觉得实习能学到东西吗
#
23187次浏览
533人参与
#
不考虑转正,实习多久合适
#
30319次浏览
137人参与
#
现代汽车前瞻技术研发急速编程挑战赛
#
23472次浏览
195人参与
#
秋招什么时候开投比较合适?
#
11869次浏览
223人参与
#
如何准备秋招
#
14282次浏览
271人参与
#
实习,不懂就问
#
34552次浏览
572人参与
#
发工资后,你做的第一件事是什么
#
66724次浏览
221人参与
#
软开人,秋招你打算投哪些公司呢
#
101555次浏览
956人参与
#
如果你有一天可以担任公司的CEO,你会做哪三件事?
#
28415次浏览
458人参与
#
运营人求职交流聚集地
#
141481次浏览
989人参与
#
大疆今年的机械笔试难吗?
#
41767次浏览
456人参与
#
每个月的工资都是怎么分配的?
#
18425次浏览
369人参与
#
你觉得现在还能进互联网吗?
#
5671次浏览
116人参与
#
预测一下26届秋招形势
#
29910次浏览
271人参与
#
你们公司几号发工资
#
19374次浏览
130人参与
#
25届如何提前做秋招准备?
#
171958次浏览
2482人参与
#
硬件应届生薪资是否普遍偏低?
#
72894次浏览
511人参与
#
晒一晒你收到的礼盒
#
70472次浏览
403人参与
#
米哈游工作体验
#
17998次浏览
117人参与
#
打工人的精神状态
#
54957次浏览
997人参与
#
高考出分的那一天,我__
#
18739次浏览
277人参与
牛客网
牛客网在线编程
牛客网题解
牛客企业服务