最近在思考分布式系统和多系统协作情况下的缓存同步机制,就百度了一下,发现ActiveMQ挺适用于这种场景并且更加强大。在此标记表示开始要了解ActiveMQ了!!!介绍:ActiveMQ是Apache的一个开源的消息收发系统,负责接收生产者生产的消息,同时将收到的消息发送给注册了要接收..
分类:
其他好文 时间:
2016-01-23 18:37:40
阅读次数:
133
Java多线程编程中,常用的多线程设计模式包括:Future模式、Master-Worker模式、Guarded Suspeionsion模式、不变模式和生产者-消费者模式等。这篇文章主要讲述Future模式,关于其他多线程设计模式的地址如下:关于其他多线程设计模式的地址如下:关于Master-Wo...
分类:
编程语言 时间:
2016-01-22 17:12:44
阅读次数:
347
上一篇记录了几种环形缓冲区的设计方法和环形缓冲区在生产者消费者模式下的使用(并发有锁),这一篇主要看看怎么实现并发无锁。0、简单的说明首先对环形缓冲区做下说明:环形缓冲区使用改进的数组版本,缓冲区容量为2的幂缓冲区满阻塞生产者,消费者进行消费后,缓冲区又有可用资源,由消费者唤醒生产者缓冲区空阻塞消费...
分类:
其他好文 时间:
2016-01-20 22:21:56
阅读次数:
223
简单说kafka是一个高吞吐的分部式消息系统kafka的架构? producer:消息生存者? consumer:消息消费者? broker:kafka集群的server,负责处理消息读、写请求,存储消息? topic:消息队列/分类? Queue里面有生产者消费者模型? broker就是代理,在k...
分类:
其他好文 时间:
2016-01-19 20:54:59
阅读次数:
245
1、环形缓冲区缓冲区的好处,就是空间换时间和协调快慢线程。缓冲区可以用很多设计法,这里说一下环形缓冲区的几种设计方案,可以看成是几种环形缓冲区的模式。设计环形缓冲区涉及到几个点,一是超出缓冲区大小的的索引如何处理,二是如何表示缓冲区满和缓冲区空,三是如何入队、出队,四是缓冲区中数据长度如何计算。ps...
分类:
其他好文 时间:
2016-01-19 19:03:59
阅读次数:
353
rabbitMQ是一种高性能的消息队列,支持或者说它实现了AMQP协议(advanced message queue protocol高级消息队列协议)。下面简单讲一讲一个小例子。我们首先要部署好rabbitMQ,然后实现一个生产者—消费者,生产者向rabbit中发布一个消息,消费者去rabbit取...
分类:
其他好文 时间:
2016-01-14 00:50:55
阅读次数:
351
一般来说,消息队列有两种场景,一种是发布者订阅者模式,一种是生产者消费者模式。利用redis这两种场景的消息队列都能够实现。生产者消费者模式:生产者生产消息放到队列里,多个消费者同时监听队列,谁先抢到消息谁就会从队列中取走消息;即对于每个消息只能被最多一个消费者拥有;发布者订阅者模式:发布者生产消....
分类:
其他好文 时间:
2016-01-12 23:10:17
阅读次数:
252
消息缓冲队列通信机制其基本思想是根据“生产者——消费者”原理,利用内存中公用消息缓冲区实现进程间的信息交换。在这种通信机制中,首先需要在内存中开辟若干空闲消息缓冲区,用以存放要通信的消息。每当一个进程需要向另一个进程发送消息时,便向系统申请一个空闲消息缓冲区,并把已准备好的消息复制到该缓冲区,然后把...
分类:
其他好文 时间:
2016-01-09 21:26:16
阅读次数:
1472
1.jms概念Java Message Service为 Java程序提供一种访问企业消息系统的方法,JMS应用由JMS生产者、JMS Provider、JMS消费者构成1.1. 一条Message 的组成(1) 头(head)每条JMS 消息都必须具有消息头。头字段包含用于路由和识别消息的值。可以...
分类:
其他好文 时间:
2016-01-08 15:53:33
阅读次数:
194
apache kafka参考http://kafka.apache.org/documentation.html消息队列方式:点对点:消息生产者生产消息发送到queue中,然后消息消费者从queue中取出并且消费消息。这里要注意:消息被消费以后,queue中不再有存储,所以消息消费者不可能消费到已经...
分类:
其他好文 时间:
2016-01-08 00:22:22
阅读次数:
182