一、架构简述 RocketMQ阿里开源的一个分布式消息传递和流媒体平台,具有低延迟,高性能和可靠性, 万亿级容量和灵活的可伸缩性。跟其它中间件相比,RocketMQ的特点是纯JAVA实现,在发生宕机和其它故障时消息丢失率更低。 它由四个部分组成:nameserver,broker,生产者和消费者。它 ...
分类:
其他好文 时间:
2020-06-21 15:31:30
阅读次数:
60
了解一些 RabbitMQ 的实现原理也是很有必要的,它可以让你在遇到问题时能透过现象看本质。比如一个队列的内部存 储其实是由5个子队列来流转运作的,队列中的消息可以有4种不同的状态等,通过这些可以明白在使用 RabbitMQ 时尽量不要有过多的消息堆积,不然会影响整体服务的性能。 ? 存储机制 R ...
分类:
其他好文 时间:
2020-06-21 00:03:39
阅读次数:
103
概述 大多应用中, 可以通过消息服务中间件来提升系统异步通信, 扩展解耦能力. 消息服务中的两个重要概念 消息代理(message broker)和目的地(destination) 当消息发送者发送消息时, 由消息代理接管, 消息代理保证消息传递到指定目的地. 消息队列主要有两种形式的目的地 队列( ...
分类:
编程语言 时间:
2020-06-16 16:56:50
阅读次数:
63
这篇文章总结了channel的11种常用操作,以一个更高的视角看待channel,会给大家带来对channel更全面的认识。 在介绍11种操作前,先简要介绍下channel的使用场景、基本操作和注意事项。 channel的使用场景 把channel用在数据流动的地方: 消息传递、消息过滤 信号广播 ...
分类:
其他好文 时间:
2020-06-14 21:01:46
阅读次数:
254
用channel实现一个消息传递,需求如下: //启动一个goroutine,生成100个数发送到ch1//启动一个goroutine,从ch1取值,计算它的平方放到ch2中//再main中,从ch2打印出来直接贴最后代码。 var wg sync.WaitGroup func main(){ wg ...
分类:
其他好文 时间:
2020-06-14 01:31:40
阅读次数:
85
概率图模型G(V,E)由节点V和边E构成。在之前马尔科夫模型相关的博客中,我谈到马尔科夫模型的本质是当两个人交流后,其意见(两个随机变量)同意0与不同意1的概率组合。而势函数表达的是两个意见相同或者相左的程度。 我们搞的那么麻烦,最后想要得到的不就是每个意见正确与否(随机变量取不同值的概率)吗?与其 ...
分类:
编程语言 时间:
2020-06-04 00:50:28
阅读次数:
122
前言 可以自行去学习一下Zookeeper中的系统模型,节点特性,权限认证以及事件通知Watcher机制相关知识,本篇主要学习Zookeeper一致性算法和满足分布式协调的Zab协议 Paxos算法 Paxos算法是莱斯利*兰伯特在1990年提出的一种基于消息传递并且具有高度容错特性的一致性算法,是 ...
分类:
编程语言 时间:
2020-06-02 11:14:57
阅读次数:
72
408大纲中是这样要求的 二、进程管理(一)进程与线程1.进程概念2.进程的状态与转换3.进程控制4.进程组织5.进程通信共享存储系统,消息传递系统,管道通信。6.线程概念与多线程模型 1.进程的概念 打开任务管理器,这些便是进程,有你打开的,也有系统一直运行着的,比如系统中断 上概念:进程是程序的 ...
分类:
系统相关 时间:
2020-05-31 11:10:30
阅读次数:
100
概念说明 通常一个消息队列需要掌握的知识点有Topic(主体)、Producer(生产者)、Consumer(消费者)、Queue(队列)、Delivery Semantics(消息传递范式) 蛋疼的是不同的消息队列关于这些名词叫法不一样,含义也不是很精确。所以阿里起了一个项目OpenMessagi ...
分类:
其他好文 时间:
2020-05-29 10:38:16
阅读次数:
55
1. 消息传递 2. 事件监听 3. 多个以及多种状态机并存 4. 状态分支 5. 状态机工厂 1. 消息传递 状态机可以看成是一个控制中心,接受外部的事件信号进行状态转移,而状态转移也是在状态机初始化的时候就设置好了的。但实际业务中,我们不仅仅只是需要控制中心进行状态转移,还会需要进行一些业务的处 ...
分类:
编程语言 时间:
2020-05-24 23:43:07
阅读次数:
491