ZeroMQ - Historique des versions

Jiel le 16 décembre 2023 à 15:53

2023-12-16T15:53:04Z

← Version précédente		Version du 16 décembre 2023 à 15:53
Ligne 139 :		Ligne 139 :
	<br/>		<br/>
	<br/>		<br/>
	'''<b>[[~~Reseau-index~~\|@ Retour à la rubrique Réseau ~~et sécurité~~]]</b>'''		'''<b>[[Réseau\|@ Retour à la rubrique Réseau]]</b>'''
	<br/>		<br/>

	[[Catégorie:Réseau ~~et sécurité~~]]		[[Catégorie:Réseau]]

Lea le 12 octobre 2016 à 12:59

2016-10-12T12:59:26Z

← Version précédente		Version du 12 octobre 2016 à 12:59
Ligne 135 :		Ligne 135 :

	== A suivre ... ==		== A suivre ... ==


			<br/>
			<br/>
			'''<b>[[Reseau-index\|@ Retour à la rubrique Réseau et sécurité]]</b>'''
			<br/>

			[[Catégorie:Réseau et sécurité]]

Lea le 12 octobre 2016 à 12:57

2016-10-12T12:57:41Z

← Version précédente		Version du 12 octobre 2016 à 12:57
Ligne 3 :		Ligne 3 :
	ZeroMQ est une librairie de transfert de données asynchrone de haute-performance. Très utile, elle permet d'envoyer des données via des méthodes qui sort du cadre des sockets habituelles ou des IPC (même si elles sont utilisés).		ZeroMQ est une librairie de transfert de données asynchrone de haute-performance. Très utile, elle permet d'envoyer des données via des méthodes qui sort du cadre des sockets habituelles ou des IPC (même si elles sont utilisés).

	Pour plus d'informations, nous vous conseillons le site [http://zeromq.org/ officiel], ainsi qu'un excellent résumé sur le site de [http://www.geek-directeur-technique.com/2011/09/21/zeromq-la-super-bibliotheque-reseau Amaury Bouchard]		Pour plus d'informations, nous vous conseillons le site [http://zeromq.org/ officiel], ainsi qu'un excellent résumé sur le site de [http://www.geek-directeur-technique.com/2011/09/21/zeromq-la-super-bibliotheque-reseau Amaury Bouchard].

	Les différentes parties de cette documentation seront en constante construction, considérez-les comme des notes rapides de recherches. Les différents morceaux de code seront écrits en python (sauf indication contraire).		Les différentes parties de cette documentation seront en constante construction, considérez-les comme des notes rapides de recherches. Les différents morceaux de code seront écrits en python (sauf indication contraire).

	Il existe une multitude de code source d'exemple sur ce site: [http://zguide.zeromq.org/page:all http://zguide.zeromq.org/page:all]		Il existe une multitude de code source d'exemple sur ce site: [http://zguide.zeromq.org/page:all http://zguide.zeromq.org/page:all].

	== ZeroMQ et le contexte ==		== ZeroMQ et le contexte ==

Lea : /* ZeroMQ */

2016-09-30T13:42:40Z

ZeroMQ

← Version précédente		Version du 30 septembre 2016 à 13:42
Ligne 1 :		Ligne 1 :
	= ZeroMQ =		= ZeroMQ =

	ZeroMQ est une librairie de transfert de données asynchrone de haute-performance. Très utile, elle permet d'envoyer des données via des méthodes qui sort du cadre des sockets ~~habituels~~ ou des IPC (même si elles sont utilisés).		ZeroMQ est une librairie de transfert de données asynchrone de haute-performance. Très utile, elle permet d'envoyer des données via des méthodes qui sort du cadre des sockets habituelles ou des IPC (même si elles sont utilisés).

	Pour plus d'informations, nous vous conseillons le site [http://zeromq.org/ officiel], ainsi qu'un excellent résumé sur le site de [http://www.geek-directeur-technique.com/2011/09/21/zeromq-la-super-bibliotheque-reseau Amaury Bouchard]		Pour plus d'informations, nous vous conseillons le site [http://zeromq.org/ officiel], ainsi qu'un excellent résumé sur le site de [http://www.geek-directeur-technique.com/2011/09/21/zeromq-la-super-bibliotheque-reseau Amaury Bouchard]

Lea : /* ZeroMQ */

2016-09-30T13:42:20Z

ZeroMQ

← Version précédente		Version du 30 septembre 2016 à 13:42
Ligne 1 :		Ligne 1 :
	= ZeroMQ =		= ZeroMQ =

	ZeroMQ est une librairie de transfert de données ~~asynchrones~~ de haute-performance. Très utile, elle permet d'envoyer des données via des méthodes qui sort du cadre des sockets habituels ou des IPC (même si elles sont utilisés).		ZeroMQ est une librairie de transfert de données asynchrone de haute-performance. Très utile, elle permet d'envoyer des données via des méthodes qui sort du cadre des sockets habituels ou des IPC (même si elles sont utilisés).

	Pour plus d'informations, nous vous conseillons le site [http://zeromq.org/ officiel], ainsi qu'un excellent résumé sur le site de [http://www.geek-directeur-technique.com/2011/09/21/zeromq-la-super-bibliotheque-reseau Amaury Bouchard]		Pour plus d'informations, nous vous conseillons le site [http://zeromq.org/ officiel], ainsi qu'un excellent résumé sur le site de [http://www.geek-directeur-technique.com/2011/09/21/zeromq-la-super-bibliotheque-reseau Amaury Bouchard]

Lea : Page créée avec « = ZeroMQ = ZeroMQ est une librairie de transfert de données asynchrones de haute-performance. Très utile, elle permet d'envoyer des données via des méthodes qui sort... »

2016-09-30T13:37:58Z

Page créée avec « = ZeroMQ = ZeroMQ est une librairie de transfert de données asynchrones de haute-performance. Très utile, elle permet d'envoyer des données via des méthodes qui sort... »

Nouvelle page

= ZeroMQ =

ZeroMQ est une librairie de transfert de données asynchrones de haute-performance. Très utile, elle permet d'envoyer des données via des méthodes qui sort du cadre des sockets habituels ou des IPC (même si elles sont utilisés).

Pour plus d'informations, nous vous conseillons le site [http://zeromq.org/ officiel], ainsi qu'un excellent résumé sur le site de [http://www.geek-directeur-technique.com/2011/09/21/zeromq-la-super-bibliotheque-reseau Amaury Bouchard]

Les différentes parties de cette documentation seront en constante construction, considérez-les comme des notes rapides de recherches. Les différents morceaux de code seront écrits en python (sauf indication contraire).

Il existe une multitude de code source d'exemple sur ce site: [http://zguide.zeromq.org/page:all http://zguide.zeromq.org/page:all]

== ZeroMQ et le contexte ==

Quand vous commencez, il faut définir un "contexte" à l'aide de *zmq.Context*.

=== Définition d'un nouveau contexte : ===
<code>
context = zmq.Context()
</code>

=== Réutilisation du contexte actuel : ===
<code>
context = zmq.Context.instance()
</code>

Attention, en "inproc", utilisez un seul contexte par processus, sinon vous ne pourrez communiquer.
Sur les autres méthodes (tcp, ipc, egpm), vous pouvez initier de nouveau contexte.

Très important à retenir, surtout dans un environnement "fork" ou de "thread".

== ZeroMQ avec une socket de type PAIR ==

La socket de type PAIR permet de joindre deux sockets de façon exclusive. Aucun autre "PAIR" ne peut se connecter en plus. Si vous avez plusieurs threads avec différents PAIR, il est normal qu'un seul marche. Les autres ne pourront jamais se connecter.

__Avantages__
* PAIR ne supprime aucun paquet même en cas d'inondation (flood) de données, il garantit la réception des données
* PAIR semble attendre que le sender et le receiver soit connectés pour s'envoyer des données. Vous avez donc la garantie de l'envoi et de la réception de vos données.(*1)

__Désavantages__
* PAIR ne peuvent être que deux.

=== Exemple de code "serveur" ===
<code>
import zmq
from zmq.eventloop import ioloop, zmqstream

context = zmq.Context.instance()

sender = context.socket(zmq.PAIR)
sender.connect("inproc://mon_pairing")

with open("votre_fichier", 'rb') as file:
for buffer in iter(lambda: file.read(65536), b''):
sender.send(buffer)
file.close()
return(True)
</code>

=== Exemple de code "client" ===
<code>
import zmq
from zmq.eventloop import ioloop, zmqstream

context = zmq.Context.instance()

receiver = context.socket(zmq.PAIR)
receiver.bind("inproc://mon_pairing")

while receiver.poll():
buffer = receiver.recv()
print(buffer)
</code>

*1 = En tout cas, dans les nombreux tests effectués, il n'y a eu aucune perte de données ni même de retard dans la réception.

== ZeroMQ avec une socket de type PUB/SUB ==

Si vous souhaitez avoir plusieurs sockets en écoute, vous pouvez utiliser PUBLISH et SUBSCRIBE.

=== Exemple de la partie serveur PUBLISHER (corps seulement) ===

<code>
context = zmq.Context.instance()

sender = context.socket(zmq.PUB)
sender.bind("inproc://thread")

while (...)
</code>

=== Exemple de la partie client SUBSCRIBE (corps seulement) ===
<code>
context = zmq.Context.instance()

receiver = context.socket(zmq.SUB)
receiver.connect("inproc://thread")
receiver.setsockopt(zmq.SUBSCRIBE, b'')

while (...)
</code>

Le setsockopt "SUBSCRIBE" à (vide) défini qu'on souhaite l'ensemble des données (aucun filtre)
Vous pouvez définir plusieurs clients avec les mêmes éléments. Chaque client va recevoir les données du "PUBLISHER".
Il est important de définir le setsockopt SUBSCRIBE après le connect.

Important à savoir, les sockets de type "PUB/SUB" comme ROUTER/DEALER/etc. vont supprimer des paquets si vous envoyez trop de données en même temps.
Pour éviter ce genre de problème, définissez les "Watermarks" (HWM) à 0 (illimité). Il est important de définir les watermarks APRÉS la socket et AVANT le connect ou bind.

=== Exemple ===
<code>
context = zmq.Context.instance()

sender = context.socket(zmq.PUB)
sender.setsockopt(zmq.SNDHWM, 0)
sender.setsockopt(zmq.RCVHWM, 0)
sender.bind("inproc://thread")

while (...)
</code>
<code>
context = zmq.Context.instance()

receiver = context.socket(zmq.SUB)
receiver.setsockopt(zmq.SNDHWM, 0)
receiver.setsockopt(zmq.RCVHWM, 0)
receiver.connect("inproc://thread")
receiver.setsockopt(zmq.SUBSCRIBE, b'')

while (...)
</code>

Il est important de respecter cette hiérarchie (socket, setsockopt HWM, connect/bind, setsockopt SUBSCRIBE). Sans cela, vous aurez soit des pertes de paquets, soit aucune information. Important aussi: il faut démarrer les instances clientes (SUB) AVANT le publisher. Sinon, il peut manquer des informations en tout début d'envoi ou de réception.

== A suivre ... ==

ZeroMQ - Historique des versions

Jiel le 16 décembre 2023 à 15:53

Lea le 12 octobre 2016 à 12:59

Lea le 12 octobre 2016 à 12:57

Lea : /* ZeroMQ */

Lea : /* ZeroMQ */

Lea : Page créée avec « = ZeroMQ = ZeroMQ est une librairie de transfert de données asynchrones de haute-performance. Très utile, elle permet d'envoyer des données via des méthodes qui sort... »

Lea : /* ZeroMQ */

Lea : /* ZeroMQ */

Lea : Page créée avec « = ZeroMQ = ZeroMQ est une librairie de transfert de données asynchrones de haute-performance. Très utile, elle permet d'envoyer des données via des méthodes qui sort... »