Discussion :

[pinartch]

Bonjour,
J'ai recherché sur divers sites une définition claire et précise du fonctionnement d'une boite aux lettres, de son intéret, etc. Parceque lire les man, ce n'est pas forcément suffisant...
Je comprends la théorie du fonctionnement de chaque fonction, mais globalement, je n'y arrive pas.
Quelqu'un pourrait il m'aider, ou bien s'il connait une page où tout cela est décrit facilement?
Merci encore, et je m'excuse si quelque n'a pas été fait dans les règles de l'art

[Metalman]

Alors, sans être expert, je crois qu'il s'agit d'un mécanisme d'IPC.

Chez IBM ils ont un produit assez connu : MQ Series qui sert justement à envoyer des messages entre diverses applications (elles même sur diverses machines).
D'après ce lien, cela a l'air confirmé.

Pour être plus précis : tu vas envoyer et recevoir des messages de façon asynchrone.
Plusieurs applications vont pouvoir ouvrir une même file (identifiée par son nom), puis émettre/recevoir des messages dedans.
L'intérêt de cette IPC, c'est juste d'envoyer des messages de façon asynchrone, avec un nom "commun" de file.
Par de fork nécessaire dans ton application pour créer de l'intercommunication, pas besoin de connaitre un chemin dans ton arborescence... juste le nom de la file.

Après : je n'ai pas testé ce mécanisme. Je ne peux que te dire les souvenirs que j'ai de MQ Series, et ce que je déduis de quelques lignes du man !

[Metalman]

Comme je n'avais jamais travaillé sur les MQ, j'ai voulu tester en vitesse.

ansi.h

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
#ifndef ANSI_H_
# define ANSI_H_
 
# include <unistd.h>
# include <stdlib.h>
# include <stdio.h>
# include <stdarg.h>
# include <string.h>
# include <errno.h>
 
# define MAXLINE	4096
 
char	*strdup(const char	*str);
 
#endif /* !ANSI_H_ */

ansi.c

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
#include "ansi.h"
 
char	*strdup(const char	*str)
{
  size_t	len;
  char		*copy;
 
  len = strlen(str) + 1;
  if ((copy = malloc(len * sizeof (char))) == NULL)
    return (NULL);
  memcpy(copy, str, len);
  return (copy);
}

(normalement j'ai beaucoup beaucoup + de fonctions dedans...)

main.h

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
#ifndef MAIN_H_
# define MAIN_H_
 
# include <unistd.h>
# include <stdlib.h>
# include <stdio.h>
# include <fcntl.h>		/* For O_* constants */
# include <sys/stat.h>	/* For mode constants */
# include <mqueue.h>
# include <string.h>
 
# include "ansi.h"
 
#endif /* !MAIN_H_ */

main.c

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
#include "main.h"
 
#define MQ_NAME "/queuetest"
#define BUF_LEN 512
 
int	main(void)
{
	ssize_t	len_recv;
	mqd_t	My_MQ;
	char	*text;
	char	recv[BUF_LEN];
	int		ret;
 
	My_MQ = mq_open(MQ_NAME, O_RDWR);
	if (My_MQ == -1)
	{
		perror("Error : mq_open failed !\n");
		return (-1);
	}
 
	printf("%s\n", "Envoi msg de priorite 42");
	text = strdup("Message test prio : 42 !");
	ret = mq_send(My_MQ, text, strlen(text), 42);
	free(text);
 
	printf("%s\n", "Envoi msg de priorite 21");
	text = strdup("Message test prio : 21 !");
	ret = mq_send(My_MQ, text, strlen(text), 21);
	free(text);
 
	memset(recv, 0, BUF_LEN);
	len_recv = mq_receive(My_MQ, recv, BUF_LEN, NULL);
	printf("Premier msg recu (len : %u) : %s\n", (unsigned int) len_recv, recv);
 
	memset(recv, 0, BUF_LEN);
	len_recv = mq_receive(My_MQ, recv, BUF_LEN, NULL);
	printf("Deuxieme msg recu (len : %u) : %s\n", (unsigned int) len_recv, recv);
 
	mq_close(My_MQ);
	return (0);
}

Compilé avec : gcc -W -Wall -Werror -ansi -pedantic -lrt ansi.c main.c

Quand j'exécute ça ne fonctionne pas, cela m'affiche "Function not implemented".
D'après ce lien, un sleep(1) règle le problème ?!?
Je n'ai pas encore essayé (conditions de dév pas géniale là tout de suite...).
Mais contrairement à ce que le monsieur raconte sur le lien, il ne faut PAS mettre plusieurs '/' dans le nom de la queue ! Seulement 1 au début.
Enfin, toujours d'après le 1er lien en haut.

J'édite dès que j'ai un truc qui marche, et je le mets ici...
Le MQ m'intéresse grandement !

[Médinoc]

"not implemented" c'est parce qu'il existe deux types de files de message sous *n*x, et qu'ils ne sont pas toujours implémentés tous les deux:

• mq_open(), pour les IPC POSIX.
• msgget(), pour les IPC System V. Ces messages possèdent un paramètre supplémentaire pouvant être utilisé comme filtre, bien utile dans certains cas.

[Metalman]

Ca j'ai fini par le voir.
La page OpenGroup de l'interface POSIX : lien

Ce qui m'étonne, c'est que les interfaces sont déclarées, quelques docs perdues en parlent : Linuxpedia
Mais.... nul part ça fonctionne !

Apparemment les mq_* sont inclus dans les kernels linux 2.6 et +.
Ce qui "normalement" est dispo sur quasiment tous les linux du moment et depuis 5 ans.... mais en fait non ?

[kwariz]

En fait ça dépend de la configuration du noyau, tu peux ou non y inclure la gestion des IPC à la POSIX.
Suivant la distrib, le fichier décrivant les options utilisées se trouve dans /boot ou /usr/src/linux/ ou ailleurs.
Par exemple j'ai un opensuse, le fichier de config se trouve dans /boot et contient :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
CONFIG_SYSVIPC=y
CONFIG_SYSVIPC_SYSCTL=y
CONFIG_POSIX_MQUEUE=y
CONFIG_POSIX_MQUEUE_SYSCTL=y

Je peux donc utiliser les deux façons de faire et c'est effectivement le cas.