# 云消息队列 MQ #
1
关注
12100内容
Kafka 简单介绍
Kafka 简单介绍
物联网中的数据收集与处理技术
【5月更文挑战第31天】物联网依赖数据收集与处理技术实现智能化和价值化。传感器实时采集各类信息，但数据多样、复杂及海量性带来挑战。MQTT等协议用于高效传输，Python示例展示了数据发布。数据处理涉及清洗、转换和分析，如机器学习用于故障预测。实时数据处理技术确保高时效性应用的需求。持续的技术创新将推动物联网在各领域的广泛应用。
MQTT 5.0 报文解析 05：DISCONNECT
在 MQTT 中，客户端和服务端可以在断开网络连接前向对端发送一个 DISCONNECT 报文，来指示连接关闭的原因。客户端发送的 DISCONNECT 报文还可以影响服务端在连接断开后的行为，例如是否发送遗嘱消息，是否更新会话过期间隔。
RocketMQ实战教程之常见概念和模型
Apache RocketMQ 实战教程介绍了其核心概念和模型。消息是基本的数据传输单元，主题是消息的分类容器，支持字节、数字和短划线命名，最长64个字符。消息类型包括普通、顺序、事务和定时/延时消息。消息队列是实际存储和传输消息的容器，是主题的分区。消费者分组是一组行为一致的消费者的逻辑集合，也有命名限制。此外，文档还提到了一些使用约束和建议，如主题和消费者组名的命名规则，消息大小限制，请求超时时间等。RocketMQ 提供了多种消息模型，包括发布/订阅模型，有助于理解和优化消息处理。
秒杀项目实战：遇到的问题及解决方案分享
构建了一个基于Springboot2的秒杀系统。项目利用K8S上的主从结构部署Redis和MySQL，通过Traefik作为网关。RabbitMQ在本地虚拟机的docker环境中，用Prometheus+Grafana监控。设计思路包括隐藏秒杀地址以防止脚本攻击，使用Lua脚本保证库存预扣原子性，但初期版本未处理重复订单校验。为防止MQ故障，将订单信息先保存到Redis，再通过脚本发送到MQ。采用分布式锁防止用户重复下单和缓存击穿问题，使用编程式事务确保库存扣减与订单保存一致性。项目通过JMeter测试，观察性能并分析Redis和RabbitMQ的使用情况。完整代码可在GitHub找到。
性能工具之 Kafka 快速 BenchMark 测试示例
【5月更文挑战第24天】性能工具之 Kafka 快速 BenchMark 测试示例
RocketMQ实战教程之NameServer与BrokerServer
这是一个关于RocketMQ实战教程的概要，主要讨论NameServer和BrokerServer的角色。NameServer负责管理所有BrokerServer，而BrokerServer存储和传输消息。生产者和消费者通过NameServer找到合适的Broker进行交互，不需要直接知道Broker的具体信息。工作流程包括生产者向NameServer查询后发送消息到Broker，以及消费者同样通过NameServer获取消息进行消费。这种设计类似于服务注册中心的概念，便于系统扩展和集群管理。
SpringAMQP开启“可靠性”机制
SpringAMQP开启“可靠性”机制
免费试用