分布式消息系统作为实现分布式系统可扩展、可伸缩性的关键组件，需要具有高吞吐量、高可用等特点。而谈到消息系统的设计，就回避不了两个问题： 消息的顺序问题 消息的重复问题 消息的顺序问题 消息的重复问题 RocketMQ作为阿里开源的一款高性能、高吞吐量的消息中间件，它是怎样来解决这两个问题的？Rock ...
分类：
其他好文 时间：
2017-05-23 23:51:56
阅读次数：
531
https://github.com/michaelfairley/mincemeatpy https://github.com/denghongcai/mincemeat-node https://github.com/michaelfairley/mincemeatpy https://gith ...
分类：
编程语言 时间：
2017-05-20 19:29:31
阅读次数：
116
主函数： Producer类： Consumer类： Data类 ...
分类：
其他好文 时间：
2017-05-17 23:25:10
阅读次数：
190
实现EventFactory，在newInstance方法中返回，ringBuffer缓冲区中的对象实例；代码如下： 生产消费的对象类型： disruptor的消费处理事件onEvent为消费调用的方法（下面的代码中包含并行和串行执行的消费事件）： 测试执行类： ...
分类：
其他好文 时间：
2017-05-17 19:19:54
阅读次数：
167
创建一个新网站，一开始没有内容，通常需要抓取其他人的网页内容，一般的操作步骤如下： 根据url下载网页内容，针对每个网页的html结构特征，利用正则表达式，或者其他的方式，做文本解析，提取出想要的正文。 为每个网页写特征分析这个还是太耗费开发的时间，我的思路是这样的。 Python的Beautifu ...
分类：
Web程序 时间：
2017-05-17 14:07:45
阅读次数：
569
import java.util.HashMap;import java.util.List;import java.util.Map;import java.util.Properties; import kafka.consumer.ConsumerConfig;import kafka.con ...
分类：
编程语言 时间：
2017-05-16 15:01:24
阅读次数：
371
DJ DJ是Disc Jockey的缩写，是电音圈子里的一种热门职业，一般大家在夜店或者酒吧看到的站在台上甩着膀子拧着按钮或者使劲儿搓碟的就是DJ啦。 DJ的主要工作一般就是在现场用打碟机和混音台把许多适合气氛的歌曲进行剪接混音，这一过程，俗称打碟。一个好的DJ能将这一工作做的天衣无缝。DJ有一项打 ...
分类：
其他好文 时间：
2017-05-14 17:57:48
阅读次数：
198
rocketmq通过netty获取到消息请求后，直接掉处理模块，比如：SendMessageProcessor 这个处理类主要负责处理客户端发送消息的请求。 这个类实现了com.alibaba.rocketmq.remoting.netty.NettyRequestProcessor接口。这个接口下 ...
分类：
其他好文 时间：
2017-05-08 01:17:51
阅读次数：
2392
16. Evaluate the following query: SQL> SELECT promo_name q'{'s start date was }' promo_begin_date AS "Promotion Launches" FROM promotions;What would b ...
分类：
其他好文 时间：
2017-05-06 15:51:18
阅读次数：
131
线程执行器和不使用线程执行器的对比（优缺点） 1.线程执行器分离了任务的创建和执行，通过使用执行器，只需要实现Runnable接口的对象，然后把这些对象发送给执行器即可。 2.使用线程池来提高程序的性能。当发送一个任务给执行器时，执行器会尝试使用线程池中的线程来执行这个任务。避免了不断创建和销毁线程 ...
分类：
编程语言 时间：
2017-05-04 21:43:31
阅读次数：
387
