上篇文章为大家带来了新版本的 Storm 适配器,今天来弥补一下上次匆忙发布带来的遗憾。是的,DRPC for .net Core 来了,当然,为了实现这个功能,一个精简版本的 Apache Thrift for .net core 也产生了;这个类库根据 Roadmap for adding new language bindings 完成,为了不带来误解,该项目暂时不开源,仅在 Nugut 中供 storm-net-adapter 使用,如果你也暂时需要它,可以通过 Nuget 搜索 Tnidea.Thrift 获得。
storm-net-adapter 最新版本为 2.0.5,现在支持 .Net4.0+, .Net Core。下面给大家介绍如何快速开始创建一个 DRPC Topology:
1. 创建.Net DRPC Topology项目
- 使用命令创建新的 .Net Core 项目:
1 | mkdir StormSample |
- 在项目中添加 Storm.Net.Adapter 引用:
1 | "dependencies": { |
- 创建一个 SimpleDRPC 类:
1 | using Storm; |
2. 使用Java封装Storm Topology
1 | package org.apache.storm.starter; |
- 注意调用代码中的 StormSimple.dll:
1 | super("dotnet", "StormSimple.dll", "SimpleDRPC"); |
打包 StormSample ,并将依赖项一起拷贝到 multilang/resources 。
使用 Maven 打包 Java 项目,通过 storm jar 命令提交:
1 | $ storm jar storm-starter-1.0.1.jar org.apache.storm.starter.DrpcTestTopologyCsharp simpledrpc |
3. 使用C#调用刚刚提交的DRPC Topology
1 | using System; |
至此就全部结束了!所有的代码都在 storm-net-adapter 可以找到,你可以通过 Star 与 Fork 该项目来支持我!
本文来自 The NewIdea,作者 Carey Tzou 。
永久地址:https://www.tnidea.com/dotnet-core-support-drpc-now.html
未经授权,拒绝任何全文及摘要转载!