一、kafka介绍 Kafka是一种高吞吐量的分布式发布订阅消息系统,使用scala编写。 Kafka拥有作为一个消息系统应该具备的功能,有着独特的设计。它借鉴的JMS的规范思想,但未完全遵循JMS的规范。 Kafka是一个分布式的,分区的消息(commit log)服务。 二、基础的消息术语 1、 ...
分类:
其他好文 时间:
2018-08-07 01:38:12
阅读次数:
173
6. 合理使用EXISTS,NOT EXISTS子句。如下所示: 1.SELECT SUM(T1.C1) FROM T1 WHERE (SELECT COUNT(*)FROM T2 WHERE T2.C2=T1.C2>0) 2.SELECT SUM(T1.C1) FROM T1WHERE EXIST ...
分类:
数据库 时间:
2018-08-06 22:42:37
阅读次数:
216
import requests import json import time from pyquery import PyQuery import pandas as pd from collections import OrderedDict import multiprocessing imp... ...
分类:
其他好文 时间:
2018-08-03 18:47:11
阅读次数:
183
Javascript模块化编程,已经成为一个迫切的需求。理想情况下,开发者只需要实现核心的业务逻辑,其他都可以加载别人已经写好的模块。 Javascript社区做了很多努力,在现有的运行环境中,实现”模块”的效果。 CommonJS CommonJS定义的模块分为: 模块引用(require) 模块 ...
分类:
Web程序 时间:
2018-08-03 18:10:28
阅读次数:
181
<script>let iosUser = window.navigator.userAgent.indexOf('iPhone')let inp = document.querySelector('#inp');//input输入框if (iosUser != -1) { var bfscroll ...
分类:
移动开发 时间:
2018-08-03 14:09:59
阅读次数:
191
* 查看php.net官方手册 string str_pad ( string $input , int $pad_length [, string $pad_string = " " [, int $pad_type = STR_PAD_RIGHT ]] ) * javascript code * ...
分类:
编程语言 时间:
2018-08-02 20:46:12
阅读次数:
145
RocketMQ提供的顺序消费消息实现是使用的FIFO 先进先出算法 Producer消息发送 Consumer消息消费 ...
分类:
其他好文 时间:
2018-08-02 13:17:09
阅读次数:
180
常用的时间模块1.time时间戳2.datetime3.python-deteutil(pipinstall)常用的操作:1.时间各种格式表示2.各种加减运算importtimetime.time()#时间戳1533133461.6765099start=time.time()print(start)1533133482.158626end=time.time()print(f‘过了{end-st
分类:
其他好文 时间:
2018-08-02 00:05:55
阅读次数:
138
1、面试题 如何保证消息不被重复消费啊(如何保证消息消费时的幂等性)? 2、面试官心里分析 其实这个很常见的一个问题,这俩问题基本可以连起来问。既然是消费消息,那肯定要考虑考虑会不会重复消费?能不能避免重复消费?或者重复消费了也别造成系统异常可以吗?这个是MQ领域的基本问题,其实本质上还是问你使用消 ...
分类:
其他好文 时间:
2018-08-01 22:31:31
阅读次数:
507
1、面试题 如何保证消息的可靠性传输(如何处理消息丢失的问题)? 2、面试官心里分析 这个是肯定的,用mq有个基本原则,就是数据不能多一条,也不能少一条,不能多,就是刚才说的重复消费和幂等性问题。不能少,就是说这数据别搞丢了。那这个问题你必须得考虑一下。 如果说你这个是用mq来传递非常核心的消息,比 ...
分类:
其他好文 时间:
2018-08-01 22:29:02
阅读次数:
486