Socket asincroni (possibilmente C o PHP)

Forum dedicato alla programmazione.

Moderatore: Staff

Regole del forum
1) Citare in modo preciso il linguaggio di programmazione usato.
2) Se possibile portare un esempio del risultato atteso.
3) Leggere attentamente le risposte ricevute.
4) Scrivere i messaggi con il colore di default, evitare altri colori.
5) Scrivere in Italiano o in Inglese, se possibile grammaticalmente corretto, evitate stili di scrittura poco chiari, quindi nessuna abbreviazione tipo telegramma o scrittura stile SMS o CHAT.
6) Appena registrati è consigliato presentarsi nel forum dedicato.

La non osservanza delle regole porta a provvedimenti di vari tipo da parte dello staff, in particolare la non osservanza della regola 5 porta alla cancellazione del post e alla segnalazione dell'utente. In caso di recidività l'utente rischia il ban temporaneo.
Rispondi
Avatar utente
sardylan
Linux 3.x
Linux 3.x
Messaggi: 993
Iscritto il: mar 24 apr 2007, 9:21
Nome Cognome: Luca Cireddu
Slackware: current 64bits
Kernel: 3.16
Desktop: KDE 4.14
Distribuzione: Debian - CLFS
Località: Cagliari
Contatta:

Socket asincroni (possibilmente C o PHP)

Messaggio da sardylan »

Allora... Forse voglio fare il passo più lungo della gamba...
Per fare le prove con i socket ho iniziato in PHP... Ed alla fine il tutto è diventato un BOT per IRC... E il suo dovere lo fa alla grande, però c'è il problema della lentezza, e del fatto che essendo implementato in "maniera sincrona" non posso ricevere o trasmettere dati contemporaneamente!!!
Allora ho pensato di cimentarmi con i socket asincorni in PHP, ma data la natura del linguaggio (sicuramente non progettato per threads etc...), ho deciso di passare al C, e sono più o meno riuscito a realizzare un minimo di quello che facevo con PHP (leggo e trasmetto i dati... E' solo da mettere un po' a posto)... Però rimane sempre un qualcosa di "sincrono"...
Ora, ho letto di threads ed altre cose utili per realizzare programmi con socket asincroni, ma non ho trovato gran che, e tra quel poco che c'è non ci ho capito più di tanto...

Le mie domande sono:
1. Quale linguaggio usare??? PHP bellissimo per gestire le stringhe con explode etc., ma rimane sempre un qualcosa di interpretato... C sarebbe "il mio sogno", ma non ho idea da dove iniziare... Altri linguaggi non ne conosco (a parte il Visual Basic... Mah!!! Lasciamo perdere :D) , ma non sarebbe male impararne, sopratutto se il passo non è troppo difficile da seguire!!!
2. Avete qualche guida da consigliare, oppure qualche consiglio da darmi??? Qualche presentazione, qualche PDF, qualche sito...

Intanto vi posto quel poco che sono riuscito a fare di "sincorono" in C ed in PHP...

PHP:

Codice: Seleziona tutto

#!/usr/bin/php
<?php
system("clear");

$debug = 0;
$irc_server = "indirizzo.ip.oppure.nome";
$irc_port = 6667;
$irc_chan = "#nomecanale";
$user_name = "nomeutente";
$user_psw = "VUOTO";

$bad_words = array("directory", "windows", "microsoft", "directory", "bill", "gates");

function send($stream, $data) {
	echo "   --->> $data";
	fwrite($stream, $data);
}

echo "\n\n";
echo "roBOT per IRC\n\n\n";
echo "Riepilogo dati di connessione:\n\n";
echo "Server:\t\t$irc_server\n";
echo "Porta:\t\t$irc_port\n";
echo "Nome canale:\t$irc_chan\n";
echo "Nome utente:\t$user_name\n";
echo "Password:\t$user_psw\n";
echo "\n\n";

echo "Creazione socket... ";
$irc = fsockopen($irc_server, $irc_port, $irc_errno, $irc_errstr, 15);
if ($irc) {
	echo "fatto!\n";
} else {
	echo "ERRORE!!!!\n";
	die($irc_errstr . " ($irc_errno)");
}

echo "\n\n";

send($irc, "USER $user_name \"1\" \"1\" :IRC Bot.\n");
send($irc, "NICK $user_name\n");

while (!feof($irc)) {
	$rawdata = str_replace(array("\n","\r"), "", fgets($irc, 512));
	$data = str_replace("  ", " ", $rawdata);
	echo " <<---   $data\n";
	$d = explode(" ", $data);
	if (strtolower($d[0]) == "ping") {
		if($debug == 1) {
			echo " [ deb ] Richiesta di PING...\n";
		}
		send($irc, "PONG $d[1]\n");
		if($debug == 1) {
			echo " [ deb ] Risposto!!\n";
		}
	} elseif ((count($d) > 1) and (($d[1] == "376") or ($d[1] == "422"))) {
		if($debug == 1) {
			echo " [ deb ] Join del canale $irc_chan...\n";
		}
		send($irc, "JOIN $irc_chan\n");
		if($debug == 1) {
			echo " [ deb ] Fatto!\n";
		}
		send($irc, "PRIVMSG $irc_chan :Ciao a tutti... $user_name e' tornato!\n");
		send($irc, "PRIVMSG $irc_chan :Ora controllo il canale!!!\n");
		send($irc, "PRIVMSG $irc_chan :Per informazioni dai il comando \"$user_name help\"!!!\n");
	} else {
		if(count($d) > 3) {
			$check = substr($d[3], 1, (strlen($d[3]) - 1));
		}
		$head = explode("!", $d[0]);
		$sender = substr($head[0], 1, (strlen($head[0]) - 1));
		if($debug == 1) {
			echo " [ deb ] check: $check\n";
			echo " [ deb ] cmd: $cmd\n";
			echo " [ deb ] sender: $sender\n";
		}
		for($j=3; $j<count($d); $j++) {
			if($j == 3) {
				$parola = substr(strtolower($d[$j]), 1);
			} else {
				$parola = strtolower($d[$j]);
			}
			for($k=0; $k<count($bad_words); $k++) {
				if($debug == 2) {
					echo " [ deb ] parola: $parola\n";
					echo " [ deb ] bad_words[$k]: $bad_words[$k]\n";
				}
				if($parola == $bad_words[$k]) {
					send($irc, "PRIVMSG $irc_chan :$sender::: La parola $parola non e' ammessa!!!\n");
					send($irc, "PRIVMSG $irc_chan :$sender::: Ti prendo a calci!!!\n");
					send($irc, "KICK $irc_chan $sender\n");
					$kickkati[$sender]++;
					send($irc, "PRIVMSG $irc_chan :$sender::: E siamo a $kickkati[$sender]...\n");
					if($kickkati[$sender] == 2) {
						send($irc, "PRIVMSG $irc_chan :$sender::: Alla terza ti butto FUORI!!!\n");
					} elseif($kickkati[$sender] == 3) {
						send($irc, "PRIVMSG $irc_chan :$sender::: Ti avevo avertito!!!\n");
						send($irc, "PRIVMSG $irc_chan :$sender::: FFUUOORRIIIIIII!!!\n");
						send($irc, "MODE $irc_chan +b $sender!*@*\n");
						send($irc, "PRIVMSG $irc_chan :Peggio per lui... Si arrangia!!! AHAHAHAH ;)\n");
						$kickkati[$sender] = 0;
					}
				}
			}
		}
		if($check == "$user_name") {
			if(count($d) > 4) {
				$cmd = $d[4];
				if($cmd == "salutami") {
					send($irc, "PRIVMSG $irc_chan :Ciao $sender :)\n");
				}
				if($cmd == "saluta") {
					if(count($d) > 5) {
						send($irc, "PRIVMSG $irc_chan :Ciao $d[5]... Come stai??\n");
					} else {
						send($irc, "PRIVMSG $irc_chan :Ciao a tutti!! :)\n");
					}
				}
				if($cmd == "ciao") {
					send($irc, "PRIVMSG $irc_chan :Ciao a tutti!! :)\n");
				}
				if($cmd == "help") {
					send($irc, "PRIVMSG $irc_chan :Allora... Ti do l'elenco delle parole vietate!! ;)\n");
					$testo_p = "";
					for($k=0; $k<count($bad_words); $k++) {
						$testo_p = "$testo_p " . $bad_words[$k];
					}
					send($irc, "PRIVMSG $irc_chan :$testo_p\n");
				}
				if($sender == "sardylan") {
					if($cmd == "debanna") {
						if(count($d) > 5) {
							send($irc, "PRIVMSG $irc_chan :OK... Debanno $d[5]...\n");
							send($irc, "MODE $irc_chan -b $d[5]!*@*\n");
						}
					}
				}
			} else {
				send($irc, "PRIVMSG $irc_chan :Cosa c'è $sender??\n");
			}
		}
	}
}
?>
C:

Codice: Seleziona tutto

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <fcntl.h>
#include <string.h>

struct irc_param_s {
	char *ip_addr;
	int *ip_port;
	char *usr_id;
	char *usr_psw;
	char *irc_chan;
};

typedef struct irc_param_s irc_param;

void header();
void footer();
irc_param *create_infos(int, char **);
void summary(irc_param *);
int sock_create_cli(char *, int);
void sck_send(int, FILE *, char *);
char *sck_recv(int, FILE *);
void sock_close(int);
void boter(irc_param *, int);
void chk_response(char *, int);

void header() {
	system("clear");
	printf("\n\n");
	printf("#################################\n");
	printf("####      roBOT per IRC      ####\n");
	printf("#################################\n");
	printf("\n\n");
	
}

void footer() {
	printf("\n\n");
	printf("Press ENTER to exit... ");
	getchar();
	printf("\n\n");
	
}

irc_param *create_infos(int arg_c, char **arg_str) {
	int i;
	char tmp_param[] = "-a";
	irc_param *ret;
	int len;
	ret = (irc_param *) malloc(sizeof(irc_param));
	for(i=1; i<arg_c; i++) {
		tmp_param[1] = 's';
		if(strcmp(tmp_param, arg_str[i]) == 0) {
			i++;
			len = strlen(arg_str[i]);
			ret->ip_addr = malloc((len * sizeof(char)) + 1);
			strcpy(ret->ip_addr, arg_str[i]);
		}
		tmp_param[1] = 'p';
		if(strcmp(tmp_param, arg_str[i]) == 0) {
			i++;
			len = strlen(arg_str[i]);
			ret->ip_port = malloc(sizeof(int));
			*ret->ip_port = atoi(arg_str[i]);
		}
		tmp_param[1] = 'u';
		if(strcmp(tmp_param, arg_str[i]) == 0) {
			i++;
			len = strlen(arg_str[i]);
			ret->usr_id = malloc((len * sizeof(char)) + 1);
			strcpy(ret->usr_id, arg_str[i]);
		}
		tmp_param[1] = 'k';
		if(strcmp(tmp_param, arg_str[i]) == 0) {
			i++;
			len = strlen(arg_str[i]);
			ret->usr_psw = malloc((len * sizeof(char)) + 1);
			strcpy(ret->usr_psw, arg_str[i]);
		}
		tmp_param[1] = 'c';
		if(strcmp(tmp_param, arg_str[i]) == 0) {
			i++;
			len = strlen(arg_str[i]);
			ret->irc_chan = malloc((len * sizeof(char)) + 1);
			strcpy(ret->irc_chan, arg_str[i]);
		}
	}
	return ret;
}

void summary(irc_param *infos) {
	printf("\n");
	printf("Summary of parameters:\n\n");
	printf("IRC Server Address:\t\t%s\n", infos->ip_addr);
	printf("IRC Server Port:\t\t%d\n", *infos->ip_port);
	printf("User ID:\t\t\t%s\n", infos->usr_id);
	printf("User password:\t\t\t%s\n", infos->usr_psw);
	printf("IRC Channel name:\t\t%s\n", infos->irc_chan);
	printf("\n");
}

int sock_create_cli(char* addr, int port) {
	printf("Creating socket... ");
	struct sockaddr_in temp;
	struct hostent *h;
	int sock;
	int errore;
	temp.sin_family = AF_INET;
	temp.sin_port = htons(port);
	h = gethostbyname(addr);
	if(h == 0) {
		printf("Gethostbyname fallito\n");
		exit(1);
	}
	bcopy(h->h_addr, &temp.sin_addr, h->h_length);
	sock = socket(AF_INET, SOCK_STREAM, 0);
	errore = connect(sock, (struct sockaddr*) &temp, sizeof(temp));
	printf("done!\n\n");
	return sock;
}

void sock_close(int sock) {
	close(sock);
	return;
}

void sck_send(int sock, FILE *fp, char *text) {
	if(strlen(text) > 0) {
		char *out;
		out = malloc(strlen(text) + 1);
		sprintf(out, "%s\n", text);
		fprintf(fp, "   -->> %s", out);
		write(sock, out, strlen(out), 0);
	}
}

char *sck_recv(int sock, FILE *fp) {
	char buff[2048];
	char *ret;
	int len;
	read(sock, buff, sizeof(buff));
	fprintf(fp, " <<--   %s\n", buff);
	len = strlen(buff);
	ret = malloc((len * sizeof(char)) + 1);
	strcpy(ret, buff);
	return ret;
}

void boter(irc_param *infos, int sck) {
	char *cmd;
	char *out;
	cmd = malloc(2048 * sizeof(char));
	printf("Starting communications with server... \n\n");
	sprintf(cmd, "USER %s \"1\" \"1\" :IRC Bot.", infos->usr_id);
	sck_send(sck, stdout, cmd);
	sprintf(cmd, "NICK %s", infos->usr_id);
	sck_send(sck, stdout, cmd);
	do {
		out = sck_recv(sck, stdout);
		chk_response(out, sck);
	} while(1);
	printf("Ciao\n");
}

void chk_response(char *out, int sck) {
	char cmd[2048];
	char tmp_cmd[2048];
	int cmd_chk;
	int i;
	int ln;
	sprintf(cmd, "PING");
	cmd_chk = strncmp(out, cmd, 4);
	if(cmd_chk == 0) {
		ln = strlen(out);
		for(i=0; i<(ln-4); i++) {
			tmp_cmd[i] = *(out + (i + 4));
		}
		sprintf(cmd, "PONG%s", tmp_cmd);
		sck_send(sck, stdout, cmd);
	}
}

int main(int argc, char **argv) {
	irc_param *param;
	int sck_des;
	if(argc < 10) {
		printf("\n");
		printf("Usage:  %s -s <server> -p <port> -c <channel> -u <user-id> -k <user-psw>\n\n", argv[0]);
		return 0;
	}
	header();
	param = create_infos(argc, argv);
	summary(param);
	sck_des = sock_create_cli(param->ip_addr, *param->ip_port);
	boter(param, sck_des);
	footer();
	return 0;
}
Quando avevo provato una cosa simile su Windows, usavo Visual Basic 6... Mettevo un controllo socket ed in automatico venivano richiamate delle "sub" ad ogni occorrenza di un evento (ricezione dati, connessione avvenuta, etc...). Inserivo il codice nelle sub che mi interessavano e gestivo il tutto in questo modo...
Usando il C, la cosa funziona più o meno allo stesso modo??? Oppure sono completamente fuori strada??
Vi ringrazio tutti in anticipo!!!

P.S. Non badate al modo di programmare :p :p ... Sono un "maniaco" delle tabulazioni :D e mi piacciono le cose ordinate :D

Avatar utente
tgmx
Linux 4.x
Linux 4.x
Messaggi: 1336
Iscritto il: ven 28 apr 2006, 14:40
Slackware: 14.1
Desktop: KDE 4
Località: Ancona

Re: Socket asincroni (possibilmente C o PHP)

Messaggio da tgmx »

Io farei anche un giro sulle QT4/C++.
Poi magari qualcuno ti spiega come risolvere in C ma con le QT4 e la gestione a SIGNAL/SLOT ci metti un attimo... se ho capito cosa ti serve. :D

In pratica ti crei questo oggetto e colleghi il suo segnale (di stringa arrivata) a un particolare slot che gestisce la stringa... ;)

Avatar utente
sardylan
Linux 3.x
Linux 3.x
Messaggi: 993
Iscritto il: mar 24 apr 2007, 9:21
Nome Cognome: Luca Cireddu
Slackware: current 64bits
Kernel: 3.16
Desktop: KDE 4.14
Distribuzione: Debian - CLFS
Località: Cagliari
Contatta:

Re: Socket asincroni (possibilmente C o PHP)

Messaggio da sardylan »

tgmx ha scritto:Io farei anche un giro sulle QT4/C++.
Poi magari qualcuno ti spiega come risolvere in C ma con le QT4 e la gestione a SIGNAL/SLOT ci metti un attimo... se ho capito cosa ti serve. :D

In pratica ti crei questo oggetto e colleghi il suo segnale (di stringa arrivata) a un particolare slot che gestisce la stringa... ;)
Quindi usando QT4 ed il C++ (KDevelop in tal caso farebbe il suo dovere... a dovere!!!) potrei tranquillamente gestire la cosa... Quindi punto sul C++...
Hai qualche sito dove potrei trovare guide o slide di auito??? Sai... Non ho mai usato C++ e dovrei fare pirma il passaggio dal C a l C++... Mi hanno detto che non è particolarmente "doloroso"... :D

Anche se l'idea di usare QT4 prevede la presenza di un server grafico... Mentre la mia idea sarebbe riuscire ad ottenere un demone...

Avatar utente
lyapunov
Linux 2.x
Linux 2.x
Messaggi: 204
Iscritto il: dom 4 mag 2008, 16:12

Re: Socket asincroni (possibilmente C o PHP)

Messaggio da lyapunov »

Per creare programmi asincroni devi usare select()
...o ti smazzi con pthread + mutex :D

PS: fai un po' di error checking ed error handling...

Avatar utente
tgmx
Linux 4.x
Linux 4.x
Messaggi: 1336
Iscritto il: ven 28 apr 2006, 14:40
Slackware: 14.1
Desktop: KDE 4
Località: Ancona

Re: Socket asincroni (possibilmente C o PHP)

Messaggio da tgmx »

sardylan ha scritto:
tgmx ha scritto:Io farei anche un giro sulle QT4/C++.
Poi magari qualcuno ti spiega come risolvere in C ma con le QT4 e la gestione a SIGNAL/SLOT ci metti un attimo... se ho capito cosa ti serve. :D

In pratica ti crei questo oggetto e colleghi il suo segnale (di stringa arrivata) a un particolare slot che gestisce la stringa... ;)
Quindi usando QT4 ed il C++ (KDevelop in tal caso farebbe il suo dovere... a dovere!!!) potrei tranquillamente gestire la cosa... Quindi punto sul C++...
Hai qualche sito dove potrei trovare guide o slide di auito??? Sai... Non ho mai usato C++ e dovrei fare pirma il passaggio dal C a l C++... Mi hanno detto che non è particolarmente "doloroso"... :D

Anche se l'idea di usare QT4 prevede la presenza di un server grafico... Mentre la mia idea sarebbe riuscire ad ottenere un demone...
A perte che le qt non richiedono di usare le "finestre" :) comunque ti posso consigliare la procedura che ho sempre usato:
- installa le QT4 (da slacky)
- apri "assistant" (la guida in linea delle qt)
- scorri velocemente gli esempi sull'uso di socket (ce ne sono diversi)

In ogno caso se non hai esigenze particolari e riesci a fare questa cosa in C (e credo che in qualche modo sia possibile) forse è la soluzione migliore. :)

Per il resto, quando hai approfondito l'argomento sono qui se ti serve una mano. ;)

Avatar utente
sardylan
Linux 3.x
Linux 3.x
Messaggi: 993
Iscritto il: mar 24 apr 2007, 9:21
Nome Cognome: Luca Cireddu
Slackware: current 64bits
Kernel: 3.16
Desktop: KDE 4.14
Distribuzione: Debian - CLFS
Località: Cagliari
Contatta:

Re: Socket asincroni (possibilmente C o PHP)

Messaggio da sardylan »

tgmx ha scritto:A perte che le qt non richiedono di usare le "finestre" :)
Ah... Ok... Ero convinto che fossero un qualcosa legato alle "finestre"... Allora come non detto... Le QT4 dovrebbero essere già installate... Ora do un'occhiata e controllo...
Grazie a tutti per le risposte!!!
Mi farò sentire in caso di dubbi...

Avatar utente
lyapunov
Linux 2.x
Linux 2.x
Messaggi: 204
Iscritto il: dom 4 mag 2008, 16:12

Re: Socket asincroni (possibilmente C o PHP)

Messaggio da lyapunov »

Un daemon scritto con le qt farebbe rabbrividire molta gente (me compreso ;) )
IMHO sarebbe meglio dare uno sguardo prima alla select(), almeno sa hai intenzione di scrivere un codice da distribuire.

Avatar utente
targzeta
Iper Master
Iper Master
Messaggi: 6629
Iscritto il: gio 3 nov 2005, 14:05
Nome Cognome: Emanuele Tomasi
Slackware: 64-current
Kernel: latest stable
Desktop: IceWM
Località: Carpignano Sal. (LE) <-> Pisa

Re: Socket asincroni (possibilmente C o PHP)

Messaggio da targzeta »

Anche io consiglio il C. Dai un occhiata al Gapil:
http://gapil.truelite.it/

Spina

edit: qui c'è la spiegazione della select:
http://www.lilik.it/~mirko/gapil/gapils ... 900011.1.2
Se pensi di essere troppo piccolo per fare la differenza, prova a dormire con una zanzara -- Dalai Lama

Avatar utente
sardylan
Linux 3.x
Linux 3.x
Messaggi: 993
Iscritto il: mar 24 apr 2007, 9:21
Nome Cognome: Luca Cireddu
Slackware: current 64bits
Kernel: 3.16
Desktop: KDE 4.14
Distribuzione: Debian - CLFS
Località: Cagliari
Contatta:

Re: Socket asincroni (possibilmente C o PHP)

Messaggio da sardylan »

L'idea delle QT non mi dispiacerebbe se volessi realizzare un software a finestre con il log in una casella di testo ed eventuali bottoncini per le opzioni... Per ora sto controllando la select(); perché preferire tenere la cosa su un demone... Il passo alle QT sarà il successivo..
Vi farò sapere appena riesco a mettere su qualcosa..
Grazie di nuovo!!

Avatar utente
tgmx
Linux 4.x
Linux 4.x
Messaggi: 1336
Iscritto il: ven 28 apr 2006, 14:40
Slackware: 14.1
Desktop: KDE 4
Località: Ancona

Re: Socket asincroni (possibilmente C o PHP)

Messaggio da tgmx »

lyapunov ha scritto:Un daemon scritto con le qt farebbe rabbrividire molta gente (me compreso ;) )
IMHO sarebbe meglio dare uno sguardo prima alla select(), almeno sa hai intenzione di scrivere un codice da distribuire.
mi cito da solo...
tgmx ha scritto: In ogno caso se non hai esigenze particolari e riesci a fare questa cosa in C (e credo che in qualche modo sia possibile) forse è la soluzione migliore. :)
:)
la mia era un'idea buttata lì dovuta al solo fatto che in QT ho già fatto qualcosa del genere mentre in C non ancora... :lol:

Avatar utente
guargua
Linux 0.x
Linux 0.x
Messaggi: 31
Iscritto il: mar 29 apr 2008, 18:41
Nome Cognome: Alessandro Guarguaglini
Slackware: 12
Kernel: 2.6.25.4
Desktop: kde
Località: Livorno
Contatta:

Re: Socket asincroni (possibilmente C o PHP)

Messaggio da guargua »

sardylan ha scritto: Le mie domande sono:
1. Quale linguaggio usare??? PHP bellissimo per gestire le stringhe con explode etc., ma rimane sempre un qualcosa di interpretato... C sarebbe "il mio sogno", ma non ho idea da dove iniziare... Altri linguaggi non ne conosco (a parte il Visual Basic... Mah!!! Lasciamo perdere :D) , ma non sarebbe male impararne, sopratutto se il passo non è troppo difficile da seguire!!!
2. Avete qualche guida da consigliare, oppure qualche consiglio da darmi??? Qualche presentazione, qualche PDF, qualche sito...
Anche se arrivo in ritardo, this are my 2 cent : python e twisted penso farebbero proprio al caso tuo.
Da un'occhiata qui : http://twistedmatrix.com/projects/core/ ... async.html
sardylan ha scritto: P.S. Non badate al modo di programmare :p :p ... Sono un "maniaco" delle tabulazioni :D e mi piacciono le cose ordinate :D
Allora senz'altro adorerai python ! :D

Ciao.

Rispondi