消息中间件： 转自我司郭总 就是一个容器，你把消息丢进去，不需要立即处理。然后有个程序去从你的容器里面把消息一条条读出来处理。 消息队列有入队（生产者）和出队（消费者） 使用原因： 解耦 消息系统在处理过程中间插入了一个隐含的、基于数据的接口层，两边的处理过程都要实现这一接口。这允许你独立的扩展或修
分类：
其他好文 时间：
2016-02-04 12:25:31
阅读次数：
164
转自：http://chengjianxiaoxue.iteye.com/blog/2190488 1 kafka集群搭建 1.zookeeper集群 搭建在110， 111,112 2.kafka使用3个节点110， 111,112 修改配置文件config/server.properties b
分类：
编程语言 时间：
2016-02-03 18:19:57
阅读次数：
221
用 threading.Event() 也可以实现生产者/消费者模式 （自己拍脑袋想出来的，无法知道其正确性，请大神告知为谢！） import threading import time import random products = 20 class Producer(threading.Thr
分类：
编程语言 时间：
2016-02-03 06:40:07
阅读次数：
286
我们已经知道，对公共资源进行互斥访问，可以使用Lock上锁，或者使用RLock去重入锁。 但是这些都只是方便于处理简单的同步现象，我们甚至还不能很合理的去解决使用Lock锁带来的死锁问题。 要解决更复杂的同步问题，就必须考虑别的办法了。 threading提供的Condition对象提供了对复杂线程
分类：
编程语言 时间：
2016-02-03 01:54:21
阅读次数：
179
ActiveMQ支持多种通讯协议TCP/UDP等，我们选取最常用的TCP来分析ActiveMQ的通讯机制。首先我们来明确一个概念: 客户(Client)：消息的生产者、消费者对ActiveMQ来说都叫作客户。 消息中介(Message broker)：接收消息并进行相关处理后分发给消息的消费者. 为
分类：
其他好文 时间：
2016-02-02 20:38:23
阅读次数：
186
JMS消息传送模型: 消息传送机制, 是基于拉取(pull)或者轮询(polling)的方式. JMS具备两种"消息传送模型": P2P和Pub/sub. (1) P2P：点对点消息传送模型, 允许JMS客户端通过队列(queue)这个虚拟通道来同步或异步发送消息; 消息的生产者为Sender, 消
分类：
其他好文 时间：
2016-02-02 19:47:25
阅读次数：
211
多线程的开发中有一个最经典的操作案例，就是生产者-消费者，生产者不断生产产品，消费者不断取走产品。 package com.vince; /** * 生产者与消费者案例 * @author Administrator * */ public class ThreadDemo4 { public st
分类：
编程语言 时间：
2016-02-01 18:17:15
阅读次数：
118
NSOpertaionQueue用GCD构建封装的，是GCD的高级抽象。GCD仅仅支持FIFO队列，而NSOperationQueue中的队列可以被重新设置优先级，从而实现不同操作的执行顺序调整。GCD不支持异步操作之间的依赖关系设置。如果某个操作的依赖另一个操作的数据（生产者-消费者模型是其中之一
分类：
其他好文 时间：
2016-01-29 11:49:14
阅读次数：
172
生产者/消费者模式简介用来干嘛的？生产者/消费者模式的产生主要目的就是为了解决非同步的生产与消费之间的问题。什么是非同步呢？
比如我刚刚生产了某个产品，而此时你正在打游戏，没空来取，要打完游戏来取，这就导致了我生产产品和你取产品是两个非同步的动作，你不知道我什么时候生产完产品，而我也不知道你什么时候来取。而生产者/消费者模式就是解决这个非同步问题的，因为肯定不可能我生产完一个就给你打个电话...
分类：
其他好文 时间：
2016-01-27 17:24:52
阅读次数：
251
生产者、消费者模式是多线程中的经典问题。通过中间的缓冲队列，使得生产者和消费者的速度可以相互调节。对于比较常见的单生产者、多消费者的情况，主要有以下两种策略：通过volatilebooleanproducerDone＝false来标示是否完成。生产者结束后标示为true,消费者轮询这个变量来决..
分类：
编程语言 时间：
2016-01-25 00:09:28
阅读次数：
1391
