首页
题库
公司真题
专项练习
面试题库
在线编程
面试
面试经验
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
...
实习周报不要再写流水账了
3.8W
2
...
算一笔账
9554
3
...
毕业之后再也没人给我兜底了
8565
4
...
快手凉经
8090
5
...
差点忘了以前是干嘛的,这个梗就是2025年最大的一坨
7928
6
...
工资还是得攒着
5791
7
...
字节暑期实习刚oc要不要去
3841
8
...
高德-交易业务-Java日常-面经(OC)
3745
9
...
这样的实习,我还有必要坚持下去吗?
3617
10
...
女友问我为什么进字节后不理她了
3312
创作者周榜
更多
正在热议
更多
#
如何准备秋招
#
10990次浏览
192人参与
#
软开人,秋招你打算投哪些公司呢
#
100867次浏览
945人参与
#
现代汽车前瞻技术研发急速编程挑战赛
#
22304次浏览
185人参与
#
你觉得实习能学到东西吗
#
15896次浏览
379人参与
#
秋招什么时候开投比较合适?
#
6634次浏览
146人参与
#
实习,不懂就问
#
27928次浏览
449人参与
#
每个月的工资都是怎么分配的?
#
14196次浏览
312人参与
#
你觉得实习只能是打杂吗?
#
192393次浏览
1223人参与
#
你们公司几号发工资
#
18933次浏览
128人参与
#
你觉得现在还能进互联网吗?
#
4541次浏览
99人参与
#
非技术岗简历怎么写
#
216823次浏览
2918人参与
#
预测一下26届秋招形势
#
24384次浏览
239人参与
#
技术岗笔试题求解
#
75432次浏览
974人参与
#
你最近一次加班是什么时候?
#
67826次浏览
346人参与
#
高考出分的那一天,我__
#
16282次浏览
266人参与
#
聊聊你的职场新体验
#
161387次浏览
1391人参与
#
打工人的精神状态
#
53975次浏览
987人参与
#
大家实习每天都在干啥
#
82842次浏览
506人参与
#
米哈游工作体验
#
17748次浏览
116人参与
#
来聊聊你认为的薪资天花板是哪家?
#
30853次浏览
174人参与
#
机械实习一天多少钱合适?
#
28949次浏览
176人参与
牛客网
牛客网在线编程
牛客网题解
牛客企业服务