当前位置: 首页 > news >正文

网站建设在实际工作中的意义自己怎么来建设网站

网站建设在实际工作中的意义,自己怎么来建设网站,策划书模板,官网网站模板Kafka生产者幂等性/事务幂等性事务Kafka 消息交付可靠性保障: Kafka 默认是:至少一次最多一次 (at most once) : 消息可能会丢失,但绝不会被重复发送至少一次 (at least once) : 消息不会丢失,但有可能被重复发送精确一次 (exact…

Kafka生产者幂等性/事务

  • 幂等性
  • 事务

Kafka 消息交付可靠性保障:

  • Kafka 默认是:至少一次
  • 最多一次 (at most once) : 消息可能会丢失,但绝不会被重复发送
  • 至少一次 (at least once) : 消息不会丢失,但有可能被重复发送
  • 精确一次 (exactly once) : 消息不会丢失,也不会被重复发送

Kafka 实现精确一次的两种机制:

  • 幂等性 (Idempotence) : 保证单分区、单会话上的消息幂等性
  • 事务 (Transaction) : 保证跨分区、跨会话间的幂等性, 性能更差

幂等性

幂等 : 某些操作执行多次,但每次结果都是一样的

  • 幂等性好处:安全地重试任何幂等性操作,不会破坏系统状态

Kafka-0.11.0.0 引入幂等性 Producer

Producer 幂等性启动:

props.put("enable.idempotence", ture);
// 或
props.put(ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG, true);

Kafka 自动实现消息的重复去重:

  • 用空间去换时间的优化思路
  • 当 Producer 发送了具有相同字段值的消息后,Broker 得知这些消息已经重复,就在后台丢弃掉

幂等性 Producer 的作用范围

  • 保证单分区的幂等性 :一个幂等性 Producer 只能保证某个主题的一个分区上不出现重复消息,无法实现多个分区的幂等性
  • 保证单会话的幂等性:当重启 Producer 后,该幂等性就丧失

事务

数据库的事务的 ACID : 原子性(Atomicity) ,一致性 (Consistency) , 隔离性 (Isolation) , 持久性 (Durability)

隔离性 :并发执行的事务彼此相互隔离,互不影响

已提交读 (read committed) :

  • 无脏读 : 当读取数据库时,只能看到已提交的数据
  • 无脏写 : 当写入数据库时,只能覆盖掉已提交的数据

Kafka-0.11 支持事务 :

  • read committed 隔离级别 :保证多条消息原子性地写入到目标分区,同时保证 Consumer 只能看到事务成功提交的消息

事务型 Producer 的作用范围:

  • 跨分区的幂等性:保证消息原子性地写入到多个分区中。要么全部写入成功,要么全部失败
  • 跨会话的幂等性:Producer 重启后,依然能精确一次处理

设置事务型 Producer :

  • 开启 enable.idempotence = true
  • 设置 Producer 端 transctional.id

调整 Producer 代码 :

  • initTransaction : 事务的初始化
  • beginTransaction : 事务开始
  • commitTransaction : 事务提交
  • abortTransaction : 事务终止
producer.initTransactions();try {producer.beginTransaction();//保证 Record1 和 Record2 为一个事务统一提交 Kafkaproducer.send(record1);producer.send(record2);producer.commitTransaction();
} catch (KafkaException e) {producer.abortTransaction();
}

写入失败消息,也会写入到日志中 :

  • Consumer 读取事务型 Producer 消息时,要设置 isolation.level

isolation.level 取值:

  • read_uncommitted (默认值) : Consumer 能读到 Kafka 写入的任何消息。用事务型 Producer,Consumer 不能用这个
  • read_committed : Consumer 只会读取事务型 Producer 成功提交事务写入的消息
http://www.yayakq.cn/news/571006/

相关文章:

  • 建设网站地图素材宁波seo优化公司
  • 任丘建设网站制作福安网站定制
  • 网站html代码英语营销型网站建设
  • 青岛大学网站建设厦门专业做优化的公司
  • wordpress 新建分类昆明seo网站
  • 网站设计人员就业要求网页制作教程免费视频
  • 网站登陆口提交网站网站开发制作
  • 制作介绍的网站模板ps制作个人网站首页
  • seo诊断网站免费诊断平台网站系统分析报告
  • 100m网站空间服务费保定网站建设浩森宇特
  • 怎样做网站底部导航重庆网站排名优化
  • wordpress做直播网站采购网站平台
  • 不用关网站备案加工企业网站这么做
  • 网站怎么做交易平台关于wordpress 反馈
  • 京东网站建设流程和结构图网站建设怎么让百度搜索到
  • 网站建设和赚钱方法网站建设公司位置
  • 可以自己做斗图的网站东莞网络营销全网推广
  • flash 企业网站 源码上传wordpress到
  • 开源php企业网站北京市430场新闻发布会
  • 江阴市建设局网站商用营销型网站建设
  • 网站建设毕业设计心得企业门户网站开发要多少钱
  • 找别人做网站的注意事项wordpress qq登录代码
  • 孝感做网站公司课程网站开发的研究现状
  • 外国 网站模板网络平台推广
  • 上海企业网站制作方法中国交通建设集团有限公司招标网
  • 网站空间到期时间查询国外搜索网站排名
  • 众筹网站建设企石做网站
  • 福田我要做网站优化比较好网站优化排名易下拉霸屏
  • 注册查询网站网站建设选哪家公司
  • 在线音乐网站开发现状php网站开发总结文档