Un set de legaturi de noduri bazate pe flux pentru ZeroMQ. API-ul este modelat dupa API-ul streams2.

Diferente fata de fluxuri2

Deoarece ZeroMQ nu este un operator de transport neutru, API-ul duplex streams2 ZMQStream utilizeaza este prin mesaj , nu prin octet. In timp ce API-ul duplex este preluat in spirit, nu incercati sa cititi si sa scrieti ca si cum ar fi fluxuri secundare si nici nu ar trebui sa introduceti un flux secundar in sau in afara unui socket ZMQStream.

Daca se doreste, fluxurile Transform ar putea fi utilizate pentru a inlocui incadrarea asteptata, traducand fluxul de mesaje intr-un / dintr-un flux secundar. Cand o implementare devine disponibila (este considerata a fi in afara sferei acestui pachet), va fi conectata aici.

Preocupari suplimentare

  • Exista o relatie 1: 1 intre procesele nodului si contextele ZMQ. Va rugam sa trimiteti o problema daca acest lucru cauzeaza probleme. Intreruperea acestei relatii stricte va necesita discutii cu privire la cazuri de utilizare specifice.

Instalare

Inainte de a putea instala ZMQStream cu NPM, trebuie sa aveti sursa de dezvoltare pentru ZeroMQ 3.2.x instalata local. Aceasta va fi o sarcina dependenta de platforma, dar majoritatea platformelor au instrumente pentru a face acest lucru mai usor:

brew install zeromq –devel yum install zeromq-devel

Dupa ce este gata, npm poate fi folosit in mod normal pentru a instala ZMQStream:

Exemple

var zmqstream = require (‘zmq-stream’), socket socket = zmqstream.createSocket ({type: zmqstream.Type.ROUTER}) socket.read () socket.connect (process.env.URL) socket.on (‘lizibil ‘, function () {var messages = socket.read () console.log (messages [0]) messages [0] .pop () messages [0] .push (new Buffer (‘ pong ‘)) socket.write ( mesaje [0])})

Pentru exemple mai detaliate, va rugam sa consultati directorul de exemple.

  • Ventilare / chiuveta – ventil de nod [COUNT] [TYPE], chiuveta nodului [COUNT] [TYPE] – Vente COUNT mesaje catre chiuveta peste soclurile TYPE. Implicit la 1000 de mesaje cu o priza de ventilatie PUSH si o priza pentru chiuveta PULL.
  • Router / Dealer – nod dealer [COUNT], nod router [COUNT] – Trimite COUNT mesaje de la dealer la router, asteptand COUNT raspunsuri in schimb cu acelasi plic. Daca COUNT este -1, se considera ca este Infinity. Implicit la 1000 de mesaje.
  • C Router / Dealer – c / dealer [COUNT], c / router [COUNT] – Identic la Router / Dealer (cu exceptia manevrarii -1), dar scris folosind CZMQ. Construiti utilizand marca si asigurati-va ca instalati mai intai CZMQ. Util pentru a descrie compatibilitatea inter-limba acordata de ZeroMQ. Incercati sa rulati un router C si un dealer JS si invers.

API

Constante

createSocket zmqstream.createSocket (optiuni) De asemenea: Socket nou (optiuni)

Creeaza o noua optiune.tip Instanta de socket. Valori implicite la PAIR.

Priza

Un soclu ZMQStream este intr-adevar (poate evident) doar un flux duplex pe care il puteti conecta, lega etc., la fel ca un soclu ZMQ nativ.

Proprietati

  • type – Tipul numeric al soclului creat.

inchide socket.close ()

Inchide si curata resursele subiacente. Va rugam sa va asigurati ca inchiderea este apelata dupa ce soclul nu mai este utilizat. Nu apelati nicio alta metoda dupa inchidere.

set socket.set (optiune, valoare)

Seteaza optiunea (de exemplu, IDENTITATE) la valoare (de exemplu, “ExempluClient”), exprimata conform cerintelor ZMQ (unele valori ar trebui sa fie Numere sau Booleeni).

obtine socket.get (optiune)

Extrage optiunea ca formatul specificat de ZMQ.

cititi socket.read ([marime])

Consuma un maxim de dimensiunea mesajelor de date. Daca dimensiunea este nedefinita, intreaga coada va fi citita si returnata.

Daca nu exista date de consumat sau daca exista mai putini octeti in buffer-ul intern decat argumentul size, atunci se returneaza nul, iar un viitor eveniment „lizibil” va fi emis atunci cand sunt disponibile mai multe.

Apelarea stream.read (0) este o optiune fara efecte secundare interne, dar poate fi utilizata pentru a testa validitatea Socket.

Returneaza o matrice de mesaje, care sunt la randul nostru Matrice de cadre sub forma de tampoane de noduri.

NOTA: Pentru a reitera, aceasta citire returneaza o suma diferita intr-un format diferit decat duplexul incorporat!

scrie socket.write (mesaj)

Mesaj la cozi , exprimat ca mesaj (o matrice de tampoane), care va fi transmis prin cablu la un moment dat in viitor.

Apelarea stream.write ([]) este o optiune fara efecte secundare interne, dar poate fi utilizata pentru testarea validitatii Socket.

Returneaza adevarat daca mesajul a fost pus la coada cu succes sau fals daca bufferul este plin (consultati ZMQ_DONTWAIT / EAGAIN). Daca bufferul este plin, va fi emis un eveniment „drain” cand spatiul este disponibil din nou pentru trimitere.

NOTA: Spre deosebire de clasa Duplex incorporata, o valoare returnata fals indica faptul ca scrierea nu a reusit si va trebui sa fie incercata din nou in viitor.

conectati socket.connect (punct final)

Se conecteaza sincron la punctul final , exprimat ca un sir, aruncand o eroare la esec.

deconectati socket.disconnect (punct final)

Se deconecteaza sincron de la punctul final , exprimat ca un sir, aruncand o eroare la esec.

bind socket.bind (punct final)

Se leaga sincron la punctul final , exprimat ca un sir, aruncand o eroare la esec.

dezlegare socket.unbind (punct final)

Se leaga sincron de punctul final , exprimat ca un sir, aruncand o eroare la esec.

Alternative si comparatii

  • zmq – zmq are o metoda de trimitere pe mesaj mult mai „placuta”, un cadru pe argument. In plus, toate mesajele primite sunt difuzate ca un eveniment de „mesaj” pe socket, de asemenea, cu un cadru per argument. Acestea fiind spuse, zmq nu are un tratament special pentru problemele HMM / EAGAIN si are un randament mai limitat.
  • axon – axon nu este un ambalaj ZeroMQ. Mai degraba, este o biblioteca de mesagerie similara scrisa in intregime in Javascript. API-ul sau este aproape identic cu zmq si l-as recomanda peste zmq pentru majoritatea aplicatiilor. Sufera aceleasi limitari ca si zmq, dar intr-o masura mai mica.

Licenta

Drepturi de autor (C) 2013 Michael Schoonmaker ([email protected])

Acest proiect este un software gratuit lansat sub licenta MIT / X11:

Prin prezenta se acorda, gratuit, oricarei persoane care obtine o copie a acestui software si a fisierelor de documentare asociate („Software-ul”), pentru a tranzactiona software-ul fara restrictii, inclusiv fara limitare, drepturile de utilizare, copiere, modificare, imbinare , publica, distribuie, sublicentiaza si / sau vinde copii ale software-ului si permite persoanelor carora li se furnizeaza software-ul sa faca acest lucru, sub rezerva urmatoarelor conditii:

Notificarea privind drepturile de autor de mai sus si aceasta notificare privind permisiunea vor fi incluse in toate copiile sau partile substantiale ale software-ului.

SOFTWARE-UL ESTE OFERIT „CA ATARE”, FARA GARANTIE DE NICIUN TIP, EXPRESA SAU IMPLICITA, INCLUSIV, DAR NU LIMITAT LA GARANTIILE DE VANZABILITATE, ADECVARE PENTRU UN SCOP PARTICULAR SI NEINFRACTIONARE. In niciun caz, AUTORII SAU DETINATORII DE DREPTURI DE AUTOR NU SUNT RESPONSABILI PENTRU ORICE REVENDICARE, DAUNE SAU ALTE RESPONSABILITATI, FIE INTR-O ACTIUNE A CONTRACTULUI, TORT SAU ALTUI, REZULTATE DIN, IN LEGATURA CU SAU IN LEGATURA CU SOFTWARE-UL SAU DE UTILIZARE SAU ALTE DISCIPLUTII IN SOFTWARE.

ARTICOLE SIMILAREDE LA ACELAȘI AUTOR