arganzheng arganzheng

优雅的Builder模式

package com.baidu.global.mobile.hao123.nantianmen.annotation;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

title	layout
protocal-buffers学习笔记	post

产生背景(Why Google Invent PB)

在官方文档上 A bit of history 介绍了PB的产生原因。

鹏城放生组2013年12月1号(星期日)放生公告

放生时间: 2013年12月1号(星期日)上午9点30分举行放生。集合地点:当天9点正在深圳市大鹏新区大鹏银滩大道金水湾渡假村大门口标有“金水湾”字样的指示牌处集合。开车前往的师兄导航大鹏银滩大道金水湾渡假村；乘坐公交车的师兄可选择:一是坐E11.H92或833.818到大鹏站下车后转乘b756到鹏城挢站下车,反方向步行至红绿灯左拐入银滩大道再走10分钟到金水湾度假村；二是坐E11.H92或833.818到大鹏站下车后,再在大鹏二站坐928到金水湾度假村站下车(928公交相隔20分钟一班,上车时请吩咐驾驶员到站让下。欢迎随喜参加，功德无量。放生随喜帐号：中国银行，账号6216612000005457219，户名：欧阳权

如何提高消息系统吞吐量

should not block while processing a message
prefer immutable message
batch and piggy(捎带)
avoid polling, try callback notify
cache，但是要注意数据同步更新问题

优雅的builder模式

public class NetworkUpdatesService{

	public void getNetworkUpdatesSummary(){
		UpdateQueryCriteria query = UpdateQueryCriteria.createDefaultCriteria()
				.setMemberID(2)
				.setRequestdTypes(NetworkUpdateType.CONNECTION)

.setCutoffDate(...)

import java.lang.Thread.UncaughtExceptionHandler; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.ThreadFactory;

	# determine base directory; preserve where you're running from
	#echo "Path to $(basename $0) is $(readlink -f $0)"
	realpath=$(readlink -f "$0")
	filepath=$(dirname "$realpath")
	basedir=${filepath%/*}

	LOG_DIR=${basedir}/logs
	mkdir -p ${LOG_DIR}
	GC_LOG_DIR=${basedir}/logs/gc
	mkdir -p ${GC_LOG_DIR}

	package org.opentsdb.client;

	import static com.google.common.base.Preconditions.checkArgument;

	import java.io.IOException;
	import java.util.concurrent.TimeUnit;

	import org.apache.commons.lang.StringUtils;
	import org.apache.http.HeaderElement;
	import org.apache.http.HeaderElementIterator;

	import java.io.IOException;
	import java.net.InetSocketAddress;
	import java.nio.channels.ClosedChannelException;
	import java.nio.channels.SelectableChannel;
	import java.nio.channels.SelectionKey;
	import java.nio.channels.Selector;
	import java.nio.channels.SocketChannel;
	import java.util.HashSet;
	import java.util.Iterator;
	import java.util.Set;