OAuth协议是用于授权的开放标准。目前有两个版本1.0与2.0,后一个版本并不兼容前面的版本,而是考虑了客户端程序开发的简洁性。授权的参与者有三方,一般称作Service Provider, Consumer, User。通常的情形是,User想访问Consumer的资源,而又对其不信任,可以用信...
分类:
其他好文 时间:
2014-08-11 14:50:12
阅读次数:
214
def declare_consumer(self, consumer_cls, topic, callback): """Create a Consumer using the class that was passed in and add it to our...
分类:
编程语言 时间:
2014-08-05 15:26:59
阅读次数:
291
记录一个加载配置文件的代码段,以保存以后使用
bool Consumer::loadConfigFile()
{
if( ConfigMap.size() != 0 )
ConfigMap.clear();
char szFilePath[256]={0};
GetModuleFileNameA(NULL, szFilePath, 255);
(strrchr(szFileP...
分类:
其他好文 时间:
2014-08-05 14:14:49
阅读次数:
235
Queue与Topic的比较1、JMS Queue执行load balancer语义:一条消息仅能被一个consumer收到。如果在message发送的时候没有可用的consumer,那么它将被保存一直到能处理该 message的consumer可用。如果一个consumer收到一条message后...
分类:
其他好文 时间:
2014-08-04 13:40:07
阅读次数:
448
一、关于本文 本文中实现的PCHelper类是一个简易的Producer-Consumer操作工具类。该类可以实现如下目标:由多个线程向其中的一个Queue中写入数据,同时由多个线程负责接收Queue中数据进行处理。 二、工具类代码 ...
分类:
其他好文 时间:
2014-07-29 18:27:32
阅读次数:
252
import java.util.Queue;import java.util.concurrent.LinkedBlockingQueue;public class Consumer extends Thread { private String product; private Queue st...
分类:
编程语言 时间:
2014-07-27 23:25:39
阅读次数:
258
多线程设计模式第1章 Single Threaded Execution——能通过这座桥的,只有一个人第2章 Immutable——想破坏它也没办法第3章 Guarded Suspension——要等到我准备好喔第4章 Balking——不需要的话,就算了吧第5章 Producer-Consumer...
分类:
编程语言 时间:
2014-07-18 11:38:30
阅读次数:
231
管理员指南安装手册示例提供者安装示例消费者安装Zookeeper注册中心安装Redis注册中心安装简易注册中心安装简易监控中心安装管理控制台安装运维手册管理控制台运维推荐使用Zookeeper注册中心你可以只运行Demo Provider和Demo Consumer,它们缺省配置为通过Multica...
分类:
其他好文 时间:
2014-07-16 17:04:34
阅读次数:
523
这次我们试试publish/subscribe模式,也就是将一个消息发送给多个consumer。这里用一个简单的小程序来说明publish/subscribe。由一个provider提供消息,这个消息会被多个consumer接收。consumer对同一个消息做出不同的反应,比如打英保存到文件、数据库什么的。之前的例子可能..
分类:
编程语言 时间:
2014-07-12 16:52:58
阅读次数:
410
一、整体看一下Kafka
我们知道,Kafka系统有三大组件:Producer、Consumer、broker 。
producers 生产消息并推(push)送给brokers,consumers从brokers把消息提取(pull)出来。
二、开发一个Producer应用
Producers用来生产消息并把产生的消息推送到Kafka...
分类:
其他好文 时间:
2014-07-10 23:07:37
阅读次数:
263