我是 Azure EventHub 的新手。我想编写一个简单的原型,它可以通过它的 rest api 从 AzureEventHub 发送和接收消息。
您能否通过提供代码片段来帮助我,演示如何使用 EventHub 中公开的 rest api 进行消息生成和消费。
我是 Azure EventHub 的新手。我想编写一个简单的原型,它可以通过它的 rest api 从 AzureEventHub 发送和接收消息。
您能否通过提供代码片段来帮助我,演示如何使用 EventHub 中公开的 rest api 进行消息生成和消费。
抱歉,我不确定周围是否有任何 java 示例,这里有一些可能有帮助的链接:
这是一篇小文章,解释了如何生成 SasKey(共享访问签名)。您将此密钥与每个请求一起发送。 http://www.mikelanzetta.com/2014/09/talking-to-eventhub-from-node/
有一个(非官方的)Azure Service Bus JavaScript SDK,也许这说明了它是如何工作的
它提供了以下人工制品:
这是一篇关于向 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/提供了将它与服务总线一起使用的详细信息,但它应该事件中心类似。与事件中心的主要区别在于,消息永远不会“消耗”并通过多个“分区”,因此您需要连接到所有分区,并在消息进入时存储偏移量,以便您可以在您指定时指定那些重新连接。
根据我对 EVENTHUB 的理解,Rest API 已被公开用于发送数据,并且没有可用于从事件中心接收数据的 rest api。
我尝试使用1. 在 Java 中使用https://github.com/hdinsight/eventhubs-client
实现 Receiver for event hub
2. 在 nodejs 中使用https://github.com/noodlefrenzy/node-amqp10