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

Golang|Kafka在秒杀场景中的应用

在这里插入图片描述

  • 我们的程序在面对 kill -9 这样的指令的时候会直接退出,不能保证数据持久化到mysql完后再退出
  • 而且我们现在的并发量仍然不够,只能加机器,多机器并发写mysql可能导致mysql扛不住,mysql写的并发量不能根据我们机器的数量的增长而增长
  • 考虑使用消息队列mq,当抽中奖品后把订单消息写入kafka中去,然后又其他服务器起kafka消费者去读取订单信息写入kafka

在这里插入图片描述
在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

  • 对应的,需要修改我们的抽奖函数

在这里插入图片描述
在这里插入图片描述

在这里插入图片描述

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

  • 数据在kafka里面是不会丢的,下次启动可以继续写入

相关文章:

  • day29图像处理OpenCV
  • gitlab如何查看分支的创建时间
  • tomcat http 怎么改成 https
  • 如何安全地管理固定功能设备?
  • STM32移植文件系统FATFS——片外SPI FLASH
  • 房天下平台API接口开发指南
  • Android12 自定义系统服务
  • Cython中操作C++字符串
  • BLUE-ANT 静电防护
  • PDX列式存储
  • HarmonyOS 5 开发环境全解析:从搭建到实战
  • 鹰角:EMR Serverless Spark 在《明日方舟》游戏业务的应用
  • 2025年4月15日 百度一面 面经
  • MongoDB入门与安装指南
  • 递归查询的应用
  • Python自动化处理奖金分摊:基于连续空值的智能分配算法升级
  • 树莓派超全系列教程文档--(26)在 Raspberry Pi 上配置热点
  • html页面打开后中文乱码
  • 【树莓派Pico FreeRTOS】-事件标志(Event Flags)与事件组(Event Groups)
  • 【SpringBoot】深入解析自定义拦截器、注册配置拦截器、拦截路径方法及常见拦截路径、排除拦截路径、拦截器的执行流程
  • 抗战回望15︱《五月国耻纪念专号》:“不堪回首”
  • 安徽安庆市委书记张祥安调研假日经济和旅游安全工作
  • 魔都眼|买买买,老铺黄金新店开业被挤爆:有人排队5小时
  • “网约摩托”在部分县城上线:起步价五六元,专家建议纳入监管
  • 马上评|科学谋划“十五五”,坚定不移办好自己的事
  • 两部门预拨4000万元支持山西、广西、陕西做好抗旱救灾工作