Memorizza nella cache i messaggi con Singleton Pipes

Singleton Pipe è un'aggiunta al pacchetto DBMS_PIPE che consente di inserire nella cache e recuperare un messaggio personalizzato e condividere il messaggio tra più sessioni di database con letture concorrenti.

Informazioni sulla memorizzazione nella cache dei messaggi con i tubi Singleton

Il pacchetto DBMS_PIPE ha esteso le funzionalità di Autonomous AI Database per supportare Singleton Pipes.

Un tubo Singleton in DBMS_PIPE:

Informazioni su tubi standard e tubi Singleton

Il package DBMS_PIPE consente a due o più sessioni di database di comunicare utilizzando messaggi in memoria. La funzionalità Pipe include diverse applicazioni quali l'interfaccia dei servizi esterni, il debug, le transazioni indipendenti e gli avvisi. Per ulteriori informazioni, vedere DBMS_PIPE in Oracle Database 19c PL/SQL Packages and Types Reference oppure Oracle Database 26ai PL/SQL Packages and Types Reference.

Descrizione dell'illustrazione database-pipe-messages-singleton-pipes.png

Un tubo Singleton può essere uno qualsiasi dei tipi DBMS_PIPE supportati:

Singleton Pipes offre la possibilità di inserire nella cache un singolo messaggio nella memoria dell'istanza di Autonomous AI Database.

Di seguito viene illustrato il flusso di lavoro generale per l'utilizzo di tubi singleton.

Descrizione dell'illustrazione singleton-pipe-workflow.png

Panoramica e caratteristiche di Singleton Pipe

Singleton Pipe Operazioni

Operazione Funzione o procedimento DBMS_PIPE
Crea una pipe singleton esplicita Funzione CREATE_PIPE
Inserisci un messaggio in Singleton Pipe

Procedure PACK_MESSAGE in Oracle Database 19c PL/SQL Packages and Types Reference oppure Oracle Database 26ai PL/SQL Packages and Types Reference

Funzione SEND_MESSAGE
Leggere un messaggio inserito nella cache da Singleton Pipe Funzione RECEIVE_MESSAGE, Procedure UNPACK_MESSAGE in Oracle Database 19c PL/SQL Packages and Types Reference oppure Oracle Database 26ai PL/SQL Packages and Types Reference
Elimina un messaggio in pipe singleton Procedura PURGE in Oracle Database 19c PL/SQL Packages and Types Reference oppure Oracle Database 26ai PL/SQL Packages and Types Reference
Rimuovere una pipe singleton esplicita Funzione REMOVE_PIPE in Oracle Database 19c PL/SQL Packages and Types Reference oppure Oracle Database 26ai PL/SQL Packages and Types Reference

Aggiornamento automatico del messaggio inserito nella cache con una funzione cache

Il pacchetto DBMS_PIPE consente di popolare automaticamente un messaggio Singleton Pipe utilizzando una funzione cache definita dall'utente.

Per impostazione predefinita, dopo che un messaggio viene invalidato con invalidazione esplicita o implicita di Singleton Pipe, un DBMS_PIPE.RECEIVE_MESSAGE successivo non restituisce alcun messaggio. Per aggiungere un nuovo messaggio alla pipe, il messaggio deve essere inserito nella cache in modo esplicito chiamando DBMS_PIPE.SEND_MESSAGE. Per evitare questo caso, in cui non è disponibile alcun messaggio quando si legge da una pipe Singleton, è possibile definire una funzione cache. Con una funzione cache definita, la funzione cache viene richiamata automaticamente quando si riceve un messaggio nei seguenti scenari:

Per utilizzare una funzione cache, definire la funzione cache e includere il parametro cache_func con DBMS_PIPE.RECEIVE_MESSAGE. Una funzione cache definita dall'utente fornisce quanto riportato di seguito.

L'utilizzo di una funzione cache semplifica l'utilizzo di Singleton Pipes. Non è necessario gestire i casi di errore per la ricezione di un messaggio da una pipe vuota. Inoltre, una funzione cache assicura che non ci sia cache-miss quando si leggono i messaggi da una Singleton Pipe, fornendo il massimo utilizzo del messaggio inserito nella cache.

Segue la descrizione dell'immagine automatic-cache-refresh-cache-function.eps

Descrizione dell'illustrazione automatic-cache-refresh-cache-function.png

Quando si definisce una funzione cache, il nome della funzione deve essere completamente qualificato con lo schema proprietario:

Definire una funzione cache con la firma seguente:

CREATE OR REPLACE FUNCTION *cache_function_name*(
       pipename  IN VARCHAR2
) RETURN INTEGER;

Le operazioni tipiche all'interno di una funzione cache sono le seguenti:

Per utilizzare una funzione cache, l'utente della sessione corrente che richiama DBMS_PIPE.RECEIVE_MESSAGE deve disporre dei privilegi necessari per eseguire la funzione cache.

Per ulteriori informazioni sulla definizione di una funzione cache, vedere Funzione RECIEVE_MESSAGE.

Crea una pipe singleton esplicita

Descrive i passaggi per creare una pipe Singleton con un nome di pipe specificato (una pipe Singleton esplicita).

In primo luogo, per questo esempio, creare la funzione di supporto receive_message per chiamare ripetutamente DBMS_PIPE.RECEIVE_MESSAGE. Ciò consente di testare la funzionalità del tubo singleton.

CREATE OR REPLACE FUNCTION msg_types AS
       TYPE t_rcv_row IS RECORD (c1 VARCHAR2(32767), c2 NUMBER);
       TYPE t_rcv_tab IS TABLE OF t_rcv_row;
END;


CREATE OR REPLACE FUNCTION receive_message(
      pipename    IN VARCHAR2,
      rcv_count   IN NUMBER DEFAULT 1,
      cache_func  IN VARCHAR2 DEFAULT NULL)
   RETURN msg_types.t_rcv_tab pipelined
    AS
       l_msg    VARCHAR2(32767);
       l_status NUMBER;
 BEGIN
      FOR i IN 1..rcv_count LOOP
           l_status := DBMS_PIPE.RECEIVE_MESSAGE(
            pipename   => pipename,
            cache_func => cache_func,
            timeout    => 1);
         IF l_status != 0 THEN
              raise_application_error(-20000,
             'Message not received for attempt: ' || to_char(i) || ' status: ' ||
            l_status);
         END IF;

         DBMS_PIPE.UNPACK_MESSAGE(l_msg);
             pipe row(msg_types.t_rcv_row(l_msg));
     END LOOP;
 RETURN;
 END;

  1. Creare una pipe singleton esplicita denominata PIPE_TEST con il parametro shelflife impostato su 3600 (secondi).

       DECLARE
   l_status INTEGER;
   BEGIN
   l_status := DBMS_PIPE.CREATE_PIPE(
                 pipename => 'MY_PIPE1',
                 private => TRUE,
                 singleton => TRUE,
                 shelflife => 3600);
   END;
   /

    Per ulteriori informazioni, vedere Funzione CREATE_PIPE.

  2. Verificare che la pipe singleton sia stata creata.

     SELECT name, singleton, type
      FROM v$db_pipes WHERE name= '&pipename' ORDER BY 1;

     NAME                 SINGLETON  TYPE

 -------------------- ---------- -------
 PIPE_TEST            YES        PRIVATE

  3. Imballare e inviare un messaggio sulla pipe singleton.

     EXEC DBMS_PIPE.PACK_MESSAGE('This is a real message that you can get multiple times');

 SELECT DBMS_PIPE.SEND_MESSAGE(pipename => '&pipename') status FROM DUAL;

     STATUS

 ----------
 0

    Per ulteriori informazioni, vedere Procedure PACK_MESSAGE in Oracle Database 19c PL/SQL Packages and Types Reference oppure Oracle Database 26ai PL/SQL Packages and Types Reference e SEND_MESSAGE Function.

  4. Ricevere un messaggio da una pipe singleton.

     SELECT * FROM receive_message(
     pipename => '&pipename',
     rcv_count => 2);


     MESSAGE

 --------------------------------------------------------------------------------
 This is a real message that you can get multiple times
 This is a real message that you can get multiple times

    La funzione receive_message è una funzione helper che chiama DBMS_PIPE.RECEIVE_MESSAGE.

  5. Rimuove il messaggio e la pipe.

     EXEC DBMS_PIPE.PURGE('&pipename');
 SELECT DBMS_PIPE.REMOVE_PIPE('&pipename') status FROM DUAL;

Creare una pipe singleton esplicita con una funzione cache

Descrive i passi per creare una pipe Singleton con un nome pipe specificato, una pipe Singleton esplicita e una funzione cache. Una funzione cache consente di popolare automaticamente il messaggio in una pipe singleton.

  1. Creare una funzione cache, test_cache_message per una pipe singleton.

     CREATE OR REPLACE FUNCTION test_cache_message(
      pipename IN VARCHAR2) return NUMBER

 AS
    l_status NUMBER;
    l_data VARCHAR2(4000);
 BEGIN
    l_status := DBMS_PIPE.CREATE_PIPE(
           pipename => pipename,
           private => TRUE,
           singleton => true,
           shelflife => 600);
    IF l_status != 0 THEN RETURN l_status;
    END IF;

    DBMS_PIPE.PACK_MESSAGE('This is a placeholder cache message for an empty pipe');
    l_status := DBMS_PIPE.SEND_MESSAGE(pipename => pipename);
    RETURN l_status;
  END;
 /

    Nota: per eseguire la funzione cache, l'utente della sessione corrente che richiama DBMS_PIPE.RECEIVE_MESSAGE deve disporre del privilegio richiesto.

  2. Ricevere con una funzione cache e confermare che il messaggio viene popolato nella pipe. La pipe deve esistere come pipe privata creata nella funzione cache.

     SELECT * FROM receive_message(
      pipename => '&pipename',
      rcv_count => 1,
      cache_func => 'TEST_CACHE_MESSAGE');


     MESSAGE

 ---------------
 This is a placeholder cache message for an empty pipe

    La funzione receive_message è una funzione helper che chiama DBMS_PIPE.RECEIVE_MESSAGE. Vedere Create an Explicit Singleton Pipe per la definizione di receive_message.

    Per ulteriori informazioni, vedere Funzione CREATE_PIPE.

  3. Ricezione senza la funzione cache per confermare che il messaggio persiste nella pipe.

     SELECT * FROM receive_message(
      pipename => '&pipename',
      rcv_count => 2);


     MESSAGE

 ---------------
 This is a placeholder cache message for an empty pipe
 This is a placeholder cache message for an empty pipe

    La funzione receive_message è una funzione helper che chiama DBMS_PIPE.RECEIVE_MESSAGE. Vedere Create an Explicit Singleton Pipe per la definizione di receive_message.

    Per ulteriori informazioni, vedere Funzione CREATE_PIPE.

Contenuto correlato