原文链接 CSP vs Actor 模型 Actor Actor 模型是一个通用的并发编程模型,可以应用在几乎任何一种编程语言中,典型的是 Erlang。多个 actor(进程) 可以同时运行、不共享状态、通过向与进程绑定的消息队列(也称为信箱)异步发送消息来进行通信。 actor-1 与 acto ...
分类:
其他好文 时间:
2020-03-04 18:47:45
阅读次数:
91
1.MQ 消息队列(Message Queue,简称MQ),队列可以理解为管道,以管道的方式做消息传递。 2.场景 和我们平时超市购物一样,在我们结算的时候,并不会一窝蜂涌入收银台,而是排队结算。这就是队列机制。 3.搭建RabbitMQ环境 3.1.下载地址:http://www.rabbitmq ...
RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息中间件,它是基于Erlang语言编写的,并发能力强,性能好,是目前主流的消息队列中间件之一。 RabbitMQ的安装可参照官网( https://www.rabbitmq.com/),安装完以后启动管理服务,RabbitMQ提供强大的管理 ...
分类:
其他好文 时间:
2020-03-03 11:04:33
阅读次数:
121
同步和异步 同步:同步的思想是:所有的操作都做完,才返回给用户。这样用户在线等待的时间太长,给用户一种卡死了的感觉(就是系统迁移中,点击了迁移,界面就不动了,但是程序还在执行,卡死了的感觉)。这种情况下,用户不能关闭界面,如果关闭了,即迁移程序就中断了。 异步:将用户请求放入消息队列,并反馈给用户, ...
分类:
其他好文 时间:
2020-03-02 11:06:05
阅读次数:
74
MQ简介: MQ全称为Message Queue,消息队列(MQ)是一种应用程序的通信方法。应用程序通过写和检索出入列的针对应用程序的数据(消息)来通信,而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如远程过程调用的技 ...
分类:
其他好文 时间:
2020-03-01 20:14:44
阅读次数:
97
为什么要进行持久化 为了避免MQ服务器意外宕机导致数据丢失,需要做到重启后没有被消费的数据依然在消息队列中。 ActiveMQ的持久化机制包含: 1. JDBC:持久化到数据库 2. AMQ:日志文件 3. KahaBD:AMQ基础上改进,默认选择 4. LevelDB:谷歌K/V数据库 注:Act ...
分类:
其他好文 时间:
2020-03-01 20:12:10
阅读次数:
122
(1)ActiveMQ的简介 MQ: (message queue) ,消息队列,也就是用来处理消息的,(处理JMS的)。主要用于大型企业内部或与企业之间的传递数据信息。 ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE ...
分类:
其他好文 时间:
2020-02-28 14:23:25
阅读次数:
93
一、Kafka概述1)消息队列1)点对点模式(一对一,消费者主动拉取数据,消息收到后消息清除)点对点模型通常是一个基于拉取或者轮询的消息传送模型,这种模型从队列中请求信息,而不是将消息推送到客户端。这个模型的特点是发送到队列的消息被一个且只有一个接收者接收处理,即使有多个消息监听者也是如此;2)发布/订阅模式(一对多,数据生产后,推送给所有订阅者)发布订阅模型则是一个基于推送的消息传送模型。发布订
分类:
其他好文 时间:
2020-02-28 09:13:22
阅读次数:
80
一、简介 RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(亦称面向消息的中间件)。 消息队列都涉及的生产者消费者模型,不做详解,本文只作为快速使用的参考文档。 消息队列主要有点对点和发布订阅模式。 其主要用途是异步、削峰,充当一个缓存的作用。只有可以异步处理时才可以使用消息队 ...
分类:
编程语言 时间:
2020-02-27 20:37:55
阅读次数:
67
消息队列MQ 全称为Message Queue 消息队列(MQ)是一种应用程序对应用程序的通信方法。MQ是消费 生产者模型的一个典型的代表,一端往消息队列中不断写入消息,而另一端则可以读取队列中的消息。这样发布者和使用者都不用知道对方的存在。 生产消费模型 : 我们先不管消息(Message)这个词 ...
分类:
其他好文 时间:
2020-02-26 22:40:42
阅读次数:
70