Storm系列(一):搭建dotNet开发Storm拓扑的环境

上篇博客比较了目前流行的计算框架特性,如果你是 Java 开发者,那么根据业务场景选择即可;但是如果你是 .Net 开发者,那么三者都不能拿来即用,至少在这篇文章出现之前是如此。基于上篇文章的比较发现,Storm 应该是对多语言支持比较好的框架了,但即便如此,官方也没有提供 .Net 的适配器,网上也找不到第三方的开源库。So,Storm.Net.Adapter 出现了,一个使用 Csharp 开发的 针对 Apache Storm 的适配器!项目由本人开发,按照Apache License, Version 2.0开源。

本文是“Storm系列”的第一篇,后期会根据时间情况继续更新!

安装Storm与依赖环境

安装Zookeeper

  • 获取最新 Zookeeper 程序包:官网
  • 解压程序包,拷贝 conf 下 zoo_sample.cfg 为 zoo.cfg,修改相关配置
  • Windows 环境下直接执行 bin\zkServer.cmd;Linux 下执行 bin/zkServer.sh start

安装Python, Java与Maven

  • 下载 Python 2.x 安装
  • 下载 JAVA 6+ 安装,必须安装 JDK 版,否则使用 Maven 时会出错
  • 下载 Maven 并安装

下载Storm

  • 获取最新 Storm 程序包:官网
  • 解压后修改 conf 下的 storm.yaml 里的相关配置

配置环境变量

  • 配置 Storm_Home 与 Java_Home; 目录最好不要有空格
  • classPath 里增加 .;%JAVA_HOME%\lib\dt.jar;%JAVA_HOME%\lib\toos.jar;
  • path 里增加 %STORM_HOME%\bin;%JAVA_HOME%\bin;
  • 将 Maven 的目录也加到 path 方便使用

Storm启动

  • 启动 Zookeeper
  • 运行 storm nimbus (如果未将 Storm 加到 path,需要先切换到 Storm 的 bin 目录,下同)
  • 运行 storm supervisor (集群环境下,非主可以仅执行该句)
  • 运行 storm ui,通过 http://localhost:8080/ 监控 Storm 运行状况

使用 Storm.Net.Adapter

获取 Storm.Net.Adapter

目前有以下几种方式获取最新的 Storm.Net.Adapter 库

  • 通过源代码编译自己的版本: GitHub
  • 下载编译好的版本加入引用: Release
  • 使用 NuGet 获取最新版本(推荐):PM> Install-Package Storm.Net.Adapter

创建示例项目

  • 在项目中引用 Storm.Net.Adapter,创建 Spout (基于ISpout)和 Bolt (基于IBolt或IBasicBolt),都需要 using Storm;
  • 创建一个使用 Maven 管理的 Java 项目,增加 dotNet 程序对应的 Topology
  • Windows(.Net Framework)平台下,你可以通过下面的方式来调用你的 Spout 或 Bolt:
     super("cmd", "/k", "CALL", "StormSimple.exe", "generator");
    
  • Linux, Mac OSX, Windows(mono)平台下,你可以通过下面的方式来调用你的 Spout 或 Bolt:
     super("mono", "StormSimple.exe", "generator");
    

打包与发布

  • 拷贝编译好的 dotNet 程序到 resources 目录下,使用下面的 Maven 命令打包你的 Topology:

     $ mvn package
    
  • 通过 Storm 命令行工具提交你创建好的 Topology:
     $ storm jar storm-starter-*-jar-with-dependencies.jar storm.starter.WordCountTopologyCsharp wordcount
    

Storm系列文章

(一):搭建dotNet开发Storm拓扑的环境

时间: 2024-11-10 01:00:18

Storm系列(一):搭建dotNet开发Storm拓扑的环境的相关文章

Android深度探索(卷1)HAL与驱动开发 第五章 搭建S3C6410 开发板的测试环境

第五章 搭建S3C6410 开发板的测试环境 心得体会 开始进行安装串口调试工具:minicom  OK6410开发板带了一个串口.可以通过串口线与PC连接.Linux驱动在输出调试信息的同时会通过串口线教调试信息发送到PC上,这样Linux驱动程序员就可以直接在PC上查看调试信息了.(对一些笔记本需要使用USB转RS232串口线) 1.检测当前系统是否支持USB转串口 #lsmod | grep usbserial 2.安装minicom #apt-get install minicom 3.

第五章 搭建S3C6410开发版的测试环境

第五章 搭建S3C6410开发版的测试环境 5.1 S3C6410开发版简介 S3C6410 是一款低功耗,高性价比的精简指令集计算机处理器,基于ARM11内核,应用于移动电话和通用处理等领域.   S3C6410为2.5G和3G通信服务提供了硬件性能.这个处理器内置一个非常先进的3D加速器.能实现4M triangles/s的3D加速.它还包含优化的外部存储器接口.这个接口可以满足在高端的通信服务中数据带宽要求.   S3C6410 ARM11处理器的芯片无法测试Linux驱动,必须在它的基础

第五章搭建S3C6410开发板的测试环境

第五章本章主要介绍开发板的调试环境的搭建,以及如何将Android系统安装开发板上. 开发板是开发和学习嵌入式技术的主要硬件设备. 尽管可以在PC上开发Linux驱动,然后重新编译成ARM构架的Linux驱动模块,但最终都是要在开发板上进行测试的. 开发板从技术上说与手机类似,包含显示器.键盘.Wi-Fi.蓝牙等模块.开发板可扩展的端口多,容易开发定制的硬件. 第一节S3V6410开发板简介 S3C6410是一款低功耗.高性价比的RISC处理器,它给予ARM11内核,可以广泛应用于移动电话和通用

第五章、搭建S3C6410开发板的测试环境

通过对本章的学习,我对s3c6410开发板的测试环境有了一定的认识,并掌握了如下的知识点:一.对于s3c6410这款开发板,它是一款低功耗.高性价比的处理器,它是基于ARM11的内核.二.不同开发板的区别主要在烧录嵌入式系统的方式上.三.安装串口调试工具的步骤:minicom的步骤1.检测当前环境是否支持usb转串口# lsmod | grep usbserial2.安装minicom# apt-get install minicom3.配置minicom# minicom -s 进入“seri

第五章 搭建S3C6410开发板的测试环境

在PC上可以开发Linux驱动,重新编译成ARM架构的Linux驱动模块,但最后还是要在开发板上进行测试.目前最流行的是基于三星S3C6410 ARM11架构的开发板,很多厂商在其基础上进行了扩展,开发了扩展板. 下面对S3C6410开发板进行简单的介绍:三星S3C6410是一款低功耗.高性价比的RISC精简指令集系统的处理器,基于ARM11内核,可用于移动电话和通用处理等领域.它为通信服务提供了优化的硬件性能,内置强大的硬件加速器,有运动视频处理.音频处理.2D加速.显示处理和缩放等,还集成了

搭建S3C6410开发板的测试环境

开发板(demoboard)是用来进行嵌入式系统开发的电路板,包括中央处理器.存储器.输入设备.输出设备.数据通路/总线和外部资源接口等一系列硬件组件.在一般的嵌入式系统开发过程中,硬件一般被分成两个平台,一个是开发平台(host),一个是目标平台(target)即开发板.在此描述的开发平台指的是使用计算机,通过传输的界面,例如串口(RS-232).USB.并口.或者网络(Ethernet)与目标平台连接.ARM构架的开发板可基于X86构架的PC 在CPU指令以及二进制格式上有所不同.使用OK6

第五章 搭建S3C6410开发板的测试环境 心得笔记

一.S3c6410一款比较典型的开发板,集成了各种部件.它是由三星公司推出的一款低功耗.高性价比的RISC处理器,它基于ARM11内核,可广泛应用于移动电话和通用处理等领域.串口通信就是通过使用开发板可以用某些方式显示linux驱动程序输出的调试信息.而PC需要与串口设备通信就需要在PC上安装接收和发送串口数据的程序,例如minicom. 二.要想使用该型号的开发板 1>安装串口调试工具:minicom: 第一步,检测当前系统是否支持USB转串口      #lsmod | grep usbse

五、搭建S3C6410开发板的测试环境—学习笔记

在PC上可以开发Linux驱动,重新编译成ARM架构的Linux驱动模块,但最后还是要在开发板上进行测试.目前最流行的是基于三星S3C6410 ARM11架构的开发板,很多厂商在其基础上进行了扩展,开发了扩展板. 下面对S3C6410开发板进行简单的介绍:三星S3C6410是一款低功耗.高性价比的RISC精简指令集系统的处理器,基于ARM11内核,可用于移动电话和通用处理等领域.它为通信服务提供了优化的硬件性能,内置强大的硬件加速器,有运动视频处理.音频处理.2D加速.显示处理和缩放等,还集成了

第五章、搭建S3C6410开发板的测试环境 读书笔记

开发板是开发和学习嵌入式技术的主要硬件设备 一.安装串口调试工具:minicom 1.检测当前系统是否支持USB转串口 lsmod | grep usbserial 2.安装minicom apt-get install minicom 3.配置minicom minicom –s 4.测试minicom minicom 二.烧写Android系统 1.使用EBoot擦除NandFlash 链接开发板和Pc机,并启动minicom.打开开发板的电源开关,出现5秒倒计时时,在Pc端按下空格键,进入