1 #include 2 #include 3 #include 4 #include 5 void *consumer(void *p) 6 { 7 int i; 8 printf("start (%d)\n", (int)p); 9 ...
分类：
其他好文 时间：
2014-09-27 02:32:39
阅读次数：
195
//非分离线程未使用join函数例子：#include#include#include#include#includevoid*consumer(void*p){ static a=0 ; a++; printf("<<<<<<<<<<<<<<<<<<<<<(%u),%d\n",(...
分类：
编程语言 时间：
2014-09-27 01:55:48
阅读次数：
219
#include #include #include #include void *consumer(void *p) { int i; printf("start (%d)\n", (int)p); for (i = 0; 1; i+...
分类：
其他好文 时间：
2014-09-27 01:43:08
阅读次数：
244
#include#include#include#include#includevoid *consumer(void *p){ static a = 0; a++; printf("<<<<(%u),%d\n", (unsigned)pthread_self(), a...
分类：
其他好文 时间：
2014-09-27 01:05:09
阅读次数：
233
#include #include #include #include #include void *consumer(void *p){ do{ printf("<<<<(%u),%d\n", (unsigned)pthread_self(), (unsigned int)p...
分类：
其他好文 时间：
2014-09-27 00:28:39
阅读次数：
215
OverviewArchitectureProvider: 暴露服务的服务提供方。Consumer: 调用远程服务的服务消费方。Registry: 服务注册与发现的注册中心。Monitor: 统计服务的调用次调和调用时间的监控中心。Container: 服务运行容器。Relations0. 服务容器...
分类：
其他好文 时间：
2014-09-24 19:41:27
阅读次数：
318
# consumer offset commit 使用kafka的python api时遇到了offset回滚的问题，因为最初使用了autocommit参数，发现有时会重复取记录，发现autocommit是批量提交，并且有offset回滚的问题，具体原因未发现，解决方法...
分类：
其他好文 时间：
2014-09-21 02:23:20
阅读次数：
439
1、JMS是一个由AS提供的Message服务。它能接受消息产生者(Message Provider)所发出的消息，并把消息转发给消息消费者(Message Consumer)。2、JMS提供2种类型的消息服务：(1)Queue，即点对点，每一个消息仅仅转发给一个消息消费者使用。(2)Topic，即...
分类：
其他好文 时间：
2014-09-20 20:34:19
阅读次数：
259
目前中央库中 org.apache.kafka 是用jdk1.7编译的, 故跑在1.6的jvm中会报错解决方案:1. 下载kafka源码, 本地sbt进行install, 编译前 java -version确认classpath中的jdk版本是1.62. 编译打包成功后, 进入当前kafka目录的 ...
分类：
编程语言 时间：
2014-09-14 22:06:27
阅读次数：
1889
腾讯官方文档 申请appid和appkey的用途 appid：应用的唯一标识。在OAuth2.0认证过程中，appid的值即为oauth_consumer_key的值。 appkey：appid对应的密钥，访问用户资源时用来验证应用的合法性。在OAuth2.0认证过...
分类：
其他好文 时间：
2014-09-10 12:50:30
阅读次数：
326
