`
文章列表
调用微信支付或者支付宝验签的时候会很慢,发现程序没有问题,主要是请求到返回这段时间太长。具体如下: prepayInfo->prepay response 大概用了6秒的时间 优化前[08 14:10:51,081 INFO ] [http--8081-3$598667353] util.WxmppayUtil - Wxmppay source str:[08 14:10:51,171 INFO ] [http--8081-3$598667353] util.WxmppayUtil - Wxmppay xml str: [08 14:10:51,171 INFO ] [http--80 ...

wireshark

参考书籍   Wireshark 数据包分析实战(第2版)》重排   具体协议参考地址   http://chrissanders.org/packet-captures/   Tcpdump 用法说明   tcpdump -i eth0 host 113.31.72.210 and port 80 -X -e -nn > client.txt 要让wireshark能分析tcpdump的包,关键的地方是 -s 参数, 还有要保存为 -w文件, 例如下面的例子:./tcpdump   -i  eth0  -s  0  -w  SuccessC2Server.pca ...
1, 关于如何转移分区: 以及如何新增节点的问题, 我们在 Kafka中文文档 中已经有过叙述。详细参考   2, 分析命令的执行过程 : 分区调用的脚本是 kafka-reassign-partitions.sh, 具体内容是: exec $(dirname $0)/kafka-run-class.sh kafka.admin.ReassignPartitionsCommand $@ 3, 分析一下 ReassignPartitionsCommand 的代码, 主要有三个方法,分别对应生成分区 分配的方案, 执行分配方案, 以及验证分配方案执行情况   4,   生成分区分 ...

Kafka 启动过程

1, 每个broker启动的时候都会去注册一个临时节点 /controller, 那个broker先注册这个节点,那个就是所有broker的leader,并将自己的信息写入到这个临时节点里面。如下: [zk: 10.3.63.204:2181,10.3.63.205:2181(CONNECTED) 3] get /controller{"version":1,"brokerid":0,"timestamp":"1407310302044"}cZxid = 0x700000592ctime = Wed Aug 0 ...
  hbase(main):079:0> create 'scores',{NAME=>'course',VERSIONS=>2} 0 row(s) in 0.9590 seconds  hbase(main):080:0> put 'scores','Tom','course:math','97' 0 row(s) in 0.0100 seconds     hbase(main):081:0> scan 'scores' ROW COLUMN
进入hbase shell console$HBASE_HOME/bin/hbase shell如果有kerberos认证,需要事先使用相应的keytab进行一下认证(使用kinit命令),认证成功之后再使用hbase shell进入可以使用whoami命令可查看当前用户 hbase(main)> whoami 表的管理1)查看有哪些表 hbase(main)> list 2)创建表 # 语法:create <table>, {NAME = ...
关于 Unsafe 的一些知识   A collection of methods for performing low-level, unsafe operations. Although the class and all methods are public, use of this class is limited because only trusted code can obtain instances of it.  这个类是用于执行低级别、不安全操作的方法集合。尽管这个类和所有的方法都是公开的(public),但是这个类的使用仍然受限,你无法在自己的java程序中直接使用该 ...
JDK 1.7.55 1, ReentrantLock 有一个内部类, 具体的操作是通过这个内部类来操作的。这个内部类就是同步器Sync, Sync是抽象类, 代码如下:   abstract static class Sync extends AbstractQueuedSynchronizer, 而AbstractQueuedSynchronizer 简称 AQS,继承关系如下:   public abstract class AbstractQueuedSynchronizer     extends AbstractOwnableSynchronizer     imp ...

OceanBase

  OceanBase是一个支持海量数据的高性能分布式数据库系统,实现了数千亿条记录、数百TB数据上的跨行跨表事 务,由淘宝核心系统研发部、运维、DBA、广告、应用研发等部门共同完成。在设计和实现OceanBase的时候暂时摒弃了不 ...
今天,让我们来创建一个基于Bootstrap框架的仪表板(dashboard)应用程序。 Bootstrap是一套非常流行的前端框架,它旨在帮助开发者解决开发过程中的一些主要问题,例如元素的定位、应用的响应式能力以及在多种设备上进行输出。这个仪表板应用程序的元素包括一系列的可视化图形,它们各自代表了各种关键性能指标,例如预算、访问量及其它一些关键指标。 如果你想要实现的应用不仅仅能够简单地表现数据,还能以一种具有竞争力及优秀的表现形式进行呈现,则需要通过以下两个步骤进行实现。 相关厂商内容

网络应用

红杏 http://honx.in/i/VPWNMz9d4Q-YsVU-
上节遗留问题       a) 关于 inLock(controllerContext.controllerLock) 这个代码, 因为 controllerLock 是 ReentrantLock 类型    的锁, 所以如果 处理 session失效的zookeeper线程成功抢占当前嗦的话,就能进入到 handleNewSession 内部方法, 并进一步    执行 onControllerResignation 里面的代码。 而正式因为可重入锁, 也可以执行 onControllerResignation 里面的代码    b) 里面有 deleteTopicManager.s ...
使用环境说明 a) kafka 使用版本: kafka_2.9.2-0.8.1b) 三台虚拟机 10.3.63.5 10.3.63.6 10.3.63.7 分别对应的是 1 2 3 三个节点。     宕机现象   a) 目前看到的现象是 storm 无法写入和查询(当时没有确定是那种情况), 而通过查看zookeeper中的    broker借点,发现只有3, 1 两个, 而不是正常情况下的 3, 2, 1 三个节点。    b) 2 节点丢失, 以前的做法是重启,这次也不例外。 果断重启,时间是: 2015-01-12 16:07:47    下面是对应的 controll ...

Kafka 中文文档

原文地址 http://kafka.apache.org/documentation.html   第四章   4.4 生产者负载均衡生产者直接把数据发给对应分区的主代理, 为了做到这点,所有的节点都能相应生产者关于那个服务在线以及那个话题分区的领导者是谁的请求, 并 ...
  导出数据 ./mongoexport -h 10.3.63.12 --port 27017 -d question -c ask_question -f id,title -q '{"_id":{"$gte": 100}, "_id":{"$lt": max}}'   查询和更新db.test.remove({"_id":161});db.test.update({"_id":162}, {$set:{status:2}});db.test.update({car ...
Global site tag (gtag.js) - Google Analytics