介绍 Meta相比于kafka的一个重要特性就是消息高可用方案的实现，我们称之为HA方案。消息在发送到broker之后立即写入磁盘才返回客户端告诉消息生产者消息发送成功，通过unflushThreshold和unflushInterval两个参数...
分类：
Web程序 时间：
2015-11-09 21:06:28
阅读次数：
560
简介 RabbitMQ是一个消息代理。从本质上讲，它从消息生产者处接收消息，然后传递给消息的消费者。它在消息的生产者和消费者之间根据你指定的规则对消息进行路由、缓存和持久化。RabbitMQ通常使用如下术语：生产（Producing），表示消息的发送。发送消息的程序被称为生产者。我们画一个图来表示....
分类：
其他好文 时间：
2015-11-06 00:00:20
阅读次数：
725
一、 简介NSQ主要有三个主要程序和一个Web服务程序：nsqd：是守护进程，接收，缓存，并投递消息给客户端nsqlookupd：是一个守护进程，为消费者提供运行时发现服务，来查找指定话题（topic）的生产者 nsqdnsq_to_http：消费指定的话题（topic）/通道（channel）和执...
分类：
其他好文 时间：
2015-11-05 15:18:20
阅读次数：
486
官方描述一个由数组支持的有界阻塞队列。此队列按 FIFO（先进先出）原则对元素进行排序。队列的头部 是在队列中存在时间最长的元素。队列的尾部 是在队列中存在时间最短的元素。新元素插入到队列的尾部，队列获取操作则是从队列头部开始获得元素。这是一个典型的“有界缓存区”，固定大小的数组在其中保持生产者插入...
分类：
其他好文 时间：
2015-11-05 12:00:44
阅读次数：
178
操作系统Operating Systems进程同步与信号量Processes Synchronization and Semaphore进程合作：多进程共同完成一个任务从纸上到实际：生产者? ? 消费者实例共享数据#define BUFFER_SIZE 10typedef struct { . . ...
分类：
系统相关 时间：
2015-11-05 10:41:21
阅读次数：
346
.net 业务消息队列是应用于业务的解耦和分离，应具备分布式，高可靠性，高性能，高实时性，高稳定性，高扩展性等特性。大量的业务消息堆积能力;无单点故障及故障监控，异常提醒;.生产者端负载均衡，故障转移，故障自动恢复，并行消息插入;.消费者端负载均衡，故障保持，故障自动恢复，并行消息消费;消息高可靠性...
分类：
Web程序 时间：
2015-11-03 09:12:17
阅读次数：
301
代码如下，一般10个生产者10个消费者拷贝1个g的文件大概在6s左右，速度还是不错的。 1 #include 2 #include 3 #include 4 #include 5 #include 6 #include 7 #include 8 #include 9...
分类：
其他好文 时间：
2015-11-01 17:51:01
阅读次数：
218
考虑经典的排队问题，其中一个线程正在生产一些数据，另一个是消费它。为了使问题更有趣，假设生产者必须等待，直到它会产生更多的数据消费完毕之前。在一个轮询系统，消费者会浪费大量的CPU周期，而它等待着生产者生产。一旦生产结束了，就开始轮询，浪费更多的CPU周期等待消费者??完成，依此类推。显然，这种情况...
分类：
编程语言 时间：
2015-10-31 18:23:50
阅读次数：
202
多个生产线程，当生产到一定数量时对结果进行批量处理，触发一个消费线程将全部结果取走处理。多人往一个篮子里装东西，篮子装满时还需要接着装东西，用另外一个空篮子接着装，装满的篮子要么谁最后装满谁送到指定...
分类：
其他好文 时间：
2015-10-29 18:39:14
阅读次数：
197
在kafka中，我们能创建多种类型的集群，一般如下：单节点——单个broker集群单节点——多broker集群多结点——多broker集群kafka集群中主要有五个组件：Topic：主题主要用于用一个名字标识生产者往kafka发送了什么类型的消息，作为消息归类的标识唯一键。在kafka中，主题被分区...
分类：
其他好文 时间：
2015-10-28 19:11:12
阅读次数：
167
