flume提交配置分析
Flume是一个分布式的日志收集系统，提供了很好的配置管理。今天分析一下页面提交配置的详细过程。
1，前台部分，首先，在flumeconfig.jsp页面中，提供了配置管理的表单，详细如下，
?
<h2>Configure a single node</h2><form method=post action="command.jsp"><table> <tr> <td>Configure node:</td> <td> <select name="nodeChoice"> <option value="">Choose from list</option> <% for (String s : FlumeMaster.getInstance().getKnownNodes()) { %> <option value="<%= s %>"><%= s %></option> <% } %> </select> </td> </tr> <tr> <td> or specify another node: </td> <td> <input type="text" name="node" size=128 /> </td> </tr> <tr> <td>Source: </td> <td><input type="text" name="source" size=128/> </td> </tr> <tr> <td>Sink:</td> <td><input type="text" name="sink" size=128/> </td> </tr> <tr> <td> <input type="submit"/> </td> </tr> </form></table>?
?当填好表单，并提交表单，该页面会跳转到command.jsp中进行处理，command.jsp详细如下：
?
<jsp:useBean id="cmd" scope="request"/><jsp:setProperty name="cmd" property="*"/><html><link rel="stylesheet" type="text/css" href="/flume.css"><meta HTTP-EQUIV="REFRESH" content="5;url=flumeconfig.jsp"/><body><h2>Command received</h2>You entered<br>Node: <%= cmd.getNode() %> <br>Source: <%= cmd.getSource() %> <br>Sink: <%= cmd.getSink() %> <br><p>Please wait for a few seconds, and we'll redirect you back to<a href="flumemaster.jsp">the Master overview</a>.</body></html><% FlumeMaster.getInstance().submit(cmd.toCommand());%>
?
?从command.jsp代码中，可以看出flumeconfig.jsp提交过来的表单值赋给了ConfigCommand对象cmd。然后，调用FlumeMaster对象提交该命令。其中，cmd.toCommand()代码如下：
?
public Command toCommand() { return new Command("config", node != null ? node : nodeChoice, source, sink); }?config是该命令的名称，后面是该命令的参数。将ConfigCommand对象转换成Command对象。在Flume的命令管理中，会将各种各样的不同的命令转换成Command对象，然后CommandManager对象管理这些Command，类似于Command是所有其他具体Command的超集，例如ConfigCommand,LoadConfigCommand等。
?
2，后台部分
后台部分从 FlumeMaster.getInstance().submit(cmd.toCommand());代码开始，从下面代码可以看出FlumeMaster将会调用CmmandManager对象来提交从前台提交过来的命令，并处理命令。
public long submit(Command cmd) { return cmdman.submit(cmd); //cmdman其实是CommandManager对象 }?从以上分析可以看出，Flume的提交配置非常简单，清晰。下节将会讲解CommandManager。?