Flink:ApacheFlink是一个计算框架和分布式处理引擎,用于对***和有界数据流进行有状态计算。其针对数据流的分布式计算提供了数据分布、数据通信以及容错机制等功能。Flink主要特点:1、高吞吐、低延迟、纯流式架构;2、支持对乱序事件的处理;3、有状态、提供exactly-once计算;4、高度灵活的窗口机制;5、失败恢复、故障转移、水平扩展;6、批处理、流处理统一的APINBI大数据可视
分类:
其他好文 时间:
2020-06-11 21:28:52
阅读次数:
114
1 下载ActiveMQ 前往Apache官方网站或者直接引擎搜索 ActiveMQ即可,点击对应的OS版本进行下载操作 http://activemq.apache.org/components/classic/download/ 2 解压缩ActiveMQ安装包至对应目录中 如下图所示:我们使用 ...
分类:
系统相关 时间:
2020-06-10 17:31:23
阅读次数:
99
功能:从调用线程的消息队列里取得消息并放于指定的结构。 函数原型: BOOL GetMessage(_Out_ LPMSG lpMsg,_In_opt_ HWND hWnd,_In_ UINT wMsgFilterMin,_In_ UINT wMsgFilterMax); lpMsg:指向MSG结构 ...
分类:
其他好文 时间:
2020-06-10 13:05:12
阅读次数:
64
原文 http://blog.csdn.net/xxxluozhen/article/details/4123549 TranslateMessage函数 函数功能描述:将虚拟键消息转换为字符消息。字符消息被送到调用线程的消息队列中,在下一次线程调用函数GetMessage或PeekMessage时 ...
分类:
其他好文 时间:
2020-06-10 12:59:19
阅读次数:
73
redis作为一个直接操作内存的key-value存储系统,也是一个支持数据持久化的Nosql数据库,具有非常快速的读写速度,可用于数据缓存、消息队列等。 一、单机版安装 1.下载redis 进入redis官网下载安装包,这里使用的是目前最新版6.0.4 http://download.redis. ...
分类:
系统相关 时间:
2020-06-09 18:59:55
阅读次数:
157
如果你还没有使用过消息中间件,这篇文章可以带你初步感受一下消息中间件。下面就带大家简单测试一下ActiveMq; 一、第一部分下载以及安装: 1、首先ActiveMq属于Apache下,下载路径:http://activemq.apache.org/ Classic(经典的) 2、这里有Window ...
分类:
其他好文 时间:
2020-06-09 18:39:52
阅读次数:
59
ActiveMQ作为消息队列Queue以及Topic主题订阅模式的Broker,在我们使用Windows开发环境时,需要如下配置 1 下载Jdk 略 此处作为开发人员jdk环境是比不可好的,所以jdk配置不再赘述,运行ActiveMQ是需要jdk支持的 2 下载ActiveMQ,地址如下: http ...
众所周知,消息队列是应用系统中重要的组件,主要解决应用解耦,异步消息,流量削锋等问题,实现高性能,高可用,可伸缩和最终一致性架构。目前使用较多的消息队列有 ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ. 但是如果你不想为你的系统引入一个重量级(相对 r ...
分类:
编程语言 时间:
2020-06-09 14:46:58
阅读次数:
86
是什么 是一种哈希函数,采用的是MurMurHash的一种变体,是一种高效低碰撞的非加密型哈希函数。 为什么要用 具有较高的平衡性与低碰撞率 学到什么 对于大块数据,可以分多个小的部分进行哈希计算 源码分析 主要就一个hash接口 uint32_t Hash(const char *data, si ...
分类:
数据库 时间:
2020-06-09 14:36:16
阅读次数:
86
前面的章节,我们已经把RocketMQ的环境搭建起来了,是一个两主两从的异步集群。接下来,我们就看看怎么去使用RocketMQ,在使用之前,先要在NameServer中创建Topic,我们知道RocketMQ是基于Topic的消息队列,在生产者发送消息的时候,要指定消息的Topic,这个Topic的 ...
分类:
其他好文 时间:
2020-06-09 11:21:24
阅读次数:
75