Introduzione
Hub eventi è un sistema di inserimento a scalabilità elevata, in grado di accettare milioni di eventi al secondo, che permette a un'applicazione di elaborare e analizzare le elevate quantità di dati prodotti dalle applicazioni e dai dispositivi connessi. Dopo la raccolta nell'hub eventi, i dati possono essere trasformati e archiviati tramite qualsiasi provider di analisi in tempo reale o qualsiasi cluster di archiviazione.
Per altre informazioni, vedere Panoramica di Hub eventi.
Questa esercitazione illustra come inviare eventi a un hub eventi usando un'applicazione console in Java. Per ricevere eventi usando la libreria host del processore di eventi di Java, vedere questo articolo o fare clic sul linguaggio di ricezione appropriato nel sommario a sinistra.
Per completare questa esercitazione, sono necessari gli elementi seguenti:
- Ambiente di sviluppo in Java. Per questa esercitazione si presuppone l'uso di Eclipse.
- Un account Azure attivo.
Se non si ha un account, è possibile creare un account gratuito in pochi minuti. Per informazioni dettagliate, vedere la pagina relativa alla versione di valutazione gratuita di Azure.
Inviare messaggi all'hub eventi
La libreria client Java per hub eventi è disponibile per l'utilizzo in progetti Maven dal Repository centrale Mavened è possibile farvi riferimento utilizzando la seguente dichiarazione di dipendenza all'interno del file di progetto Maven:
<dependency>
<groupId>com.microsoft.azure</groupId>
<artifactId>azure-eventhubs</artifactId>
<version>{VERSION}</version>
</dependency>
Per diversi tipi di ambienti di compilazione, è possibile ottenere in modo esplicito i file JAR rilasciati più recenti dal repository centrale Maven o dal punto di distribuzione rilascio in GitHub.
Per un autore di eventi semplice, importare il pacchetto com.microsoft.azure.eventhubs per le classi di client di hub eventi e il pacchetto com.microsoft.azure.servicebus per le classi di utilità, ad esempio eccezioni comuni condivise con il client di messaggistica del bus di servizio di Azure.
Per l'esempio seguente, creare prima un nuovo progetto Maven per un'applicazione console/shell nell'ambiente di sviluppo Java preferito. La classe verrà chiamata Send.
import java.io.IOException;
import java.nio.charset.*;
import java.util.*;
import java.util.concurrent.ExecutionException;
import com.microsoft.azure.eventhubs.*;
import com.microsoft.azure.servicebus.*;
public class Send
{
public static void main(String[] args)
throws ServiceBusException, ExecutionException, InterruptedException, IOException
{
Sostituire lo spazio dei nomi e i nomi dell'hub eventi con i valori utilizzati durante la creazione dell'hub eventi.
final String namespaceName = "----ServiceBusNamespaceName-----";
final String eventHubName = "----EventHubName-----";
final String sasKeyName = "-----SharedAccessSignatureKeyName-----";
final String sasKey = "---SharedAccessSignatureKey----";
ConnectionStringBuilder connStr = new ConnectionStringBuilder(namespaceName, eventHubName, sasKeyName, sasKey);
A questo punto creare un evento singolare trasformando una stringa nella rispettiva codifica UTF-8 byte. Creare infine una nuova istanza del client di hub eventi dalla stringa di connessione e inviare il messaggio.
byte[] payloadBytes = "Test AMQP message from JMS".getBytes("UTF-8");
EventData sendEvent = new EventData(payloadBytes);
EventHubClient ehClient = EventHubClient.createFromConnectionStringSync(connStr.toString());
ehClient.sendSync(sendEvent);
}
}
Passaggi successivi
Per ulteriori informazioni su Hub eventi visitare i collegamenti seguenti:
- Receive events using the EventProcessorHost (Ricevere eventi usando EventProcessorHost)
- Panoramica di Hub eventi
- Creare un hub eventi
- Domande frequenti su Hub eventi