Celery 分布式的任务队列 与rabbitmq消息队列的区别与联系： rabbitmq 调度的是消息，而Celery调度的是任务. Celery调度任务时，需要传递参数信息，传输载体可以选择rabbitmq. 利用rabbitmq的持久化和ack特性，Celery可以保证任务的可靠性. 优点: ...
分类：
其他好文 时间：
2016-10-13 11:48:20
阅读次数：
256
7.1 网络封包联机进入主机的流程 7.1.1 封包进入主机的流程 1.经过防火墙的分析 iptables 主要功能是封包过滤 主要分析TCP/IP的封包表头来进行过滤的机制 分析的是OSI的第二三四层，主要控制的就是 MAC,IP,ICMP,TCP,UDP的端口与状态（SYN,ACK...） tc ...
分类：
系统相关 时间：
2016-10-12 16:39:29
阅读次数：
428
新浪微博：intsmaze刘洋洋哥。 storm框架中的kafkaspout类实现的是BaseRichSpout，它里面已经重写了fail和ack方法，所以我们的bolt必须实现ack机制，就可以保证消息的重新发送；如果不实现ack机制，那么kafkaspout就无法得到消息的处理响应，就会在超时以 ...
分类：
Web程序 时间：
2016-10-10 23:01:24
阅读次数：
424
每个Consumer可能需要一段时间才能处理完收到的数据。如果在这个过程中，Consumer出错了，异常退出了，而数据还没有处理完成，那么 非常不幸，这段数据就丢失了。因为我们采用no-ack的方式进行确认，也就是说，每次Consumer接到数据后，而不管是否处理完 成，RabbitMQ Serve ...
分类：
其他好文 时间：
2016-10-10 20:57:20
阅读次数：
202
1.socket编程分三种：流式套接字（专门用于使用TCP协议通信的应用程序中）；数据报套接字（专门用于使用UDP协议通信的应用程序中）；原始套接字； 基于TCP的socket编程采用流式套接字 2.ack报文：即确认字符，数据通信中的一种传输类控制字符 3.socket用于描述地址和端口，是一个通 ...
分类：
其他好文 时间：
2016-10-01 21:41:31
阅读次数：
175
验证EIGRP重传机制本地路由器在规定时间内没有收到邻居的ack确认信息，需要重传。在组播发送数据包的时候，该数据包的单播拷贝会放进一个重传队列中进行排队，一旦这个数据包发送失败，即没有收到邻居的ack确认，那么这个拷贝会被再次发送出去，而触发这个动作的时限就是RTO。..
分类：
其他好文 时间：
2016-10-01 06:22:32
阅读次数：
189
我们在学习ack机制的时候，我们知道Storm的Bolt有BaseBasicBolt和BaseRichBolt。在BaseBasicBolt中，BasicOutputCollector在emit数据的时候，会自动和输入的tuple相关联，而在execute方法结束的时候那个输入tuple会被自动ac ...
分类：
其他好文 时间：
2016-09-30 23:22:08
阅读次数：
226
P10.考虑一条10米短链路，某发送方经过它能够以150bps速率双向传输。假定包含数据的分组是100000比特长，仅包含控制（如ACK或握手）的分组是200比特长。假定N个并行连接每个都获得1/N的链路带宽。现在考虑HTTP协议，并且假定每个下载对象是100Kb长，这些初始下载对象包含10个来..
分类：
其他好文 时间：
2016-09-30 12:38:33
阅读次数：
2366
如果要手动ack,需要将Listener container 的 acknowledge 设置为manul,在消费消息的类中需实现ChannelAwareMessageListener接口。 override onMessage(Message,Channel) 方法,之后channel.basic ...
分类：
编程语言 时间：
2016-09-29 21:37:02
阅读次数：
773
正在学习storm的大兄弟们，我又来传道授业解惑了，是不是觉得自己会用ack了。好吧，那就让我开始啪啪打你们脸吧。 先说一下ACK机制： 为了保证数据能正确的被处理, 对于spout产生的每一个tuple, storm都会进行跟踪。 这里面涉及到ack/fail的处理，如果一个tuple处理成功是指 ...
分类：
其他好文 时间：
2016-09-29 01:45:52
阅读次数：
159
