Discussion :

[jfv.work]

Bonjour,

depuis plusieurs jours je suis bloqué par le problème suivant: je souhaite interroger une instance unique de prolog contenant de nombreux prédicats et règles à travers un système de socket.
Les prédicats et règles étant partagées entre les clients et particulièrement nombreux je préfère ne pas mettre en oeuvre un système de chargement des données par fichier (il pourrait y avoir plusieurs milliers de requetes par seconde).
Les librairies Prolog proposent tout ce qu'il faut pour construire un serveur qui écoute les appels sur une socket, gère des files d'attentes... mais jusqu'à présent je n'ai pas réussi à exécuter une requête sur un prédicat ou une règle connue par prolog. Je pense ne pas être très loin, et un œil extérieur pourra sans doute trouver le détail qui me manque : le client

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
 
:- use_module(library(socket)).
:- use_module(library(streampool)).
 
server(Port) :-
        tcp_socket(Socket),
	tcp_bind(Socket, Port),
        tcp_listen(Socket, 5),
        tcp_open_socket(Socket, In, _Out),
        add_stream_to_pool(In, accept(Socket)),
        stream_pool_main_loop.
 
accept(Socket) :-
        tcp_accept(Socket, Slave, Peer),
        tcp_open_socket(Slave, In, Out),
        add_stream_to_pool(In, client(In, Out, Peer)).
 
client(In, Out, _Peer) :-
        read_line_to_codes(In, Command),
        close(In),
	write(Out, animal(Command)),
        close(Out),
 
cat(tom).
animal(X) :- cat(X).

J'ai tenté des appels via call, sans résultat.

D'avance merci pour vos idées.

Cdt,

jfv

[Trap D]

Avant de me pencher plus avant sur ton code avais-tu vu ce post ?
Peut-être y trouveras-tu les réponses que tu attends.

[EDIT] Tu as une erreur de syntaxe à la fin de la ligne précédent cat(tom), tu as mis une virgule au lieu d'un point ! [/EDIT]

[Trap D]

J'ai un peu modifié ton prog pour gérer les erreurs :

Code :

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

1
2
3
4
5
6
7
8
9
client(In, Out, _Peer) :-
        read_line_to_codes(In, Command),
        close(In),
	string_to_atom(Command, CA),
	catch(call(CA, A),
	      A,
	      format(Out, 'Erreur de saisie ~w~n', [A])),
	write(Out,A),
        close(Out).

[jfv.work]

Merci pour ta solution et pour ta réactivité, je vais repartir du code que tu propose pour finir de l'adapter à mon besoin. Ca marche bien maintenant.

Joyeuses fêtes à tous,

cdt,

jfv

[jfv.work]

re-Bonjour,

la solution proposée pour la calcatrice fonctionne bien, par contre, je n'arrive pas à l'adapter à mon besoin passer en paramètre via telnet non seulement les paramètes mais aussi la question: exemple cat(tom) : j'ai l'impression que l'évaluation des règles est bien faite, mais je n'arrive pas à obtenir la réponse, au mieux je récupère un code du type G280.

Merci de vos idées.

cdt,

jfv

[Trap D]

Tu peux poster le code à jour du serveur et du client ?

[jfv.work]

Bonjour,

pour le serveur, j'ai repris le code initial et l'ai complté à l'aide des propositions faites précédemment, comme suit:

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
cat(tom).
cat(tim).
dog(waf).
 
pet(X):- call(cat(X)).
 
 
:- use_module(library(socket)).
:- use_module(library(streampool)).
 
server(Port) :-
        tcp_socket(Socket),
	tcp_bind(Socket, Port),
        tcp_listen(Socket, 5),
        tcp_open_socket(Socket, In, _Out),
        add_stream_to_pool(In, accept(Socket)),
        stream_pool_main_loop.
 
accept(Socket) :-
        tcp_accept(Socket, Slave, Peer),
        tcp_open_socket(Slave, In, Out),
        add_stream_to_pool(In, client(In, Out, Peer)).
 
client(In, Out, _Peer) :-
        read_line_to_codes(In, StringCommand),
        read_line_to_codes(In, StringParam),
        close(In),
	string_to_atom(StringCommand,AtomS),
	string_to_atom(StringParam,AtomP),
	catch(call(AtomS,AtomP,A),
	      A, 
	      format('Erreur de saisie ~a~n', A)),
        format(Out, '~w~n', [A]),
	format('Calcul demandé : ~w~n', [A]),
	close(Out).

pour le client, je fais juste un telnet localhost 5000 (après avoir lancé le serveur sur le même port bien sur). puis j'entre mes atomes sous la forme:
cat
tom

D'avance merci de vos propositions

[Trap D]

Voici quelque chose qui fonctionne chez moi :
le serveur :

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
:- use_module(library(socket)).
:- use_module(library(streampool)).
 
cat(tom).
cat(tim).
dog(waf).
 
pet(X):- call(cat(X)).
 
init :-
	server(5000).
server(Port) :-
        tcp_socket(Socket),
	writeln(Socket),
	tcp_bind(Socket, Port),
        tcp_listen(Socket, 5),
        tcp_open_socket(Socket, In, _Out),
        add_stream_to_pool(In, accept(Socket)),
        stream_pool_main_loop.
 
accept(Socket) :-
        tcp_accept(Socket, Slave, Peer),
        tcp_open_socket(Slave, In, Out),
        add_stream_to_pool(In, client(In, Out, Peer)).
 
client(In, Out, _Peer) :-
        read_line_to_codes(In, Command),
        close(In),
	string_to_atom(Command, CA),
	catch(call(CA, A),
	      A,
	      format(Out, 'Erreur de saisie ~w~n', [A])),
	write(Out,A),
        close(Out).

Dans un autre fichier, le client :

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
create_client(Host, Port) :-
	% boucle de connexion
	repeat,
        tcp_socket(Socket),
        tcp_connect(Socket, Host:Port),
        tcp_open_socket(Socket, ReadFd, WriteFd),
	write('Tapez quelque chose, (0 pour cesser) '),
	read_line_to_codes(user_input, X),
	format(WriteFd, '~s~n', [X]),
	flush_output(WriteFd),
	read_line_to_codes(ReadFd, Lst),
	string_to_list(Command, Lst),
	writeln(Command),
        close(ReadFd),
        close(WriteFd),
	string_to_list("0", X).
 
calcul :-
	create_client('localhost', 5000).

Voici ce que j'obtiens pour le client :

2 ?- calcul.
Tapez quelque chose, (0 pour cesser) pet
tom
Tapez quelque chose, (0 pour cesser) cat
tom
Tapez quelque chose, (0 pour cesser)

[jfv.work]

Bonjour,

ça commence à s'approcher de ce que je souhaite, je retrouve bien le premier résultat qd j'interroge le serveur avec "cat" par exemple. Je pense qu'en utilisant un findall, je devrais pouvoir sans trop de difficultés pouvoir obtenir la liste des résultats.

Par contre, je souhaiterai également pouvoir passer des paramètres pour avoir des réponses comme par exemple envoyer au serveur cat(tom) et recevoir en retour true ou false.

Cela semble-il faisable ?

cdt,

jfv

[Trap D]

Bien sur, il faut bricoler un peu c'est tout.
Essaye d'instaurer un dialogue de connexion, afficher des messages pour aider à la saisie.