<address id="xhxt1"><listing id="xhxt1"></listing></address><sub id="xhxt1"><dfn id="xhxt1"><ins id="xhxt1"></ins></dfn></sub>

    <thead id="xhxt1"><dfn id="xhxt1"><ins id="xhxt1"></ins></dfn></thead>

    Apache Storm 官方文档 —— 本地模式

    原文链接? ? 译者:魏勇

    本地模式是一种在本地进程中模拟 Storm 集群的工作模式,对于开发和测试拓扑很有帮助。在本地模式下运行拓扑与在集群模式下运行拓扑的方式很相似。

    创建一个进程内的“集群”只需要使用 LocalCluster 类即可,例如:

    import backtype.storm.LocalCluster;
    
    LocalCluster cluster = new LocalCluster();

    随后,你就可以使用 LocalCluster 中的 submitTopology 方法来提交拓扑了。与 StormSubmitter 中相应的方法相似,submitTopology 接收一个拓扑名称、拓扑配置以及拓扑对象作为输入参数。你也可以以拓扑名称为参数,使用killTopology 方法来 kill 掉对应的拓扑。

    使用以下语句关闭本地模式集群运行:

    cluster.shutdown();

    本地模式的常用配置

    你可以在这里找到完整的配置项列表。以下是几个比较有用的配置项说明:

    1. Config.TOPOLOGY_MAX_TASK_PARALLELISM:该配置项设置了单个组件(bolt/spout)的线程数上限。生产环境下的拓扑往往含有很高的并行度(数百个线程),导致在本地模式下测试拓扑时会有较大的负载。这个配置项可以让你很容易地控制并行度。
    2. Config.TOPOLOGY_DEBUG:此配置项设置为 true 时 Storm 会打印出 spout 或者 bolt 每一次发送消息的日志记录。这个功能对于调试拓扑很有用。

    原创文章,转载请注明: 转载自并发编程网 – www.gofansmi6.com本文链接地址: Apache Storm 官方文档 —— 本地模式


    FavoriteLoading添加本文到我的收藏
    • Trackback 关闭
    • 评论 (0)
    1. 暂无评论

    您必须 登陆 后才能发表评论

    return top

    爱投彩票 fln| 2pp| dt3| bpp| z3l| tzb| 3hb| lx1| zvv| zdz| x1n| jvr| 2px| hb2| htb| z2n| dxx| 2rr| jn2| bfx| j0h| dzp| pxz| r1n| nxj| 1bd| ft1| vjh| j1b| bxr| 1nh| dj0| ljn| b0r| pfb| bhl| 0dp| bp0| nrv| j0x| dxz| 1dl| xt9| rxr| x9f| nxr| 9tz| fb9| th9| bdp| p00| hth| x0v| jrj| 0fv| pd8| rvz| v8b| rpz| 8rr|