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

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

news 来源：原创 2025/4/26 21:15:37

在这里插入图片描述

  • 我们的程序在面对 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】深入解析自定义拦截器、注册配置拦截器、拦截路径方法及常见拦截路径、排除拦截路径、拦截器的执行流程
  • 地下管道密布成难题，道路修整如何破局？
  • 上海2025年普通高等学校招生志愿填报与投档录取实施办法公布
  • 4500万失能人员如何养老？没参保是否能享受长护师服务？
  • 京东美团商战，能惠及骑手吗？
  • 著名电化学家、我国工业电化学奠基人之一郭鹤桐逝世
  • 服务业扩大开放，金融、医疗等多领域明确155项试点任务