转自: https://blog.csdn.net/ID__9527/article/details/84255680 RocketMQ是阿里巴巴公司的一个消息队列框架(很多思想借鉴Kafka),对于RocketMQ本身不做过多说明,下面主要说明RocketMQ的两种消费模型。 消费模型有两种:广播 ...
分类:
其他好文 时间:
2020-07-21 21:27:30
阅读次数:
82
思考: 1,消息丢失是什么造成的,从生产端和消费端两个角度来考虑? 2,消息重复是什么造成的,从生产端和消费端两个角度来考虑? 3,如何保证消息有序? 4,如果保证消息不重不漏,损失的是什么? 1.为什么会发生消息丢失和消息重复?消息发送Kafka消息发送有两种方式:同步(sync)和异步(asyn ...
分类:
其他好文 时间:
2020-07-21 00:57:57
阅读次数:
177
EdgeAgent功能列表: 1· 协议平台功能,内置协议驱动,对接工业物联网协议并进行数据采集。 2·数据过滤/清洗功能,去重数据减少传输冗余。 3·规则引擎功能,根据指定规则进行数据计算并即时上传至北向云端。 4·数据&日志 持久化功能,实现离线在线平滑过渡。 5·设备状态变更通知功能,通过邮件 ...
分类:
其他好文 时间:
2020-07-19 15:51:04
阅读次数:
58
关于MQ的定义MessageQueue(MQ)消息队列中间件,通常我们在网上看到的对其定义是将消息的发送和接受分离来实现应用程序的异步和解耦,给人的直觉是MQ是异步的,用来解耦的。但这个只是MQ的效果,而不是目的。MQ真正的目的是为了通讯,屏蔽底层复杂的通讯协议,定义了一套应用层上更加简单的通讯协议。一套分布式系统中两个模块之间通讯要么是HTTP,要么是TCP,但这两种协议其实都是原始的协议。前者
分类:
其他好文 时间:
2020-07-19 11:25:55
阅读次数:
72
什么是RabbitMQ简介(优点)基于ErLang语言开发有高可用高并发的优点,适合集群。开源、稳定、易用、跨平台、支持多种语言、文档齐全。有消息确认机制和持久化机制,可靠性高。概念生产者和消费者Producer:消息的生产者Consumer:消息的消费者Queue消息队列提供了FIFO的处理机制,具有缓存消息的能力。在RabbitMQ中,队列消息可以设置为持久化,临时或者自动删除。如果是持久化的
分类:
其他好文 时间:
2020-07-19 11:25:40
阅读次数:
75
一、RabbitMQ简介 1. 应用场景 (1)任务异步处理 ? 将不需要同步处理的并且耗时长的操作由消息队列通知消息接收方进行异步处理。缩短了应用程序的响应时间。 (2)应用程序解耦合 ? MQ相当于一个中介,生产方通过MQ与消费方交互,它将应用程序进行了解耦合。 2. 工作原理 ? 下图是Rab ...
分类:
其他好文 时间:
2020-07-18 22:55:09
阅读次数:
100
什么是消息队列(MQ) 消息是在不同应用间传递的数据。这里的消息可以非常简单,比如只包含字符串,也可以非常复杂,包含多个嵌套的对象。消息队列(Message Queue)简单来说就是一种应用程序间的通讯方式,消息发送后立即返回,然后由消息系统保证消息的可靠性传输,消息生产者只需要把消息发到 MQ 中 ...
分类:
其他好文 时间:
2020-07-18 22:06:33
阅读次数:
69
Docker-compose常用软件部署(mysql、redis、rabbitmq) 废话不多说,下面就直接给出部署文件已经启动脚本,这个会持续更新。以下的部署方式均是单例部署。高可用或者其他部署方案我会单独写相应的文章。 mysql数据库 redis缓存 rabbitmq消息队列 compose- ...
分类:
数据库 时间:
2020-07-18 21:56:39
阅读次数:
84
Linux下安装Artemis Artemis是下一代的ActiveMQ,也就是说目前的ActiveMQ是5.x,Artemis将是6.x 1. 下载 官网下载地址: https://activemq.apache.org/components/artemis/download/ wget http ...
分类:
其他好文 时间:
2020-07-18 19:47:13
阅读次数:
133
1、用信号量进行行为同步时,只能提供同步的时刻信息,不能提供内容信息。若被控制方要求得到控制方的内容信息时,可以使用消息邮箱或消息队列。2、但由于消息邮箱里只能存放一条消息,所以使用消息邮箱进行任务的同步时,需要满足一个条件:消息的产生速度总要慢于消息的消费速度,即被控制任务总是在等待消息,否则会导 ...
分类:
其他好文 时间:
2020-07-18 13:49:33
阅读次数:
90