使用paho的MQTT时遇到的重连导致订阅无法收到问题和解决
最近在使用MQTT来实现消息的传输,网上demo很多,这里就不在重复介绍了,直接上代码,百度就能出现一大堆
下面是MQTT实现订阅的主要代码部分
MqttClient client = new MqttClient(HOST, clientid, new MemoryPersiste...
Kafka vs RocketMQ——Topic数量对单机性能的影响
上一期我们对比了三类消息产品(Kafka、RabbitMQ、RocketMQ)单纯发送小消息的性能,受到了程序猿们的广泛关注,其中大家对这种单纯的发送场景感到并不过瘾,因为没有任何一个网站的业务只有发送消息。本期,我们就来模拟一个真实的场景:
消息的发送和订阅一定是共存的
要支持多..
交易系统架构
交易系统的业务域是什么?即交易系统应该负责那些内容。
面对多样性的业务场景,交易系统如何承接他们?即交易系统的业务扩展性如何保证。
交易系统的复杂性问题,以及如何处理,特别是业务、系统解耦问题。
事件驱动流程。
简述高并发与高可用技术。
在ESP32上使用umqtt接入阿里云物联网平台
网络上已经有使用python 模拟设备接入阿里云,手里刚好有块ESP32的小板子,在上面跑过Alios Things,然后接入阿里云。但是终究感觉麻烦,有的时候只是做一个很简单的应用,跑os确实不太方便。
Kafka vs RocketMQ——单机系统可靠性
引言
前几期的评测中,我们对比了Kafka和RocketMQ的吞吐量和稳定性,本期我们要引入一个新的评测标准——软件可靠性。
何为“可靠性”?
先看下面这种情况:有A,B两辆越野汽车,在城市的周边地区均能很好应对泥泞的路况。当一同开去穿越西藏,A车会因为西藏本地的汽油不达标,导致油路受阻无