如何通过 rest 在事件中心发送和使用消息 api

how to send and consume messages in Event hub via rest api

我是 Azure EventHub 的新手。我想编写一个简单的原型,它可以通过其其余部分 api.

从 AzureEventHub 发送和接收消息

能否请您提供代码片段来帮助我演示如何使用 EventHub 中公开的剩余 api 来生成和使用消息。

根据我对 EVENTHUB 的了解,Rest API 已公开发送数据,并且没有 rest api 可用于从事件中心接收数据。
我尝试使用
为事件中心实现 Receiver 1. 在 Java 中使用 https://github.com/hdinsight/eventhubs-client
2.在nodejs中使用https://github.com/noodlefrenzy/node-amqp10

抱歉,我不确定周围是否有任何 java 示例,这里有一些链接可能会有所帮助:

这里有一篇小文章解释了如何生成 SasKey(共享访问签名)。您将此密钥连同每个请求一起发送。 http://www.mikelanzetta.com/2014/09/talking-to-eventhub-from-node/

有一个(非官方的)Azure 服务总线 JavaScript SDK,也许这说明了它是如何工作的

它提供以下工件:

  • 队列客户端
  • 主题客户端
  • 订阅客户端
  • EventHubClient

这是一篇关于将数据发送到 EventHub 的文章:使用 javascript sdk。 http://developers.de/blogs/damir_dobric/archive/2015/01/26/eventhubs-support-for-azure-servicebus-javascript-sdk.aspx

我是 https://github.com/noodlefrenzy/node-amqp10 的(合)作者,可以验证没有 RESTful 方法可以使用来自事件中心的消息 - 您需要使用 AMQP。您可以使用通过 Qpid-Proton 为 AMQP 绑定的 JMS。

这篇文章 https://azure.microsoft.com/en-gb/documentation/articles/service-bus-java-how-to-use-jms-api-amqp/ 包含有关将其与服务总线一起使用的详细信息,但对于事件中心应该类似。与事件中心的主要区别在于,消息永远不会 "consumed" 并通过多个 "partitions" 传递,因此您需要连接到所有分区,并在消息传入时存储偏移量,以便您可以重新连接时指定那些。