Pubblica messaggi su un argomento in un modello Pub/Sub

Il modello Pub/Sub (Editore/Abbonato) in NCache consente la messaggistica disaccoppiata e basata sugli eventi. Gli editori possono inviare messaggi a un argomento utilizzando ITopic interfaccia senza sapere chi sono gli abbonati. Fornisce anche registrazioni di eventi per errori di recapito dei messaggi, ricezione di messaggi ed eliminazione di argomenti. Fornisce Publish metodo, che pubblica il messaggio su un argomento specifico nella cache. Durante la pubblicazione dei messaggi su un argomento, l'editore può impostare il opzione di consegna per i messaggi, scadenza del messaggio, notifica di mancata consegna del messaggioe Notifica di eliminazione dell'argomentoQui descriviamo come pubblicare messaggi, pubblicare i messaggi in modo asincrono, pubblicare messaggi in bloccoe pubblicare messaggi ordinati.

Prerequisiti

Prima di usare il NCache Per le API lato client, assicurarsi che siano soddisfatti i seguenti prerequisiti:

Pubblica messaggi

Il seguente esempio di codice mostra come:

  1. Crea argomenti dedicati per i messaggi relativi agli ordini.
  2. Registrati MessageDeliveryFailure evento per l'argomento.
  3. Registrati OnTopicDeleted evento per l'argomento.
  4. Crea messaggi per ogni argomento, abilitando le opzioni di scadenza e consegna.
  5. Pubblica i messaggi.
try
{
    // Precondition: Cache is already connected

    // Topic "orderTopic" exists in cache
    string topicName = "orderTopic";

    // Get the Topic
    ITopic orderTopic = cache.MessagingService.GetTopic(topicName);

    if (orderTopic != null)
    {
        // Create the object to be sent in message
        Order order = FetchOrderFromDB(10248);

        // Create the new message with the object order
        var orderMessage = new Message(order);

        // Set the expiration time of the message
        orderMessage.ExpirationTime = TimeSpan.FromSeconds(5000);

        // Register message delivery failure
        orderTopic.MessageDeliveryFailure += OnFailureMessageReceived;

        // Register Topic deletion notification
        orderTopic.OnTopicDeleted = TopicDeleted;

        // Publish the order with delivery option set as all and register message delivery failure
        orderTopic.Publish(orderMessage, DeliveryOption.All, true);
    }
    else
    {
        // No Topic exists
    }
}
catch (OperationFailedException ex)
{
    if (ex.ErrorCode == NCacheErrorCodes.MESSAGE_ID_ALREADY_EXISTS)
    {
        // Message ID already exists, specify a new ID
    }
    if (ex.ErrorCode == NCacheErrorCodes.TOPIC_DISPOSED)
    {
        // Specified topic has been disposed
    }
    if (ex.ErrorCode == NCacheErrorCodes.PATTERN_BASED_PUBLISHING_NOT_ALLOWED)
    {
        // Message publishing on pattern based topic is not allowed
        // Get non-pattern based topic
    }
    else
    {
        // Exception can occur due to:
        // Connection Failures
        // Operation Timeout
        // Operation performed during state transfer
    }
}
catch (Exception ex)
{
    // Any other generic exception like ArgumentNullException or ArgumentException
    // Topic name is null/empty
}
Note:

Per garantire che l'operazione sia a prova di errore, si consiglia di gestire eventuali potenziali eccezioni all'interno dell'applicazione, come spiegato in Gestione dei guasti.

Pubblica in modo asincrono

I messaggi possono essere pubblicati sull'argomento in modo asincrono utilizzando PubblicaAsync In questo modo, l'applicazione non attende il completamento dell'operazione per eseguire la successiva. Il controllo viene restituito immediatamente, consentendo all'applicazione di continuare l'elaborazione. L'esempio seguente mostra come pubblicare un messaggio in modo asincrono.

// Precondition: Cache is already connected

// Topic "orderTopic" exists in cache
string topicName = "orderTopic";

// Get the Topic
ITopic orderTopic = cache.MessagingService.GetTopic(topicName);

if (orderTopic != null)
{
    // Create the object to be sent in message
    Order order = FetchOrderFromDB(10248);

    // Create the new message with the object order
    var orderMessage = new Message(order);

    // Set the expiration time of the message
    orderMessage.ExpirationTime = TimeSpan.FromSeconds(5000);

    // Register message delivery failure
    orderTopic.MessageDeliveryFailure += OnFailureMessageReceived;

    // Register Topic deletion notification
    orderTopic.OnTopicDeleted = TopicDeleted;

    // Publish the order with delivery option set as all and register message delivery failure
    Task task = orderTopic.PublishAsync(orderMessage, DeliveryOption.All, true);

    if(task.IsFaulted)
    {
        // Task Failed
    }
}
else
{
    // No Topic exists
}

Pubblica messaggi collettivi

È possibile pubblicare più messaggi in una singola chiamata utilizzando il Pubblica in blocco metodo. Ciò migliora le prestazioni e l'utilizzo della memoria poiché un sacco di messaggi verrà combinato e pubblicato in una singola chiamata. Il codice seguente prende un'istanza di un argomento già creato ordineArgomentoe mostra la pubblicazione in blocco dei messaggi nell'argomento.

// Precondition: Cache is already connected

// Topic "orderTopic" exists in cache
ITopic topic = cache.MessagingService.GetTopic("orderTopic");

if (topic != null)
{
    // Create dictionary for storing bulk
    List<Tuple<Message, DeliveryOption>> messageList = new List<Tuple<Message, DeliveryOption>>();
    Order[] orders = FetchOrdersFromDB();
        for (int i = 0; i < 100; i++)
    {
        Message message = new Message(orders[i]);
        message.ExpirationTime = TimeSpan.FromSeconds(10000);
        messageList.Add(new Tuple<Message, DeliveryOption>(message, DeliveryOption.All));
    }
    // Register message delivery failure
    topic.MessageDeliveryFailure += OnFailureMessageReceived;

    // Register Topic deletion notification
    topic.OnTopicDeleted = TopicDeleted;

    // Publish the order with delivery option set as all and register message delivery failure
    // In case of failed publishing of messages, exceptions will be returned
    IDictionary<Message, Exception> keys = topic.PublishBulk(messageList, true);
}

Pubblica messaggi ordinati

Note:

Questa funzione è disponibile solo in NCache Dal 5.2 in poi.

I messaggi possono essere pubblicati specificando un nome di sequenza che fa sì che i messaggi vengano pubblicati in un ordine specifico. Per specificare messaggi ordinati, un nome sequenza stringa viene aggiunto alla catena dei messaggi che assicura la pubblicazione di tutti i messaggi appartenenti a un nome sequenza specifico sullo stesso nodo server. Nell'esempio riportato di seguito, un nome sequenza viene aggiunto con i messaggi e i messaggi vengono quindi pubblicati utilizzando Publish metodo.

// Precondition: Cache is already connected

// Specify the Topic name that already exists
string topicName = "orderTopic";
// Get the Topic with the specified name
ITopic orderTopic = cache.MessagingService.GetTopic(topicName);
if (orderTopic  != null)
{
    for (int i = 0; i < 30; i++)
    {
        // Create the object to be sent in message
        Order order = FetchOrderFromDB(10248);

        // Create the new message with the object order
        var orderMessage = new Message(order);

        // Specify a unique sequence name for the messages
        string sequenceName = "OrderMessages";

        // Set the expiration time of the message
        orderMessage.ExpirationTime = TimeSpan.FromSeconds(5000);

        // Publish message with the sequence name
        orderTopic.Publish(orderMessage, DeliveryOption.All, sequenceName, true);
    }
}
else
{
    // No Topic found
}

Registra le richiamate

private void OnFailureMessageReceived(object sender, MessageFailedEventArgs args)
{
    // Failure reason can be get from args.MessageFailureReason
}

private void TopicDeleted(object sender, TopicDeleteEventArgs args)
{
    // Deleted Topic is args.TopicName
}

Risorse addizionali

NCache fornisce un'applicazione di esempio per Pub/Sub su GitHub.

Vedere anche

.NETTO: Alachisoft.NCache.Memorizzazione.della.cache spazio dei nomi.
Giava: com.alachisoft.ncache.runtime.caching pacchetto.
Pitone: servizi.ncache.client modulo.
Node.js: Argomento classe.