可以利用该框架简单快捷的开发项目

kube-azure-servicebus-autoscaler :glowing_star: 该项目是 Kubernetes Pod自动缩放器基于Azure Service Bus队列中的队列大小。 它会定期检索队列中的消息数，并相应地缩放窗格。 配置 设置kube-azure-servicebus-autoscaler需要两个步骤： 在Secrets中添加Service Prinicipal凭证，订阅ID和租户ID，以便它可以读取队列中的消息数。 将其作为集群服务部署在集群中 部署kube-azure-servicebus-autoscaler 部署kube-azure-servicebus-autoscaler应该与应用此部署一样简单： --- apiVersion : extensions/v1beta1 kind : Deployment metadata : name : kube-azure-servicebus-autoscaler labels : app : kube-azure-servicebus-autoscaler spec :

Apache Pulsar 是 Apache 软件基金会顶级项目，是下一代云原生分布式消息流平台，集消息、存储、轻量化函数式计算为一体，采用计算与存储分离架构设计，支持多租户、持久化存储、多机房跨区域数据复制，具有强一致性、高吞吐、低延时及高可扩展性等流数据存储特性。

Apache Pulsar 是 Apache 软件基金会顶级项目，是下一代云原生分布式消息流平台，集消息、存储、轻量化函数式计算为一体，采用计算与存储分离架构设计，支持多租户、持久化存储、多机房跨区域数据复制，具有强一致性、高吞吐、低延时及高可扩展性等流数据存储特性。

跨平台/全局/消息队列/共享内存/信号量/自动解锁 //1个进程读,1个进程写 //windows 1000万条 19秒 //linux 1000万条 3秒 //1个进程读,2个进程写 //windows 2000万条 80秒 //linux 2000万条 23秒 //linux编译测试，加1个参数与不加参数来区分读写队列 //g++ -o t -D MESSAGE_QUEUE_TRACE MessageQueueMain.cpp -lpthread && ./t -r //清理消息队列编译命令 //g++ -o t -D MESSAGE_QUEUE_TRACE -D MESSAGE_QU

Qt 线程任务队列demo，见博客 https://blog.csdn.net/yonggandess/article/details/107227435

队列使用全集

Apache Kafka 企业级消息队列的原理、基本架构、搭建 Kafka 集群、操作集群的两种方式、Apache Kafka 原理、消费策略、负载均衡等。

Kafka的基本介绍 Kafka是最初由Linkedin公司开发，是一个分布式、分区的、多副本的、多订阅者，基于zookeeper协调的分布式日志系统（也可以当做MQ系统），常见可以用于web/nginx日志、访问日志，消息服务等等，Linkedin于2010年贡献给了Apache基金会并成为顶级开源项目。

在 Pulsar 里，可以基于 geo-replication 将数据在多个机房进行复制，这个特性主要是复制的消息数据，而今天我们分享的主要是订阅状态的跨机房同步。 订阅状态主要指订阅的消费进度，开启订阅状态跨机房复制可以在其中某个机房出现故障时，consumer 切换其他机房可以根据消费进度继续进行消费，这样可以减少消息的重复消费以及consumer丢失消息的问题。