Spring集成MQTT推送消息
(mqtt java客户端的使用参看这篇文章)
Spring Integration基于Eclipse Paho MQTT客户端库提供了支持MQTT协议的入站和出站通道适配器。
跟阿里大牛捞干货:2019年带你玩转人工智能、大数据
2019年,你都立了哪些flag?等一年之后回头看看,这些flag都能拔掉吗?其实新的一年已经过去一周多了,这一周你是怎样过的,有没有一点小小的进步?为了让你的2019年过得充实,不虚度,华章计算机小编今天推荐10本书,作者来自于阿里的技术大牛,内容都是跟当前持续火爆的大数据行业相关。
rocketMq-Topic创建过程
Topic可以理解为在rocketMq体系当中作为一个逻辑消息组织形式,一般情况下一类业务消息会申请一个topic来实现业务之间隔离。
Topic的存储
Topic的实际存储模型
说明:
该图分享自: RocketMQ概念模型
Topic是一个逻辑上的概念,实际上在每个broker上以queue的形式保存,也就是说每个topic在broker上会划分成几个逻辑队列,每个逻辑队列保存一部分消息数据,但是保存的消息数据实际上不是真正的消息数据,而是指向commit log的消息索引。
消息中间件系列五、rabbit消息的确认机制
一、消息的确认机制
1、消费者收到的每一条消息都必须进行确认。(分为自动确认和消费者自行确认)
消费者在声明队列时,指定autoAck参数,true自动确认,false时rabbitmq会等到消费者显示的发回一个ack信号才会删除消息。