一、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
