监控客户端设计-记录-输出部分

现在正在做一个监控的工作，看似简单，但如果多想想还是有很多技巧和问题可以探讨的

需求场景：

1. 客户端应该是一个静态类
2. 客户端调用该类的记录信息API频度可能很大
3. 该类记录信息的API应该是异步的，保证主体性能
4. 能够提供多种记录的方式
5. 能够记录多种数据方式

所以设计的时候，在最开始用Recorder和Out两个接口来表达。

其中Recorder中定义以下方法

/**
 * 信息记录者借口
 * @author dongxuan.lb
 *
 */
public interface Recorder {
	/**
	 * 记录信息
	 * @param keys
	 */
	void record(String... keys);
	
	/**
	 * 该Recorder的名称
	 * @return
	 */
	String getName();
	
	void setName(String name);
	
	/**
	 * 将记录输出
	 * 同时清理内部数据
	 * 内部使用Out接口
	 */
	void free();
}

 Out接口很简单：

/**
 * 记录输出接口
 * @author dongxuan.lb
 *
 */
public interface Out {
	void output(String info);
}

 复杂的输出由具体的子类来完成。

到这里，这两个接口是完全解耦的，彼此没有什么关系。

========================================================================

到这里，可以开始设计具体的Recorder类了。（不同的业务需求可以自己实现Recorder）

这里需要具体化的需求：

 监控方面的设计，在使用API记录是不能同步阻塞住 主体业务，所以使用线程方式进行异步。

在这里使用了ThreadPoolExecutor作为作为线程池。

protected ThreadPoolExecutor recorderPool = new ThreadPoolExecutor(
			coreSize, coreSize * 2, 30, TimeUnit.SECONDS, 
			new ArrayBlockingQueue<Runnable>(60), 
			new RecorderThreadFactory("recorderPool"), 
			new ThreadPoolExecutor.CallerRunsPolicy());

 这里需要注意的是coreSize和maxPoolSize的设置，当然这里也是可以调优的地方。

当然使用ThreadPoolExecutor最主要的是RejectedExecutionHandler的具体实现可以高度自由化

当核心处理不过来的时候可以选择自己实现的RejectedExecutionHandler，以满足业务需求

AbstractKeyCountRecorder中代码

private Integer coreSize = Runtime.getRuntime().availableProcessors();
	/*
	 * 记录者线程池
	 */
	protected ThreadPoolExecutor recorderPool = new ThreadPoolExecutor(
			coreSize, coreSize * 2, 30, TimeUnit.SECONDS, 
			new ArrayBlockingQueue<Runnable>(60), 
			new RecorderThreadFactory("recorderPool"), 
			new ThreadPoolExecutor.CallerRunsPolicy());
	
	protected abstract Runnable getWorker(String... key);
	
	@Override
	public void record(String... keys) {
		recorderPool.execute(getWorker(keys));
	}

========================================================================

回到具体需求上来。

首先为了记录key的次数，需要一个map来作为记录存数，其中map的K中存储key的名称，map的V中存储key的出现次数。

但这里有两个问题：

1. 使用hashMap线程不安全，get和put方法均有可能出现并发问题，导致记录错误
2. map中的V存在自加操作，在操作也会有线程问题

public LevelKeyCountRecorder(Out out) {
		this();
		this.out = out;
	}

@Override
	public void free() {
		if(!hitMap.isEmpty()) {
			StringBuilder value = new StringBuilder();
			for (final Entry<String, AtomicInteger> entry : hitMap.entrySet()) {
				value.append(
						entry.getKey()
						+ "=" 
						+ entry.getValue() 
						+ "|");
			}
			out.output(value.toString());
			hitMap.clear();
		}
	}

Logger logger = Logger.getLogger(LevelKeyCountRecorder.class);
		Out logOut = new LogOut(logger);
		Recorder levelRecorder = new LevelKeyCountRecorder(logOut)